Class: Smith::Workflow::MessageBatch

Inherits:
Object
  • Object
show all
Extended by:
Dry::Initializer
Defined in:
lib/smith/workflow/message_batch.rb

Constant Summary collapse

MAX_MESSAGES = 
100
MAX_DEPTH = 
MessageValueNormalizer::MAX_DEPTH
MAX_NODES = 
MessageValueNormalizer::MAX_NODES
MAX_BYTES = 
MessageValueNormalizer::MAX_BYTES

Instance Method Summary collapse

Instance Method Details

#call ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/smith/workflow/message_batch.rb', line 22

def call
  batch = normalize_batch
  batch.each { reject!("each session message must be a Hash") unless _1.is_a?(Hash) }
  admission = MessageAdmission.new(messages: batch)
  admission.messages.each { validate_message!(_1) }
  admission
end