Import Action Mailbox

2 files changed, 31 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..b12ff6f88e
--- /dev/null
+++ b/actionmailbox/app/jobs/action_mailbox/incineration_job.rb
@@ -0,0 +1,20 @@
+# frozen_string_literal: true
+
+# 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 ActionMailbox::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
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..fc3388daff
--- /dev/null
+++ b/actionmailbox/app/jobs/action_mailbox/routing_job.rb
@@ -0,0 +1,11 @@
+# frozen_string_literal: true
+
+# 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 ActionMailbox::RoutingJob < ActiveJob::Base
+  queue_as { ActionMailbox.queues[:routing] }
+
+  def perform(inbound_email)
+    inbound_email.route
+  end
+end