Contents

# frozen_string_literal: true

require 'emailbutler/webhooks/mappers/sendgrid'

module Emailbutler
  module Webhooks
    class Receiver
      SENDGRID_USER_AGENT = 'SendGrid Event API'

      def self.call(...)
        new.call(...)
      end

      def call(user_agent:, payload:)
        select_mapper(user_agent)
          .call(payload: payload)
          .each { |event|
            message = Emailbutler.find_message_by(uuid: event.delete(:message_uuid))
            next unless message

            Emailbutler.update_message(message, event)
          }
      end

      private

      def select_mapper(user_agent)
        case user_agent
        when SENDGRID_USER_AGENT then Emailbutler::Webhooks::Mappers::Sendgrid
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
emailbutler-0.6.1	lib/emailbutler/webhooks/receiver.rb
emailbutler-0.6.0	lib/emailbutler/webhooks/receiver.rb
emailbutler-0.5.9	lib/emailbutler/webhooks/receiver.rb
emailbutler-0.5.8	lib/emailbutler/webhooks/receiver.rb
emailbutler-0.5.7	lib/emailbutler/webhooks/receiver.rb