Sha256: 3a07c4d2d731e2e7aa48c03c29a8065c872369b5f76a553f30d3b0083a0b0e56
Contents?: true
Size: 1.04 KB
Versions: 9
Compression:
Stored size: 1.04 KB
Contents
require 'json'
require 'alephant/logger'
require 'rack'
module Alephant
module Broker
class Environment
include Logger
attr_reader :settings
def initialize(env)
@settings = env
end
def method
settings['REQUEST_METHOD']
end
def post?
settings['REQUEST_METHOD'] == 'POST'
end
def get?
settings['REQUEST_METHOD'] == 'GET'
end
def query
settings['QUERY_STRING'] || ""
end
def path
settings['PATH_INFO']
end
def data
parse(rack_input) if post?
end
def options
Rack::Utils.parse_nested_query query
end
private
def rack_input
(settings['rack.input'].read).tap { settings['rack.input'].rewind }
end
def parse(json)
begin
::JSON.parse(json)
rescue ::JSON::ParserError => e
logger.warn "Broker.environment#data: ParserError"
logger.metric "JSONParserError"
nil
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems