1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
defmodule ShardWeb.RoomChannel do
use ShardWeb, :channel
require Logger
def join("room:" <> room_name, payload, socket) do
if authorized?(payload) do
list = for {_chid, %SApp.Chat.Manifest{channel: chan}, chpid} <- Shard.Manager.list_shards,
do: {chan, chpid}
pid = case List.keyfind(list, room_name, 0) do
nil ->
{:ok, pid} = Shard.Manifest.start %SApp.Chat.Manifest{channel: 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 {{pk, msgbin, _sign}, true} ->
{_ts, msg} = SData.term_unbin msgbin
nick = SApp.Identity.get_nick pk
push(socket, "shout", %{
name: nick,
pk16: Shard.Keys.pk_display(pk),
message: msg,
})
end)
{:noreply, socket}
end
def handle_info({:chat_recv, _chan, {pk, msgbin, _sign}}, socket) do
{_ts, msg} = SData.term_unbin msgbin
nick = SApp.Identity.get_nick pk
Logger.info("#{inspect self()} :chat_recv #{inspect msg}")
push socket, "shout", %{"name" => nick,
"pk16" => Shard.Keys.pk_display(pk),
"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
pk = socket.assigns.pk
nick = SApp.Identity.get_nick pk
payload = Map.put(payload, "name", nick)
payload = Map.put(payload, "pk16", Shard.Keys.pk_display pk)
broadcast socket, "shout", payload
GenServer.cast(socket.assigns.pid, {:chat_send, pk, payload["message"]})
{:noreply, socket}
end
# Add authorization logic here as required.
defp authorized?(_payload) do
true
end
end
|
