mobilizon/lib/service/notifier/push.ex

98 lines
2.8 KiB
Elixir

defmodule Mobilizon.Service.Notifier.Push do
@moduledoc """
WebPush notifier
"""
alias Mobilizon.Activities.Activity
alias Mobilizon.{Config, Users}
alias Mobilizon.Service.Activity.{Renderer, Utils}
alias Mobilizon.Service.Notifier
alias Mobilizon.Service.Notifier.{Filter, Push}
alias Mobilizon.Storage.Page
alias Mobilizon.Users.{PushSubscription, User}
@behaviour Notifier
@impl Notifier
def ready? do
Config.get([__MODULE__, :enabled])
end
@impl Notifier
def send(user, activity, options \\ [])
def send(%User{id: user_id, locale: locale} = user, %Activity{} = activity, options) do
if can_send_activity?(activity, user) do
options = Keyword.put_new(options, :locale, locale)
%Page{elements: subscriptions} = Users.list_user_push_subscriptions(user_id, 1, 100)
subscriptions
|> Enum.map(&convert_subscription/1)
|> Enum.map(fn subscription ->
Task.async(fn -> send_subscription(activity, subscription, options) end)
end)
|> Task.await_many(10_000)
{:ok, :sent}
else
{:ok, :skipped}
end
end
@impl Notifier
def send(%User{} = user, activities, options) when is_list(activities) do
Enum.map(activities, &Push.send(user, &1, options))
end
@spec can_send_activity?(Activity.t(), User.t()) :: boolean()
defp can_send_activity?(%Activity{} = activity, %User{} = user) do
Filter.can_send_activity?(activity, "push", user, &default_activity_behavior/1)
end
@default_behavior %{
"participation_event_updated" => true,
"participation_event_comment" => true,
"event_new_pending_participation" => true,
"event_new_participation" => false,
"event_created" => false,
"event_updated" => false,
"discussion_updated" => false,
"post_published" => false,
"post_updated" => false,
"resource_updated" => false,
"member_request" => true,
"member_updated" => false,
"user_email_password_updated" => false,
"event_comment_mention" => true,
"discussion_mention" => false,
"event_new_comment" => false
}
@spec default_activity_behavior(String.t()) :: boolean()
defp default_activity_behavior(activity_setting) do
Map.get(@default_behavior, activity_setting, false)
end
@spec send_subscription(Activity.t(), any, Keyword.t()) :: any()
defp send_subscription(activity, subscription, options) do
activity
|> payload(options)
|> WebPushEncryption.send_web_push(subscription)
end
@spec payload(Activity.t(), Keyword.t()) :: String.t()
defp payload(%Activity{} = activity, options) do
activity
|> Utils.add_activity_object()
|> Renderer.render(options)
|> Jason.encode!()
end
defp convert_subscription(%PushSubscription{} = subscription) do
%{
endpoint: subscription.endpoint,
keys: %{auth: subscription.auth, p256dh: subscription.p256dh}
}
end
end