X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=test%2Fweb%2Fstreamer_test.exs;h=96fa7645f982b1f596af704dafb1d378a4db3706;hb=4fabf83ad01352442906d79187aeab4c777f4df8;hp=47d491d1bf2d21153a766c493046bee090368ffe;hpb=a9baf955fa47b58ec9ae1f90da14abc10379dcde;p=akkoma

diff --git a/test/web/streamer_test.exs b/test/web/streamer_test.exs
deleted file mode 100644
index 47d491d1b..000000000
--- 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