Class: Danthes::FayeExtension

Inherits:
Object
  • Object
show all
Defined in:
lib/danthes/faye_extension.rb

Overview

This class is an extension for the Faye::RackAdapter. It is used inside of Danthes.faye_app.

Instance Method Summary collapse

Instance Method Details

#incoming(message, callback) ⇒ Object

Callback to handle incoming Faye messages. This authenticates both subscribe and publish calls.



7
8
9
10
11
12
13
14
 
# File 'lib/danthes/faye_extension.rb', line 7

def incoming(message, callback)
  if message['channel'] == '/meta/subscribe'
    authenticate_subscribe(message)
  elsif message['channel'] !~ %r{^/meta/}
    authenticate_publish(message)
  end
  callback.call(message)
end