Sha256: 3ebc14b0866648b979368c738f4415f5fc63171429a1586d8c5f0ab9e2a959e4
Contents?: true
Size: 961 Bytes
Versions: 40
Compression:
Stored size: 961 Bytes
Contents
# frozen_string_literal: true
module ActionMailbox
# = Action Mailbox \Router
#
# Encapsulates the routes that live on the ApplicationMailbox and performs the actual routing when
# an inbound_email is received.
class 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 = mailbox_for(inbound_email)
mailbox.receive(inbound_email)
else
inbound_email.bounced!
raise RoutingError
end
end
def mailbox_for(inbound_email)
routes.detect { |route| route.match?(inbound_email) }&.mailbox_class
end
private
attr_reader :routes
end
end
require "action_mailbox/router/route"
Version data entries
40 entries across 40 versions & 5 rubygems