How to use _getDelayMsForRetry method in Cypress

1"use strict";
2Object.defineProperty(exports, "__esModule", { value: true });
3exports.getWsTargetFor = exports.getRemoteDebuggingPort = exports._connectAsync = exports._getDelayMsForRetry = void 0;
4const tslib_1 = require("tslib");
5const lodash_1 = (0, tslib_1.__importDefault)(require("lodash"));
6const chrome_remote_interface_1 = (0, tslib_1.__importDefault)(require("chrome-remote-interface"));
7const network_1 = require("../../../network");
8const bluebird_1 = (0, tslib_1.__importDefault)(require("bluebird"));
9const lazy_ass_1 = (0, tslib_1.__importDefault)(require("lazy-ass"));
10const debug_1 = (0, tslib_1.__importDefault)(require("debug"));
11const utils_1 = (0, tslib_1.__importDefault)(require("./utils"));
12const errors = require('../errors');
13const is = require('check-more-types');
14const debug = (0, debug_1.default)('cypress:server:browsers:protocol');
15function _getDelayMsForRetry(i, browserName) {
16    if (i < 10) {
17        return 100;
18    }
19    if (i < 18) {
20        return 500;
21    }
22    if (i < 63) { // after 5 seconds, begin logging and retrying
23        errors.warning('CDP_RETRYING_CONNECTION', i, browserName);
24        return 1000;
25    }
26    return;
27}
28exports._getDelayMsForRetry = _getDelayMsForRetry;
29function _connectAsync(opts) {
30    return bluebird_1.default.fromCallback((cb) => {
31        network_1.connect.createRetryingSocket(opts, cb);
32    })
33        .then((sock) => {
34        // can be closed, just needed to test the connection
35        sock.end();
36    });
37}
38exports._connectAsync = _connectAsync;
39/**
40 * Tries to find the starting page (probably blank tab)
41 * among all targets returned by CRI.List call.
42 *
43 * @returns {string} web socket debugger url
44 */
45const findStartPage = (targets) => {
46    debug('CRI List %o', { numTargets: targets.length, targets });
47    // activate the first available id
48    // find the first target page that's a real tab
49    // and not the dev tools or background page.
50    // since we open a blank page first, it has a special url
51    const newTabTargetFields = {
52        type: 'page',
53        url: 'about:blank',
54    };
55    const target = lodash_1.default.find(targets, newTabTargetFields);
56    (0, lazy_ass_1.default)(target, 'could not find CRI target');
57    debug('found CRI target %o', target);
58    return target.webSocketDebuggerUrl;
59};
60const findStartPageTarget = (connectOpts) => {
61    debug('CRI.List %o', connectOpts);
62    // what happens if the next call throws an error?
63    // it seems to leave the browser instance open
64    // need to clone connectOpts, CRI modifies it
65    return chrome_remote_interface_1.default.List(lodash_1.default.clone(connectOpts)).then(findStartPage);
66};
67function getRemoteDebuggingPort() {
68    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {
69        const port = Number(process.env.CYPRESS_REMOTE_DEBUGGING_PORT);
70        return port || utils_1.default.getPort();
71    });
72}
73exports.getRemoteDebuggingPort = getRemoteDebuggingPort;
74/**
75 * Waits for the port to respond with connection to Chrome Remote Interface
76 * @param {number} port Port number to connect to
77 * @param {string} browserName Browser name, for warning/error messages
78 */
79const getWsTargetFor = (port, browserName) => {
80    debug('Getting WS connection to CRI on port %d', port);
81    (0, lazy_ass_1.default)(is.port(port), 'expected port number', port);
82    let retryIndex = 0;
83    // force ipv4
84    // https://github.com/cypress-io/cypress/issues/5912
85    const connectOpts = {
86        host: '127.0.0.1',
87        port,
88        getDelayMsForRetry: (i) => {
89            retryIndex = i;
90            return _getDelayMsForRetry(i, browserName);
91        },
92    };
93    return _connectAsync(connectOpts)
94        .then(() => {
95        const retry = () => {
96            debug('attempting to find CRI target... %o', { retryIndex });
97            return findStartPageTarget(connectOpts)
98                .catch((err) => {
99                retryIndex++;
100                const delay = _getDelayMsForRetry(retryIndex, browserName);
101                debug('error finding CRI target, maybe retrying %o', { delay, err });
102                if (typeof delay === 'undefined') {
103                    throw err;
104                }
105                return bluebird_1.default.delay(delay)
106                    .then(retry);
107            });
108        };
109        return retry();
110    })
111        .catch((err) => {
112        debug('failed to connect to CDP %o', { connectOpts, err });
113        errors.throw('CDP_COULD_NOT_CONNECT', port, err, browserName);
114    });
115};
116exports.getWsTargetFor = getWsTargetFor;
117

