aboutsummaryrefslogtreecommitdiffstats
path: root/lib/action_mailbox/base.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/action_mailbox/base.rb')
-rw-r--r--lib/action_mailbox/base.rb45
1 files changed, 45 insertions, 0 deletions
diff --git a/lib/action_mailbox/base.rb b/lib/action_mailbox/base.rb
new file mode 100644
index 0000000000..476c343415
--- /dev/null
+++ b/lib/action_mailbox/base.rb
@@ -0,0 +1,45 @@
+require "active_support/rescuable"
+
+require "action_mailbox/callbacks"
+require "action_mailbox/routing"
+
+class ActionMailbox::Base
+ include ActiveSupport::Rescuable
+ include ActionMailbox::Callbacks, ActionMailbox::Routing
+
+ attr_reader :inbound_email
+ delegate :mail, :bounced!, to: :inbound_email
+
+ def self.receive(inbound_email)
+ new(inbound_email).perform_processing
+ end
+
+ def initialize(inbound_email)
+ @inbound_email = inbound_email
+ end
+
+ def perform_processing
+ run_callbacks :process do
+ track_status_of_inbound_email do
+ process
+ end
+ end
+ rescue => exception
+ # TODO: Include a reference to the inbound_email in the exception raised so error handling becomes easier
+ rescue_with_handler(exception) || raise
+ end
+
+ def process
+ # Overwrite in subclasses
+ end
+
+ private
+ def track_status_of_inbound_email
+ inbound_email.processing!
+ yield
+ inbound_email.delivered! unless inbound_email.bounced?
+ rescue => exception
+ inbound_email.failed!
+ raise
+ end
+end