Add temporary AVA patch

See avajs/ava#3151.

Author: codetheweb

package.json

@@ -80,6 +80,7 @@
     "nanoid": "3.2.0",
     "nock": "13.2.7",
     "p-event": "4.2.0",
+    "patch-package": "6.5.1",
     "pgknexlove": "1.1.21",
     "pkg": "5.5.2",
     "playwright": "1.19.2",
@@ -106,6 +107,7 @@
   "scripts": {
     "prepare": "husky install",
     "prepack": "npm run build && npm run pack:cli",
+    "postinstall": "patch-package",
     "build:package": "tsup",
     "build:docs": "typedoc",
     "build:json-response-schemas": "ts-json-schema-generator --path src/types/route-responses.ts -o src/types/route-responses.generated.json && ts-json-schema-generator --path src/types/models.ts -o src/types/models.generated.json",

patches/ava+5.1.0.patch

@@ -0,0 +1,99 @@
+diff --git a/node_modules/ava/lib/plugin-support/shared-workers.js b/node_modules/ava/lib/plugin-support/shared-workers.js
+index 94030ce..2d65454 100644
+--- a/node_modules/ava/lib/plugin-support/shared-workers.js
++++ b/node_modules/ava/lib/plugin-support/shared-workers.js
+@@ -49,35 +49,54 @@ function launchWorker(filename, initialData) {
+ }
+ 
+ export async function observeWorkerProcess(fork, runStatus) {
+-	let registrationCount = 0;
+-	let signalDeregistered;
+-	const deregistered = new Promise(resolve => {
+-		signalDeregistered = resolve;
++	let signalDone;
++
++	const done = new Promise(resolve => {
++		signalDone = () => {
++			resolve();
++		};
+ 	});
+ 
+-	fork.promise.finally(() => {
+-		if (registrationCount === 0) {
+-			signalDeregistered();
++	const activeInstances = new Set();
++
++	const removeInstance = instance => {
++		instance.worker.unref();
++		activeInstances.delete(instance);
++
++		if (activeInstances.size === 0) {
++			signalDone();
++		}
++	};
++
++	const removeAllInstances = () => {
++		if (activeInstances.size === 0) {
++			signalDone();
++			return;
+ 		}
++
++		for (const instance of activeInstances) {
++			removeInstance(instance);
++		}
++	};
++
++	fork.promise.finally(() => {
++		removeAllInstances();
+ 	});
+ 
+ 	fork.onConnectSharedWorker(async ({filename, initialData, port, signalError}) => {
+ 		const launched = launchWorker(filename, initialData);
++		activeInstances.add(launched);
+ 
+ 		const handleWorkerMessage = async message => {
+ 			if (message.type === 'deregistered-test-worker' && message.id === fork.threadId) {
+ 				launched.worker.off('message', handleWorkerMessage);
+-
+-				registrationCount--;
+-				if (registrationCount === 0) {
+-					signalDeregistered();
+-				}
++				removeInstance(launched);
+ 			}
+ 		};
+ 
+ 		launched.statePromises.error.then(error => {
+-			signalDeregistered();
+ 			launched.worker.off('message', handleWorkerMessage);
++			removeAllInstances();
+ 			runStatus.emitStateChange({type: 'shared-worker-error', err: serializeError('Shared worker error', true, error)});
+ 			signalError();
+ 		});
+@@ -85,8 +104,6 @@ export async function observeWorkerProcess(fork, runStatus) {
+ 		try {
+ 			await launched.statePromises.available;
+ 
+-			registrationCount++;
+-
+ 			port.postMessage({type: 'ready'});
+ 
+ 			launched.worker.postMessage({
+@@ -104,15 +121,8 @@ export async function observeWorkerProcess(fork, runStatus) {
+ 			});
+ 
+ 			launched.worker.on('message', handleWorkerMessage);
+-		} catch {
+-			return;
+-		} finally {
+-			// Attaching listeners has the side-effect of referencing the worker.
+-			// Explicitly unreference it now so it does not prevent the main process
+-			// from exiting.
+-			launched.worker.unref();
+-		}
++		} catch {}
+ 	});
+ 
+-	return deregistered;
++	return done;
+ }