2009-12-19 03:16:58 +01:00
|
|
|
require 'thread'
|
2010-06-14 06:09:24 +02:00
|
|
|
require 'rack/mock'
|
|
|
|
require 'rack/session/pool'
|
2009-12-19 03:16:58 +01:00
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
describe Rack::Session::Pool do
|
2009-12-19 03:16:58 +01:00
|
|
|
session_key = Rack::Session::Pool::DEFAULT_OPTIONS[:key]
|
|
|
|
session_match = /#{session_key}=[0-9a-fA-F]+;/
|
2010-06-14 06:09:24 +02:00
|
|
|
|
2009-12-19 03:16:58 +01:00
|
|
|
incrementor = lambda do |env|
|
|
|
|
env["rack.session"]["counter"] ||= 0
|
|
|
|
env["rack.session"]["counter"] += 1
|
|
|
|
Rack::Response.new(env["rack.session"].inspect).to_a
|
|
|
|
end
|
2010-06-14 06:09:24 +02:00
|
|
|
|
|
|
|
drop_session = lambda do |env|
|
2009-12-19 03:16:58 +01:00
|
|
|
env['rack.session.options'][:drop] = true
|
|
|
|
incrementor.call(env)
|
|
|
|
end
|
2010-06-14 06:09:24 +02:00
|
|
|
|
|
|
|
renew_session = lambda do |env|
|
2009-12-19 03:16:58 +01:00
|
|
|
env['rack.session.options'][:renew] = true
|
|
|
|
incrementor.call(env)
|
|
|
|
end
|
2010-06-14 06:09:24 +02:00
|
|
|
|
|
|
|
defer_session = lambda do |env|
|
2009-12-19 03:16:58 +01:00
|
|
|
env['rack.session.options'][:defer] = true
|
|
|
|
incrementor.call(env)
|
|
|
|
end
|
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
it "creates a new cookie" do
|
2009-12-19 03:16:58 +01:00
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
res = Rack::MockRequest.new(pool).get("/")
|
|
|
|
res["Set-Cookie"].should.match session_match
|
|
|
|
res.body.should.equal '{"counter"=>1}'
|
|
|
|
end
|
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
it "determines session from a cookie" do
|
2009-12-19 03:16:58 +01:00
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
req = Rack::MockRequest.new(pool)
|
|
|
|
cookie = req.get("/")["Set-Cookie"]
|
|
|
|
req.get("/", "HTTP_COOKIE" => cookie).
|
|
|
|
body.should.equal '{"counter"=>2}'
|
|
|
|
req.get("/", "HTTP_COOKIE" => cookie).
|
|
|
|
body.should.equal '{"counter"=>3}'
|
|
|
|
end
|
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
it "survives nonexistant cookies" do
|
2009-12-19 03:16:58 +01:00
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
res = Rack::MockRequest.new(pool).
|
|
|
|
get("/", "HTTP_COOKIE" => "#{session_key}=blarghfasel")
|
|
|
|
res.body.should.equal '{"counter"=>1}'
|
|
|
|
end
|
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
it "deletes cookies with :drop option" do
|
2009-12-19 03:16:58 +01:00
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
req = Rack::MockRequest.new(pool)
|
|
|
|
drop = Rack::Utils::Context.new(pool, drop_session)
|
|
|
|
dreq = Rack::MockRequest.new(drop)
|
|
|
|
|
|
|
|
res0 = req.get("/")
|
|
|
|
session = (cookie = res0["Set-Cookie"])[session_match]
|
|
|
|
res0.body.should.equal '{"counter"=>1}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res1 = req.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res1["Set-Cookie"][session_match].should.equal session
|
|
|
|
res1.body.should.equal '{"counter"=>2}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res2 = dreq.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res2["Set-Cookie"].should.equal nil
|
|
|
|
res2.body.should.equal '{"counter"=>3}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 0
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res3 = req.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res3["Set-Cookie"][session_match].should.not.equal session
|
|
|
|
res3.body.should.equal '{"counter"=>1}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
end
|
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
it "provides new session id with :renew option" do
|
2009-12-19 03:16:58 +01:00
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
req = Rack::MockRequest.new(pool)
|
|
|
|
renew = Rack::Utils::Context.new(pool, renew_session)
|
|
|
|
rreq = Rack::MockRequest.new(renew)
|
|
|
|
|
|
|
|
res0 = req.get("/")
|
|
|
|
session = (cookie = res0["Set-Cookie"])[session_match]
|
|
|
|
res0.body.should.equal '{"counter"=>1}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res1 = req.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res1["Set-Cookie"][session_match].should.equal session
|
|
|
|
res1.body.should.equal '{"counter"=>2}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res2 = rreq.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
new_cookie = res2["Set-Cookie"]
|
|
|
|
new_session = new_cookie[session_match]
|
|
|
|
new_session.should.not.equal session
|
|
|
|
res2.body.should.equal '{"counter"=>3}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res3 = req.get("/", "HTTP_COOKIE" => new_cookie)
|
|
|
|
res3["Set-Cookie"][session_match].should.equal new_session
|
|
|
|
res3.body.should.equal '{"counter"=>4}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
end
|
|
|
|
|
2010-06-14 06:09:24 +02:00
|
|
|
it "omits cookie with :defer option" do
|
2009-12-19 03:16:58 +01:00
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
req = Rack::MockRequest.new(pool)
|
|
|
|
defer = Rack::Utils::Context.new(pool, defer_session)
|
|
|
|
dreq = Rack::MockRequest.new(defer)
|
|
|
|
|
|
|
|
res0 = req.get("/")
|
|
|
|
session = (cookie = res0["Set-Cookie"])[session_match]
|
|
|
|
res0.body.should.equal '{"counter"=>1}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res1 = req.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res1["Set-Cookie"][session_match].should.equal session
|
|
|
|
res1.body.should.equal '{"counter"=>2}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res2 = dreq.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res2["Set-Cookie"].should.equal nil
|
|
|
|
res2.body.should.equal '{"counter"=>3}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
|
|
|
|
res3 = req.get("/", "HTTP_COOKIE" => cookie)
|
|
|
|
res3["Set-Cookie"][session_match].should.equal session
|
|
|
|
res3.body.should.equal '{"counter"=>4}'
|
2010-06-14 06:09:24 +02:00
|
|
|
pool.pool.size.should.equal 1
|
2009-12-19 03:16:58 +01:00
|
|
|
end
|
|
|
|
|
|
|
|
# anyone know how to do this better?
|
2010-06-14 06:09:24 +02:00
|
|
|
it "should merge sessions when multithreaded" do
|
|
|
|
unless $DEBUG
|
|
|
|
1.should.equal 1
|
|
|
|
next
|
|
|
|
end
|
|
|
|
|
2009-12-19 03:16:58 +01:00
|
|
|
warn 'Running multithread tests for Session::Pool'
|
|
|
|
pool = Rack::Session::Pool.new(incrementor)
|
|
|
|
req = Rack::MockRequest.new(pool)
|
|
|
|
|
|
|
|
res = req.get('/')
|
|
|
|
res.body.should.equal '{"counter"=>1}'
|
|
|
|
cookie = res["Set-Cookie"]
|
|
|
|
sess_id = cookie[/#{pool.key}=([^,;]+)/,1]
|
|
|
|
|
|
|
|
delta_incrementor = lambda do |env|
|
|
|
|
# emulate disconjoinment of threading
|
|
|
|
env['rack.session'] = env['rack.session'].dup
|
|
|
|
Thread.stop
|
|
|
|
env['rack.session'][(Time.now.usec*rand).to_i] = true
|
|
|
|
incrementor.call(env)
|
|
|
|
end
|
|
|
|
tses = Rack::Utils::Context.new pool, delta_incrementor
|
|
|
|
treq = Rack::MockRequest.new(tses)
|
|
|
|
tnum = rand(7).to_i+5
|
|
|
|
r = Array.new(tnum) do
|
|
|
|
Thread.new(treq) do |run|
|
|
|
|
run.get('/', "HTTP_COOKIE" => cookie, 'rack.multithread' => true)
|
|
|
|
end
|
|
|
|
end.reverse.map{|t| t.run.join.value }
|
|
|
|
r.each do |res|
|
|
|
|
res['Set-Cookie'].should.equal cookie
|
|
|
|
res.body.should.include '"counter"=>2'
|
|
|
|
end
|
|
|
|
|
|
|
|
session = pool.pool[sess_id]
|
2010-06-14 06:09:24 +02:00
|
|
|
session.size.should.equal tnum+1 # counter
|
|
|
|
session['counter'].should.equal 2 # meeeh
|
2009-12-19 03:16:58 +01:00
|
|
|
end
|
|
|
|
end
|