Packages

push_ex

0.2.0-rc2
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_presence.ex
Raw

lib/push_ex_web/channels/push_presence.ex 

defmodule PushExWeb.PushPresence do

  @moduledoc false



  # Phoenix.Presence propagates presence_diff to channels. However, this is not necessary for pushex

  # use case and sending the message comes at significant cost.

  def handle_diff(_diff, state) do

    {:ok, state}

  end



  use Phoenix.Presence,

    otp_app: :push_ex,

    pubsub_server: PushEx.PubSub



  def track(%Phoenix.Socket{topic: topic} = socket) do

    id = PushEx.Config.socket_impl().presence_identifier(socket)



    track(socket.channel_pid, topic, id, %{

      online_at: PushEx.unix_ms_now()

    })

  end



  def listeners?(topic) do

    topic

    |> list()

    |> Enum.any?()

  end

end