aboutsummaryrefslogtreecommitdiff
path: root/test/support/websocket_client.ex
diff options
context:
space:
mode:
authorMark Felder <feld@feld.me>2022-10-10 13:20:28 -0400
committerMark Felder <feld@feld.me>2022-10-10 13:20:28 -0400
commitb3a02c6b9f823798fb6e077cf36dcf123a3bad7e (patch)
tree315adc61df49588a6992e7c55021d13966b6240e /test/support/websocket_client.ex
parent7ac4e858a019891ce5873936db1b4a0ec0566a97 (diff)
parent8042e0ebe1277519d446a7e2fbcf17629c1ffab2 (diff)
downloadpleroma-finch_everywhere.tar.gz
Merge branch 'develop' into finch_everywherefinch_everywhere
Diffstat (limited to 'test/support/websocket_client.ex')
-rw-r--r--test/support/websocket_client.ex32
1 files changed, 18 insertions, 14 deletions
diff --git a/test/support/websocket_client.ex b/test/support/websocket_client.ex
index d149b324e..7163bbd41 100644
--- a/test/support/websocket_client.ex
+++ b/test/support/websocket_client.ex
@@ -5,18 +5,17 @@
defmodule Pleroma.Integration.WebsocketClient do
# https://github.com/phoenixframework/phoenix/blob/master/test/support/websocket_client.exs
+ use WebSockex
+
@doc """
Starts the WebSocket server for given ws URL. Received Socket.Message's
are forwarded to the sender pid
"""
def start_link(sender, url, headers \\ []) do
- :crypto.start()
- :ssl.start()
-
- :websocket_client.start_link(
- String.to_charlist(url),
+ WebSockex.start_link(
+ url,
__MODULE__,
- [sender],
+ %{sender: sender},
extra_headers: headers
)
end
@@ -36,27 +35,32 @@ defmodule Pleroma.Integration.WebsocketClient do
end
@doc false
- def init([sender], _conn_state) do
- {:ok, %{sender: sender}}
+ @impl true
+ def handle_frame(frame, state) do
+ send(state.sender, frame)
+ {:ok, state}
end
- @doc false
- def websocket_handle(frame, _conn_state, state) do
- send(state.sender, frame)
+ @impl true
+ def handle_disconnect(conn_status, state) do
+ send(state.sender, {:close, conn_status})
{:ok, state}
end
@doc false
- def websocket_info({:text, msg}, _conn_state, state) do
+ @impl true
+ def handle_info({:text, msg}, state) do
{:reply, {:text, msg}, state}
end
- def websocket_info(:close, _conn_state, _state) do
+ @impl true
+ def handle_info(:close, _state) do
{:close, <<>>, "done"}
end
@doc false
- def websocket_terminate(_reason, _conn_state, _state) do
+ @impl true
+ def terminate(_reason, _state) do
:ok
end
end