Class: Necropsy::Analyzers::Dynamic::CoverbandPayloadSet

Inherits:
Object
  • Object
show all
Defined in:
lib/necropsy/analyzers/dynamic/coverband_payload_set.rb

Constant Summary collapse

PAYLOAD_KEYS = 
%w[files coverage runtime production nodes executed observation].freeze

Instance Method Summary collapse

Constructor Details

#initialize(limits:, deadline:) ⇒ CoverbandPayloadSet

Returns a new instance of CoverbandPayloadSet.



9
10
11
12
 
# File 'lib/necropsy/analyzers/dynamic/coverband_payload_set.rb', line 9

def initialize(limits:, deadline:)
  @limits = limits
  @deadline = deadline
end

Instance Method Details

#from_hash_entries(entries) ⇒ Object 



22
23
24
25
26
27
28
29
 
# File 'lib/necropsy/analyzers/dynamic/coverband_payload_set.rb', line 22

def from_hash_entries(entries, &)
  domain_error('Malformed Redis hash response') unless entries.is_a?(Array) && entries.length.even?

  hash = entries.each_slice(2).to_h
  return coverband_hash_payload(hash) if coverband_hash_payload?(hash)

  generic_hash_payload(hash, &)
end

#merge(payloads) ⇒ Object 



14
15
16
17
18
19
20
 
# File 'lib/necropsy/analyzers/dynamic/coverband_payload_set.rb', line 14

def merge(payloads)
  payloads.compact.reduce({}) do |merged, payload|
    validate_payload_hash!(payload)
    deadline.check!
    limits.validate_payload!(merge_payload(merged, payload))
  end
end

#payload_shape?(value) ⇒ Boolean

Returns:

  • (Boolean) 


31
32
33
 
# File 'lib/necropsy/analyzers/dynamic/coverband_payload_set.rb', line 31

def payload_shape?(value)
  value.is_a?(Hash) && value.keys.any? { |key| PAYLOAD_KEYS.include?(key.to_s) }
end