Sha256: dd0047376f897912ca48b0899dad55e0c784d544bc06d0fabfb450d23eb9cad6

Contents?: true

Size: 293 Bytes

Versions: 139

Compression:

Stored size: 293 Bytes

Contents

module Jets::Job::Helpers
  module S3EventHelper
    def s3_event
      message = event["Records"][0]["Sns"]["Message"]
      h = JSON.load(message)
      ActiveSupport::HashWithIndifferentAccess.new(h)
    end

    def s3_object
      s3_event["Records"][0]["s3"]["object"]
    end
  end
end

Version data entries

139 entries across 139 versions & 3 rubygems

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