Add echo server0.2.0

Modify `acceptor` to pass over the connection to a task echo server.

1 files changed, 25 insertions, 0 deletions

diff --git a/lib/octonetcat/servers/echo.ex b/lib/octonetcat/servers/echo.ex
new file mode 100644
index 0000000..0d7487f
--- /dev/null
+++ b/lib/octonetcat/servers/echo.ex
@@ -0,0 +1,25 @@
+defmodule Octonetcat.Echo do
+  @moduledoc """
+  Echo TCP Socket Server
+
+  Started under a task supervisor, lives for the life of the socket,
+  dies on failure or disconnect.
+  """
+
+  def serve(socket) do
+    socket
+    |> read_line!()
+    |> write_line!(socket)
+
+    serve(socket)
+  end
+
+  def read_line!(socket) do
+    {:ok, line} = :gen_tcp.recv(socket, 0)
+    line
+  end
+
+  def write_line!(line, socket) do
+    :gen_tcp.send(socket, line)
+  end
+ end