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(%{"access_token" => token} = params, socket) do
15 with %Token{user_id: user_id} <- Repo.get_by(Token, token: token),
16 %User{} = user <- Repo.get(User, user_id),
27 ] <- params["stream"] do
30 "hashtag" -> "hashtag:#{params["tag"]}"
31 "list" -> "list:#{params["list"]}"
37 |> assign(:topic, topic)
38 |> assign(:user, user)
40 Pleroma.Web.Streamer.add_socket(topic, socket)
47 def connect(%{"stream" => stream} = params, socket)
48 when stream in ["public", "public:local", "hashtag"] do
51 "hashtag" -> "hashtag:#{params["tag"]}"
57 |> assign(:topic, topic) do
58 Pleroma.Web.Streamer.add_socket(topic, socket)
67 def handle(:text, message, _state) do
71 # | {:text, message, state}
72 # | {:close, "Goodbye!"}
76 def handle(:closed, _, %{socket: socket}) do
77 topic = socket.assigns[:topic]
78 Pleroma.Web.Streamer.remove_socket(topic, socket)