diff options
author | kaniini <ariadne@dereferenced.org> | 2019-09-16 09:09:21 +0000 |
---|---|---|
committer | kaniini <ariadne@dereferenced.org> | 2019-09-16 09:09:21 +0000 |
commit | c623b4324deaf236334a0f77a81435b5bffadf3c (patch) | |
tree | 3e4ed9af085e410ebab1adbb6ecc1d9cd84f3e42 /test/web/streamer/state_test.exs | |
parent | 4fabf83ad01352442906d79187aeab4c777f4df8 (diff) | |
download | pleroma-c623b4324deaf236334a0f77a81435b5bffadf3c.tar.gz pleroma-c623b4324deaf236334a0f77a81435b5bffadf3c.zip |
Revert "Merge branch 'streamer-refactoring' into 'develop'"
This reverts merge request !1653
Diffstat (limited to 'test/web/streamer/state_test.exs')
-rw-r--r-- | test/web/streamer/state_test.exs | 54 |
1 files changed, 0 insertions, 54 deletions
diff --git a/test/web/streamer/state_test.exs b/test/web/streamer/state_test.exs deleted file mode 100644 index d1aeac541..000000000 --- a/test/web/streamer/state_test.exs +++ /dev/null @@ -1,54 +0,0 @@ -# Pleroma: A lightweight social networking server -# Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/> -# SPDX-License-Identifier: AGPL-3.0-only - -defmodule Pleroma.Web.StateTest do - use Pleroma.DataCase - - import Pleroma.Factory - alias Pleroma.Web.Streamer - alias Pleroma.Web.Streamer.StreamerSocket - - @moduletag needs_streamer: true - - describe "sockets" do - setup do - user = insert(:user) - user2 = insert(:user) - {:ok, %{user: user, user2: user2}} - end - - test "it can add a socket", %{user: user} do - Streamer.add_socket("public", %{transport_pid: 1, assigns: %{user: user}}) - - assert(%{"public" => [%StreamerSocket{transport_pid: 1}]} = Streamer.get_sockets()) - end - - test "it can add multiple sockets per user", %{user: user} do - Streamer.add_socket("public", %{transport_pid: 1, assigns: %{user: user}}) - Streamer.add_socket("public", %{transport_pid: 2, assigns: %{user: user}}) - - assert( - %{ - "public" => [ - %StreamerSocket{transport_pid: 2}, - %StreamerSocket{transport_pid: 1} - ] - } = Streamer.get_sockets() - ) - end - - test "it will not add a duplicate socket", %{user: user} do - Streamer.add_socket("activity", %{transport_pid: 1, assigns: %{user: user}}) - Streamer.add_socket("activity", %{transport_pid: 1, assigns: %{user: user}}) - - assert( - %{ - "activity" => [ - %StreamerSocket{transport_pid: 1} - ] - } = Streamer.get_sockets() - ) - end - end -end |