Class: Puppeteer::WebSocket

Inherits:
Object
  • Object
show all
Defined in:
lib/puppeteer/web_socket.rb

Overview

ref: github.com/rails/rails/blob/master/actioncable/lib/action_cable/connection/client_socket.rb ref: github.com/cavalle/chrome_remote/blob/master/lib/chrome_remote/web_socket_client.rb

Defined Under Namespace

Classes: DriverImpl, TransportError

Constant Summary collapse

STATE_CONNECTING = 
0
STATE_OPENED = 
1
STATE_CLOSING = 
2
STATE_CLOSED = 
3

Instance Method Summary collapse

Constructor Details

#initialize(url:, max_payload_size:) ⇒ WebSocket

Returns a new instance of WebSocket.



31
32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/puppeteer/web_socket.rb', line 31

def initialize(url:, max_payload_size:)
  @impl = DriverImpl.new(url)
  @driver = ::WebSocket::Driver.client(@impl, max_length: max_payload_size)

  setup
  @driver.start

  Thread.new do
    wait_for_data until @ready_state >= STATE_CLOSING
  rescue EOFError
    # Google Chrome was gone.
    # We have nothing todo. Just finish polling.
  end
end

Instance Method Details

#close(code: 1000, reason: "") ⇒ Object 



78
79
80
81
82
 
# File 'lib/puppeteer/web_socket.rb', line 78

def close(code: 1000, reason: "")
  return if @ready_state >= STATE_CLOSING
  @ready_state = STATE_CLOSING
  @driver.close(reason, code)
end

#on_close(&block) ⇒ Object

Parameters:

  • block (Proc(reason: String, code: Numeric)) 


89
90
91
 
# File 'lib/puppeteer/web_socket.rb', line 89

def on_close(&block)
  @on_close = block
end

#on_error(&block) ⇒ Object

Parameters:

  • block (Proc(error_message: String)) 


94
95
96
 
# File 'lib/puppeteer/web_socket.rb', line 94

def on_error(&block)
  @on_error = block
end

#on_message(&block) ⇒ Object 



98
99
100
 
# File 'lib/puppeteer/web_socket.rb', line 98

def on_message(&block)
  @on_message = block
end

#on_open(&block) ⇒ Object 



84
85
86
 
# File 'lib/puppeteer/web_socket.rb', line 84

def on_open(&block)
  @on_open = block
end

#send_text(message) ⇒ Object

Parameters:

  • message (String) 


73
74
75
76
 
# File 'lib/puppeteer/web_socket.rb', line 73

def send_text(message)
  return if @ready_state >= STATE_CLOSING
  @driver.text(message)
end