1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
|
require 'test/unit'
require 'soap/rpc/driver'
require 'soap/rpc/standaloneServer'
require 'soap/filter'
module SOAP
module Filter
class TestFilter < Test::Unit::TestCase
Port = 17171
PortName = 'http://tempuri.org/filterPort'
class FilterTestServer < SOAP::RPC::StandaloneServer
class Servant
def self.create
new
end
def echo(amt)
amt
end
end
class ServerFilter1 < SOAP::Filter::Handler
# 15 -> 30
def on_outbound(envelope, opt)
unless envelope.body.is_fault
node = envelope.body.root_node
node.retval = SOAPInt.new(node.retval.data * 2)
node.elename = XSD::QName.new(nil, 'return')
end
envelope
end
# 4 -> 5
def on_inbound(xml, opt)
xml = xml.sub(/4/, '5')
xml
end
end
class ServerFilter2 < SOAP::Filter::Handler
# 5 -> 15
def on_outbound(envelope, opt)
unless envelope.body.is_fault
node = envelope.body.root_node
node.retval = SOAPInt.new(node.retval.data + 10)
node.elename = XSD::QName.new(nil, 'return')
end
envelope
end
# 5 -> 6
def on_inbound(xml, opt)
xml = xml.sub(/5/, '6')
xml
end
end
def initialize(*arg)
super
add_rpc_servant(Servant.new, PortName)
self.filterchain << ServerFilter1.new
self.filterchain << ServerFilter2.new
end
end
def setup
@endpoint = "http://localhost:#{Port}/"
setup_server
setup_client
end
def setup_server
@server = FilterTestServer.new(self.class.name, nil, '0.0.0.0', Port)
@server.level = Logger::Severity::ERROR
@t = Thread.new {
@server.start
}
end
def setup_client
@client = SOAP::RPC::Driver.new(@endpoint, PortName)
@client.wiredump_dev = STDERR if $DEBUG
@client.add_method('echo', 'amt')
end
def teardown
teardown_server if @server
teardown_client if @client
end
def teardown_server
@server.shutdown
@t.kill
@t.join
end
def teardown_client
@client.reset_stream
end
class ClientFilter1 < SOAP::Filter::Handler
# 1 -> 2
def on_outbound(envelope, opt)
param = envelope.body.root_node.inparam
param["amt"] = SOAPInt.new(param["amt"].data + 1)
param["amt"].elename = XSD::QName.new(nil, 'amt')
envelope
end
# 31 -> 32
def on_inbound(xml, opt)
xml = xml.sub(/31/, '32')
xml
end
end
class ClientFilter2 < SOAP::Filter::Handler
# 2 -> 4
def on_outbound(envelope, opt)
param = envelope.body.root_node.inparam
param["amt"] = SOAPInt.new(param["amt"].data * 2)
param["amt"].elename = XSD::QName.new(nil, 'amt')
envelope
end
# 30 -> 31
def on_inbound(xml, opt)
xml = xml.sub(/30/, '31')
xml
end
end
def test_call
@client.filterchain << ClientFilter1.new
@client.filterchain << ClientFilter2.new
assert_equal(32, @client.echo(1))
end
end
end
end
|
