Packages

slipstream

0.1.2
1.2.2 1.2.1 1.2.0 1.1.3 1.1.2 1.1.1 1.1.0 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.8.5 0.8.4 0.8.3 0.8.2 0.8.1 0.8.0 0.8.0-rc.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.4 0.5.3 0.5.2 0.5.1 0.5.0 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

A slick websocket client for Phoenix channels

HexDocs

Current section

Files

Jump to
Readme
48 Versions
4 Dependencies
Dependants
Files
Activity
slipstream lib slipstream command_router.ex
Raw

lib/slipstream/command_router.ex 

defmodule Slipstream.CommandRouter do

  @moduledoc false



  # Implements how a command is routed.

  # Note that many commands are simply forwarded to the connection process

  # for further handling.

  # For other commands like OpenConnection, there is no connection process to

  # send to



  alias Slipstream.Commands.{

    OpenConnection,

    JoinTopic,

    LeaveTopic,

    PushMessage,

    CollectGarbage,

    CloseConnection

  }



  alias Slipstream.Socket



  import Slipstream.Signatures, only: [command: 1]



  @forwarded_command_types [

    JoinTopic,

    LeaveTopic,

    CollectGarbage,

    CloseConnection

  ]



  @spec route_command(struct()) :: any()

  def route_command(command)



  def route_command(%OpenConnection{} = cmd) do

    DynamicSupervisor.start_child(

      Slipstream.ConnectionSupervisor,

      {Slipstream.Connection, cmd}

    )

  end



  # forward the commands to the connection process

  def route_command(%command_type{socket: socket} = cmd)

      when command_type in @forwarded_command_types do

    Socket.send(socket, command(cmd))

  end



  # this one is a synchronous push with a reply from the connection process

  def route_command(%PushMessage{socket: socket} = cmd) do

    Socket.call(socket, command(cmd), cmd.timeout)

  end

end