Contents

# frozen_string_literal: true

module Msgr
  class Route
    attr_reader :consumer, :action, :opts

    MATCH_REGEXP = /\A(?<consumer>\w+)#(?<action>\w+)\z/

    # rubocop:disable Metrics/AbcSize
    # rubocop:disable Metrics/MethodLength
    def initialize(key, opts = {})
      @opts = opts
      raise ArgumentError.new 'Missing `to` options.' unless @opts[:to]

      add key

      result = MATCH_REGEXP.match(opts[:to].strip.to_s)

      unless result
        raise ArgumentError.new \
          "Invalid consumer format: #{opts[:to].strip.to_s.inspect}. " \
          'Must be `consumer_class#action`.'
      end

      @consumer = "#{result[:consumer].camelize}Consumer"
      @action   = result[:action].underscore
    end

    def keys
      @keys ||= []
    end
    alias routing_keys keys

    def add(key)
      raise ArgumentError.new 'Routing key required.' unless key.present?

      keys << key
    end

    def accept?(_key, opts)
      self.opts == opts
    end

    def name
      "msgr.consumer.#{consumer}.#{action}"
    end
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
msgr-0.15.2.1.b175	lib/msgr/route.rb
msgr-0.15.2.1.b169	lib/msgr/route.rb
msgr-0.15.2.1.b167	lib/msgr/route.rb
msgr-0.15.2.1.b166	lib/msgr/route.rb
msgr-0.15.2.1.b165	lib/msgr/route.rb
msgr-0.15.2.1.b164	lib/msgr/route.rb
msgr-0.15.2.1.b163	lib/msgr/route.rb
msgr-0.15.2.1.b162	lib/msgr/route.rb
msgr-0.15.2.1.b161	lib/msgr/route.rb
msgr-0.15.2.1.b160	lib/msgr/route.rb
msgr-0.15.2.1.b159	lib/msgr/route.rb
msgr-0.15.2.1.b158	lib/msgr/route.rb