Class: Faye::RackAdapter
- Inherits:
-
Object
show all
- Includes:
- Logging
- Defined in:
- lib/faye/adapters/rack_adapter.rb
Defined Under Namespace
Classes: DeferredBody
Constant Summary
collapse
- ASYNC_RESPONSE =
Only supported under Thin
[-1, {}, []].freeze
- DEFAULT_ENDPOINT =
'/bayeux'
- SCRIPT_PATH =
File.join(ROOT, 'faye-browser-min.js')
- TYPE_JSON =
{'Content-Type' => 'application/json'}
- TYPE_SCRIPT =
{'Content-Type' => 'text/javascript'}
- TYPE_TEXT =
{'Content-Type' => 'text/plain'}
Constants included
from Logging
Logging::DEFAULT_LOG_LEVEL, Logging::LOG_LEVELS
Instance Attribute Summary
Attributes included from Logging
#log_level
Instance Method Summary
collapse
Methods included from Logging
#log
Constructor Details
#initialize(app = nil, options = nil) ⇒ RackAdapter
Returns a new instance of RackAdapter.
22
23
24
25
26
27
28
29
30
31
32
|
# File 'lib/faye/adapters/rack_adapter.rb', line 22
def initialize(app = nil, options = nil)
@app = app if app.respond_to?(:call)
@options = [app, options].grep(Hash).first || {}
@endpoint = @options[:mount] || DEFAULT_ENDPOINT
@endpoint_re = Regexp.new('^' + @endpoint + '(/[^/]*)*(\\.js)?$')
@server = Server.new(@options)
return unless extensions = @options[:extensions]
[*extensions].each { |extension| add_extension(extension) }
end
|
Instance Method Details
#add_extension(extension) ⇒ Object
34
35
36
|
# File 'lib/faye/adapters/rack_adapter.rb', line 34
def add_extension(extension)
@server.add_extension(extension)
end
|
#call(env) ⇒ Object
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
# File 'lib/faye/adapters/rack_adapter.rb', line 51
def call(env)
Faye.ensure_reactor_running!
request = Rack::Request.new(env)
unless request.path_info =~ @endpoint_re
env['faye.client'] = get_client
return @app ? @app.call(env) :
[404, TYPE_TEXT, ["Sure you're not looking for #{@endpoint} ?"]]
end
return handle_options(request) if env['REQUEST_METHOD'] == 'OPTIONS'
return handle_upgrade(request) if env['HTTP_UPGRADE'] == 'WebSocket'
return [200, TYPE_SCRIPT, File.new(SCRIPT_PATH)] if request.path_info =~ /\.js$/
handle_request(request)
end
|
#get_client ⇒ Object
42
43
44
|
# File 'lib/faye/adapters/rack_adapter.rb', line 42
def get_client
@client ||= Client.new(@server)
end
|
#listen(port) ⇒ Object
46
47
48
49
|
# File 'lib/faye/adapters/rack_adapter.rb', line 46
def listen(port)
handler = Rack::Handler.get('thin')
handler.run(self, :Port => port)
end
|
#remove_extension(extension) ⇒ Object
38
39
40
|
# File 'lib/faye/adapters/rack_adapter.rb', line 38
def remove_extension(extension)
@server.remove_extension(extension)
end
|