Sha256: 1d2efe41b2ddcabc98653ff730435c48b2e19e27124c47675a044be1293cfc8e
Contents?: true
Size: 1.1 KB
Versions: 9
Compression:
Stored size: 1.1 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(:name => "BrokerEnvironmentJSONParserError", :unit => "Count", :value => 1)
nil
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems