module FayeAudit

Constants

VERSION

Public Class Methods

audit(bayeux) click to toggle source

# File lib/faye_audit.rb, line 26
  def audit(bayeux)
    @@bayeux = bayeux
    bayeux.on(:handshake) do |client_id|
      logger.info <<LOG
      faye: { client_count: #{client_count + 1}, channel_count: #{channel_count} }
      handshake:
      client_id: #{client_id}
LOG
    end
    bayeux.on(:subscribe) do |client_id, channel|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      subscribe:
      client_id: #{client_id}
      channel: #{channel}
LOG
    end
    bayeux.on(:unsubscribe) do |client_id, channel|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      unsubscribe:
      client_id: #{client_id}
      channel: #{channel}
LOG
    end
    bayeux.on(:publish) do |client_id, channel, data|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      publish:
      client_id: #{client_id}
      channel: #{channel}
      data: #{data}
LOG
    end
    bayeux.on(:disconnect) do |client_id|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      disconnect:
      client_id: #{client_id}
LOG
    end
  end

channel_count() click to toggle source

# File lib/faye_audit.rb, line 19
def channel_count
  @@bayeux.instance_variable_get(:@server)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@channels).size
end

client_count() click to toggle source

# File lib/faye_audit.rb, line 12
def client_count
  @@bayeux.instance_variable_get(:@server)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@clients).keys.size
end

logger() click to toggle source

# File lib/faye_audit.rb, line 4
def logger
  @@logger
end

logger=(logger) click to toggle source

# File lib/faye_audit.rb, line 8
def logger=(logger)
  @@logger = logger
end

Private Instance Methods

audit(bayeux) click to toggle source

# File lib/faye_audit.rb, line 26
  def audit(bayeux)
    @@bayeux = bayeux
    bayeux.on(:handshake) do |client_id|
      logger.info <<LOG
      faye: { client_count: #{client_count + 1}, channel_count: #{channel_count} }
      handshake:
      client_id: #{client_id}
LOG
    end
    bayeux.on(:subscribe) do |client_id, channel|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      subscribe:
      client_id: #{client_id}
      channel: #{channel}
LOG
    end
    bayeux.on(:unsubscribe) do |client_id, channel|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      unsubscribe:
      client_id: #{client_id}
      channel: #{channel}
LOG
    end
    bayeux.on(:publish) do |client_id, channel, data|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      publish:
      client_id: #{client_id}
      channel: #{channel}
      data: #{data}
LOG
    end
    bayeux.on(:disconnect) do |client_id|
      logger.info <<LOG
      faye: { client_count: #{client_count}, channel_count: #{channel_count} }
      disconnect:
      client_id: #{client_id}
LOG
    end
  end

channel_count() click to toggle source

# File lib/faye_audit.rb, line 19
def channel_count
  @@bayeux.instance_variable_get(:@server)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@channels).size
end

client_count() click to toggle source

# File lib/faye_audit.rb, line 12
def client_count
  @@bayeux.instance_variable_get(:@server)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@engine)
          .instance_variable_get(:@clients).keys.size
end

logger() click to toggle source

# File lib/faye_audit.rb, line 4
def logger
  @@logger
end

logger=(logger) click to toggle source

# File lib/faye_audit.rb, line 8
def logger=(logger)
  @@logger = logger
end