Function onExtensionMessage

apps/cli/src/commands/cli/stdin-stream.ts:445–567

(message: {
		type?: string
		text?: unknown
		state?: {
			currentTaskId?: unknown
			currentTaskItem?: { id?: unknown }
			messageQueue?: unknown
		}
	})

	})

	const onExtensionMessage = (message: {
		type?: string
		text?: unknown
		state?: {
			currentTaskId?: unknown
			currentTaskItem?: { id?: unknown }
			messageQueue?: unknown
		}
	}) => {
		if (message.type === "commandExecutionStatus") {
			if (typeof message.text !== "string") {
				return
			}

			let parsedStatus: unknown
			try {
				parsedStatus = JSON.parse(message.text)
			} catch {
				return
			}

			if (!isRecord(parsedStatus) || typeof parsedStatus.status !== "string") {
				return
			}

			if (parsedStatus.status === "output" && typeof parsedStatus.output === "string") {
				jsonEmitter.emitCommandOutputChunk(parsedStatus.output)
				return
			}

			if (parsedStatus.status === "exited") {
				const exitCode =
					parsedStatus.status === "exited" && typeof parsedStatus.exitCode === "number"
						? parsedStatus.exitCode
						: undefined

				if (typeof parsedStatus.output === "string") {
					jsonEmitter.emitCommandOutputChunk(parsedStatus.output)
				}

				jsonEmitter.markCommandOutputExited(exitCode)
				return
			}

			if (parsedStatus.status === "timeout" || parsedStatus.status === "fallback") {
				jsonEmitter.emitCommandOutputDone(undefined)
				return
			}

			return
		}

		if (message.type !== "state") {
			return
		}

		const currentTaskId = message.state?.currentTaskId ?? message.state?.currentTaskItem?.id
		if (typeof currentTaskId === "string" && currentTaskId.trim().length > 0) {