Class: Spider::HTTP::MongrelCGIServlet

Inherits:
Mongrel::HttpHandler
  • Object
show all
Defined in:
lib/spiderfw/http/adapters/mongrel.rb

Instance Method Summary collapse

Constructor Details

#initialize(server) ⇒ MongrelCGIServlet

Returns a new instance of MongrelCGIServlet.



177
178
179
 
# File 'lib/spiderfw/http/adapters/mongrel.rb', line 177

def initialize(server)
    @server = server
end

Instance Method Details

#parse_header(str, response) ⇒ Object 



216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
 
# File 'lib/spiderfw/http/adapters/mongrel.rb', line 216

def parse_header(str, response)
    Spider.logger.debug("HEADER #{str}")
    key, val = str.split(':', 2)
    return unless key
    key.strip!
    val.strip! if val
    if (val)
        if (key == 'Status')
            response.status = val
            response.send_status(nil)
        end
        response.header[key] = val
    elsif(str =~ /^(\d+)\s*/)
        response.status = $1
        response.send_status(nil)
    end 
end

#process(request, response) ⇒ Object 



181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
 
# File 'lib/spiderfw/http/adapters/mongrel.rb', line 181

def process(request, response)
    
    ENV['SPIDER_PATH'] = $SPIDER_PATH
    ['SERVER_NAME', 'PATH_INFO', 'HTTP_ACCEPT_ENCODING', 'HTTP_USER_AGENT', 'SCRIPT_NAME',
     'SERVER_PROTOCOL', 'HTTP_COOKIE', 'HTTP_HOST', 'HTTP_ACCEPT_LANGUAGE', 'SERVER_SOFTWARE', 'REQUEST_PATH',
     'HTTP_VERSION', 'REQUEST_URI', 'SERVER_PORT', 'GATEWAY_INTERFACE', 'HTTP_ACCEPT', 'HTTP_CONNECTION',
     'REQUEST_METHOD', 'QUERY_STRING', 'CONTENT_TYPE', 'CONTENT_LENGTH'].each do |key|
        ENV[key] = request.params[key]
    end
    io = IO.popen("ruby "+$SPIDER_PATH+"/lib/spiderfw/http/adapters/cgi.rb", 'r+')
    
    while (request.body.gets)
        io.write($_)
    end
    headers_sent = false
    while(io.gets)
        if !response.header_sent
            if ($_ == "\n")
                unless response.status_sent
                    response.status = 200
                    response.send_status(nil)
                end
                response.send_header 
            else
                parse_header($_, response)
            end
        else
            response.write($_)
        end
    end
    io.close
    response.finished

end