X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fworkers%2Fcron%2Fdigest_emails_worker.ex;h=7f09ff3cf56a05ca043732e9ae333bb25c2c0115;hb=d35be02e7064da8ffce51fb10a937af30b145c7b;hp=c589a59eb8da754feef4ea1a419ad7d4eb93c193;hpb=4a45b96a91485a39f26bcc86b6cbd21d1547511e;p=akkoma diff --git a/lib/pleroma/workers/cron/digest_emails_worker.ex b/lib/pleroma/workers/cron/digest_emails_worker.ex index c589a59eb..7f09ff3cf 100644 --- a/lib/pleroma/workers/cron/digest_emails_worker.ex +++ b/lib/pleroma/workers/cron/digest_emails_worker.ex @@ -31,11 +31,14 @@ defmodule Pleroma.Workers.Cron.DigestEmailsWorker do from(u in inactive_users_query, where: fragment(~s(? ->'digest' @> 'true'), u.email_notifications), + where: not is_nil(u.email), where: u.last_digest_emailed_at < datetime_add(^now, ^negative_interval, "day"), select: u ) |> Repo.all() |> send_emails + else + :ok end end