diff options
Diffstat (limited to 'lib/action_mailbox/base.rb')
-rw-r--r-- | lib/action_mailbox/base.rb | 45 |
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 |