Function startEventSeenPolling

src/spec-node/utils.ts:217–244

(params: DockerResolverParameters, labels: Record<string, string>, canceled: Promise<void>, output: Log, trace: boolean)

// Polling-based fallback for runtimes that don't support `events` (e.g., wslc).
function startEventSeenPolling(params: DockerResolverParameters, labels: Record<string, string>, canceled: Promise<void>, output: Log, trace: boolean) {
	let stopped = false;
	canceled.catch(() => { stopped = true; });
	const labelFilters = Object.entries(labels).map(([k, v]) => `${k}=${v}`);
	return {
		started: new Promise<void>((resolve, reject) => {
			canceled.catch(reject);
			const poll = async () => {
				while (!stopped) {
					try {
						const containers = await listContainers(params, false, labelFilters);
						if (trace) {
							output.write(`Log: startEventSeenPolling found ${containers.length} container(s)\r\n`);
						}
						if (containers.length > 0) {
							resolve();
							return;
						}
					} catch (e) {
						// Ignore transient errors during polling.
					}
					await delay(500);
				}
			};
			poll();
		})
	};
}

async function hasLabels(params: DockerResolverParameters, info: any, expectedLabels: Record<string, string>) {
	const actualLabels = info.Actor?.Attributes