Function handleHookEvent

cli/src/opencode/opencodeLocalLauncher.ts:321–599

(event: OpencodeHookEvent)

    const toolExecutionQueues = new Map<string, string[]>();

    const handleHookEvent = (event: OpencodeHookEvent) => {
        const payload = event.payload;
        const eventType = event.event;
        const payloadRecord = isObject(payload) ? payload as Record<string, unknown> : null;
        const sessionId = event.sessionId
            || extractSessionId(payload)
            || (payloadRecord ? extractSessionId(payloadRecord.info) : null);
        if (sessionId) {
            session.onSessionFound(sessionId);
            storageScanner?.onNewSession(sessionId);
        }

        if (eventType === 'session.created' || eventType === 'session.updated') {
            if (payloadRecord) {
                const info = isObject(payloadRecord.info) ? payloadRecord.info as Record<string, unknown> : payloadRecord;
                const sessionIdValue = extractSessionId(info) || getString(info.id);
                if (sessionIdValue) {
                    session.onSessionFound(sessionIdValue);
                    storageScanner?.onNewSession(sessionIdValue);
                }
            }
            return;
        }

        if (eventType === 'message.updated') {
            const message = unwrapMessage(payload);
            if (!message) {
                return;
            }
            const messageId = getString(message.id) || getString(message.messageId);
            const role = getString(message.role);
            if (messageId && role) {
                messageRoles.set(messageId, role);
            }
            return;
        }

        if (eventType === 'message.part.updated') {
            const part = unwrapPart(payload);
            if (!part) {
                return;
            }
            const partType = getString(part.type);
            const partId = getString(part.id);
            const messageId = getString(part.messageID)
                || getString(part.messageId)
                || (payloadRecord ? getString(payloadRecord.messageID) || getString(payloadRecord.messageId) : null);
            const delta = getTextDelta(payloadRecord);

            if (partType === 'text') {
                if (partId && sentTextParts.has(partId)) {
                    return;
                }
                const role = (messageId && messageRoles.get(messageId)) ?? 'assistant';
                const key = partId ?? messageId;
                const bufferValue = key ? textBuffers.get(key) ?? '' : '';
                const textFromPart = getString(part.text);
                const nextBuffer = delta ? bufferValue + delta : bufferValue;