Packages
pigeon
1.1.2
2.0.1
2.0.0
2.0.0-rc.3
2.0.0-rc.2
2.0.0-rc.1
2.0.0-rc.0
1.6.3
1.6.2
1.6.1
1.6.0
1.5.1
1.5.0
1.4.0
1.3.2
1.3.1
1.3.0
1.2.4
1.2.3
1.2.2
1.2.1
1.2.0
1.1.6
1.1.5
1.1.4
1.1.3
1.1.2
1.1.1
1.1.0
1.1.0-rc.1
1.1.0-rc.0
1.0.4
1.0.3
1.0.2
1.0.1
1.0.0
0.13.1
0.13.0
0.12.1
0.12.0
0.11.0
0.10.3
0.10.2
0.10.1
0.10.0
0.9.1
0.9.0
0.8.0
0.7.0
0.6.0
0.5.2
0.5.1
0.5.0
0.4.1
0.4.0
0.3.0
0.2.0
0.1.0
iOS (APNS), Android (FCM), and Amazon Android (ADM) push notifications for Elixir.
Current section
Files
Jump to
Current section
Files
lib/pigeon.ex
defmodule Pigeon do
@moduledoc """
HTTP2-compliant wrapper for sending iOS and Android push notifications.
"""
use Application
require Logger
import Supervisor.Spec
alias Pigeon.{ADM, APNS, FCM}
alias Pigeon.Http2.Client
@doc false
def start(_type, _args) do
Client.default().start
opts = [strategy: :one_for_one, name: :pigeon]
Supervisor.start_link(workers(), opts)
end
defp workers do
adm_workers()
++ apns_workers()
++ fcm_workers()
++ env_workers()
++ task_supervisors()
end
defp task_supervisors do
[supervisor(Task.Supervisor, [[name: Pigeon.Tasks]])]
end
defp env_workers do
case Application.get_env(:pigeon, :workers) do
nil -> []
workers ->
Enum.map(workers, fn({mod, fun}) ->
config = apply(mod, fun, [])
worker(config)
end)
end
end
defp worker(%ADM.Config{} = config) do
worker(ADM.Worker, [config], id: config.name, restart: :temporary)
end
defp worker(config) do
worker(Pigeon.Worker, [config], id: config.name, restart: :temporary)
end
defp adm_workers do
workers_for(:adm, &ADM.Config.new/1, Pigeon.ADM.Worker)
end
defp apns_workers do
workers_for(:apns, &APNS.Config.new/1, Pigeon.Worker)
end
defp fcm_workers do
workers_for(:fcm, &FCM.Config.new/1, Pigeon.Worker)
end
defp workers_for(name, config_fn, mod) do
case Application.get_env(:pigeon, name) do
nil -> []
workers ->
Enum.map(workers, fn({worker_name, _config}) ->
config = config_fn.(worker_name)
worker(mod, [config], id: config.name, restart: :temporary)
end)
end
end
@doc false
def start_connection(state) do
opts = [restart: :temporary, id: :erlang.make_ref]
spec = worker(Pigeon.Connection, [state], opts)
Supervisor.start_child(:pigeon, spec)
end
def debug_log?, do: Application.get_env(:pigeon, :debug_log, false)
end