Method pushIsolateAndClear

cli/src/utils/MessageQueue2.ts:152–185

* Push a message that must be processed in complete isolation. * Clears any pending messages and ensures this message is never batched with others. * Used for special commands that require dedicated processing.

(message: string, mode: T, localId?: string)

     * Used for special commands that require dedicated processing.
     */
    pushIsolateAndClear(message: string, mode: T, localId?: string): void {
        if (this.closed) {
            throw new Error('Cannot push to closed queue');
        }

        const modeHash = this.modeHasher(mode);
        logger.debug(`[MessageQueue2] pushIsolateAndClear() called with mode hash: ${modeHash} - clearing ${this.queue.length} pending messages`);

        // Clear any pending messages to ensure this message is processed in complete isolation
        this.queue = [];

        this.queue.push({
            message,
            mode,
            modeHash,
            localId,
            isolate: true
        });

        // Trigger message handler if set
        if (this.onMessageHandler) {
            this.onMessageHandler(message, mode);
        }

        // Notify waiter if any
        if (this.waiter) {
            logger.debug(`[MessageQueue2] Notifying waiter for isolated message`);
            const waiter = this.waiter;
            this.waiter = null;
            waiter(true);
        }

        logger.debug(`[MessageQueue2] pushIsolateAndClear() completed. Queue size: ${this.queue.length}`);
    }

    /**
     * Push a message to the beginning of the queue with a mode.