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-2.2.0 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.7 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.6 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.5 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.4 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.3 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.2 lib/jets/job/helpers/s3_event_helper.rb
jets_bb_fork-0.0.4 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.1 lib/jets/job/helpers/s3_event_helper.rb
jets-2.1.0 lib/jets/job/helpers/s3_event_helper.rb
jets-2.0.6 lib/jets/job/helpers/s3_event_helper.rb
jets-2.0.5 lib/jets/job/helpers/s3_event_helper.rb
jets-2.0.4 lib/jets/job/helpers/s3_event_helper.rb
jets-2.0.3 lib/jets/job/helpers/s3_event_helper.rb
jets-2.0.1 lib/jets/job/helpers/s3_event_helper.rb
jets-2.0.0 lib/jets/job/helpers/s3_event_helper.rb
jets-1.9.32 lib/jets/job/helpers/s3_event_helper.rb
jets-1.9.31 lib/jets/job/helpers/s3_event_helper.rb
jets-1.9.30 lib/jets/job/helpers/s3_event_helper.rb
jets-1.9.29 lib/jets/job/helpers/s3_event_helper.rb