350 lines
10 KiB
Elixir
350 lines
10 KiB
Elixir
defmodule Mobilizon.Service.Workers.NotificationTest do
|
|
@moduledoc """
|
|
Test the scheduler module
|
|
"""
|
|
|
|
alias Mobilizon.Actors.Actor
|
|
alias Mobilizon.Events
|
|
alias Mobilizon.Events.{Event, Participant}
|
|
alias Mobilizon.Service.Workers.Notification
|
|
alias Mobilizon.Users.User
|
|
alias Mobilizon.Web.Email.Notification, as: NotificationMailer
|
|
|
|
use Mobilizon.DataCase
|
|
use Bamboo.Test
|
|
|
|
import Mobilizon.Factory
|
|
|
|
describe "A before_event_notification job sends an email" do
|
|
test "if the user is still participating" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings,
|
|
user_id: user_id,
|
|
notification_before_event: true
|
|
)
|
|
|
|
user = %User{user | settings: settings}
|
|
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
%Participant{id: participant_id} =
|
|
participant = insert(:participant, role: :participant, actor: actor)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "before_event_notification", "participant_id" => participant_id}
|
|
})
|
|
|
|
assert_delivered_email(
|
|
NotificationMailer.before_event_notification(
|
|
participant.actor.user.email,
|
|
participant
|
|
)
|
|
)
|
|
end
|
|
|
|
test "unless the person is no longer participating" do
|
|
%Event{id: event_id} = insert(:event)
|
|
|
|
%User{} = user = insert(:user)
|
|
%Actor{id: actor_id} = insert(:actor, user: user)
|
|
|
|
{:ok, %Participant{id: participant_id} = participant} =
|
|
Events.create_participant(%{actor_id: actor_id, event_id: event_id, role: :participant})
|
|
|
|
actor = %Actor{participant.actor | user: user}
|
|
event = Events.get_event_with_preload!(participant.event_id)
|
|
participant = %Participant{participant | actor: actor, event: event}
|
|
|
|
assert {:ok, %{participant: %Participant{}}} = Events.delete_participant(participant)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "before_event_notification", "participant_id" => participant_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.before_event_notification(
|
|
participant.actor.user.email,
|
|
participant
|
|
)
|
|
)
|
|
end
|
|
|
|
test "unless the event has been cancelled" do
|
|
%Event{} = event = insert(:event, status: :cancelled)
|
|
|
|
%Participant{id: participant_id} =
|
|
participant = insert(:participant, role: :participant, event: event)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "before_event_notification", "participant_id" => participant_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.before_event_notification(
|
|
participant.actor.user.email,
|
|
participant
|
|
)
|
|
)
|
|
end
|
|
end
|
|
|
|
describe "A on_day_notification job sends an email" do
|
|
test "if the user is still participating" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_on_day: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
%Participant{} = participant = insert(:participant, role: :participant, actor: actor)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "on_day_notification", "user_id" => user_id}
|
|
})
|
|
|
|
assert_delivered_email(
|
|
NotificationMailer.on_day_notification(
|
|
user,
|
|
[participant],
|
|
1
|
|
)
|
|
)
|
|
end
|
|
|
|
test "unless the person is no longer participating" do
|
|
%Event{id: event_id} = event = insert(:event)
|
|
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_on_day: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
{:ok, %Participant{} = participant} =
|
|
Events.create_participant(%{actor_id: actor.id, event_id: event_id, role: :participant})
|
|
|
|
actor = Map.put(participant.actor, :user, user)
|
|
participant = %Participant{participant | actor: actor, event: event}
|
|
|
|
assert {:ok, %{participant: %Participant{}}} = Events.delete_participant(participant)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "on_day_notification", "user_id" => user_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.on_day_notification(
|
|
user,
|
|
[participant],
|
|
1
|
|
)
|
|
)
|
|
end
|
|
|
|
test "unless the event has been cancelled" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_on_day: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
%Event{} = event = insert(:event, status: :cancelled)
|
|
|
|
%Participant{} =
|
|
participant = insert(:participant, role: :participant, event: event, actor: actor)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "on_day_notification", "user_id" => user_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.on_day_notification(
|
|
user,
|
|
[participant],
|
|
1
|
|
)
|
|
)
|
|
end
|
|
|
|
test "with a lot of events" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_on_day: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
participants =
|
|
Enum.reduce(0..10, [], fn _i, acc ->
|
|
%Participant{} = participant = insert(:participant, role: :participant, actor: actor)
|
|
acc ++ [participant]
|
|
end)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "on_day_notification", "user_id" => user_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.on_day_notification(
|
|
user,
|
|
participants,
|
|
3
|
|
)
|
|
)
|
|
end
|
|
end
|
|
|
|
describe "A weekly_notification job sends an email" do
|
|
test "if the user is still participating" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_each_week: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
%Participant{} = participant = insert(:participant, role: :participant, actor: actor)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "weekly_notification", "user_id" => user_id}
|
|
})
|
|
|
|
assert_delivered_email(
|
|
NotificationMailer.weekly_notification(
|
|
user,
|
|
[participant],
|
|
1
|
|
)
|
|
)
|
|
end
|
|
|
|
test "unless the person is no longer participating" do
|
|
%Event{id: event_id} = event = insert(:event)
|
|
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_each_week: true, timezone: "Europe/Paris")
|
|
|
|
user = %User{user | settings: settings}
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
{:ok, %Participant{} = participant} =
|
|
Events.create_participant(%{actor_id: actor.id, event_id: event_id, role: :participant})
|
|
|
|
actor = %Actor{participant.actor | user: user}
|
|
participant = %Participant{participant | actor: actor, event: event}
|
|
|
|
assert {:ok, %{participant: %Participant{}}} = Events.delete_participant(participant)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "weekly_notification", "user_id" => user_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.weekly_notification(
|
|
user,
|
|
[participant],
|
|
1
|
|
)
|
|
)
|
|
end
|
|
|
|
test "unless the event has been cancelled" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_each_week: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
%Event{} = event = insert(:event, status: :cancelled)
|
|
|
|
%Participant{} =
|
|
participant = insert(:participant, role: :participant, event: event, actor: actor)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "weekly_notification", "user_id" => user_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.weekly_notification(
|
|
user,
|
|
[participant],
|
|
1
|
|
)
|
|
)
|
|
end
|
|
|
|
test "with a lot of events" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings, user_id: user_id, notification_each_week: true, timezone: "Europe/Paris")
|
|
|
|
user = Map.put(user, :settings, settings)
|
|
%Actor{} = actor = insert(:actor, user: user)
|
|
|
|
participants =
|
|
Enum.reduce(0..10, [], fn _i, acc ->
|
|
%Participant{} = participant = insert(:participant, role: :participant, actor: actor)
|
|
acc ++ [participant]
|
|
end)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{"op" => "weekly_notification", "user_id" => user_id}
|
|
})
|
|
|
|
refute_delivered_email(
|
|
NotificationMailer.weekly_notification(
|
|
user,
|
|
participants,
|
|
3
|
|
)
|
|
)
|
|
end
|
|
end
|
|
|
|
describe "A pending_participation_notification job sends an email" do
|
|
test "if there are participants to approve" do
|
|
%User{id: user_id} = user = insert(:user)
|
|
|
|
settings =
|
|
insert(:settings,
|
|
user_id: user_id,
|
|
timezone: "Europe/Paris"
|
|
)
|
|
|
|
%Event{id: event_id} = event = insert(:event)
|
|
|
|
%Participant{} = insert(:participant, event: event, role: :not_approved)
|
|
%Participant{} = insert(:participant, event: event, role: :not_approved)
|
|
|
|
Notification.perform(%Oban.Job{
|
|
args: %{
|
|
"op" => "pending_participation_notification",
|
|
"user_id" => user_id,
|
|
"event_id" => event_id
|
|
}
|
|
})
|
|
|
|
assert_delivered_email(
|
|
NotificationMailer.pending_participation_notification(
|
|
%User{user | settings: settings},
|
|
event,
|
|
2
|
|
)
|
|
)
|
|
end
|
|
end
|
|
end
|