Sha256: cba64f1f6af546e6f91f9e0ccc9bd7da77804293794fb3471f04062650df9b6f
Contents?: true
Size: 1.19 KB
Versions: 1
Compression:
Stored size: 1.19 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 if_none_match settings["IF_NONE_MATCH"] end def if_modified_since settings["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) 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
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
alephant-broker-3.10.0 | lib/alephant/broker/environment.rb |