6f5a7b2004
seperate out protocol marshaling into a small 'ws' library in vendor, so that AWS itself only does integration with ActionPack, and so we can keep protocol specific code in AWS proper to a minimum. refactor unit tests to get 95% code coverage (for a baseline). be far more relaxed about the types given to us by the remote side, don't do any poor man's type checking, just try to cast and marshal to the correct types if possible, and if not, return what they gave us anyway. this should make interoperating with fuzzy XML-RPC clients easier. if exception reporting is turned on, do best-effort error responses, so that we can avoid "Internal protocol error" with no details if there is a bug in AWS itself. also perform extensive cleanups on AWS proper. git-svn-id: http://svn-commit.rubyonrails.org/rails/trunk@800 5ecf4fe2-1ee6-0310-87b1-e25e094e27de
129 lines
2.8 KiB
Ruby
129 lines
2.8 KiB
Ruby
require File.dirname(__FILE__) + '/abstract_unit'
|
|
require 'webrick'
|
|
require 'webrick/log'
|
|
require 'singleton'
|
|
|
|
module ClientTest
|
|
class Person < ActionWebService::Struct
|
|
member :firstnames, [:string]
|
|
member :lastname, :string
|
|
|
|
def ==(other)
|
|
firstnames == other.firstnames && lastname == other.lastname
|
|
end
|
|
end
|
|
|
|
class API < ActionWebService::API::Base
|
|
api_method :void
|
|
api_method :normal, :expects => [:int, :int], :returns => [:int]
|
|
api_method :array_return, :returns => [[Person]]
|
|
api_method :struct_pass, :expects => [[Person]], :returns => [:bool]
|
|
api_method :client_container, :returns => [:int]
|
|
api_method :named_parameters, :expects => [{:key=>:string}, {:id=>:int}]
|
|
api_method :thrower
|
|
end
|
|
|
|
class NullLogOut
|
|
def <<(*args); end
|
|
end
|
|
|
|
class Container < ActionController::Base
|
|
web_service_api API
|
|
|
|
attr_accessor :value_void
|
|
attr_accessor :value_normal
|
|
attr_accessor :value_array_return
|
|
attr_accessor :value_struct_pass
|
|
attr_accessor :value_named_parameters
|
|
|
|
def initialize
|
|
@session = @assigns = {}
|
|
@value_void = nil
|
|
@value_normal = nil
|
|
@value_array_return = nil
|
|
@value_struct_pass = nil
|
|
@value_named_parameters = nil
|
|
end
|
|
|
|
def void
|
|
@value_void = @method_params
|
|
end
|
|
|
|
def normal
|
|
@value_normal = @method_params
|
|
5
|
|
end
|
|
|
|
def array_return
|
|
person = Person.new
|
|
person.firstnames = ["one", "two"]
|
|
person.lastname = "last"
|
|
@value_array_return = [person]
|
|
end
|
|
|
|
def struct_pass
|
|
@value_struct_pass = @method_params
|
|
true
|
|
end
|
|
|
|
def client_container
|
|
50
|
|
end
|
|
|
|
def named_parameters
|
|
@value_named_parameters = @method_params
|
|
end
|
|
|
|
def thrower
|
|
raise "Hi"
|
|
end
|
|
end
|
|
|
|
class AbstractClientLet < WEBrick::HTTPServlet::AbstractServlet
|
|
def initialize(controller)
|
|
@controller = controller
|
|
end
|
|
|
|
def get_instance(*args)
|
|
self
|
|
end
|
|
|
|
def require_path_info?
|
|
false
|
|
end
|
|
|
|
def do_GET(req, res)
|
|
raise WEBrick::HTTPStatus::MethodNotAllowed, "GET request not allowed."
|
|
end
|
|
|
|
def do_POST(req, res)
|
|
raise NotImplementedError
|
|
end
|
|
end
|
|
|
|
class AbstractServer
|
|
include ClientTest
|
|
include Singleton
|
|
attr :container
|
|
def initialize
|
|
@container = Container.new
|
|
@clientlet = create_clientlet(@container)
|
|
log = WEBrick::BasicLog.new(NullLogOut.new)
|
|
@server = WEBrick::HTTPServer.new(:Port => server_port, :Logger => log, :AccessLog => log)
|
|
@server.mount('/', @clientlet)
|
|
@thr = Thread.new { @server.start }
|
|
until @server.status == :Running; end
|
|
at_exit { @server.stop; @thr.join }
|
|
end
|
|
|
|
protected
|
|
def create_clientlet
|
|
raise NotImplementedError
|
|
end
|
|
|
|
def server_port
|
|
raise NotImplementedError
|
|
end
|
|
end
|
|
end
|