ichrome 1.1.3

A toolkit for using chrome browser with the [Chrome Devtools Protocol(CDP)](https://chromedevtools.github.io/devtools-protocol/), support python3.7+. Read more: https://github.com/ClericPy/ichrome.

ichrome

A toolkit to control Chrome browser with the Chrome Devtools Protocol(CDP), support python3.7+.

Install

pip install ichrome -U

Why?

• pyppeteer / selenium is awesome, but I don't need so much
  • spelling of pyppeteer is hard to remember.
  • selenium is slow.
• async communication with Chrome remote debug port, stable choice. [Recommended]
• sync way to test CDP, which is not recommended for complex production environments. [Deprecated]

Features

• Chrome process daemon
• Connect to existing chrome debug port
• Operations on Tabs

Examples

Quick Start

1. Start a new chrome daemon process with headless=False
2. Create the connection to exist chrome browser
3. Operations on the tabs: new tab, wait loading, run javascript, get html, close tab
4. Close the browser GRACEFULLY instead of killing process

AsyncChrome feature list

1. server

   return f"http://{self.host}:{self.port}", such as http://127.0.0.1:9222

2. version

   version info from /json/version format like:

   {'Browser': 'Chrome/77.0.3865.90', 'Protocol-Version': '1.3', 'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/77.0.3865.90 Safari/537.36', 'V8-Version': '7.7.299.11', 'WebKit-Version': '537.36 (@58c425ba843df2918d9d4b409331972646c393dd)', 'webSocketDebuggerUrl': 'ws://127.0.0.1:9222/devtools/browser/b5fbd149-959b-4603-b209-cfd26d66bdc1'}
   

3. connect / check / ok

   check alive

4. get_tabs / tabs / get_tab / get_tabs

   get the AsyncTab instance from /json.

5. new_tab / activate_tab / close_tab / close_tabs

   operating tabs.

6. close_browser

   find the activated tab and send Browser.close message, close the connected chrome browser gracefully.

   await chrome.close_browser()
   

7. kill

   force kill the chrome process with self.port.

   await chrome.kill()
   

8. connect_tabs

   connect websockets for multiple tabs in one with context, and disconnect before exiting.

   tab0: AsyncTab = (await chrome.tabs)[0]
   tab1: AsyncTab = await chrome.new_tab()
   async with chrome.connect_tabs([tab0, tab1]):
       assert (await tab0.current_url) == 'about:blank'
       assert (await tab1.current_url) == 'about:blank'
   

AsyncTab feature list

1. set_url / reload

   navigate to a new url. reload equals to set_url(None)

2. wait_event

   listening the events with given name, and separate from other same-name events with filter_function, finally run the callback_function with result.

3. wait_page_loading / wait_loading

   wait for Page.loadEventFired event, or stop loading while timeout. Different from wait_loading_finished.

4. wait_response

   filt the Network.responseReceived event by filter_function, return the request_dict which can be used by get_response

5. wait_request_loading / wait_loading_finished

   sometimes event got request_dict with wait_response, but the ajax request is still fetching, which need to wait the Network.loadingFinished event.

6. activate / activate_tab

   activate tab with websocket / http message.

7. close / close_tab

   close tab with websocket / http message.

8. add_js_onload

   Page.addScriptToEvaluateOnNewDocument, which means this javascript code will be run before page loaded.

9. clear_browser_cache / clear_browser_cookies

   Network.clearBrowserCache and Network.clearBrowserCookies

10. querySelectorAll

    get the tag instance, which contains the tagName, innerHTML, outerHTML, textContent, attributes attrs.

11. click

    click the element queried by given css selector.

12. refresh_tab_info

    to refresh the init attrs: url, title.

13. current_html / current_title / current_url

    get the current html / title / url with tab.js. or using the refresh_tab_info method and init attrs.

14. crash

    Page.crash

15. get_cookies / get_all_cookies / delete_cookies / set_cookie

    some page cookies operations.

16. set_headers / set_ua

    Network.setExtraHTTPHeaders and Network.setUserAgentOverride, used to update headers dynamically.

17. close_browser

    send Browser.close message to close the chrome browser gracefully.

18. get_bounding_client_rect / get_element_clip

    get_element_clip is alias name for the other, these two method is to get the rect of element which queried by css element.

19. screenshot / screenshot_element

    get the screenshot base64 encoded image data. screenshot_element should be given a css selector to locate the element.

20. get_page_size / get_screen_size

    size of current window or the whole screen.

21. get_response

    get the response body with the given request dict.

22. js

    run the given js code, return the raw response from sending Runtime.evaluate message.

23. inject_js_url

    inject some js url, like <script src="xxx/static/js/jquery.min.js"></script> do.

24. get_value & get_variable

    run the given js variable or expression, and return the result.

    await tab.get_value('document.title')
    await tab.get_value("document.querySelector('title').innerText")
    

25. keyboard_send

    dispath key event with Input.dispatchKeyEvent

26. mouse_click

    dispath click event on given position

27. mouse_drag

    dispath drag event on given position, and return the target x, y. duration arg is to slow down the move speed.

28. mouse_drag_rel

    dispath drag event on given offset, and return the target x, y.

29. mouse_drag_rel

    drag with offsets continuously.

    await tab.set_url('https://draw.yunser.com/')
    walker = await tab.mouse_drag_rel_chain(320, 145).move(50, 0, 0.2).move(
        0, 50, 0.2).move(-50, 0, 0.2).move(0, -50, 0.2)
    await walker.move(50 * 1.414, 50 * 1.414, 0.2)
    

30. mouse_press / mouse_release / mouse_move / mouse_move_rel / mouse_move_rel_chain

    similar to the drag features. These mouse features is only dispatched events, not the real mouse action.

from ichrome import AsyncChromeDaemon, AsyncChrome
import asyncio


async def main():
    # async with AsyncChromeDaemon() as chromed:
    # If there is no operation for chromed, it can be omitted for short
    async with AsyncChromeDaemon(headless=False):
        # connect to an opened chrome
        async with AsyncChrome() as chrome:
            tab = await chrome.new_tab(url="https://github.com/ClericPy")
            # async with tab() as tab:
            # and `as tab` can be omitted
            async with tab():
                await tab.wait_loading(2)
                await tab.js("document.write('<h1>Document updated.</h1>')")
                await asyncio.sleep(1)
                # await tab.js('alert("test ok")')
                print('output:', await tab.html)
                # output: <html><head></head><body><h1>Document updated.</h1></body></html>
                await tab.close()
            # close_browser gracefully, I have no more need of chrome instance
            await chrome.close_browser()


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(main())

Command Line Usage

Be used for launching a chrome daemon process. The unhandled args will be treated as chrome raw args and appended to extra_config list.

Chromium Command Line Args List

λ python3 -m ichrome -s 9222
2018-11-27 23:01:59 DEBUG [ichrome] base.py(329): kill chrome.exe --remote-debugging-port=9222
2018-11-27 23:02:00 DEBUG [ichrome] base.py(329): kill chrome.exe --remote-debugging-port=9222

λ python3 -m ichrome -p 9222 --start_url "http://bing.com" --disable_image
2018-11-27 23:03:57 INFO  [ichrome] __main__.py(69): ChromeDaemon cmd args: {'daemon': True, 'block': True, 'chrome_path': '', 'host': 'localhost', 'port': 9222, 'headless': False, 'user_agent': '', 'proxy': '', 'user_data_dir': None, 'disable_image': True, 'start_url': 'http://bing.com', 'extra_config': '', 'max_deaths': 1, 'timeout': 2}

Details: python3 -m ichrome --help

usage:
    All the unknown args will be append to extra_config.
Demo:
    > python -m ichrome --host=127.0.0.1 --window-size=1200,800 --incognito
    > ChromeDaemon cmd args: {'daemon': True, 'block': True, 'chrome_path': '', 'host': '127.0.0.1', 'port': 9222, 'headless': False, 'user_agent': '', 'proxy': '', 'user_data_dir': None, 'disable_image': False, 'start_url': 'about:blank', 'extra_config':['--window-size=1212,1212', '--incognito'], 'max_deaths': 1, 'timeout': 2}

optional arguments:
  -h, --help            show this help message and exit
  -V, --version         show ichrome version info
  -c CHROME_PATH, --chrome_path CHROME_PATH
                        chrome_path
  --host HOST           host
  -p PORT, --port PORT  port
  --headless            is_headless
  -s SHUTDOWN, --shutdown SHUTDOWN
                        shutdown the port
  --user_agent USER_AGENT
                        user_agent
  --proxy PROXY         proxy
  --user_data_dir USER_DATA_DIR
                        user_data_dir
  --disable_image       disable_image
  --start_url START_URL
                        start_url
  --max_deaths MAX_DEATHS
                        max_deaths
  --timeout TIMEOUT     timeout

[Async] Operating tabs with coroutines

Run in a completely asynchronous environment, it's a stable choice.

Code

import asyncio


async def test_examples():
    from ichrome import AsyncChrome as Chrome
    from ichrome import AsyncTab as Tab
    from ichrome import AsyncChromeDaemon, Tag, logger
    logger.setLevel('DEBUG')
    # Tab._log_all_recv = True
    port = 9222

    async with AsyncChromeDaemon(host="127.0.0.1", port=port, max_deaths=1):
        # ===================== Chrome Test Cases =====================
        async with Chrome() as chrome:
            assert str(chrome) == '<Chrome(connected): http://127.0.0.1:9222>'
            assert chrome.server == 'http://127.0.0.1:9222'
            try:
                await chrome.version
            except AttributeError as e:
                assert str(
                    e
                ) == 'Chrome has not connected. `await chrome.connect()` before request.'
            # waiting chrome launching
            for _ in range(5):
                connected = await chrome.connect()
                if connected:
                    break
                await asyncio.sleep(1)
            assert connected is True
            version = await chrome.version
            assert isinstance(version, dict) and 'Browser' in version
            ok = await chrome.check()
            assert ok is True
            ok = await chrome.ok
            assert ok is True
            resp = await chrome.get_server('json')
            assert isinstance(resp.json(), list)
            tabs1: Tab = await chrome.get_tabs()
            tabs2: Tab = await chrome.tabs
            assert tabs1 == tabs2
            tab0: Tab = tabs1[0]
            tab1: Tab = await chrome.new_tab()
            assert isinstance(tab1, Tab)
            await asyncio.sleep(1)
            await chrome.activate_tab(tab0)
            async with chrome.connect_tabs([tab0, tab1]):
                assert (await tab0.current_url) == 'about:blank'
                assert (await tab1.current_url) == 'about:blank'
            async with chrome.connect_tabs(tab0):
                assert await tab0.current_url == 'about:blank'
            await chrome.close_tab(tab1)
            # ===================== Tab Test Cases =====================
            tab: Tab = await chrome.new_tab()
            assert tab.ws is None
            async with tab():
                assert tab.ws
            assert tab.ws is None
            # also work: async with tab.connect():
            async with tab():
                assert tab.status == 'connected'
                assert tab.msg_id == tab.msg_id - 1
                assert await tab.refresh_tab_info()

                # watch the tabs switch
                await tab.activate_tab()
                await asyncio.sleep(.2)
                await tab0.activate_tab()
                await asyncio.sleep(.2)
                await tab.activate_tab()

                assert await tab.send('Network.enable') == {
                    'id': 3,
                    'result': {}
                }
                await tab.clear_browser_cookies()
                assert len(await tab.get_cookies(urls='http://python.org')) == 0
                assert await tab.set_cookie(
                    'test', 'test_value', url='http://python.org')
                assert await tab.set_cookie(
                    'test2', 'test_value', url='http://python.org')
                assert len(await tab.get_cookies(urls='http://python.org')) == 2
                assert await tab.delete_cookies('test', url='http://python.org')
                assert len(await tab.get_cookies(urls='http://python.org')) == 1
                # get all Browser cookies
                assert len(await tab.get_all_cookies()) > 0
                # disable Network
                assert await tab.disable('Network')
                # set new url for this tab, timeout will stop loading
                assert await tab.set_url('http://python.org', timeout=2)
                # reload the page
                assert await tab.reload(timeout=2)
                # here should be press OK by human in 10 secs, get the returned result
                js_result = await tab.js('document.title', timeout=3)
                # {'id': 18, 'result': {'result': {'type': 'string', 'value': 'Welcome to Python.org'}}}
                assert 'result' in js_result
                # inject JS timeout return None
                assert (await tab.js('alert()', timeout=0.1)) is None
                # close the alert dialog
                await tab.enable('Page')
                await tab.send('Page.handleJavaScriptDialog', accept=True)
                # querySelectorAll with JS, return list of Tag object
                tag_list = await tab.querySelectorAll('#id-search-field')
                assert tag_list[0].tagName == 'input'
                # querySelectorAll with JS, index arg is Not None, return Tag or None
                one_tag = await tab.querySelectorAll(
                    '#id-search-field', index=0)
                assert isinstance(one_tag, Tag)
                # inject js url: vue.js
                # get window.Vue variable before injecting
                vue_obj = await tab.js('window.Vue')
                # {'id': 22, 'result': {'result': {'type': 'undefined'}}}
                assert 'undefined' in str(vue_obj)
                assert await tab.inject_js_url(
                    'https://cdn.staticfile.org/vue/2.6.10/vue.min.js',
                    timeout=3)
                vue_obj = await tab.js('window.Vue')
                # {'id': 23, 'result': {'result': {'type': 'function', 'className': 'Function', 'description': 'function wn(e){this._init(e)}', 'objectId': '{"injectedScriptId":1,"id":1}'}}}
                assert 'Function' in str(vue_obj)

                # update title
                await tab.js("document.title = 'Press about'")
                assert (await tab.current_title) == 'Press about'

                # wait_response by filter_function
                # {'method': 'Network.responseReceived', 'params': {'requestId': '1000003000.69', 'loaderId': 'D7814CD633EDF3E699523AF0C4E9DB2C', 'timestamp': 207483.974238, 'type': 'Script', 'response': {'url': 'https://www.python.org/static/js/libs/masonry.pkgd.min.js', 'status': 200, 'statusText': '', 'headers': {'date': 'Sat, 05 Oct 2019 08:18:34 GMT', 'via': '1.1 vegur, 1.1 varnish, 1.1 varnish', 'last-modified': 'Tue, 24 Sep 2019 18:31:03 GMT', 'server': 'nginx', 'age': '290358', 'etag': '"5d8a60e7-6643"', 'x-served-by': 'cache-iad2137-IAD, cache-tyo19928-TYO', 'x-cache': 'HIT, HIT', 'content-type': 'application/x-javascript', 'status': '200', 'cache-control': 'max-age=604800, public', 'accept-ranges': 'bytes', 'x-timer': 'S1570263515.866582,VS0,VE0', 'content-length': '26179', 'x-cache-hits': '1, 170'}, 'mimeType': 'application/x-javascript', 'connectionReused': False, 'connectionId': 0, 'remoteIPAddress': '151.101.108.223', 'remotePort': 443, 'fromDiskCache': True, 'fromServiceWorker': False, 'fromPrefetchCache': False, 'encodedDataLength': 0, 'timing': {'requestTime': 207482.696803, 'proxyStart': -1, 'proxyEnd': -1, 'dnsStart': -1, 'dnsEnd': -1, 'connectStart': -1, 'connectEnd': -1, 'sslStart': -1, 'sslEnd': -1, 'workerStart': -1, 'workerReady': -1, 'sendStart': 0.079, 'sendEnd': 0.079, 'pushStart': 0, 'pushEnd': 0, 'receiveHeadersEnd': 0.836}, 'protocol': 'h2', 'securityState': 'unknown'}, 'frameId': 'A2971702DE69F008914F18EAE6514DD5'}}
                async def cb(request):
                    if request:
                        await tab.wait_request_loading(request, 5)
                        ok = 'Masonry PACKAGED' in (
                            await tab.get_response(request))['result']['body']
                        logger.warning(
                            f'check wait_response callback, get_response {ok}')
                        assert ok
                    else:
                        raise ValueError

                # listening response
                def filter_function(r):
                    ok = 'www.python.org/static/js/libs/masonry.pkgd.min.js' in r[
                        'params']['response']['url']
                    return print('get response url:',
                                 r['params']['response']['url'], ok) or ok

                task = asyncio.ensure_future(
                    tab.wait_response(
                        filter_function=filter_function,
                        callback_function=cb,
                        timeout=10),
                    loop=tab.loop)
                await tab.click('#about>a')
                await tab.wait_loading(2)
                await task
                # click download link, without wait_loading.
                # request
                # {'method': 'Network.responseReceived', 'params': {'requestId': '2FAFC4FC410A6DEDE88553B1836C530B', 'loaderId': '2FAFC4FC410A6DEDE88553B1836C530B', 'timestamp': 212239.182469, 'type': 'Document', 'response': {'url': 'https://www.python.org/downloads/', 'status': 200, 'statusText': '', 'headers': {'status': '200', 'server': 'nginx', 'content-type': 'text/html; charset=utf-8', 'x-frame-options': 'DENY', 'cache-control': 'max-age=604800, public', 'via': '1.1 vegur\n1.1 varnish\n1.1 varnish', 'accept-ranges': 'bytes', 'date': 'Sat, 05 Oct 2019 10:51:48 GMT', 'age': '282488', 'x-served-by': 'cache-iad2139-IAD, cache-hnd18720-HND', 'x-cache': 'MISS, HIT', 'x-cache-hits': '0, 119', 'x-timer': 'S1570272708.444646,VS0,VE0', 'content-length': '113779'}, 'mimeType': 'text/html', 'connectionReused': False, 'connectionId': 0, 'remoteIPAddress': '123.23.54.43', 'remotePort': 443, 'fromDiskCache': True, 'fromServiceWorker': False, 'fromPrefetchCache': False, 'encodedDataLength': 0, 'timing': {'requestTime': 212239.179388, 'proxyStart': -1, 'proxyEnd': -1, 'dnsStart': -1, 'dnsEnd': -1, 'connectStart': -1, 'connectEnd': -1, 'sslStart': -1, 'sslEnd': -1, 'workerStart': -1, 'workerReady': -1, 'sendStart': 0.392, 'sendEnd': 0.392, 'pushStart': 0, 'pushEnd': 0, 'receiveHeadersEnd': 0.975}, 'protocol': 'h2', 'securityState': 'secure', 'securityDetails': {'protocol': 'TLS 1.2', 'keyExchange': 'ECDHE_RSA', 'keyExchangeGroup': 'X25519', 'cipher': 'AES_128_GCM', 'certificateId': 0, 'subjectName': 'www.python.org', 'sanList': ['www.python.org', 'docs.python.org', 'bugs.python.org', 'wiki.python.org', 'hg.python.org', 'mail.python.org', 'pypi.python.org', 'packaging.python.org', 'login.python.org', 'discuss.python.org', 'us.pycon.org', 'pypi.io', 'docs.pypi.io', 'pypi.org', 'docs.pypi.org', 'donate.pypi.org', 'devguide.python.org', 'www.bugs.python.org', 'python.org'], 'issuer': 'DigiCert SHA2 Extended Validation Server CA', 'validFrom': 1537228800, 'validTo': 1602676800, 'signedCertificateTimestampList': [], 'certificateTransparencyCompliance': 'unknown'}}, 'frameId': '882CFDEEA07EB00A5E7510ADD2A39F22'}}
                # response
                # {'id': 30, 'result': {'body': '<!doctype html>\n<!--[if lt IE 7]>   <html class="no-js ie6 lt-ie...', 'base64Encoded': False}}
                # test set_ua
                await tab.set_ua('Test UA')
                await tab.add_js_onload(source='window.title=123456789')
                await tab.set_url('http://httpbin.org/forms/post')
                assert (await tab.get_variable('window.title')) == 123456789
                html = await tab.get_html()
                assert 'Customer name:' in html
                # test double click some positions. test keyboard_send input
                rect = await tab.get_bounding_client_rect('[type="email"]')
                await tab.mouse_click(rect['left'], rect['top'], count=1)
                await tab.keyboard_send(text='1')
                await tab.keyboard_send(text='2')
                await tab.keyboard_send(text='3')
                await tab.mouse_click(rect['left'], rect['top'], count=2)
                selection = await tab.get_variable(
                    'window.getSelection().toString()')
                assert selection == '123'
                # test set_headers
                await tab.set_headers({'A': '1', 'B': '2'})
                await tab.set_url('http://httpbin.org/get')
                html = await tab.get_html()
                assert '"A": "1"' in html and '"B": "2"' in html
                # screenshot
                await tab.set_url('http://python.org')
                await tab.wait_loading(1)
                screen = await tab.screenshot()
                part = await tab.screenshot_element('.site-headline')
                assert screen
                assert part
                assert len(screen) > len(part)
                # draw
                await tab.set_url('https://awwapp.com/')
                await tab.wait_loading(1, timeout_stop_loading=True)
                await tab.mouse_click(5, 5)
                walker = await tab.mouse_drag_rel_chain(320, 145).move(50, 0, 0.2).move(
                    0, 50, 0.2).move(-50, 0, 0.2).move(0, -50, 0.2)
                await walker.move(50 * 1.414, 50 * 1.414, 0.2)
                # clear cache
                assert await tab.clear_browser_cache()
                # close tab
                await tab.close()
            # close_browser gracefully, I have no more need of chrome instance
            await chrome.close_browser()
            # await chrome.kill()
            sep = f'\n{"=" * 80}\n'
            logger.critical(
                f'{sep}Congratulations, all test cases passed.{sep}')


if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    loop.run_until_complete(test_examples())

[Sync] Simple Usage (Archived)

Sync utils will be hardly maintained, only for simple test usage.

No more new features to be developed.

Code

"""
Test normal usage of ichrome.

1. use `with` context for launching ChromeDaemon daemon process.
2. init Chrome for connecting with chrome background server.
3. Tab ops:
  3.1 create a new tab
  3.2 goto new url with tab.set_url, and will stop load for timeout.
  3.3 get cookies from url
  3.4 inject the jQuery lib by a static url.
  3.5 auto click ok from the alert dialog.
  3.6 remove `href` from the third `a` tag, which is selected by css path.
  3.7 remove all `href` from the `a` tag, which is selected by css path.
  3.8 use querySelectorAll to get the elements.
  3.9 Network crawling from the background ajax request.
  3.10 click some element by tab.click with css selector.
  3.11 show html source code of the tab
"""


def test_example():
    from ichrome import Chrome, ChromeDaemon, logger
    import re
    import json
    """Example for crawling a special background request."""

    # reset default logger level, such as DEBUG
    # import logging
    # logger.setLevel(logging.INFO)
    # launch the Chrome process and daemon process, will auto shutdown by 'with' expression.
    with ChromeDaemon(host="127.0.0.1", port=9222, max_deaths=1) as chromed:
        logger.info(chromed)
        # create connection to Chrome Devtools
        chrome = Chrome(host="127.0.0.1", port=9222, timeout=3, retry=1)
        # now create a new tab without url
        tab = chrome.new_tab()
        # reset the url to bing.com, if loading time more than 5 seconds, will stop loading.
        # if inject js success, will alert Vue
        tab.set_url(
            "https://www.bing.com/",
            referrer="https://www.github.com/",
            timeout=5)
        # get_cookies from url
        logger.info(tab.get_cookies("http://cn.bing.com"))
        # test inject_js, if success, will alert jQuery version info 3.3.1
        logger.info(
            tab.inject_js(
                "https://cdn.staticfile.org/jquery/3.3.1/jquery.min.js"))
        logger.info(
            tab.js("alert('jQuery inject success:' + jQuery.fn.jquery)"))
        tab.js(
            'alert("Check the links above disabled, and then input `test` to the input position.")'
        )
        # automate press accept for alert~
        tab.send("Page.handleJavaScriptDialog", accept=True)
        # remove href of the a tag.
        tab.click("#sc_hdu>li>a", index=3, action="removeAttribute('href')")
        # remove href of all the 'a' tag.
        tab.querySelectorAll(
            "#sc_hdu>li>a", index=None, action="removeAttribute('href')")
        # use querySelectorAll to get the elements.
        for i in tab.querySelectorAll("#sc_hdu>li"):
            logger.info("Tag: %s, id:%s, class:%s, text:%s" %
                        (i, i.get("id"), i.get("class"), i.text))
        # enable the Network function, otherwise will not recv Network request/response.
        logger.info(tab.send("Network.enable"))
        # here will block until input string "test" in the input position.
        # tab is waiting for the event Network.responseReceived which accord with the given filter_function.
        recv_string = tab.wait_event(
            "Network.responseReceived",
            filter_function=lambda r: re.search(r"&\w+=test", r or ""),
            wait_seconds=None,
        )
        # now catching the "Network.responseReceived" event string, load the json.
        recv_string = json.loads(recv_string)
        # get the requestId to fetch its response body.
        request_id = recv_string["params"]["requestId"]
        logger.info("requestId: %s" % request_id)
        # send request for getResponseBody
        resp = tab.send(
            "Network.getResponseBody", requestId=request_id, timeout=5)
        # now resp is the response body result.
        logger.info("getResponseBody success %s" % resp)
        # directly click the button matched the cssselector #sb_form_go, here is the submit button.
        logger.info(tab.click("#sb_form_go"))
        tab.wait_loading(3)
        # show some html source code of the tab
        logger.info(tab.html[:100])
        tab.send('Browser.close')
        # # now click close button of the chrome browser.
        # chromed.run_forever()


if __name__ == "__main__":
    test_example()

TODO

• Concurrent support. (gevent, threading, asyncio)
• Add auto_restart while crash.
• Auto remove the zombie tabs with a lifebook.
• Add some useful examples.
• Coroutine support (for asyncio).
• Standard test cases.
• HTTP apis server console [fastapi]. (maybe write a new lib)
• Complete document.

Documentary

• On the way...