[#1149] Introduced `quantum` job scheduler. Documentation & config changes.

2 files changed, 27 insertions, 15 deletions

diff --git a/config/config.exs b/config/config.exs
index 1a6348bcd..43d114d70 100644
--- a/config/config.exs
+++ b/config/config.exs
@@ -51,6 +51,24 @@ config :pleroma, Pleroma.Repo,
   telemetry_event: [Pleroma.Repo.Instrumenter],
   migration_lock: nil
 
+scheduled_jobs =
+  with digest_config <- Application.get_env(:pleroma, :email_notifications)[:digest],
+       true <- digest_config[:active] do
+    [{digest_config[:schedule], {Pleroma.DigestEmailWorker, :perform, []}}]
+  else
+    _ -> []
+  end
+
+scheduled_jobs =
+  scheduled_jobs ++
+    [{"0 */6 * * * *", {Pleroma.Web.Websub, :refresh_subscriptions, []}}]
+
+config :pleroma, Pleroma.Scheduler,
+  global: true,
+  overlap: true,
+  timezone: :utc,
+  jobs: scheduled_jobs
+
 config :pleroma, Pleroma.Captcha,
   enabled: false,
   seconds_valid: 60,
@@ -449,23 +467,19 @@ config :pleroma, Pleroma.User,
     "web"
   ]
 
-job_queues = [
-  federator_incoming: 50,
-  federator_outgoing: 50,
-  web_push: 50,
-  mailer: 10,
-  transmogrifier: 20,
-  scheduled_activities: 10,
-  background: 5
-]
-
-config :pleroma_job_queue, :queues, job_queues
-
 config :pleroma, Oban,
   repo: Pleroma.Repo,
   verbose: false,
   prune: {:maxage, 60 * 60 * 24 * 7},
-  queues: job_queues
+  queues: [
+    federator_incoming: 50,
+    federator_outgoing: 50,
+    web_push: 50,
+    mailer: 10,
+    transmogrifier: 20,
+    scheduled_activities: 10,
+    background: 5
+  ]
 
 config :pleroma, :workers,
   retries: [
diff --git a/config/test.exs b/config/test.exs
index a0fa67516..62f2a04d2 100644
--- a/config/test.exs
+++ b/config/test.exs
@@ -61,8 +61,6 @@ config :web_push_encryption, :vapid_details,
 
 config :web_push_encryption, :http_client, Pleroma.Web.WebPushHttpClientMock
 
-config :pleroma_job_queue, disabled: true
-
 config :pleroma, Oban,
   queues: false,
   prune: :disabled