analytics/lib/workers/notify_annual_renewal.ex

51 lines
1.5 KiB
Elixir
Raw Normal View History

defmodule Plausible.Workers.NotifyAnnualRenewal do
use Plausible.Repo
use Oban.Worker, queue: :notify_annual_renewal
@yearly_plans Plausible.Billing.Plans.yearly_plan_ids()
@impl Oban.Worker
@doc """
Sends a notification at most 7 days and at least 1 day before the renewal of an annual subscription
"""
def perform(_args, _job) do
users =
Repo.all(
from u in Plausible.Auth.User,
left_join: sent in "sent_renewal_notifications",
join: s in Plausible.Billing.Subscription,
on: s.user_id == u.id,
where: s.paddle_plan_id in @yearly_plans,
where:
s.next_bill_date > fragment("now()::date") and
s.next_bill_date <= fragment("now()::date + INTERVAL '7 days'"),
where: is_nil(sent.id) or sent.timestamp < fragment("now() - INTERVAL '1 month'"),
preload: [subscription: s]
)
for user <- users do
case user.subscription.status do
"active" ->
template = PlausibleWeb.Email.yearly_renewal_notification(user)
Plausible.Mailer.send_email(template)
"deleted" ->
template = PlausibleWeb.Email.yearly_expiration_notification(user)
Plausible.Mailer.send_email(template)
_ ->
Sentry.capture_message("Invalid subscription for renewal", user: user)
end
Repo.insert_all("sent_renewal_notifications", [
%{
user_id: user.id,
timestamp: NaiveDateTime.utc_now()
}
])
end
:ok
end
end