Contents

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

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

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
jets-1.8.3	lib/jets/job/s3_event_helper.rb
jets-1.8.2	lib/jets/job/s3_event_helper.rb
jets-1.8.1	lib/jets/job/s3_event_helper.rb
jets-1.8.0	lib/jets/job/s3_event_helper.rb