Function removeContainer

src/spec-shutdown/dockerUtils.ts:173–213

(params: DockerCLIParameters | PartialExecParameters | DockerResolverParameters, nameOrId: string)

}

export async function removeContainer(params: DockerCLIParameters | PartialExecParameters | DockerResolverParameters, nameOrId: string) {
	const useEvents = !('cliVariant' in params && params.cliVariant === CLIVariant.Wslc);
	let eventsProcess: Exec | undefined;
	let removedSeenP: Promise<void> | undefined;
	try {
		for (let i = 0, n = 7; i < n; i++) {
			try {
				await dockerCLI(params, 'rm', '-f', nameOrId);
				return;
			} catch (err) {
				// https://github.com/microsoft/vscode-remote-release/issues/6509
				const stderr: string = err?.stderr?.toString().toLowerCase() || '';
				if (i === n - 1 || !stderr.includes('already in progress')) {
					throw err;
				}
				if (useEvents && !removedSeenP) {
					eventsProcess = await getEvents(params, {
						container: [nameOrId],
						event: ['destroy'],
					});
					removedSeenP = new Promise<void>(resolve => {
						eventsProcess!.stdout.on('data', () => {
							resolve();
							eventsProcess!.terminate();
							removedSeenP = new Promise(() => {}); // safeguard in case we see the 'removal already in progress' error again
						});
					});
				}
				if (removedSeenP) {
					await Promise.race([removedSeenP, delay(1000)]);
				} else {
					await delay(1000);
				}
			}
		}
	} finally {
		if (eventsProcess) {
			eventsProcess.terminate();
		}
	}
}

export async function getEvents(params: DockerCLIParameters | PartialExecParameters | DockerResolverParameters, filters?: Record<string, string[]>) {
	const { exec, cmd, args, env, output } = toExecParameters(params);