fix: createDevice race condition

Creating a second device would terminate the second device correctly, then delete the old one from the map, causing it to be leaked and go missing

Co-authored-by: Johan Nyman <[email protected]>

packages/timeline-state-resolver/src/conductor.ts

@@ -418,8 +418,8 @@ export class Conductor extends EventEmitter<ConductorEvents> {
 		options?: { signal?: AbortSignal }
 	): Promise<DeviceContainer<DeviceOptionsBase<any>>> {
 		let newDevice: DeviceContainer<DeviceOptionsBase<any>> | undefined
-		const throwIfAborted = () => this.throwIfAborted(options?.signal, deviceId, 'creation')
 		try {
+			const throwIfAborted = () => this.throwIfAborted(options?.signal, deviceId, 'creation')
 			if (this.devices.has(deviceId)) {
 				throw new Error(`Device "${deviceId}" already exists when creating device`)
 			}
@@ -441,7 +441,7 @@ export class Conductor extends EventEmitter<ConductorEvents> {
 
 			if (!newDevicePromise) {
 				const type: any = deviceOptions.type
-				return Promise.reject(`No matching device type for "${type}" ("${DeviceType[type]}") found in conductor`)
+				throw new Error(`No matching device type for "${type}" ("${DeviceType[type]}") found in conductor`)
 			}
 
 			newDevice = await makeImmediatelyAbortable(async () => {
@@ -466,15 +466,16 @@ export class Conductor extends EventEmitter<ConductorEvents> {
 				throw new Error(`Device "${deviceId}" already exists when creating device`)
 			}
 			throwIfAborted()
-			this.devices.set(deviceId, newDevice)
-
-			return newDevice
 		} catch (e) {
 			await this.terminateUnwantedDevice(newDevice)
-			this.devices.delete(deviceId)
+
 			this.emit('error', 'conductor.createDevice', e)
-			return Promise.reject(e)
+			throw e
 		}
+
+		this.devices.set(deviceId, newDevice)
+
+		return newDevice
 	}
 
 	private throwIfAborted(signal: AbortSignal | undefined, deviceId: string, action: string) {