mobilizon.chapril.org-mobil.../lib/service/workers/notification.ex
Thomas Citharel 770a518ad1
Properly handle un-needed background jobs
Cancel them if they're not needed

Signed-off-by: Thomas Citharel <tcit@tcit.fr>
2022-11-03 18:00:42 +01:00

159 lines
5.0 KiB
Elixir

defmodule Mobilizon.Service.Workers.Notification do
@moduledoc """
Worker to send notifications
"""
alias Mobilizon.{Actors, Events, Users}
alias Mobilizon.Actors.Actor
alias Mobilizon.Events.{Event, Participant}
alias Mobilizon.Storage.Page
alias Mobilizon.Users.{Setting, User}
alias Mobilizon.Web.Email.{Mailer, Notification}
require Logger
import Mobilizon.Service.DateTime,
only: [
datetime_tz_convert: 2
]
use Mobilizon.Service.Workers.Helper, queue: "mailers"
@impl Oban.Worker
def perform(%Job{
args: %{"op" => "before_event_notification", "participant_id" => participant_id}
}) do
with %Participant{} = participant <- Events.get_participant(participant_id),
%Event{status: :confirmed} = event <-
Events.get_event_with_preload!(participant.event_id),
%Actor{user_id: user_id} = actor when not is_nil(user_id) <-
Actors.get_actor_with_preload!(participant.actor_id) do
%User{email: email, locale: locale, settings: %Setting{notification_before_event: true}} =
Users.get_user_with_settings!(user_id)
email
|> Notification.before_event_notification(
%Participant{participant | event: event, actor: actor},
locale
)
|> Mailer.send_email()
:ok
end
end
def perform(%Job{
args: %{"op" => "on_day_notification", "user_id" => user_id}
}) do
with %User{locale: locale, settings: %Setting{timezone: timezone, notification_on_day: true}} =
user <- Users.get_user_with_settings!(user_id),
{start, tomorrow} <- calculate_start_end(1, timezone || "Etc/UTC"),
%Page{
elements: participations,
total: total
}
when total > 0 <-
Events.list_participations_for_user(user_id, start, tomorrow, 1, 5),
participations <-
Enum.filter(participations, fn participation ->
participation.event.status == :confirmed
end),
true <- length(participations) > 0,
participations <-
Enum.map(participations, fn participation ->
%Event{} = event = Events.get_event_with_preload!(participation.event_id)
%Participant{participation | event: event}
end) do
user
|> Notification.on_day_notification(participations, total, locale)
|> Mailer.send_email()
:ok
else
%Page{elements: [], total: 0} ->
{:cancel, :no_user_participations}
_ ->
:ok
end
end
def perform(%Job{
args: %{"op" => "weekly_notification", "user_id" => user_id}
}) do
with %User{
locale: locale,
settings: %Setting{timezone: timezone, notification_each_week: true}
} = user <- Users.get_user_with_settings!(user_id),
{start, end_week} <- calculate_start_end(7, timezone || "Etc/UTC"),
%Page{
elements: participations,
total: total
}
when total > 0 <-
Events.list_participations_for_user(user_id, start, end_week, 1, 5),
participations <-
Enum.filter(participations, fn participation ->
participation.event.status == :confirmed
end),
true <- length(participations) > 0,
participations <-
Enum.map(participations, fn participation ->
%Event{} = event = Events.get_event_with_preload!(participation.event_id)
%Participant{participation | event: event}
end) do
user
|> Notification.weekly_notification(participations, total, locale)
|> Mailer.send_email()
:ok
else
%Page{elements: [], total: 0} ->
{:cancel, :no_user_participations}
_err ->
:ok
end
end
def perform(%Job{
args: %{
"op" => "pending_participation_notification",
"user_id" => user_id,
"event_id" => event_id
}
}) do
with %User{} = user <- Users.get_user_with_settings!(user_id),
{:ok, %Event{} = event} <- Events.get_event_with_preload(event_id),
%Page{total: total} when total > 0 <-
Events.list_participants_for_event(event_id, [:not_approved]) do
user
|> Notification.pending_participation_notification(event, total)
|> Mailer.send_email()
:ok
else
{:error, :event_not_found} ->
{:cancel, :event_participation_not_found}
%Page{elements: [], total: 0} ->
{:cancel, :no_participants_to_approve}
err ->
Logger.debug(inspect(err))
err
end
end
defp calculate_start_end(days, timezone) do
now = DateTime.utc_now()
%DateTime{} = now_shifted = datetime_tz_convert(now, timezone)
start = %{now_shifted | hour: 8, minute: 0, second: 0, microsecond: {0, 0}}
{:ok, %NaiveDateTime{} = tomorrow} =
Date.utc_today() |> Date.add(days) |> NaiveDateTime.new(~T[08:00:00])
{:ok, %DateTime{} = tomorrow} = DateTime.from_naive(tomorrow, timezone)
{start, tomorrow}
end
end