Contents

require 'faye/websocket'
require 'eventmachine'
require 'rest-client'
require 'json'

module Perus::Pinger
    class ChromeCommand < Command
        option :timeout_seconds, default: 2
        option :host, default: 'localhost'
        option :port, default: 9222
        abstract!

        def send_command(command)
            @ws.send(command)
        end

        def execute(commands, &message_callback)
            # discover the first page shown in chrome
            tries = 0
            @page = nil
            begin
                pages = JSON.parse(RestClient.get("http://#{options.host}:#{options.port}/json"))
                pages.reject! {|page| page['url'].include?('chrome-extension')}
                @page = pages.first
            rescue Errno::ECONNREFUSED, Errno::ECONNRESET => e
                tries += 1
                sleep 3
                retry if tries < 4
                return
            end

            EM.run do
                @ws = Faye::WebSocket::Client.new(@page['webSocketDebuggerUrl'])

                @ws.on :error do |event|
                    puts "Chrome error: #{event}"
                    EM.stop_event_loop
                end

                @ws.on :close do |event|
                    EM.stop_event_loop
                end

                @ws.on :message do |event|
                    if block_given?
                        json = JSON.parse(event.data)
                        message_callback.call(json)
                    end
                end

                # send each command, responses will appear
                commands.each do |command|
                    send_command(command)
                end

                # cutoff console message loading after N seconds
                EM.add_timer(options.timeout_seconds) do
                    @ws.close
                end
            end
        end
    end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
perus-0.1.26	lib/perus/pinger/chrome_command.rb
perus-0.1.25	lib/perus/pinger/chrome_command.rb
perus-0.1.24	lib/perus/pinger/chrome_command.rb
perus-0.1.23	lib/perus/pinger/chrome_command.rb