Handler now directly talks to allocated worker node, so the Client is no longer locked up by all redis commands

lib/srh/http/command_handler.ex

@@ -2,6 +2,7 @@ defmodule Srh.Http.CommandHandler do
   alias Srh.Http.RequestValidator
   alias Srh.Auth.TokenResolver
   alias Srh.Redis.Client
+  alias Srh.Redis.ClientWorker
 
   def handle_command(conn, token) do
     case RequestValidator.validate_redis_body(conn.body_params) do
@@ -26,7 +27,8 @@ defmodule Srh.Http.CommandHandler do
     case GenRegistry.lookup_or_start(Client, srh_id, [max_connections, connection_info]) do
       {:ok, pid} ->
         # Run the command
-        case Client.redis_command(pid, command_array) do
+        case Client.find_worker(pid)
+             |> ClientWorker.redis_command(command_array) do
           {:ok, res} ->
             {:ok, %{result: res}}
           {:error, error} ->

lib/srh/redis/client.ex

@@ -25,15 +25,15 @@ defmodule Srh.Redis.Client do
     }
   end
 
-  def redis_command(client, command_array)  do
-    GenServer.call(client, {:redis_command, command_array})
+  def find_worker(client)  do
+    GenServer.call(client, {:find_worker})
   end
 
-  def handle_call({:redis_command, command_array}, _from, %{registry_pid: registry_pid} = state)
+  def handle_call({:find_worker}, _from, %{registry_pid: registry_pid} = state)
       when is_pid(registry_pid) do
     {:ok, worker} = ClientRegistry.find_worker(registry_pid)
     Process.send(self(), :reset_idle_death, [])
-    {:reply, ClientWorker.redis_command(worker, command_array), state}
+    {:reply, worker, state}
   end
 
   def handle_call(_msg, _from, state) do