=> {
+ if (browserClosed) {
+ return;
+ }
+
+ await browser.deleteSession();
+ browserClosed = true;
+ };
+
let loginState: SaveStateData;
let status: WebdriverIO.Element;
const mockAuthServer = new AuthServer();
@@ -52,6 +62,8 @@ const removeDomainFromCookies = (loginState: SaveStateData): void => {
isolation,
});
+ browserClosed = false;
+
assert.ok(browser, "Browser should be initialized");
assert.ok(browser.sessionId, "Browser should have a valid session ID");
@@ -77,6 +89,10 @@ const removeDomainFromCookies = (loginState: SaveStateData): void => {
const logInButton = await browser.$('[type="submit"]');
await logInButton.click();
+ await browser.waitUntil(async () => (await status.getText()) === "You are logged in", {
+ timeoutMsg: "Login should complete before saving browser state",
+ });
+
// save state
loginState = await browser.saveState();
@@ -90,7 +106,7 @@ const removeDomainFromCookies = (loginState: SaveStateData): void => {
path: "./state.json",
});
- await browser.deleteSession();
+ await closeBrowser();
const fileExist = fs.existsSync("./state.json");
assert.strictEqual(fileExist, true);
@@ -103,7 +119,7 @@ const removeDomainFromCookies = (loginState: SaveStateData): void => {
path: "./state.json",
});
- await browser.deleteSession();
+ await closeBrowser();
const fileExist = fs.existsSync("./state.json");
assert.strictEqual(fileExist, false);
@@ -118,7 +134,7 @@ const removeDomainFromCookies = (loginState: SaveStateData): void => {
sessionStorage: false,
});
- await browser.deleteSession();
+ await closeBrowser();
const fileExist = fs.existsSync("./state.json");
assert.strictEqual(fileExist, false);
@@ -172,11 +188,9 @@ const removeDomainFromCookies = (loginState: SaveStateData): void => {
assert.ok(state.cookies?.length === 0);
});
- afterEach(async () => {
- if (browser) {
- await browser.deleteSession();
- }
- });
+ // Some tests close the session themselves to check file cleanup.
+ // Do not send another DELETE to an already stopped driver.
+ afterEach(closeBrowser);
after(async () => {
console.log("Stop mock server");
diff --git a/test/integration/standalone/standalone.test.ts b/test/integration/standalone/standalone.test.ts
index 44b13397c..55c934362 100644
--- a/test/integration/standalone/standalone.test.ts
+++ b/test/integration/standalone/standalone.test.ts
@@ -1,4 +1,7 @@
import { strict as assert } from "assert";
+import http from "node:http";
+import { once } from "node:events";
+import type { AddressInfo } from "node:net";
import { launchBrowser, attachToBrowser } from "../../../src/browser/standalone";
import { BROWSER_CONFIG } from "./constants";
@@ -24,13 +27,34 @@ describe("Standalone Browser E2E Tests", function () {
let browser: WebdriverIO.Browser & { getDriverPid?: () => number | undefined };
+ let pageUrl: string;
+ const server = http.createServer((_req, res) => {
+ res.writeHead(200, { "content-type": "text/html; charset=utf-8" });
+ res.end(`Example Domain
+ Example Domain
+ This domain is for use in documentation examples without needing permission.
+ `);
+ });
+
+ before(async () => {
+ server.listen(0, "127.0.0.1");
+ await once(server, "listening");
+ pageUrl = `http://127.0.0.1:${(server.address() as AddressInfo).port}`;
+ });
+
+ after(async () => {
+ await new Promise((resolve, reject) => {
+ server.close(error => (error ? reject(error) : resolve()));
+ });
+ });
+
it("should launch browser and access a website", async function () {
browser = await launchBrowser(BROWSER_CONFIG);
assert.ok(browser, "Browser should be initialized");
assert.ok(browser.sessionId, "Browser should have a valid session ID");
- await browser.url("https://example.com");
+ await browser.url(pageUrl);
const title = await browser.getTitle();
assert.strictEqual(title, "Example Domain", "Page title should match");
@@ -42,7 +66,7 @@ describe("Standalone Browser E2E Tests", function () {
it("should execute JavaScript in the browser", async function () {
assert.ok(browser, "Browser should be available from previous test");
- await browser.url("https://example.com");
+ await browser.url(pageUrl);
const result = await browser.execute(() => {
// This code runs in the browser
@@ -58,7 +82,7 @@ describe("Standalone Browser E2E Tests", function () {
it("should take screenshots", async function () {
assert.ok(browser, "Browser should be available from previous test");
- await browser.url("https://example.com");
+ await browser.url(pageUrl);
const screenshotBuffer = await browser.takeScreenshot();
assert.ok(screenshotBuffer, "Should be able to take a screenshot");
@@ -69,7 +93,7 @@ describe("Standalone Browser E2E Tests", function () {
it("attach to browser works", async function () {
browser = await launchBrowser(BROWSER_CONFIG);
- await browser.url("https://example.com");
+ await browser.url(pageUrl);
const driverPid = (await browser.getDriverPid!()) as number;
const attachedBrowser = await attachToBrowser({
@@ -82,12 +106,12 @@ describe("Standalone Browser E2E Tests", function () {
driverPid,
});
- await attachedBrowser.url("https://yandex.com/");
+ await attachedBrowser.url(`${pageUrl}/attached`);
const url = await browser.getUrl();
// Check that change url in attached browser change url in original browser
- assert.strictEqual(url, "https://yandex.com/");
+ assert.strictEqual(url, `${pageUrl}/attached`);
// Check that browser process exist
assert.strictEqual(checkProcessExists(driverPid), true);
diff --git a/test/src/browser/client-scripts/build.ts b/test/src/browser/client-scripts/build.ts
index 7cb60edd5..2c5b2da67 100644
--- a/test/src/browser/client-scripts/build.ts
+++ b/test/src/browser/client-scripts/build.ts
@@ -1,8 +1,10 @@
-import sinon, { type SinonSpy, type SinonStub } from "sinon";
-import browserify from "browserify";
+import sinon, { type SinonStub } from "sinon";
+import { parse } from "@babel/parser";
import path from "path";
import fs from "fs-extra";
+type AstNode = { type: string; [key: string]: unknown };
+
describe("client-scripts/build", () => {
const sandbox = sinon.createSandbox();
const targetDir = path.resolve(process.cwd(), "src", "browser", "client-scripts", "browser-utils");
@@ -10,12 +12,10 @@ describe("client-scripts/build", () => {
let ensureDirStub: SinonStub;
let writeFileStub: SinonStub;
- let transformSpy: SinonSpy;
beforeEach(() => {
ensureDirStub = sandbox.stub(fs, "ensureDir").resolves();
writeFileStub = sandbox.stub(fs, "writeFile").resolves();
- transformSpy = sandbox.spy(browserify.prototype, "transform");
});
afterEach(() => sandbox.restore());
@@ -36,25 +36,58 @@ describe("client-scripts/build", () => {
};
const assertForNativeLibrary_ = (): void => {
- assert.calledWithMatch(transformSpy, {
- aliases: {
- "@lib": "./src/browser/client-scripts/browser-utils/tsc-out/client-scripts/shared/lib.native.js",
- },
- verbose: false,
- });
assert.calledWith(ensureDirStub, buildDir);
- assert.calledWith(writeFileStub, path.join(buildDir, "bundle.native.js"), sinon.match.string);
+ assert.calledWith(
+ writeFileStub,
+ path.join(buildDir, "bundle.native.js"),
+ sinon.match(
+ (value: string) =>
+ value.startsWith("(function (__geminiNamespace) {") && value.endsWith(")(arguments[0])"),
+ ),
+ );
};
const assertForCompatLibrary_ = (): void => {
- assert.calledWithMatch(transformSpy, {
- aliases: {
- "@lib": "./src/browser/client-scripts/browser-utils/tsc-out/client-scripts/shared/lib.compat.js",
- },
- verbose: false,
- });
assert.calledWith(ensureDirStub, buildDir);
- assert.calledWith(writeFileStub, path.join(buildDir, "bundle.compat.js"), sinon.match.string);
+ assert.calledWith(
+ writeFileStub,
+ path.join(buildDir, "bundle.compat.js"),
+ sinon.match((value: string) => {
+ if (!value.startsWith("(function (__geminiNamespace) {") || !value.endsWith(")(arguments[0])")) {
+ return false;
+ }
+
+ const ast = parse(value, { sourceType: "script" });
+ const nodes = [ast.program as unknown as AstNode];
+
+ while (nodes.length) {
+ const node = nodes.pop() as AstNode;
+
+ if (
+ node.type === "ArrowFunctionExpression" ||
+ node.type === "ClassDeclaration" ||
+ node.type === "ClassExpression" ||
+ (node.type === "VariableDeclaration" && node.kind !== "var")
+ ) {
+ return false;
+ }
+
+ for (const value of Object.values(node)) {
+ if (Array.isArray(value)) {
+ nodes.push(
+ ...value.filter((item): item is AstNode =>
+ Boolean(item && typeof item === "object" && item.type),
+ ),
+ );
+ } else if (value && typeof value === "object" && "type" in value) {
+ nodes.push(value as AstNode);
+ }
+ }
+ }
+
+ return true;
+ }),
+ );
};
it("should build bundles for compat and native library", async function () {
diff --git a/test/src/browser/existing-browser.js b/test/src/browser/existing-browser.js
index a6cbb730a..65a228c96 100644
--- a/test/src/browser/existing-browser.js
+++ b/test/src/browser/existing-browser.js
@@ -3,7 +3,6 @@
const { EventEmitter } = require("events");
const crypto = require("crypto");
const _ = require("lodash");
-const jsdom = require("jsdom-global");
const { Calibrator } = require("src/browser/calibrator");
const { Camera } = require("src/browser/camera");
const history = require("src/browser/history");
@@ -917,16 +916,24 @@ describe("ExistingBrowser", () => {
});
describe("scrollBy", () => {
- let cleanupJsdom;
+ let originalGlobals;
beforeEach(() => {
- cleanupJsdom = jsdom();
- global.window.scrollTo = sinon.stub();
- global.document.querySelector = sinon.stub();
+ originalGlobals = Object.fromEntries(
+ ["window", "document"].map(key => [key, Object.getOwnPropertyDescriptor(global, key)]),
+ );
+ global.window = { scrollTo: sinon.stub() };
+ global.document = { querySelector: sinon.stub() };
});
afterEach(() => {
- cleanupJsdom();
+ for (const [key, descriptor] of Object.entries(originalGlobals)) {
+ if (descriptor) {
+ Object.defineProperty(global, key, descriptor);
+ } else {
+ delete global[key];
+ }
+ }
});
it("should throw error if passed selector is not found", async () => {
diff --git a/test/src/browser/new-browser.ts b/test/src/browser/new-browser.ts
index 0ec2deb8a..6eb26f4c1 100644
--- a/test/src/browser/new-browser.ts
+++ b/test/src/browser/new-browser.ts
@@ -56,6 +56,27 @@ describe("NewBrowser", () => {
afterEach(() => sandbox.restore());
describe("constructor", () => {
+ it("should leave BiDi dialogs to the attached execution browser", async () => {
+ session.isBidi = true;
+ session.on = sandbox.stub();
+
+ await mkBrowser_().init();
+
+ assert.calledOnceWith(session.on, "dialog", sinon.match.func);
+ const dialog = { dismiss: sandbox.stub(), accept: sandbox.stub() };
+ session.on.firstCall.args[1](dialog);
+ assert.notCalled(dialog.dismiss);
+ assert.notCalled(dialog.accept);
+ });
+
+ it("should not add a dialog observer to a Classic session", async () => {
+ session.on = sandbox.stub();
+
+ await mkBrowser_().init();
+
+ assert.notCalled(session.on);
+ });
+
it("should create session with properties from browser config", async () => {
await mkBrowser_().init();
diff --git a/test/src/runner/browser-env/vite/server.ts b/test/src/runner/browser-env/vite/server.ts
index 6828e9241..217bdb570 100644
--- a/test/src/runner/browser-env/vite/server.ts
+++ b/test/src/runner/browser-env/vite/server.ts
@@ -1,7 +1,7 @@
import path from "node:path";
import proxyquire from "proxyquire";
import sinon, { type SinonStub } from "sinon";
-import Vite from "vite";
+import type Vite from "vite";
import chalk from "chalk";
import { ViteServer } from "../../../../../src/runner/browser-env/vite/server";
@@ -18,6 +18,7 @@ import type { BrowserTestRunEnvOptions } from "../../../../../src/runner/browser
describe("runner/browser-env/vite/server", () => {
const sandbox = sinon.createSandbox();
let ViteServerStub: typeof ViteServer;
+ let createViteServerStub: SinonStub;
let getPortStub: SinonStub;
let createSocketServer: SinonStub;
let generateIndexHtmlPlugin: () => Vite.Plugin[];
@@ -46,7 +47,7 @@ describe("runner/browser-env/vite/server", () => {
};
beforeEach(() => {
- sandbox.stub(Vite, "createServer").resolves(mkViteServer_());
+ createViteServerStub = sandbox.stub().resolves(mkViteServer_());
loggerLogStub = sandbox.stub();
createSocketServer = sandbox.stub();
@@ -58,6 +59,7 @@ describe("runner/browser-env/vite/server", () => {
sandbox.stub(RuntimeConfig, "getInstance").returns({ extend: sandbox.stub() });
({ ViteServer: ViteServerStub } = proxyquire("../../../../../src/runner/browser-env/vite/server", {
+ vite: { createServer: createViteServerStub },
"get-port": getPortStub,
"./socket": { createSocketServer },
"./plugins/generate-index-html": { plugin: generateIndexHtmlPlugin },
@@ -76,33 +78,33 @@ describe("runner/browser-env/vite/server", () => {
it("on localhost", async () => {
await ViteServerStub.create(mkConfig_()).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ server: { host: "localhost" } }));
+ assert.calledOnceWith(createViteServerStub, sinon.match({ server: { host: "localhost" } }));
});
it("allows runtime modules from the Testplane package root", async () => {
await ViteServerStub.create(mkConfig_()).start();
- const viteConfig = (Vite.createServer as SinonStub).firstCall.args[0] as Vite.InlineConfig;
+ const viteConfig = createViteServerStub.firstCall.args[0] as Vite.InlineConfig;
assert.include(viteConfig.server?.fs?.allow ?? [], path.resolve(__dirname, "../../../../.."));
});
it("without config file", async () => {
await ViteServerStub.create(mkConfig_()).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ configFile: false }));
+ assert.calledOnceWith(createViteServerStub, sinon.match({ configFile: false }));
});
it("with inlined source map", async () => {
await ViteServerStub.create(mkConfig_()).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ build: { sourcemap: "inline" } }));
+ assert.calledOnceWith(createViteServerStub, sinon.match({ build: { sourcemap: "inline" } }));
});
it("with silent log level", async () => {
await ViteServerStub.create(mkConfig_()).start();
assert.calledOnceWith(
- Vite.createServer,
+ createViteServerStub,
sinon.match({
logLevel: "silent",
optimizeDeps: {
@@ -114,12 +116,25 @@ describe("runner/browser-env/vite/server", () => {
);
});
+ it("with required CommonJS dependencies pre-bundled", async () => {
+ await ViteServerStub.create(mkConfig_()).start();
+
+ assert.calledOnceWith(
+ createViteServerStub,
+ sinon.match({
+ optimizeDeps: {
+ include: sinon.match.array.contains(["expect", "debug"]),
+ },
+ }),
+ );
+ });
+
it("with generated port", async () => {
getPortStub.resolves(98765);
await ViteServerStub.create(mkConfig_()).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ server: { port: 98765 } }));
+ assert.calledOnceWith(createViteServerStub, sinon.match({ server: { port: 98765 } }));
});
});
@@ -129,7 +144,10 @@ describe("runner/browser-env/vite/server", () => {
await ViteServerStub.create(config).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ server: { host: "0.0.0.0", port: 4000 } }));
+ assert.calledOnceWith(
+ createViteServerStub,
+ sinon.match({ server: { host: "0.0.0.0", port: 4000 } }),
+ );
});
});
@@ -148,7 +166,10 @@ describe("runner/browser-env/vite/server", () => {
await ViteServerStub.create(config).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ server: { host: "1.1.1.1", port: 5000 } }));
+ assert.calledOnceWith(
+ createViteServerStub,
+ sinon.match({ server: { host: "1.1.1.1", port: 5000 } }),
+ );
});
});
@@ -161,7 +182,10 @@ describe("runner/browser-env/vite/server", () => {
await ViteServerStub.create(config).start();
- assert.calledOnceWith(Vite.createServer, sinon.match({ server: { host: "2.2.2.2", port: 6000 } }));
+ assert.calledOnceWith(
+ createViteServerStub,
+ sinon.match({ server: { host: "2.2.2.2", port: 6000 } }),
+ );
});
});
@@ -176,7 +200,7 @@ describe("runner/browser-env/vite/server", () => {
await ViteServerStub.create(config).start();
assert.calledOnceWith(
- Vite.createServer,
+ createViteServerStub,
sinon.match({
plugins: [
{ name: "user-plugin-1" },
@@ -215,7 +239,7 @@ describe("runner/browser-env/vite/server", () => {
it("should create socket server", async () => {
const viteServer = mkViteServer_();
- (Vite.createServer as SinonStub).resolves(viteServer);
+ createViteServerStub.resolves(viteServer);
await ViteServerStub.create(mkConfig_()).start();
@@ -224,7 +248,7 @@ describe("runner/browser-env/vite/server", () => {
it("should create socket server before listening vite server", async () => {
const viteServer = mkViteServer_();
- (Vite.createServer as SinonStub).resolves(viteServer);
+ createViteServerStub.resolves(viteServer);
await ViteServerStub.create(mkConfig_()).start();
@@ -239,7 +263,7 @@ describe("runner/browser-env/vite/server", () => {
network: [],
},
});
- (Vite.createServer as SinonStub).resolves(viteServer);
+ createViteServerStub.resolves(viteServer);
await ViteServerStub.create(mkConfig_()).start();
@@ -256,7 +280,7 @@ describe("runner/browser-env/vite/server", () => {
network: [],
},
});
- (Vite.createServer as SinonStub).resolves(viteServer);
+ createViteServerStub.resolves(viteServer);
const config = makeConfigStub({
baseUrl: defaults.baseUrl,
@@ -277,7 +301,7 @@ describe("runner/browser-env/vite/server", () => {
network: [],
},
});
- (Vite.createServer as SinonStub).resolves(viteServer);
+ createViteServerStub.resolves(viteServer);
await ViteServerStub.create(mkConfig_()).start();
@@ -288,7 +312,7 @@ describe("runner/browser-env/vite/server", () => {
describe("close", () => {
it("should close server", async () => {
const viteServer = mkViteServer_();
- (Vite.createServer as SinonStub).resolves(viteServer);
+ createViteServerStub.resolves(viteServer);
const viteServerWrapper = ViteServerStub.create(mkConfig_());
await viteServerWrapper.start();
diff --git a/test/src/test-reader/mocha-reader/index.js b/test/src/test-reader/mocha-reader/index.js
index 705936d35..9318ef0f9 100644
--- a/test/src/test-reader/mocha-reader/index.js
+++ b/test/src/test-reader/mocha-reader/index.js
@@ -7,7 +7,7 @@ const { TreeBuilder } = require("src/test-reader/tree-builder");
const { Test } = require("src/test-reader/test-object");
const { TestReaderEvents: ReadEvents } = require("src/events");
const { MasterEvents: RunnerEvents } = require("src/events");
-const Mocha = require("mocha");
+const { Mocha } = require("mocha");
const proxyquire = require("proxyquire").noCallThru();
const { EventEmitter } = require("events");
@@ -54,7 +54,7 @@ describe("test-reader/mocha-reader", () => {
loggerWarnStub = sinon.stub();
readFiles = proxyquire("src/test-reader/mocha-reader", {
- mocha: MochaConstructorStub,
+ mocha: { Mocha: MochaConstructorStub },
"@cspotcode/source-map-support": SourceMapSupportStub,
"./utils": { getMethodsByInterface: getMethodsByInterfaceStub },
"../../utils/typescript": { enableSourceMaps: enableSourceMapsStub },
diff --git a/test/src/testplane.js b/test/src/testplane.js
index ab7762406..cd61c454a 100644
--- a/test/src/testplane.js
+++ b/test/src/testplane.js
@@ -23,7 +23,7 @@ const { promiseDelay } = require("../../src/utils/promise");
describe("testplane", () => {
const sandbox = sinon.createSandbox();
- let Testplane, initReporters, signalHandler, loggerWarnStub, loggerErrorStub;
+ let Testplane, initReporters, signalHandler, loggerWarnStub, loggerErrorStub, preloadWebdriverIO;
const mkTestplane_ = async config => {
Config.create.resolves(config || makeConfigStub());
@@ -51,6 +51,7 @@ describe("testplane", () => {
sandbox.stub(fs, "outputJSON").resolves();
initReporters = sandbox.stub().resolves();
+ preloadWebdriverIO = sandbox.stub().resolves();
signalHandler = new AsyncEmitter();
loggerWarnStub = sandbox.stub();
@@ -62,6 +63,7 @@ describe("testplane", () => {
Testplane = proxyquire("src/testplane", {
"./reporters": { initReporters },
+ "./utils/preload-utils": { preloadWebdriverIO },
"./signal-handler": signalHandler,
"./utils/logger": {
warn: loggerWarnStub,
@@ -425,6 +427,22 @@ describe("testplane", () => {
return runTestplane().then(() => assert.calledOnce(MainRunner.prototype.run));
});
+ it("should finish preloading WebdriverIO before running tests", async () => {
+ const runner = mkRunner_();
+ const preloadCompleted = sandbox.spy();
+ preloadWebdriverIO.callsFake(async () => {
+ await new Promise(resolve => setImmediate(resolve));
+ preloadCompleted();
+ });
+
+ await runTestplane();
+ await preloadWebdriverIO.firstCall.returnValue;
+
+ assert.calledOnce(preloadWebdriverIO);
+ assert.calledOnce(runner.run);
+ assert.callOrder(preloadCompleted, runner.run);
+ });
+
it("should use read tests", async () => {
mkRunner_();
diff --git a/test/src/utils/processor.js b/test/src/utils/processor.js
new file mode 100644
index 000000000..92defe825
--- /dev/null
+++ b/test/src/utils/processor.js
@@ -0,0 +1,91 @@
+"use strict";
+
+const proxyquire = require("proxyquire");
+
+describe("utils/processor", () => {
+ const sandbox = sinon.createSandbox();
+ let processor, webdriverReady, mochaReady, preloadWebdriverIO, preloadMochaReader, run, callback;
+
+ const deferred = () => {
+ let resolve;
+ const promise = new Promise(done => {
+ resolve = done;
+ });
+ return { promise, resolve };
+ };
+
+ beforeEach(() => {
+ webdriverReady = deferred();
+ mochaReady = deferred();
+ preloadWebdriverIO = sandbox.stub().returns(webdriverReady.promise);
+ preloadMochaReader = sandbox.stub().returns(mochaReady.promise);
+ run = sandbox.stub().returns("result");
+ callback = sandbox.spy();
+ sandbox.stub(process, "on");
+
+ processor = proxyquire.noCallThru().load("src/utils/processor", {
+ "./preload-utils.js": { preloadWebdriverIO, preloadMochaReader },
+ "worker-module": { run },
+ });
+ });
+
+ afterEach(() => sandbox.restore());
+
+ it("should finish preloading WebdriverIO before importing the Mocha reader", async () => {
+ assert.calledOnce(preloadWebdriverIO);
+ assert.notCalled(preloadMochaReader);
+
+ webdriverReady.resolve();
+ await webdriverReady.promise;
+
+ assert.calledOnce(preloadMochaReader);
+ });
+
+ it("should wait for both preloads before reporting the worker module as loaded", async () => {
+ const loading = processor.loadModule("worker-module", callback);
+ assert.notCalled(callback);
+
+ webdriverReady.resolve();
+ await webdriverReady.promise;
+ assert.notCalled(callback);
+
+ mochaReady.resolve();
+ await loading;
+
+ assert.calledOnceWithExactly(callback, null);
+ });
+
+ it("should wait for both preloads before executing a worker method", async () => {
+ const executing = processor.execute("worker-module", "run", ["argument"], callback);
+ assert.notCalled(run);
+ assert.notCalled(callback);
+
+ webdriverReady.resolve();
+ await webdriverReady.promise;
+ assert.notCalled(run);
+ assert.notCalled(callback);
+
+ mochaReady.resolve();
+ await executing;
+
+ assert.calledOnceWithExactly(run, "argument");
+ assert.calledOnceWithExactly(callback, null, "result");
+ });
+
+ it("should share preload completion between concurrent worker requests", async () => {
+ const loaded = sandbox.spy();
+ const loading = processor.loadModule("worker-module", loaded);
+ const executing = processor.execute("worker-module", "run", [], callback);
+ assert.notCalled(loaded);
+ assert.notCalled(run);
+
+ webdriverReady.resolve();
+ mochaReady.resolve();
+ await Promise.all([loading, executing]);
+
+ assert.calledOnce(preloadWebdriverIO);
+ assert.calledOnce(preloadMochaReader);
+ assert.calledOnceWithExactly(loaded, null);
+ assert.calledOnceWithExactly(callback, null, "result");
+ });
+});