Contents

module Rack #:nodoc:
  class HTTPLogger
    VERSION = '0.2.1'

    def initialize(app, options = {})
      @app = app

      @stream = options[:stream] || $stdout
      @stream.sync = true unless options.fetch(:sync, true)
      @source = options[:source] || "rack-http-logger"

      @method = options[:method] ? "#{options[:method]}".upcase : "LOG"
      @path = options[:path] || "/"
    end

    def call(env)
      request = Rack::Request.new(env)

      return @app.call(env) unless request.request_method == @method and request.path == @path

      if request.media_type == "application/json" and (body = request.body.read).length.nonzero?
        log JSON.parse(body)
      else
        log request.params
      end

      [201, {"Content-Type" => "text/plain"}, []]
    end

    private

    def log(parameters)
      return if parameters.nil? or parameters.empty?

      measures = flatten(parameters).collect{|keys, value| "#{keys.collect(&:to_s).join('.')}=#{value}"}

      @stream.puts ["source=#{@source}", *measures].join(" ")
    end

    def flatten(hash, k = [])
      return {Array(k) => hash} unless hash.is_a?(Hash)
      hash.inject({}){ |h, v| h.merge! flatten(v[-1], k + [v[0]]) }
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
rack-http-logger-0.2.1	./lib/rack/http-logger.rb