git.squeep.com Git - akkoma/blob - lib/pleroma/web/chat_channel.ex

   1 defmodule Pleroma.Web.ChatChannel do
   2   use Phoenix.Channel
   3   alias Pleroma.Web.ChatChannel.ChatChannelState
   4
   5   def join("chat:public", _message, socket) do
   6     send(self(), :after_join)
   7     {:ok, socket}
   8   end
   9
  10   def handle_info(:after_join, socket) do
  11     push socket, "messages", %{messages: ChatChannelState.messages()}
  12     {:noreply, socket}
  13   end
  14
  15   def handle_in("new_msg", %{"text" => text}, socket) do
  16     author = socket.assigns[:user]
  17     author = Pleroma.Web.MastodonAPI.AccountView.render("account.json", user: author)
  18     message= ChatChannelState.add_message(%{text: text, author: author})
  19
  20     broadcast! socket, "new_msg", message
  21     {:noreply, socket}
  22   end
  23 end
  24
  25 defmodule Pleroma.Web.ChatChannel.ChatChannelState do
  26   use Agent
  27   @max_messages 20
  28
  29   def start_link do
  30     Agent.start_link(fn -> %{max_id: 1, messages: []} end, name: __MODULE__)
  31   end
  32
  33   def add_message(message) do
  34     Agent.get_and_update(__MODULE__, fn state ->
  35       id = state[:max_id] + 1
  36       message = Map.put(message, "id", id)
  37       messages = [message | state[:messages]] |> Enum.take(@max_messages)
  38       {message, %{max_id: id, messages: messages}}
  39     end)
  40   end
  41
  42   def messages() do
  43     Agent.get(__MODULE__, fn state -> state[:messages] |> Enum.reverse end)
  44   end
  45 end