class Travis::Client::Listener::Socket

def fetch_auth(*channels)
  channels.select! { |c| signatures[c].nil? if c.start_with? 'private-' }
  signatures.merge! session.post_raw('/pusher/auth', :channels => channels, :socket_id => socket_id)['channels'] if channels.any?
end

def get_private_auth(channel)
  fetch_auth(channel.name)
  signatures[channel.name]
end

def initialize(application_key, options = {})
  @session    = options.fetch(:session)
  @signatures = {}
  super
end

def subscribe_all
  # bulk auth on connect
  fetch_auth(*channels.channels.keys)
  super
end