Contents

module Jets::Job::Helpers
    module SnsEventHelper
       def sns_event_payload
          message = event&.dig("Records", 0, "Sns", "Message")
          @sns_event_payload ||= ActiveSupport::HashWithIndifferentAccess.new(JSON.load(message))
      end
    end
end

Version data entries

28 entries across 28 versions & 1 rubygems

Version	Path
jets-4.0.12	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.11	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.6	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.5	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.4	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.3	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.2	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.1	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.0	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.10	lib/jets/job/helpers/sns_event_helper.rb
jets-5.0.0.beta1	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.9	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.8	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.7	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.6	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.5	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.4	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.3	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.2	lib/jets/job/helpers/sns_event_helper.rb
jets-4.0.1	lib/jets/job/helpers/sns_event_helper.rb