Module: Jets::Job::Helpers::SnsEvent
- Included in:
- Base
- Defined in:
- lib/jets/job/helpers/sns_event.rb
Instance Method Summary collapse
-
#sns_event_payload ⇒ Object
Deprecated methods below.
- #sns_events ⇒ Object (also: #sns_event_payloads)
- #sns_events? ⇒ Boolean (also: #sns_event_payloads?)
Instance Method Details
#sns_event_payload ⇒ Object
Deprecated methods below
19 20 21 22 23 24 |
# File 'lib/jets/job/helpers/sns_event.rb', line 19 def sns_event_payload puts "WARN: sns_event_payload is deprecated".color(:yellow) puts "It can possibly drop events when they come in extremely fast." puts "Use sns_events instead" sns_events.first end |
#sns_events ⇒ Object Also known as: sns_event_payloads
3 4 5 6 7 8 9 10 |
# File 'lib/jets/job/helpers/sns_event.rb', line 3 def sns_events records = event["Records"] return [] unless records records.map do |record| = record["Sns"]["Message"] ActiveSupport::HashWithIndifferentAccess.new(JSON.load()) end end |
#sns_events? ⇒ Boolean Also known as: sns_event_payloads?
13 14 15 |
# File 'lib/jets/job/helpers/sns_event.rb', line 13 def sns_events? event["Records"]&.any? { |r| r.dig("Sns", "Message") } end |