aboutsummaryrefslogtreecommitdiffstats
path: root/actionmailbox/app/jobs/action_mailbox
diff options
context:
space:
mode:
Diffstat (limited to 'actionmailbox/app/jobs/action_mailbox')
-rw-r--r--actionmailbox/app/jobs/action_mailbox/incineration_job.rb22
-rw-r--r--actionmailbox/app/jobs/action_mailbox/routing_job.rb13
2 files changed, 35 insertions, 0 deletions
diff --git a/actionmailbox/app/jobs/action_mailbox/incineration_job.rb b/actionmailbox/app/jobs/action_mailbox/incineration_job.rb
new file mode 100644
index 0000000000..224c9329a5
--- /dev/null
+++ b/actionmailbox/app/jobs/action_mailbox/incineration_job.rb
@@ -0,0 +1,22 @@
+# frozen_string_literal: true
+
+module ActionMailbox
+ # You can configure when this `IncinerationJob` will be run as a time-after-processing using the
+ # `config.action_mailbox.incinerate_after` or `ActionMailbox.incinerate_after` setting.
+ #
+ # Since this incineration is set for the future, it'll automatically ignore any `InboundEmail`s
+ # that have already been deleted and discard itself if so.
+ class IncinerationJob < ActiveJob::Base
+ queue_as { ActionMailbox.queues[:incineration] }
+
+ discard_on ActiveRecord::RecordNotFound
+
+ def self.schedule(inbound_email)
+ set(wait: ActionMailbox.incinerate_after).perform_later(inbound_email)
+ end
+
+ def perform(inbound_email)
+ inbound_email.incinerate
+ end
+ end
+end
diff --git a/actionmailbox/app/jobs/action_mailbox/routing_job.rb b/actionmailbox/app/jobs/action_mailbox/routing_job.rb
new file mode 100644
index 0000000000..4ddf6e4231
--- /dev/null
+++ b/actionmailbox/app/jobs/action_mailbox/routing_job.rb
@@ -0,0 +1,13 @@
+# frozen_string_literal: true
+
+module ActionMailbox
+ # Routing a new InboundEmail is an asynchronous operation, which allows the ingress controllers to quickly
+ # accept new incoming emails without being burdened to hang while they're actually being processed.
+ class RoutingJob < ActiveJob::Base
+ queue_as { ActionMailbox.queues[:routing] }
+
+ def perform(inbound_email)
+ inbound_email.route
+ end
+ end
+end