actionmailbox/lib/action_mailbox/router.rb


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
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"