2005-02-19 08:29:42 +00:00
|
|
|
require 'benchmark'
|
|
|
|
|
|
|
|
module ActionWebService # :nodoc:
|
|
|
|
module Dispatcher # :nodoc:
|
|
|
|
class DispatcherError < ActionWebService::ActionWebServiceError # :nodoc:
|
|
|
|
end
|
|
|
|
|
|
|
|
def self.append_features(base) # :nodoc:
|
|
|
|
super
|
|
|
|
base.class_inheritable_option(:web_service_dispatching_mode, :direct)
|
|
|
|
base.class_inheritable_option(:web_service_exception_reporting, true)
|
|
|
|
base.send(:include, ActionWebService::Dispatcher::InstanceMethods)
|
|
|
|
end
|
|
|
|
|
|
|
|
module InstanceMethods # :nodoc:
|
|
|
|
private
|
2005-02-25 23:39:39 +00:00
|
|
|
def invoke_web_service_request(protocol_request)
|
|
|
|
invocation = web_service_invocation(protocol_request)
|
2005-02-19 08:29:42 +00:00
|
|
|
case web_service_dispatching_mode
|
|
|
|
when :direct
|
2005-02-25 23:39:39 +00:00
|
|
|
web_service_direct_invoke(invocation)
|
2005-02-27 21:21:40 +00:00
|
|
|
when :delegated, :layered
|
2005-02-25 23:39:39 +00:00
|
|
|
web_service_delegated_invoke(invocation)
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
|
|
|
end
|
2005-02-25 23:39:39 +00:00
|
|
|
|
|
|
|
def web_service_direct_invoke(invocation)
|
|
|
|
@method_params = invocation.method_ordered_params
|
|
|
|
return_value = self.__send__(invocation.api_method_name)
|
2005-02-27 21:21:40 +00:00
|
|
|
if invocation.api.has_api_method?(invocation.api_method_name)
|
|
|
|
returns = invocation.returns ? invocation.returns[0] : nil
|
|
|
|
else
|
|
|
|
returns = return_value.class
|
|
|
|
end
|
2005-02-25 23:39:39 +00:00
|
|
|
invocation.protocol.marshal_response(invocation.public_method_name, return_value, returns)
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
|
|
|
|
2005-02-25 23:39:39 +00:00
|
|
|
def web_service_delegated_invoke(invocation)
|
2005-02-19 08:29:42 +00:00
|
|
|
cancellation_reason = nil
|
2005-02-25 23:39:39 +00:00
|
|
|
return_value = invocation.service.perform_invocation(invocation.api_method_name, invocation.method_ordered_params) do |x|
|
2005-02-19 08:29:42 +00:00
|
|
|
cancellation_reason = x
|
|
|
|
end
|
|
|
|
if cancellation_reason
|
|
|
|
raise(DispatcherError, "request canceled: #{cancellation_reason}")
|
|
|
|
end
|
2005-02-25 23:39:39 +00:00
|
|
|
returns = invocation.returns ? invocation.returns[0] : nil
|
|
|
|
invocation.protocol.marshal_response(invocation.public_method_name, return_value, returns)
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
|
|
|
|
2005-02-25 23:39:39 +00:00
|
|
|
def web_service_invocation(request)
|
2005-02-27 21:21:40 +00:00
|
|
|
public_method_name = request.method_name
|
2005-02-25 23:39:39 +00:00
|
|
|
invocation = Invocation.new
|
|
|
|
invocation.protocol = request.protocol
|
|
|
|
invocation.service_name = request.service_name
|
2005-02-27 21:21:40 +00:00
|
|
|
if web_service_dispatching_mode == :layered
|
|
|
|
if request.method_name =~ /^([^\.]+)\.(.*)$/
|
|
|
|
public_method_name = $2
|
|
|
|
invocation.service_name = $1
|
|
|
|
end
|
|
|
|
end
|
|
|
|
invocation.public_method_name = public_method_name
|
2005-02-19 08:29:42 +00:00
|
|
|
case web_service_dispatching_mode
|
|
|
|
when :direct
|
2005-02-25 23:39:39 +00:00
|
|
|
invocation.api = self.class.web_service_api
|
|
|
|
invocation.service = self
|
2005-02-27 21:21:40 +00:00
|
|
|
when :delegated, :layered
|
|
|
|
invocation.service = web_service_object(invocation.service_name) rescue nil
|
2005-02-25 23:39:39 +00:00
|
|
|
unless invocation.service
|
2005-02-27 21:21:40 +00:00
|
|
|
raise(DispatcherError, "service #{invocation.service_name} not available")
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
2005-02-25 23:39:39 +00:00
|
|
|
invocation.api = invocation.service.class.web_service_api
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
2005-02-27 21:21:40 +00:00
|
|
|
if invocation.api.has_public_api_method?(public_method_name)
|
|
|
|
invocation.api_method_name = invocation.api.api_method_name(public_method_name)
|
|
|
|
else
|
|
|
|
if invocation.api.default_api_method.nil?
|
|
|
|
raise(DispatcherError, "no such method '#{public_method_name}' on API #{invocation.api}")
|
|
|
|
else
|
|
|
|
invocation.api_method_name = invocation.api.default_api_method.to_s.to_sym
|
|
|
|
end
|
|
|
|
end
|
|
|
|
unless invocation.service.respond_to?(invocation.api_method_name)
|
|
|
|
raise(DispatcherError, "no such method '#{public_method_name}' on API #{invocation.api} (#{invocation.api_method_name})")
|
2005-02-25 23:39:39 +00:00
|
|
|
end
|
|
|
|
info = invocation.api.api_methods[invocation.api_method_name]
|
2005-02-27 21:21:40 +00:00
|
|
|
invocation.expects = info ? info[:expects] : nil
|
|
|
|
invocation.returns = info ? info[:returns] : nil
|
2005-02-25 23:39:39 +00:00
|
|
|
if invocation.expects
|
|
|
|
i = 0
|
|
|
|
invocation.method_ordered_params = request.method_params.map do |param|
|
|
|
|
if invocation.protocol.is_a?(Protocol::XmlRpc::XmlRpcProtocol)
|
|
|
|
marshaler = invocation.protocol.marshaler
|
|
|
|
decoded_param = WS::Encoding::XmlRpcDecodedParam.new(param.info.name, param.value)
|
|
|
|
marshaled_param = marshaler.typed_unmarshal(decoded_param, invocation.expects[i]) rescue nil
|
|
|
|
param = marshaled_param ? marshaled_param : param
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
2005-02-25 23:39:39 +00:00
|
|
|
i += 1
|
|
|
|
param.value
|
|
|
|
end
|
|
|
|
i = 0
|
|
|
|
params = []
|
|
|
|
invocation.expects.each do |spec|
|
|
|
|
type_binding = invocation.protocol.register_signature_type(spec)
|
2005-02-27 21:21:40 +00:00
|
|
|
info = WS::ParamInfo.create(spec, type_binding, i)
|
2005-02-25 23:39:39 +00:00
|
|
|
params << WS::Param.new(invocation.method_ordered_params[i], info)
|
|
|
|
i += 1
|
|
|
|
end
|
|
|
|
invocation.method_ws_params = params
|
|
|
|
invocation.method_named_params = {}
|
|
|
|
invocation.method_ws_params.each do |param|
|
|
|
|
invocation.method_named_params[param.info.name] = param.value
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
|
|
|
else
|
2005-02-25 23:39:39 +00:00
|
|
|
invocation.method_ordered_params = []
|
|
|
|
invocation.method_named_params = {}
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
2005-02-27 21:21:40 +00:00
|
|
|
if invocation.returns
|
|
|
|
invocation.returns.each do |spec|
|
|
|
|
invocation.protocol.register_signature_type(spec)
|
|
|
|
end
|
|
|
|
end
|
2005-02-25 23:39:39 +00:00
|
|
|
invocation
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
|
|
|
|
2005-02-27 21:21:40 +00:00
|
|
|
class Invocation # :nodoc:
|
2005-02-25 23:39:39 +00:00
|
|
|
attr_accessor :protocol
|
|
|
|
attr_accessor :service_name
|
|
|
|
attr_accessor :api
|
|
|
|
attr_accessor :public_method_name
|
|
|
|
attr_accessor :api_method_name
|
|
|
|
attr_accessor :method_ordered_params
|
|
|
|
attr_accessor :method_named_params
|
|
|
|
attr_accessor :method_ws_params
|
|
|
|
attr_accessor :expects
|
|
|
|
attr_accessor :returns
|
|
|
|
attr_accessor :service
|
2005-02-19 08:29:42 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|