projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'develop' into activation-meta
[akkoma]
/
lib
/
pleroma
/
web
/
streamer
/
streamer.ex
diff --git
a/lib/pleroma/web/streamer/streamer.ex
b/lib/pleroma/web/streamer/streamer.ex
index b22297955f084931875268eba9c568bf5b2fe61e..d1d2c9b9c5f85bfa53bd48168a5796a8523c80b1 100644
(file)
--- a/
lib/pleroma/web/streamer/streamer.ex
+++ b/
lib/pleroma/web/streamer/streamer.ex
@@
-6,7
+6,7
@@
defmodule Pleroma.Web.Streamer do
require Logger
alias Pleroma.Activity
require Logger
alias Pleroma.Activity
- alias Pleroma.ChatMessageReference
+ alias Pleroma.Chat
.
MessageReference
alias Pleroma.Config
alias Pleroma.Conversation.Participation
alias Pleroma.Notification
alias Pleroma.Config
alias Pleroma.Conversation.Participation
alias Pleroma.Notification
@@
-187,7
+187,7
@@
defmodule Pleroma.Web.Streamer do
end)
end
end)
end
- defp do_stream(topic, {user, %
Chat
MessageReference{} = cm_ref})
+ defp do_stream(topic, {user, %MessageReference{} = cm_ref})
when topic in ["user", "user:pleroma_chat"] do
topic = "#{topic}:#{user.id}"
when topic in ["user", "user:pleroma_chat"] do
topic = "#{topic}:#{user.id}"