Contents

module Jets::Job::Helpers
    module SqsEventHelper
       def sqs_event_payload
          message = event&.dig("Records", 0, "body")
          @sqs_event_payload ||= ActiveSupport::HashWithIndifferentAccess.new(JSON.parse(message))
       end
    end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version	Path
jets-4.0.0	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.2.2	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.2.1	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.2.0	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.1.5	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.1.4	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.1.3	lib/jets/job/helpers/sqs_event_helper.rb
jets-3.1.2	lib/jets/job/helpers/sqs_event_helper.rb