- stream when stream in ["public", "public:local"] <- params["stream"] do
- socket = socket
- |> assign(:topic, params["stream"])
- |> assign(:user, user)
- Pleroma.Web.Streamer.add_socket(params["stream"], socket)
+ stream
+ when stream in [
+ "public",
+ "public:local",
+ "public:media",
+ "public:local:media",
+ "user",
+ "direct",
+ "list",
+ "hashtag"
+ ] <- params["stream"] do
+ topic = if stream == "list", do: "list:#{params["list"]}", else: stream
+ socket_stream = if stream == "hashtag", do: "hashtag:#{params["tag"]}", else: stream
+
+ socket =
+ socket
+ |> assign(:topic, topic)
+ |> assign(:user, user)
+
+ Pleroma.Web.Streamer.add_socket(socket_stream, socket)