diff options
author | Mark Felder <feld@feld.me> | 2022-10-10 13:20:28 -0400 |
---|---|---|
committer | Mark Felder <feld@feld.me> | 2022-10-10 13:20:28 -0400 |
commit | b3a02c6b9f823798fb6e077cf36dcf123a3bad7e (patch) | |
tree | 315adc61df49588a6992e7c55021d13966b6240e /test/support/websocket_client.ex | |
parent | 7ac4e858a019891ce5873936db1b4a0ec0566a97 (diff) | |
parent | 8042e0ebe1277519d446a7e2fbcf17629c1ffab2 (diff) | |
download | pleroma-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.ex | 32 |
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 |