#!/usr/bin/env escript
main(_) ->
    TestProtocol = enoise_protocol:from_name("Noise_XK_25519_ChaChaPoly_Blake2b"),
    ServerPrivKey =
        <<200, 81, 196, 192, 228, 196, 182, 200, 181, 83, 169, 255, 242, 54, 99, 113, 8, 49, 129,
    ServerPubKey =
    end.
srv_reply(Reply, SrvOpts) ->
    case proplists:get_value(reply, SrvOpts, undefined) of
        undefined ->
            ok;
        Pid ->
            Pid ! {self(), server_result, Reply}
    end.
    Res.
    enoise:close(EConn),
    srv_reply(Res, SrvOpts),
    Echos = proplists:get_value(echos, SrvOpts, 3),
    Res = [begin
               Msg = receive
                   {noise, EConn, Data} ->
                       Data
               after 1000 ->
                   error(timeout)
               end,
               io:format("got message: ~p~n", [Msg]),
               ok = enoise:send(EConn, Msg)
           end
           || _ <- lists:seq(1, Echos)],
    io:format("Result:~p~n", [Res]),
echo_srv_loop(EConn, EHs, SrvOpts) ->
    io:format("got handshake!~n~p~n", [EHs]),
    %gen_tcp:close(LSock),
    %io:format("socket closed~n"),
    case AcceptRes of
        {ok, EConn, EHs} ->
            echo_srv_loop(EConn, EHs, SrvOpts);
        Err = {error, _} ->
            srv_reply(Err, SrvOpts)
    Opts =
        [{noise, TestProtocol},
         {s, enoise_keypair:new(dh25519, ServerPrivKey, ServerPubKey)},
         {prologue, <<0, 8, 0, 0, 3>>}],
    AcceptRes =
        try
            enoise:accept(TcpSock, Opts)
        catch
            _:R:S ->
                gen_tcp:close(TcpSock),
                {error, {R, S}}
        end,
    io:format("got preample~n"),
    {ok, TcpSock} = gen_tcp:accept(LSock, 10000),
    io:format("socket accepted~n"),
    receive
        {tcp, TcpSock, <<0, 8, 0, 0, 3>>} ->
            ok
    after 1000 ->
        error(timeout)
    end,
    TcpOpts = [{active, true}, {reuseaddr, true}, binary],
    {ok, LSock} = gen_tcp:listen(7891, TcpOpts),
        <<112, 91, 141, 253, 183, 66, 217, 102, 211, 40, 13, 249, 238, 51, 77, 114, 163, 159, 32,
          1, 162, 219, 76, 106, 89, 164, 34, 71, 149, 2, 103, 59>>,
          92, 225, 220, 99, 50, 93, 96, 253, 250, 116, 196, 137, 103>>,
    SrvOpts =
        [{mode, active},
         {echos, 5},
         % or whatever Pid you want to reply to
         {reply, self()}],

#!/usr/bin/env escript
main(_) ->
    TestProtocol = enoise_protocol:from_name("Noise_XK_25519_ChaChaPoly_BLAKE2b"),
    ClientPrivKey =
        <<64, 168, 119, 119, 151, 194, 94, 141, 86, 245, 144, 220, 78, 53, 243, 231, 168, 216, 66,
            199, 49, 148, 202, 117, 98, 40, 61, 109, 170, 37, 133, 122>>,
    ClientPubKey =
        <<115, 39, 86, 77, 44, 85, 192, 176, 202, 11, 4, 6, 194, 144, 127, 123, 34, 67, 62, 180,
            190, 232, 251, 5, 216, 168, 192, 190, 134, 65, 13, 64>>,
    ServerPubKey =
        <<112, 91, 141, 253, 183, 66, 217, 102, 211, 40, 13, 249, 238, 51, 77, 114, 163, 159, 32, 1,
            162, 219, 76, 106, 89, 164, 34, 71, 149, 2, 103, 59>>,
    {ok, TcpSock} = gen_tcp:connect(
        "localhost",
        7891,
        1000
    ),
    io:format("dialed socket~n"),
    Opts = [
        {noise, TestProtocol},
        {s, enoise_keypair:new(dh25519, ClientPrivKey, ClientPubKey)},
        {prologue, <<0, 8, 0, 0, 3>>}
    ],
    {ok, EConn, EHs} = enoise:connect(TcpSock, Opts),
    io:format("enoise connected~p~n", [EHs]),
    receive
    end,
    timer:sleep(100), % Optional: avoid flooding
    send_receive_loop(EConn, N - 1).
        {noise, EConn, Message} ->
            io:format("Received: ~p~n", [Message])
    after 3000 ->
        error({timeout, N})
    LoopCount = 3,
    send_receive_loop(EConn, LoopCount),
    enoise:close(EConn).
send_receive_loop(_EConn, 0) ->
    io:format("Finished loop~n");
send_receive_loop(EConn, N) ->
    Message = <<"ok\n">>,
    ok = enoise:send(EConn, Message),
    io:format("Sent: ~p~n", [Message]),
        {rs, ServerPubKey},
    ok = gen_tcp:send(TcpSock, <<0, 8, 0, 0, 3>>),
        TcpOpts,
    TcpOpts = [
        {active, true},
        binary,
        {reuseaddr, true}
    ],