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