aboutsummaryrefslogtreecommitdiff
path: root/test/support
diff options
context:
space:
mode:
authorTusooa Zhu <tusooa@kazv.moe>2022-08-19 13:56:39 -0400
committerTusooa Zhu <tusooa@kazv.moe>2022-08-19 20:24:21 -0400
commiteb42e90c4f9ca35a6dc0e84e6f87b6f4b680173c (patch)
tree3b4b8aa04c9583a449ebd3b4092a501c72961e00 /test/support
parentc62a4f1c173490ad64fdfbab0c005ca3523b6013 (diff)
downloadpleroma-eb42e90c4f9ca35a6dc0e84e6f87b6f4b680173c.tar.gz
Use Websockex to replace websocket_client
Diffstat (limited to 'test/support')
-rw-r--r--test/support/websocket_client.ex28
1 files changed, 13 insertions, 15 deletions
diff --git a/test/support/websocket_client.ex b/test/support/websocket_client.ex
index 34b955474..2660f6151 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,26 @@ defmodule Pleroma.Integration.WebsocketClient do
end
@doc false
- def init([sender], _conn_state) do
- {:ok, %{sender: sender}}
- end
-
- @doc false
- def websocket_handle(frame, _conn_state, state) do
+ @impl true
+ def handle_frame(frame, state) do
send(state.sender, frame)
{: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