Request and Share communication

3 files changed, 23 insertions, 2 deletions

diff --git a/lib/rook_web/channels/request_channel.ex b/lib/rook_web/channels/request_channel.ex
new file mode 100644
index 0000000..6290ae6
--- /dev/null
+++ b/lib/rook_web/channels/request_channel.ex
@@ -0,0 +1,20 @@
+defmodule RookWeb.RequestChannel do
+  use RookWeb, :channel
+
+  def join("request:" <> token, %{"share" => share_token}, socket) do
+    if Rook.Token.match?(token, socket) do
+      if Rook.Share.exists?(share_token) do
+        Rook.Request.start(token, share_token)
+        {:ok, socket}
+      else
+        {:error, %{reason: "No such share exists."}}
+      end
+    else
+      {:error, %{reason: "Wrong token."}}
+    end
+  end
+
+  def join("request:" <> _token, _params, _socket) do
+    {:error, %{reason: "No share given to request."}}
+  end
+end
diff --git a/lib/rook_web/channels/share_channel.ex b/lib/rook_web/channels/share_channel.ex
index 2d99d87..0efb3ba 100644
--- a/lib/rook_web/channels/share_channel.ex
+++ b/lib/rook_web/channels/share_channel.ex
@@ -21,8 +21,8 @@ defmodule RookWeb.ShareChannel do
     {:error, %{reason: "No request given to accept."}}
   end
 
-  def handle_out("new_request", msg, socket) do
-    # TODO: Send ACK
+  def handle_out("new_request", %{request: request_token} = msg, socket) do
+    Rook.Request.acknowledge_request(request_token)
     push(socket, "new_request", msg)
     {:noreply, socket}
   end
diff --git a/lib/rook_web/channels/user_socket.ex b/lib/rook_web/channels/user_socket.ex
index ae82b6b..d6ce9c4 100644
--- a/lib/rook_web/channels/user_socket.ex
+++ b/lib/rook_web/channels/user_socket.ex
@@ -4,6 +4,7 @@ defmodule RookWeb.UserSocket do
   ## Channels
   channel "token", RookWeb.TokenChannel
   channel "share:*", RookWeb.ShareChannel
+  channel "request:*", RookWeb.RequestChannel
 
   # Socket params are passed from the client and can
   # be used to verify and authenticate a user. After