honkoma/lib/pleroma/web/mastodon_api/mastodon_socket.ex

82 lines
1.9 KiB
Elixir
Raw Normal View History

2017-11-11 13:59:25 +00:00
defmodule Pleroma.Web.MastodonAPI.MastodonSocket do
use Phoenix.Socket
2017-11-16 12:48:58 +00:00
alias Pleroma.Web.OAuth.Token
alias Pleroma.{User, Repo}
2018-03-30 13:01:53 +00:00
transport(
2018-12-09 09:12:48 +00:00
:websocket,
2018-03-30 13:01:53 +00:00
Phoenix.Transports.WebSocket.Raw,
# We never receive data.
timeout: :infinity
)
2017-11-11 13:59:25 +00:00
2018-12-10 06:39:57 +00:00
@spec connect(params :: map(), Phoenix.Socket.t()) :: {:ok, Phoenix.Socket.t()} | :error
def connect(%{"access_token" => token} = params, socket) do
with %Token{user_id: user_id} <- Repo.get_by(Token, token: token),
2017-11-16 12:48:58 +00:00
%User{} = user <- Repo.get(User, user_id),
stream
when stream in [
"public",
"public:local",
"public:media",
"public:local:media",
"user",
"direct",
"list",
"hashtag"
] <- params["stream"] do
2018-11-11 03:33:14 +00:00
topic =
case stream do
"hashtag" -> "hashtag:#{params["tag"]}"
"list" -> "list:#{params["list"]}"
_ -> stream
end
2018-05-30 13:33:37 +00:00
2018-03-30 13:01:53 +00:00
socket =
socket
2018-05-30 13:33:37 +00:00
|> assign(:topic, topic)
2018-03-30 13:01:53 +00:00
|> assign(:user, user)
2018-11-11 03:33:14 +00:00
Pleroma.Web.Streamer.add_socket(topic, socket)
{:ok, socket}
else
2017-11-16 12:48:58 +00:00
_e -> :error
end
2017-11-11 13:59:25 +00:00
end
def connect(%{"stream" => stream} = params, socket)
when stream in ["public", "public:local", "hashtag"] do
topic =
case stream do
"hashtag" -> "hashtag:#{params["tag"]}"
_ -> stream
end
2018-12-10 06:39:57 +00:00
socket =
socket
|> assign(:topic, topic)
Pleroma.Web.Streamer.add_socket(topic, socket)
{:ok, socket}
end
2018-12-10 06:39:57 +00:00
def connect(_params, _socket), do: :error
2017-11-19 01:22:07 +00:00
def id(_), do: nil
2017-11-11 13:59:25 +00:00
2017-11-19 01:22:07 +00:00
def handle(:text, message, _state) do
2018-03-30 13:01:53 +00:00
# | :ok
# | state
# | {:text, message}
# | {:text, message, state}
# | {:close, "Goodbye!"}
2017-11-11 13:59:25 +00:00
{:text, message}
end
2017-11-19 01:22:07 +00:00
def handle(:closed, _, %{socket: socket}) do
topic = socket.assigns[:topic]
Pleroma.Web.Streamer.remove_socket(topic, socket)
2017-11-11 13:59:25 +00:00
end
end