mirror of
https://github.com/plausible/analytics.git
synced 2024-11-28 04:30:42 +03:00
e71de6dc1f
* Invite existing user to a site * Add invitation flow for non-existing users * Accept and reject invitations * Use invitation flow for existing users * Locking mechanism for sites * Authorization for site settings * Show usage based on site ownership * Add ability to remove members from a site * Do not show settings link to viewer roles * Ability to remove invitations * Remove `Plausible.Sites.count_for/1` * Fix tests * Do not show the trial banner after the trial * Correct trial emails * Transfer ownership * Send invitation email to existing user * Add invitation email flows * Add plug for role-based authorization * Rename AuthorizeStatsPlug -> AuthorizeSiteAccess * Add email flow for ownership transfer * Fix URLs in emails * Fix small copy issues * Make 'People' its own section in site settings * Notify user via email if their access has been removed * Check site lock status when invitation is accepted * Check lock status when user subscribes * Make sure only admins and owners can create shared links * Changelog * Add LockSites to daily cron * Clean invitations after 48 hours * Add notices about expiry * Add invitation expired page * Add doc link
114 lines
2.8 KiB
Elixir
114 lines
2.8 KiB
Elixir
defmodule Plausible.Workers.SendSiteSetupEmails do
|
|
use Plausible.Repo
|
|
use Oban.Worker, queue: :site_setup_emails
|
|
require Logger
|
|
alias Plausible.Stats.Clickhouse, as: Stats
|
|
|
|
@impl Oban.Worker
|
|
def perform(_job) do
|
|
send_create_site_emails()
|
|
send_setup_help_emails()
|
|
send_setup_success_emails()
|
|
|
|
:ok
|
|
end
|
|
|
|
defp send_create_site_emails() do
|
|
q =
|
|
from(s in Plausible.Auth.User,
|
|
left_join: se in "create_site_emails",
|
|
on: se.user_id == s.id,
|
|
where: is_nil(se.id),
|
|
where:
|
|
s.inserted_at > fragment("(now() at time zone 'utc') - '72 hours'::interval") and
|
|
s.inserted_at < fragment("(now() at time zone 'utc') - '48 hours'::interval"),
|
|
preload: :sites
|
|
)
|
|
|
|
for user <- Repo.all(q) do
|
|
if Enum.empty?(user.sites) do
|
|
send_create_site_email(user)
|
|
end
|
|
end
|
|
end
|
|
|
|
defp send_setup_help_emails() do
|
|
q =
|
|
from(s in Plausible.Site,
|
|
left_join: se in "setup_help_emails",
|
|
on: se.site_id == s.id,
|
|
where: is_nil(se.id),
|
|
where: s.inserted_at > fragment("(now() at time zone 'utc') - '72 hours'::interval")
|
|
)
|
|
|
|
for site <- Repo.all(q) do
|
|
owner =
|
|
Plausible.Sites.owner_for(site)
|
|
|> Repo.preload(:subscription)
|
|
|
|
setup_completed = Stats.has_pageviews?(site)
|
|
hours_passed = Timex.diff(Timex.now(), site.inserted_at, :hours)
|
|
|
|
if !setup_completed && hours_passed > 47 do
|
|
send_setup_help_email(owner, site)
|
|
end
|
|
end
|
|
end
|
|
|
|
defp send_setup_success_emails() do
|
|
q =
|
|
from(s in Plausible.Site,
|
|
left_join: se in "setup_success_emails",
|
|
on: se.site_id == s.id,
|
|
where: is_nil(se.id),
|
|
where: s.inserted_at > fragment("(now() at time zone 'utc') - '72 hours'::interval")
|
|
)
|
|
|
|
for site <- Repo.all(q) do
|
|
owner =
|
|
Plausible.Sites.owner_for(site)
|
|
|> Repo.preload(:subscription)
|
|
|
|
if Stats.has_pageviews?(site) do
|
|
send_setup_success_email(owner, site)
|
|
end
|
|
end
|
|
end
|
|
|
|
defp send_create_site_email(user) do
|
|
PlausibleWeb.Email.create_site_email(user)
|
|
|> Plausible.Mailer.send_email()
|
|
|
|
Repo.insert_all("create_site_emails", [
|
|
%{
|
|
user_id: user.id,
|
|
timestamp: NaiveDateTime.utc_now()
|
|
}
|
|
])
|
|
end
|
|
|
|
defp send_setup_success_email(user, site) do
|
|
PlausibleWeb.Email.site_setup_success(user, site)
|
|
|> Plausible.Mailer.send_email()
|
|
|
|
Repo.insert_all("setup_success_emails", [
|
|
%{
|
|
site_id: site.id,
|
|
timestamp: NaiveDateTime.utc_now()
|
|
}
|
|
])
|
|
end
|
|
|
|
defp send_setup_help_email(user, site) do
|
|
PlausibleWeb.Email.site_setup_help(user, site)
|
|
|> Plausible.Mailer.send_email()
|
|
|
|
Repo.insert_all("setup_help_emails", [
|
|
%{
|
|
site_id: site.id,
|
|
timestamp: NaiveDateTime.utc_now()
|
|
}
|
|
])
|
|
end
|
|
end
|