Sha256: ae1139048a71a2ecf9e2d74d295cb2cc884537fd7c7ebe733afc0a0ba7cad68c
Contents?: true
Size: 1.24 KB
Versions: 9
Compression:
Stored size: 1.24 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 options?
settings["REQUEST_METHOD"] == "OPTIONS"
end
def query
settings["QUERY_STRING"] || ""
end
def path
settings["PATH_INFO"]
end
def if_none_match
settings["HTTP_IF_NONE_MATCH"]
end
def if_modified_since
settings["HTTP_IF_MODIFIED_SINCE"]
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)
::JSON.parse(json)
rescue ::JSON::ParserError => e
logger.warn "Broker.environment#data: ParserError"
logger.metric "JSONParserError"
nil
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems