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

diff --git a/test/web/streamer_test.exs b/test/web/streamer_test.exs
deleted file mode 100644
index 905e29d06..000000000
--- a/test/web/streamer_test.exs
+++ /dev/null
@@ -1,174 +0,0 @@
-# Pleroma: A lightweight social networking server
-# Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/>
-# SPDX-License-Identifier: AGPL-3.0-only
-
-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