aboutsummaryrefslogtreecommitdiffstats
path: root/actionmailbox/lib/action_mailbox/router.rb
diff options
context:
space:
mode:
authorGeorge Claghorn <george.claghorn@gmail.com>2018-12-26 11:02:59 -0500
committerGitHub <noreply@github.com>2018-12-26 11:02:59 -0500
commit9b35b9ff417e8ec9888deac1e66c2855677164cd (patch)
tree82dc9a20a23b855f91f743c5029ec7a97a35b824 /actionmailbox/lib/action_mailbox/router.rb
parentb5ed468492387d42a44ca6af525d4a274cda756d (diff)
parenta5b2fff64ca0c1fa7be5124f40a251d991c10a85 (diff)
downloadrails-9b35b9ff417e8ec9888deac1e66c2855677164cd.tar.gz
rails-9b35b9ff417e8ec9888deac1e66c2855677164cd.tar.bz2
rails-9b35b9ff417e8ec9888deac1e66c2855677164cd.zip
Merge pull request #34786 from georgeclaghorn/actionmailbox
Import Action Mailbox
Diffstat (limited to 'actionmailbox/lib/action_mailbox/router.rb')
-rw-r--r--actionmailbox/lib/action_mailbox/router.rb40
1 files changed, 40 insertions, 0 deletions
diff --git a/actionmailbox/lib/action_mailbox/router.rb b/actionmailbox/lib/action_mailbox/router.rb
new file mode 100644
index 0000000000..0f041a8389
--- /dev/null
+++ b/actionmailbox/lib/action_mailbox/router.rb
@@ -0,0 +1,40 @@
+# frozen_string_literal: true
+
+# Encapsulates the routes that live on the ApplicationMailbox and performs the actual routing when
+# an inbound_email is received.
+class ActionMailbox::Router
+ class RoutingError < StandardError; end
+
+ def initialize
+ @routes = []
+ end
+
+ def add_routes(routes)
+ routes.each do |(address, mailbox_name)|
+ add_route address, to: mailbox_name
+ end
+ end
+
+ def add_route(address, to:)
+ routes.append Route.new(address, to: to)
+ end
+
+ def route(inbound_email)
+ if mailbox = match_to_mailbox(inbound_email)
+ mailbox.receive(inbound_email)
+ else
+ inbound_email.bounced!
+
+ raise RoutingError
+ end
+ end
+
+ private
+ attr_reader :routes
+
+ def match_to_mailbox(inbound_email)
+ routes.detect { |route| route.match?(inbound_email) }.try(:mailbox_class)
+ end
+end
+
+require "action_mailbox/router/route"