More scaffolding—found some pain points to address

Author: ashton314

lib/tcp/accepter_pool_impl.ex

@@ -0,0 +1,7 @@
+defmodule Tcp.AccepterPoolImpl do
+  use Tcp.ListenerChor.Chorex, :accepterpool
+
+  def spawn_handler(_socket) do
+	# startup instance of the handler choreography
+  end
+end

lib/tcp/client_impl.ex

@@ -0,0 +1,6 @@
+defmodule Tcp.ClientImpl do
+  use Tcp.HandlerChor.Chorex, :tcpclient
+
+  def send_over_socket(_sock, _msg) do
+  end
+end

lib/tcp/handler_chor.ex

@@ -2,21 +2,49 @@ defmodule Tcp.HandlerChor do
   import Chorex
 
   defchor [Handler, TcpClient] do
-    def loop(Handler.(_x)) do
+    def loop(TcpClient.(sock)) do
       with Handler.(resp) <- Handler.run() do
         if Handler.continue?(resp) do
           Handler[L] ~> TcpClient
           Handler.fmt_reply(resp) ~> TcpClient.(resp)
-          TcpClient.send(resp)
-          loop(Handler.(nil))
+          TcpClient.send_over_socket(sock, resp)
+          loop(TcpClient.(sock))
         else
           Handler[R] ~> TcpClient
           Handler.fmt_reply(resp) ~> TcpClient.(resp)
-          TcpClient.send(resp)
+          TcpClient.send_over_socket(sock, resp)
         end
       end
     end
 
-    loop(Handler.(nil))
+    def init(TcpClient.(sock)) do
+      loop(TcpClient.(sock))
+    end
   end
+
+  # quote do
+  #   defchor [Handler, TcpClient] do
+  #     def loop(TcpClient.(sock)) do
+  #       with Handler.(resp) <- Handler.run() do
+  #         if Handler.continue?(resp) do
+  #           Handler[L] ~> TcpClient
+  #           Handler.fmt_reply(resp) ~> TcpClient.(resp)
+  #           TcpClient.send_over_socket(sock, resp)
+  #           loop(TcpClient.(sock))
+  #         else
+  #           Handler[R] ~> TcpClient
+  #           Handler.fmt_reply(resp) ~> TcpClient.(resp)
+  #           TcpClient.send_over_socket(sock, resp)
+  #         end
+  #       end
+  #     end
+
+  #     def init(TcpClient.(sock)) do
+  #       loop(TcpClient.(sock))
+  #     end
+  #   end
+  # end
+  # |> Macro.expand_once(__ENV__)
+  # |> Macro.to_string()
+  # |> IO.puts()
 end

lib/tcp/handler_impl.ex

@@ -0,0 +1,12 @@
+defmodule Tcp.HandlerImpl do
+  use Tcp.HandlerChor.Chorex, :handler
+
+  def run() do
+  end
+
+  def continue?({:continue, _resp}), do: true
+  def continue?({:halt, _resp}), do: false
+
+  def fmt_reply({_status, resp}), do: resp
+
+end

lib/tcp/listener_chor.ex

@@ -2,7 +2,7 @@ defmodule Tcp.ListenerChor do
   import Chorex
 
   defchor [Listener, AccepterPool] do
-    def loop(Listener.(_x)) do # FIXME: functions without an argument; or is it that all branches loop?
+    def loop(Listener.(_x)) do
       Listener.await_connection() ~> AccepterPool.(socket)
       AccepterPool.spawn_handler(socket)
       loop(Listener.(nil))

lib/tcp/listener_impl.ex

@@ -0,0 +1,7 @@
+defmodule Tcp.ListenerImpl do
+  use Tcp.ListenerChor.Chorex, :listener
+
+  def await_connection() do
+    42
+  end
+end