Module: ActiveSupport::Messages::Rotator

Do not use. This module is for internal use only.

Relationships & Source Files
Extension / Inclusion / Inheritance Descendants
Included In: `::ActiveSupport::MessageEncryptor`, `::ActiveSupport::MessageVerifier`
Defined in:	activesupport/lib/active_support/messages/rotator.rb

Instance Method Summary

#fall_back_to(fallback)
#initialize(*args, on_rotation: nil, **options)
#read_message(message, on_rotation: @on_rotation, **options)
#rotate(*args, **options)
#build_rotation(*args, **options) private
#catch_rotation_error(&block) private

Instance Method Details

#build_rotation(*args, **options) (private)

[ GitHub ]

# File 'activesupport/lib/active_support/messages/rotator.rb', line 44


def build_rotation(*args, **options)
  self.class.new(*args, *@args.drop(args.length), **@options, **options)
end

#catch_rotation_error(&block) (private)

[ GitHub ]

# File 'activesupport/lib/active_support/messages/rotator.rb', line 48


def catch_rotation_error(&block)
  error = catch :invalid_message_format do
    error = catch :invalid_message_serialization do
      return [nil, block.call]
    end
    return [:invalid_message_serialization, error]
  end
  [:invalid_message_format, error]
end

#fall_back_to(fallback)

[ GitHub ]

# File 'activesupport/lib/active_support/messages/rotator.rb', line 18


def fall_back_to(fallback)
  @rotations << fallback
  self
end

#initialize(*args, on_rotation: nil, **options)

[ GitHub ]

# File 'activesupport/lib/active_support/messages/rotator.rb', line 6


def initialize(*args, on_rotation: nil, **options)
  super(*args, **options)
  @args = args
  @options = options
  @rotations = []
  @on_rotation = on_rotation
end

#read_message(message, on_rotation: @on_rotation, **options)

[ GitHub ]

# File 'activesupport/lib/active_support/messages/rotator.rb', line 23


def read_message(message, on_rotation: @on_rotation, **options)
  if @rotations.empty?
    super(message, **options)
  else
    thrown, error = catch_rotation_error do
      return super(message, **options)
    end

    @rotations.each do |rotation|
      catch_rotation_error do
        value = rotation.read_message(message, **options)
        on_rotation&.call
        return value
      end
    end

    throw thrown, error
  end
end

#rotate(*args, **options)

[ GitHub ]

# File 'activesupport/lib/active_support/messages/rotator.rb', line 14


def rotate(*args, **options)
  fall_back_to build_rotation(*args, **options)
end