Packages

push_ex

1.0.0-rc3
2.2.0 2.1.0 2.0.0 1.2.0 1.1.0 1.0.2 1.0.1-rc3 1.0.1-rc2 1.0.1-rc1 1.0.0-rc9 1.0.0-rc8 1.0.0-rc7 1.0.0-rc6 1.0.0-rc5 1.0.0-rc4 1.0.0-rc3 1.0.0-rc2 1.0.0-rc15 1.0.0-rc14 1.0.0-rc13 1.0.0-rc12 1.0.0-rc11 1.0.0-rc10 1.0.0-rc1 0.2.0-rc2 0.2.0-rc1 0.1.0-rc1 0.0.1-rc4 0.0.1-rc3 0.0.1-rc2 0.0.1-rc

PushEx is an implementation of Phoenix websockets/channels which handles best practices of running websockets for you, but allows your business logic to be specified through simple behaviour modules.

HexDocs

Current section

Files

Jump to
Readme
31 Versions
7 Dependencies
Dependants
Files
Activity
push_ex lib push_ex_web channels push_socket.ex
Raw

lib/push_ex_web/channels/push_socket.ex 

defmodule PushExWeb.PushSocket do

  @moduledoc false



  # Override Phoenix.Socket init in order to track the socket (with transport_pid) in pushex tracker

  def init(state) do

    case Phoenix.Socket.__init__(state) do

      res = {:ok, {_, %Phoenix.Socket{} = socket}} ->

        PushEx.Instrumentation.Tracker.track_socket(socket)

        res



      res ->

        res

    end

  end



  use Phoenix.Socket



  channel "*", PushExWeb.PushChannel



  def connect(params, socket) do

    PushEx.Config.socket_impl().socket_connect(params, socket)

  end



  def id(socket) do

    PushEx.Config.socket_impl().socket_id(socket)

  end

end