debianize-mobilizon/lib/service/workers/notification.ex

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}

  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_later()

      :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),
         %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_later()

      :ok
    else
      _ -> :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),
         %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_later()

      :ok
    else
      _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(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_later()

      :ok
    else
      err ->
        require Logger
        Logger.debug(inspect(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