1 defmodule Pleroma.Web.MastodonAPI.MastodonSocket do
4 alias Pleroma.Web.OAuth.Token
5 alias Pleroma.{User, Repo}
9 Phoenix.Transports.WebSocket.Raw,
10 # We never receive data.
14 def connect(params, socket) do
15 with token when not is_nil(token) <- params["access_token"],
16 %Token{user_id: user_id} <- Repo.get_by(Token, token: token),
17 %User{} = user <- Repo.get(User, user_id),
28 ] <- params["stream"] do
29 topic = if stream == "list", do: "list:#{params["list"]}", else: stream
30 socket_stream = if stream == "hashtag", do: "hashtag:#{params["tag"]}", else: stream
34 |> assign(:topic, topic)
35 |> assign(:user, user)
37 Pleroma.Web.Streamer.add_socket(socket_stream, socket)
46 def handle(:text, message, _state) do
50 # | {:text, message, state}
51 # | {:close, "Goodbye!"}
55 def handle(:closed, _, %{socket: socket}) do
56 topic = socket.assigns[:topic]
57 Pleroma.Web.Streamer.remove_socket(topic, socket)