Merge branch 'streamer-refactoring' into 'develop'

[akkoma] / test / web / streamer_test.exs

diff --git a/test/web/streamer_test.exs b/test/web/streamer_test.exs
deleted file mode 100644 (file)
index 47d491d..0000000
--- a/test/web/streamer_test.exs
+++ /dev/null
@@ -1,63 +0,0 @@
-defmodule Pleroma.Web.StreamerTest do
-  use Pleroma.DataCase
-
-  alias Pleroma.Web.Streamer
-  alias Pleroma.User
-  alias Pleroma.Web.CommonAPI
-  import Pleroma.Factory
-
-  test "it sends to public" do
-    user = insert(:user)
-    other_user = insert(:user)
-
-    task =
-      Task.async(fn ->
-        assert_receive {:text, _}, 4_000
-      end)
-
-    fake_socket = %{
-      transport_pid: task.pid,
-      assigns: %{
-        user: user
-      }
-    }
-
-    {:ok, activity} = CommonAPI.post(other_user, %{"status" => "Test"})
-
-    topics = %{
-      "public" => [fake_socket]
-    }
-
-    Streamer.push_to_socket(topics, "public", activity)
-
-    Task.await(task)
-  end
-
-  test "it doesn't send to blocked users" do
-    user = insert(:user)
-    blocked_user = insert(:user)
-    {:ok, user} = User.block(user, blocked_user)
-
-    task =
-      Task.async(fn ->
-        refute_receive {:text, _}, 1_000
-      end)
-
-    fake_socket = %{
-      transport_pid: task.pid,
-      assigns: %{
-        user: user
-      }
-    }
-
-    {:ok, activity} = CommonAPI.post(blocked_user, %{"status" => "Test"})
-
-    topics = %{
-      "public" => [fake_socket]
-    }
-
-    Streamer.push_to_socket(topics, "public", activity)
-
-    Task.await(task)
-  end
-end