summaryrefslogtreecommitdiff
path: root/sample/soap/authheader
diff options
context:
space:
mode:
Diffstat (limited to 'sample/soap/authheader')
-rw-r--r--sample/soap/authheader/authmgr.rb41
-rw-r--r--sample/soap/authheader/client.rb40
-rw-r--r--sample/soap/authheader/client2.rb42
-rw-r--r--sample/soap/authheader/server.rb73
-rw-r--r--sample/soap/authheader/server2.rb83
5 files changed, 0 insertions, 279 deletions
diff --git a/sample/soap/authheader/authmgr.rb b/sample/soap/authheader/authmgr.rb
deleted file mode 100644
index a4d3b66c0d..0000000000
--- a/sample/soap/authheader/authmgr.rb
+++ /dev/null
@@ -1,41 +0,0 @@
-class Authmgr
- def initialize
- @users = {
- 'NaHi' => 'passwd',
- 'HiNa' => 'wspass'
- }
- @sessions = {}
- end
-
- def login(userid, passwd)
- userid and passwd and @users[userid] == passwd
- end
-
- # returns userid
- def auth(sessionid)
- @sessions[sessionid]
- end
-
- def create_session(userid)
- while true
- key = create_sessionkey
- break unless @sessions[key]
- end
- @sessions[key] = userid
- key
- end
-
- def get_session(userid)
- @sessions.index(userid)
- end
-
- def destroy_session(sessionkey)
- @sessions.delete(sessionkey)
- end
-
-private
-
- def create_sessionkey
- Time.now.usec.to_s
- end
-end
diff --git a/sample/soap/authheader/client.rb b/sample/soap/authheader/client.rb
deleted file mode 100644
index 4055fe63fe..0000000000
--- a/sample/soap/authheader/client.rb
+++ /dev/null
@@ -1,40 +0,0 @@
-require 'soap/rpc/driver'
-require 'soap/header/simplehandler'
-
-server = ARGV.shift || 'http://localhost:7000/'
-
-class ClientAuthHeaderHandler < SOAP::Header::SimpleHandler
- MyHeaderName = XSD::QName.new("http://tempuri.org/authHeader", "auth")
-
- def initialize(userid, passwd)
- super(MyHeaderName)
- @sessionid = nil
- @userid = userid
- @passwd = passwd
- @mustunderstand = true
- end
-
- def on_simple_outbound
- if @sessionid
- { "sessionid" => @sessionid }
- else
- { "userid" => @userid, "passwd" => @passwd }
- end
- end
-
- def on_simple_inbound(my_header, mustunderstand)
- @sessionid = my_header["sessionid"]
- end
-end
-
-ns = 'http://tempuri.org/authHeaderPort'
-serv = SOAP::RPC::Driver.new(server, ns)
-serv.add_method('deposit', 'amt')
-serv.add_method('withdrawal', 'amt')
-
-serv.headerhandler << ClientAuthHeaderHandler.new('NaHi', 'passwd')
-
-serv.wiredump_dev = STDOUT
-
-p serv.deposit(150)
-p serv.withdrawal(120)
diff --git a/sample/soap/authheader/client2.rb b/sample/soap/authheader/client2.rb
deleted file mode 100644
index aa5172a5b1..0000000000
--- a/sample/soap/authheader/client2.rb
+++ /dev/null
@@ -1,42 +0,0 @@
-require 'soap/rpc/driver'
-require 'soap/header/simplehandler'
-
-server = ARGV.shift || 'http://localhost:7000/'
-
-class ClientAuthHeaderHandler < SOAP::Header::SimpleHandler
- MyHeaderName = XSD::QName.new("http://tempuri.org/authHeader", "auth")
-
- attr_accessor :sessionid
-
- def initialize
- super(MyHeaderName)
- @sessionid = nil
- end
-
- def on_simple_outbound
- if @sessionid
- { "sessionid" => @sessionid }
- end
- end
-
- def on_simple_inbound(my_header, mustunderstand)
- @sessionid = my_header["sessionid"]
- end
-end
-
-ns = 'http://tempuri.org/authHeaderPort'
-serv = SOAP::RPC::Driver.new(server, ns)
-serv.add_method('login', 'userid', 'passwd')
-serv.add_method('deposit', 'amt')
-serv.add_method('withdrawal', 'amt')
-
-h = ClientAuthHeaderHandler.new
-
-serv.headerhandler << h
-
-serv.wiredump_dev = STDOUT
-
-sessionid = serv.login('NaHi', 'passwd')
-h.sessionid = sessionid
-p serv.deposit(150)
-p serv.withdrawal(120)
diff --git a/sample/soap/authheader/server.rb b/sample/soap/authheader/server.rb
deleted file mode 100644
index 9c6adf280d..0000000000
--- a/sample/soap/authheader/server.rb
+++ /dev/null
@@ -1,73 +0,0 @@
-#!/usr/bin/env ruby
-
-require 'soap/rpc/standaloneServer'
-require 'soap/header/simplehandler'
-require 'authmgr'
-
-class AuthHeaderPortServer < SOAP::RPC::StandaloneServer
- class AuthHeaderService
- def self.create
- new
- end
-
- def deposit(amt)
- "deposit #{amt} OK"
- end
-
- def withdrawal(amt)
- "withdrawal #{amt} OK"
- end
- end
-
- Name = 'http://tempuri.org/authHeaderPort'
- def initialize(*arg)
- super
- add_rpc_servant(AuthHeaderService.new, Name)
- # header handler must be a per request handler.
- add_rpc_request_headerhandler(ServerAuthHeaderHandler)
- end
-
- class ServerAuthHeaderHandler < SOAP::Header::SimpleHandler
- MyHeaderName = XSD::QName.new("http://tempuri.org/authHeader", "auth")
-
- @authmgr = Authmgr.new
- def self.create
- new(@authmgr)
- end
-
- def initialize(authmgr)
- super(MyHeaderName)
- @authmgr = authmgr
- @userid = @sessionid = nil
- end
-
- def on_simple_outbound
- { "sessionid" => @sessionid }
- end
-
- def on_simple_inbound(my_header, mu)
- auth = false
- userid = my_header["userid"]
- passwd = my_header["passwd"]
- if @authmgr.login(userid, passwd)
- auth = true
- elsif sessionid = my_header["sessionid"]
- if userid = @authmgr.auth(sessionid)
- @authmgr.destroy_session(sessionid)
- auth = true
- end
- end
- raise RuntimeError.new("authentication failed") unless auth
- @userid = userid
- @sessionid = @authmgr.create_session(userid)
- end
- end
-end
-
-if $0 == __FILE__
- svr = AuthHeaderPortServer.new('AuthHeaderPortServer', nil, '0.0.0.0', 7000)
- trap(:INT) do
- svr.shutdown
- end
- status = svr.start
-end
diff --git a/sample/soap/authheader/server2.rb b/sample/soap/authheader/server2.rb
deleted file mode 100644
index 8a0eaafc8d..0000000000
--- a/sample/soap/authheader/server2.rb
+++ /dev/null
@@ -1,83 +0,0 @@
-#!/usr/bin/env ruby
-
-require 'soap/rpc/standaloneServer'
-require 'soap/header/simplehandler'
-require 'authmgr'
-
-class AuthHeaderPortServer < SOAP::RPC::StandaloneServer
- class AuthHeaderService
- def initialize(authmgr)
- @authmgr = authmgr
- end
-
- def login(userid, passwd)
- if @authmgr.login(userid, passwd)
- @authmgr.create_session(userid)
- else
- raise RuntimeError.new("authentication failed")
- end
- end
-
- def deposit(amt)
- "deposit #{amt} OK"
- end
-
- def withdrawal(amt)
- "withdrawal #{amt} OK"
- end
- end
-
- Name = 'http://tempuri.org/authHeaderPort'
- def initialize(*arg)
- super
- authmgr = Authmgr.new
- add_rpc_servant(AuthHeaderService.new(authmgr), Name)
- ServerAuthHeaderHandler.init(authmgr)
- # header handler must be a per request handler.
- add_rpc_request_headerhandler(ServerAuthHeaderHandler)
- end
-
- class ServerAuthHeaderHandler < SOAP::Header::SimpleHandler
- MyHeaderName = XSD::QName.new("http://tempuri.org/authHeader", "auth")
-
- def self.init(authmgr)
- @authmgr = authmgr
- end
-
- def self.create
- new(@authmgr)
- end
-
- def initialize(authmgr)
- super(MyHeaderName)
- @authmgr = authmgr
- @sessionid = nil
- end
-
- def on_simple_outbound
- if @sessionid
- { "sessionid" => @sessionid }
- end
- end
-
- def on_simple_inbound(my_header, mu)
- auth = false
- if sessionid = my_header["sessionid"]
- if userid = @authmgr.auth(sessionid)
- @authmgr.destroy_session(sessionid)
- @sessionid = @authmgr.create_session(userid)
- auth = true
- end
- end
- raise RuntimeError.new("authentication failed") unless auth
- end
- end
-end
-
-if $0 == __FILE__
- svr = AuthHeaderPortServer.new('AuthHeaderPortServer', nil, '0.0.0.0', 7000)
- trap(:INT) do
- svr.shutdown
- end
- status = svr.start
-end
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-20 09:23:45 +0000