diff options
author | lain <lain@soykaf.club> | 2020-05-07 15:05:40 +0200 |
---|---|---|
committer | lain <lain@soykaf.club> | 2020-05-07 15:05:40 +0200 |
commit | fb2d284d2897e8b789da4f81ae8d288373d2bf76 (patch) | |
tree | 35b6a6d3c656244528dc2455f768b4f9704fce8e /test/web/streamer/state_test.exs | |
parent | 1748e2694815da20689005110937ea42cd554d70 (diff) | |
parent | b7635bf2b6c5251ffc8f3b3b8e1bc7ee9db83b7e (diff) | |
download | pleroma-fb2d284d2897e8b789da4f81ae8d288373d2bf76.tar.gz pleroma-fb2d284d2897e8b789da4f81ae8d288373d2bf76.zip |
Merge branch 'develop' of git.pleroma.social:pleroma/pleroma into remake-remodel-dms
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 a755e75c0..000000000 --- a/test/web/streamer/state_test.exs +++ /dev/null @@ -1,54 +0,0 @@ -# Pleroma: A lightweight social networking server -# Copyright © 2017-2020 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 |