Module: Riffer::Messages::Converter

Included in:
Agent, Providers::Base
Defined in:
lib/riffer/messages/converter.rb

Overview

Module for converting hashes to message objects.

Included in Agent and Provider classes to handle message normalization.

Instance Method Summary collapse

Instance Method Details

#convert_to_message_object(msg) ⇒ Object

Converts a hash or message object to a Riffer::Messages::Base subclass.

Raises Riffer::ArgumentError if the message format is invalid.

: ((Hash[Symbol | String, untyped] | Riffer::Messages::Base)) -> Riffer::Messages::Base



13
14
15
16
17
18
19
20
21
 
# File 'lib/riffer/messages/converter.rb', line 13

def convert_to_message_object(msg)
  return msg if msg.is_a?(Riffer::Messages::Base)

  unless msg.is_a?(Hash)
    raise Riffer::ArgumentError, "Message must be a Hash or Message object, got #{msg.class}"
  end

  convert_hash_to_message(msg)
end