Contents

module Jets::Event::Helpers
  module SnsEvent
    def sns_events
      records = event["Records"]
      return [] unless records
      records.map do |record|
        message = record["Sns"]["Message"]
        ActiveSupport::HashWithIndifferentAccess.new(JSON.load(message))
      end
    end

    def sns_events?
      event["Records"]&.any? { |r| r.dig("Sns", "Message") }
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
jets-6.0.5	lib/jets/event/helpers/sns_event.rb
jets-6.0.4	lib/jets/event/helpers/sns_event.rb
jets-6.0.3	lib/jets/event/helpers/sns_event.rb
jets-6.0.2	lib/jets/event/helpers/sns_event.rb