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
|
# File 'lib/spiderfw/http/adapters/rack.rb', line 70
def call(env)
Spider.request_started
env = prepare_env(env)
controller_request = RackRequest.new(env)
controller_request.server = RackApplication
controller_request.rack_input = env['rack.input']
path = env['PATH_INFO'].chomp('/')
controller_request.action = path
controller_request.request_time = DateTime.now
controller_response = Spider::Response.new
if (Spider.conf.get('webserver.force_threads'))
r, w = IO.pipe
rack_response_hash = {:body => r}
controller_response.server_output = RackIO.new(rack_response_hash, controller_response, w)
else
w = StringIO.new
controller_response.server_output = w
rack_response_hash = {:body => w}
end
controller_done = false
run_block = lambda do
begin
controller = ::Spider::HTTPController.new(controller_request, controller_response)
controller.extend(Spider::FirstResponder)
controller.before(path)
controller.execute(path)
controller.after(path)
Spider::Logger.debug("Controller done")
rescue => exc
Spider.logger.debug("Error:")
Spider.logger.debug(exc)
controller.ensure() if controller
ensure
if (Spider.conf.get('webserver.force_threads'))
controller_response.server_output. unless controller_response.server_output.
else
controller_response.
rack_response_hash[:status] = controller_response.status
rack_response_hash[:headers] = {}
controller_response..each do |key, val|
if (val.is_a?(Array))
val.each{ |v| rack_response_hash[:headers][key] = v.to_s }
else
rack_response_hash[:headers][key] = val.to_s
end
end
w.rewind
end
controller_done = true
Spider.request_finished
end
end
if (Spider.conf.get('webserver.force_threads'))
controllerThread = Thread.start &run_block
while (!controller_done && !controller_response.server_output.)
Thread.stop
end
controllerThread.join
else
run_block.call
end
Spider.logger.debug("Rack responding")
return [rack_response_hash[:status], rack_response_hash[:headers], rack_response_hash[:body]]
end
|