Method accept

cli/src/api/apiSession.ts:121–152

Returns true if this message should be processed; false to drop as a duplicate.

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

    /** Returns true if this message should be processed; false to drop as a duplicate. */
    accept(message: { id?: string | null; seq?: number | null }): boolean {
        const id = typeof message.id === 'string' && message.id.length > 0 ? message.id : null
        if (id && this.seenIds.has(id)) {
            // Refresh recency: the hub re-emits the same id every 5 s until the
            // CLI acks (releaseMatureScheduledMessages contract).  Without a
            // delete+re-add the entry stays at its first-insert position and can
            // be evicted by a burst of unrelated ids before the ack lands —
            // the next re-emit would then be treated as new and double-deliver.
            this.seenIds.delete(id)
            this.seenIds.add(id)
            return false
        }

        const seq = typeof message.seq === 'number' ? message.seq : null
        if (!id && seq !== null && this.lastSeenSeq !== null && seq <= this.lastSeenSeq) {
            return false
        }

        if (id) {
            this.seenIds.add(id)
            if (this.seenIds.size > this.capacity) {
                // Set iteration is insertion-ordered; with delete+re-add on dedup hit
                // (above) this becomes a true LRU eviction.
                const oldest = this.seenIds.values().next().value
                if (oldest !== undefined) this.seenIds.delete(oldest)
            }
        }
        if (seq !== null) {
            this.lastSeenSeq = Math.max(this.lastSeenSeq ?? 0, seq)
        }
        return true
    }
}

export class ApiSessionClient extends EventEmitter {