projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'hotfix/delete-activities' into 'develop'
[akkoma]
/
test
/
web
/
streamer_test.exs
diff --git
a/test/web/streamer_test.exs
b/test/web/streamer_test.exs
index 16d7b9c24d7d7351a6f0f5435720a05a64b66ad6..0a2e91298155fb49d72d78a146b8436e45bb9a6c 100644
(file)
--- a/
test/web/streamer_test.exs
+++ b/
test/web/streamer_test.exs
@@
-5,10
+5,10
@@
defmodule Pleroma.Web.StreamerTest do
use Pleroma.DataCase
defmodule Pleroma.Web.StreamerTest do
use Pleroma.DataCase
- alias Pleroma.Web.Streamer
alias Pleroma.List
alias Pleroma.User
alias Pleroma.Web.CommonAPI
alias Pleroma.List
alias Pleroma.User
alias Pleroma.Web.CommonAPI
+ alias Pleroma.Web.Streamer
import Pleroma.Factory
test "it sends to public" do
import Pleroma.Factory
test "it sends to public" do
@@
-39,7
+39,15
@@
defmodule Pleroma.Web.StreamerTest do
task =
Task.async(fn ->
task =
Task.async(fn ->
- assert_receive {:text, _}, 4_000
+ expected_event =
+ %{
+ "event" => "delete",
+ "payload" => activity.id
+ }
+ |> Jason.encode!()
+
+ assert_receive {:text, received_event}, 4_000
+ assert received_event == expected_event
end)
fake_socket = %{
end)
fake_socket = %{