Sha256: 6b759966b49a9adaa8df455055d1796db2697cd44287466ede3eb42c882a9e39
Contents?: true
Size: 1.92 KB
Versions: 5
Compression:
Stored size: 1.92 KB
Contents
class Rack::App::Endpoint attr_reader :properties LAST_MODIFIED_HEADER = "Last-Modified".freeze def initialize(properties) @properties = properties @app_class = properties[:app_class] @error_handler = properties[:error_handler] || Rack::App::ErrorHandler.new @serializer = properties[:serializer] || Rack::App::Serializer.new @headers = properties[:default_headers] || {} @middleware = (properties[:middleware] || Rack::Builder.new).dup @middleware.run(lambda { |env| self.execute(env) }) @path_params_matcher = {} @endpoint_method_name = register_method_to_app_class(properties[:user_defined_logic]) @app = @middleware.to_app end def call(env) @app.call(env) end def execute(request_env) request = Rack::Request.new(request_env) response = Rack::Response.new set_response_body(response, get_response_body(request, response)) return response.finish end def get_response_body(rack_request, rack_response) request_handler = @app_class.new set_default_headers(rack_response) request_handler.request = rack_request request_handler.response = rack_response rack_request.env[::Rack::App::Constants::PATH_PARAMS_MATCHER]= @path_params_matcher.dup return @error_handler.execute_with_error_handling_for(request_handler, @endpoint_method_name) end def register_path_params_matcher(params_matcher) @path_params_matcher.clear @path_params_matcher.merge!(params_matcher) end protected def set_response_body(response, result) return nil unless response.body.is_a?(Array) response.write(String(@serializer.serialize(result))) end def set_default_headers(response) @headers.each do |header, value| response.header[header]=value end end def register_method_to_app_class(proc) method_name = ::Rack::App::Utils.uuid @app_class.__send__(:define_method, method_name, &proc) return method_name end end
Version data entries
5 entries across 5 versions & 1 rubygems