Module: Jets::Job::Helpers::SqsEventHelper

Included in:
Base
Defined in:
lib/jets/job/helpers/sqs_event_helper.rb

Instance Method Summary collapse

Instance Method Details

#sqs_event_payload ⇒ Object

Deprecated methods below



17
18
19
20
21
22
 
# File 'lib/jets/job/helpers/sqs_event_helper.rb', line 17

def sqs_event_payload
  puts "WARN: sqs_event_payload is deprecated".color(:yellow)
  puts "It can possibly drop events when come in extremely fast."
  puts "Use sqs_event_payloads instead"
  sqs_event_payloads.first
end

#sqs_event_payloads ⇒ Object 



3
4
5
6
7
8
9
10
 
# File 'lib/jets/job/helpers/sqs_event_helper.rb', line 3

def sqs_event_payloads
  records = event["Records"]
  return [] unless records
  records.map do |record|
    message = record["body"]
    ActiveSupport::HashWithIndifferentAccess.new(JSON.load(message))
  end
end

#sqs_event_payloads? ⇒ Boolean

Returns:

  • (Boolean) 


12
13
14
 
# File 'lib/jets/job/helpers/sqs_event_helper.rb', line 12

def sqs_event_payloads?
  event["Records"]&.any? { |r| r.dig("body") }
end