Class: Spider::HTTP::RackApplication

Inherits:
Object
  • Object
show all
Defined in:
lib/spiderfw/http/adapters/rack.rb

Instance Method Summary collapse

Instance Method Details

#call(env) ⇒ Object 



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.send_headers unless controller_response.server_output.headers_sent?
            else
                controller_response.prepare_headers
                rack_response_hash[:status] = controller_response.status
                rack_response_hash[:headers] = {}
                controller_response.headers.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.headers_sent?)
            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

#finalize_server ⇒ Object 



150
151
152
 
# File 'lib/spiderfw/http/adapters/rack.rb', line 150

def finalize_server
    Spider.shutdown
end

#initialize_server ⇒ Object 



146
147
148
 
# File 'lib/spiderfw/http/adapters/rack.rb', line 146

def initialize_server
    Spider.startup
end

#prepare_env(env) ⇒ Object 



141
142
143
144
 
# File 'lib/spiderfw/http/adapters/rack.rb', line 141

def prepare_env(env)
    env['HTTP_CONTENT_TYPE'] = env['CONTENT_TYPE']
    return env
end