Contents

require "base64"
require "json"
require "stringio"
require "zlib"

module Jets::Event::Helpers
  module LogEvent
    def log_event
      encoded = event["awslogs"]["data"]
      compressed_string = Base64.decode64(encoded)
      gz = Zlib::GzipReader.new(StringIO.new(compressed_string))
      uncompressed_string = gz.read
      data = JSON.load(uncompressed_string)
      ActiveSupport::HashWithIndifferentAccess.new(data)
    end

    def log_event?
      !!event.dig("awslogs", "data")
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
jets-6.0.5	lib/jets/event/helpers/log_event.rb
jets-6.0.4	lib/jets/event/helpers/log_event.rb
jets-6.0.3	lib/jets/event/helpers/log_event.rb
jets-6.0.2	lib/jets/event/helpers/log_event.rb