aboutsummaryrefslogtreecommitdiff
path: root/shardweb/lib/shard_web/channels/room_channel.ex
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2018-09-01 16:07:22 +0200
committerAlex Auvolat <alex@adnab.me>2018-09-01 16:07:22 +0200
commit81b5a844a2a155e28c497a8ce671eb5f02803e5d (patch)
tree15e878ebe47d5993e7af46a48a1ccdc1dd1e4b2f /shardweb/lib/shard_web/channels/room_channel.ex
parentc6ec33d6e612168e14d77007915a4ea423c55a2e (diff)
downloadshard-81b5a844a2a155e28c497a8ce671eb5f02803e5d.tar.gz
shard-81b5a844a2a155e28c497a8ce671eb5f02803e5d.zip
Import shardweb0.0.2
Diffstat (limited to 'shardweb/lib/shard_web/channels/room_channel.ex')
-rw-r--r--shardweb/lib/shard_web/channels/room_channel.ex68
1 files changed, 68 insertions, 0 deletions
diff --git a/shardweb/lib/shard_web/channels/room_channel.ex b/shardweb/lib/shard_web/channels/room_channel.ex
new file mode 100644
index 0000000..2dd733b
--- /dev/null
+++ b/shardweb/lib/shard_web/channels/room_channel.ex
@@ -0,0 +1,68 @@
+defmodule ShardWeb.RoomChannel do
+ use ShardWeb, :channel
+
+ require Logger
+
+ def join("room:" <> room_name, payload, socket) do
+ if authorized?(payload) do
+
+ list = for {_chid, manifest, chpid} <- :ets.tab2list(:shard_db),
+ {:chat, chan} = manifest,
+ do: {chan, chpid}
+ pid = case List.keyfind(list, room_name, 0) do
+ nil ->
+ {:ok, pid} = DynamicSupervisor.start_child(Shard.DynamicSupervisor, {SApp.Chat, room_name})
+ pid
+ {_, pid} ->
+ pid
+ end
+ socket = assign(socket, :pid, pid)
+
+ GenServer.cast(pid, {:subscribe, self()})
+ send(self(), :after_join)
+
+ {:ok, socket}
+ else
+ {:error, %{reason: "unauthorized"}}
+ end
+ end
+
+ def handle_info(:after_join, socket) do
+ GenServer.call(socket.assigns.pid, {:read_history, nil, 100})
+ |> Enum.each(fn {{_ts, nick, msg}, true} -> push(socket, "shout", %{
+ name: nick,
+ message: msg,
+ }) end)
+ {:noreply, socket}
+ end
+
+ def handle_info({:chat_recv, _chan, {_ts, from, msg}}, socket) do
+ Logger.info("#{inspect self()} :chat_recv #{inspect msg}")
+ push socket, "shout", %{"name" => from, "message" => msg}
+ {:noreply, socket}
+ end
+
+ def handle_info({:chat_send, _, _}, socket) do
+ {:noreply, socket}
+ end
+
+ # Channels can be used in a request/response fashion
+ # by sending replies to requests from the client
+ def handle_in("ping", payload, socket) do
+ {:reply, {:ok, payload}, socket}
+ end
+
+ # It is also common to receive messages from the client and
+ # broadcast to everyone in the current topic (room:lobby).
+ def handle_in("shout", payload, socket) do
+ broadcast socket, "shout", payload
+ Shard.Identity.set_nickname(payload["name"])
+ GenServer.cast(socket.assigns.pid, {:chat_send, payload["message"]})
+ {:noreply, socket}
+ end
+
+ # Add authorization logic here as required.
+ defp authorized?(_payload) do
+ true
+ end
+end