Source: protocol.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.getWsTargetFor = exports.getRemoteDebuggingPort = exports._connectAsync = exports._getDelayMsForRetry = void 0;
const tslib_1 = require("tslib");
const lodash_1 = (0, tslib_1.__importDefault)(require("lodash"));
const chrome_remote_interface_1 = (0, tslib_1.__importDefault)(require("chrome-remote-interface"));
const network_1 = require("../../../network");
const bluebird_1 = (0, tslib_1.__importDefault)(require("bluebird"));
const lazy_ass_1 = (0, tslib_1.__importDefault)(require("lazy-ass"));
const debug_1 = (0, tslib_1.__importDefault)(require("debug"));
const utils_1 = (0, tslib_1.__importDefault)(require("./utils"));
const errors = require('../errors');
const is = require('check-more-types');
const debug = (0, debug_1.default)('cypress:server:browsers:protocol');
function _getDelayMsForRetry(i, browserName) {
    if (i < 10) {
        return 100;
    }
    if (i < 18) {
        return 500;
    }
    if (i < 63) { // after 5 seconds, begin logging and retrying
        errors.warning('CDP_RETRYING_CONNECTION', i, browserName);
        return 1000;
    }
    return;
}
exports._getDelayMsForRetry = _getDelayMsForRetry;
function _connectAsync(opts) {
    return bluebird_1.default.fromCallback((cb) => {
        network_1.connect.createRetryingSocket(opts, cb);
    })
        .then((sock) => {
        // can be closed, just needed to test the connection
        sock.end();
    });
}
exports._connectAsync = _connectAsync;
/**
 * Tries to find the starting page (probably blank tab)
 * among all targets returned by CRI.List call.
 *
 * @returns {string} web socket debugger url
 */
const findStartPage = (targets) => {
    debug('CRI List %o', { numTargets: targets.length, targets });
    // activate the first available id
    // find the first target page that's a real tab
    // and not the dev tools or background page.
    // since we open a blank page first, it has a special url
    const newTabTargetFields = {
        type: 'page',
        url: 'about:blank',
    };
    const target = lodash_1.default.find(targets, newTabTargetFields);
    (0, lazy_ass_1.default)(target, 'could not find CRI target');
    debug('found CRI target %o', target);
    return target.webSocketDebuggerUrl;
};
const findStartPageTarget = (connectOpts) => {
    debug('CRI.List %o', connectOpts);
    // what happens if the next call throws an error?
    // it seems to leave the browser instance open
    // need to clone connectOpts, CRI modifies it
    return chrome_remote_interface_1.default.List(lodash_1.default.clone(connectOpts)).then(findStartPage);
};
function getRemoteDebuggingPort() {
    return (0, tslib_1.__awaiter)(this, void 0, void 0, function* () {
        const port = Number(process.env.CYPRESS_REMOTE_DEBUGGING_PORT);
        return port || utils_1.default.getPort();
    });
}
exports.getRemoteDebuggingPort = getRemoteDebuggingPort;
/**
 * Waits for the port to respond with connection to Chrome Remote Interface
 * @param {number} port Port number to connect to
 * @param {string} browserName Browser name, for warning/error messages
 */
const getWsTargetFor = (port, browserName) => {
    debug('Getting WS connection to CRI on port %d', port);
    (0, lazy_ass_1.default)(is.port(port), 'expected port number', port);
    let retryIndex = 0;
    // force ipv4
    // https://github.com/cypress-io/cypress/issues/5912
    const connectOpts = {
        host: '127.0.0.1',
        port,
        getDelayMsForRetry: (i) => {
            retryIndex = i;
            return _getDelayMsForRetry(i, browserName);
        },
    };
    return _connectAsync(connectOpts)
        .then(() => {
        const retry = () => {
            debug('attempting to find CRI target... %o', { retryIndex });
            return findStartPageTarget(connectOpts)
                .catch((err) => {
                retryIndex++;
                const delay = _getDelayMsForRetry(retryIndex, browserName);
                debug('error finding CRI target, maybe retrying %o', { delay, err });
                if (typeof delay === 'undefined') {
                    throw err;
                }
                return bluebird_1.default.delay(delay)
                    .then(retry);
            });
        };
        return retry();
    })
        .catch((err) => {
        debug('failed to connect to CDP %o', { connectOpts, err });
        errors.throw('CDP_COULD_NOT_CONNECT', port, err, browserName);
    });
};
exports.getWsTargetFor = getWsTargetFor;