Class: CircleCI::CLI::Networking::CircleCIPusherClient

Inherits:
Object
  • Object
show all
Defined in:
lib/circleci/cli/networking/pusher_client.rb

Instance Method Summary collapse

Instance Method Details

#bind(channel, event) ⇒ Object 



15
16
17
18
19
20
 
# File 'lib/circleci/cli/networking/pusher_client.rb', line 15

def bind(channel, event)
  @socket.subscribe(channel)
  @socket[channel].bind(event) do |data|
    yield data
  end
end

#bind_event_json(channel, event) ⇒ Object 



22
23
24
25
26
 
# File 'lib/circleci/cli/networking/pusher_client.rb', line 22

def bind_event_json(channel, event)
  bind(channel, event) do |data|
    JSON.parse(data).each { |json| yield(json) }
  end
end

#connect ⇒ Object 



9
10
11
12
13
 
# File 'lib/circleci/cli/networking/pusher_client.rb', line 9

def connect
  PusherClient.logger.level = Logger::ERROR
  @socket = PusherClient::Socket.new(app_key, pusher_options)
  @socket.connect(true)
end

#unsubscribe(channel) ⇒ Object 



28
29
30
 
# File 'lib/circleci/cli/networking/pusher_client.rb', line 28

def unsubscribe(channel)
  @socket.unsubscribe(channel)
end