Packages

push_ex

0.2.0-rc1
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 push item_server.ex
Raw

lib/push_ex/push/item_server.ex 

defmodule PushEx.Push.ItemServer do

  @moduledoc false



  require Logger



  def start_link(

        %{

          item: item = %PushEx.Push{channel: channel, event: event},

          at: unix_inserted_at

        },

        opts \\ []

      ) do

    Task.start_link(fn ->

      channel_api_mod = Keyword.get(opts, :channel_api_mod, PushExWeb.PushChannel)

      ms_since_insertion = PushEx.unix_ms_now() - unix_inserted_at



      channel_api_mod.broadcast({:msg, channel}, item)

      |> case do

        {:ok, :broadcast} ->

          Logger.debug("Push.ItemServer broadcast channel=#{channel} event=#{event} ms_in_stage=#{ms_since_insertion}")



        {:ok, :no_listeners} ->

          Logger.debug("Push.ItemServer no_listeners channel=#{channel} event=#{event} ms_in_stage=#{ms_since_insertion}")

      end

    end)

  end

end