tcp endpoint

rebar.config

@@ -1,7 +1,7 @@
 {lib_dirs,[".."]}.
 {deps_dir,["deps"]}.
 {deps,[
-    {nitro, ".*", {git, "git://github.com/synrc/nitro.git", {tag,"master"}}},
+    {nitro, ".*", {git, "git://github.com/synrc/nitro.git", {tag,"0.9"}}},
     {jsone, ".*", {git, "git://github.com/sile/jsone.git", {tag,"v0.3.3"}}},
     {cowboy, ".*", {git, "git://github.com/extend/cowboy", {tag,"1.0.1"}}},
     {gproc, ".*", {git, "git://github.com/uwiger/gproc.git", {tag,"0.3"}}}

samples/apps/review/src/config.erl

@@ -5,8 +5,8 @@ log_level() -> info.
 log_modules() -> % any
   [
     login,
-    wf_convert,
-    n2o_file,
+%    wf_convert,
+%    n2o_file,
     n2o_async,
     n2o_proto,
     n2o_client,

src/endpoints/n2o_relay.erl

@@ -0,0 +1,20 @@
+-module(n2o_relay).
+-description('N2O TCP relay endpoint handler').
+-compile(export_all).
+
+connect(IP, PortNo) ->
+    {ok, Socket} = gen_tcp:connect(IP, PortNo, [{active, false}, {packet, 2}]),
+    spawn(fun() -> recv(Socket) end),
+    Socket.
+
+send(Socket, Message) ->
+    BinMsg = term_to_binary(Message),
+    gen_tcp:send(Socket, BinMsg).
+
+recv(Socket) ->
+    {ok, A} = gen_tcp:recv(Socket, 0),
+    io:format("Received: ~p~n", [A]),
+    recv(Socket).
+
+disconnect(Socket) ->
+    gen_tcp:close(Socket).