Packages

francis

0.3.3
0.3.3 0.3.2 0.3.1 0.3.0 0.2.0 0.1.25 0.1.24 0.1.23 0.1.22 0.1.21 0.1.20 0.1.19 0.1.18 0.1.17 retired 0.1.16 0.1.15 0.1.14 0.1.13 0.1.12 0.1.11 0.1.10 0.1.9 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.1.0-pre

Boilerplate killer using Plug with Bandit to quickly build endpoints, websocket and SSE listeners

HexDocs

Current section

Files

Jump to
Readme
32 Versions
4 Dependencies
Dependants
Files
Activity
francis test support ws_tester.ex
Raw

test/support/ws_tester.ex 

defmodule Support.WsTester do

  @moduledoc """

  Websocket client to test Francis websocket routes

  """

  use WebSockex



  def start_link(state), do: WebSockex.start_link(state.url, __MODULE__, state)



  def handle_ping(:ping, %{parent_pid: parent_pid} = state) do

    send(parent_pid, {:client, {:ping, <<>>}})

    {:ok, state}

  end



  def handle_ping({:ping, payload}, %{parent_pid: parent_pid} = state) do

    send(parent_pid, {:client, {:ping, payload}})

    {:ok, state}

  end



  def handle_pong(:pong, %{parent_pid: parent_pid} = state) do

    send(parent_pid, {:client, {:pong, <<>>}})

    {:ok, state}

  end



  def handle_pong({:pong, payload}, %{parent_pid: parent_pid} = state) do

    send(parent_pid, {:client, {:pong, payload}})

    {:ok, state}

  end



  def handle_frame({:text, msg}, %{parent_pid: parent_pid} = state) when is_binary(msg) do

    case Jason.decode(msg) do

      {:ok, decoded_msg} -> send(parent_pid, {:client, decoded_msg})

      {:error, _} -> send(parent_pid, {:client, msg})

    end



    {:ok, state}

  end

end