Method handleIncomingMessage

cli/src/api/apiSession.ts:358–370

(message: { id?: string; seq?: number; localId?: string | null; content: unknown })

    }

    private handleIncomingMessage(message: { id?: string; seq?: number; localId?: string | null; content: unknown }): void {
        if (!this.incomingFilter.accept({ id: message.id, seq: message.seq })) {
            return
        }

        const userResult = UserMessageSchema.safeParse(message.content)
        if (userResult.success) {
            this.enqueueUserMessage(userResult.data, message.localId ?? undefined)
            return
        }

        this.emit('message', message.content)
    }

    private async backfillIfNeeded(): Promise<void> {
        if (!this.needsBackfill) {