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

diff --git a/test/web/streamer_test.exs b/test/web/streamer_test.exs
deleted file mode 100644
index df58441f0..000000000
--- a/test/web/streamer_test.exs
+++ /dev/null
@@ -1,170 +0,0 @@
-defmodule Pleroma.Web.StreamerTest do
-  use Pleroma.DataCase
-
-  alias Pleroma.Web.Streamer
-  alias Pleroma.{List, 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
-
-  test "it doesn't send unwanted DMs to list" do
-    user_a = insert(:user)
-    user_b = insert(:user)
-    user_c = insert(:user)
-
-    {:ok, user_a} = User.follow(user_a, user_b)
-
-    {:ok, list} = List.create("Test", user_a)
-    {:ok, list} = List.follow(list, user_b)
-
-    task =
-      Task.async(fn ->
-        refute_receive {:text, _}, 1_000
-      end)
-
-    fake_socket = %{
-      transport_pid: task.pid,
-      assigns: %{
-        user: user_a
-      }
-    }
-
-    {:ok, activity} =
-      CommonAPI.post(user_b, %{
-        "status" => "@#{user_c.nickname} Test",
-        "visibility" => "direct"
-      })
-
-    topics = %{
-      "list:#{list.id}" => [fake_socket]
-    }
-
-    Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
-
-    Task.await(task)
-  end
-
-  test "it doesn't send unwanted private posts to list" do
-    user_a = insert(:user)
-    user_b = insert(:user)
-
-    {:ok, list} = List.create("Test", user_a)
-    {:ok, list} = List.follow(list, user_b)
-
-    task =
-      Task.async(fn ->
-        refute_receive {:text, _}, 1_000
-      end)
-
-    fake_socket = %{
-      transport_pid: task.pid,
-      assigns: %{
-        user: user_a
-      }
-    }
-
-    {:ok, activity} =
-      CommonAPI.post(user_b, %{
-        "status" => "Test",
-        "visibility" => "private"
-      })
-
-    topics = %{
-      "list:#{list.id}" => [fake_socket]
-    }
-
-    Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
-
-    Task.await(task)
-  end
-
-  test "it send wanted private posts to list" do
-    user_a = insert(:user)
-    user_b = insert(:user)
-
-    {:ok, user_a} = User.follow(user_a, user_b)
-
-    {:ok, list} = List.create("Test", user_a)
-    {:ok, list} = List.follow(list, user_b)
-
-    task =
-      Task.async(fn ->
-        assert_receive {:text, _}, 1_000
-      end)
-
-    fake_socket = %{
-      transport_pid: task.pid,
-      assigns: %{
-        user: user_a
-      }
-    }
-
-    {:ok, activity} =
-      CommonAPI.post(user_b, %{
-        "status" => "Test",
-        "visibility" => "private"
-      })
-
-    topics = %{
-      "list:#{list.id}" => [fake_socket]
-    }
-
-    Streamer.handle_cast(%{action: :stream, topic: "list", item: activity}, topics)
-
-    Task.await(task)
-  end
-end