Method buildMigratorForRequest

hub/src/sync/syncEngine.ts:553–602

(_request: CursorMigrateToAcpRequest)

    }

    private buildMigratorForRequest(_request: CursorMigrateToAcpRequest): CursorLegacyMigrator {
        const migratorOpts: CursorLegacyMigratorOptions = {}
        return new CursorLegacyMigrator(migratorOpts, {
            archiveSession: async (sessionId) => {
                await this.archiveSession(sessionId)
            },
            // NOTE: no awaitSessionInactive injection — handleSessionEnd()
            // synchronously sets cache.active=false inside archiveSession,
            // so any cache-based poll would return immediately and provide
            // false reassurance. The migrator now relies on
            // awaitLockRelease's minimum-dwell + SQLite busy-probe +
            // size-stability combination instead. Codex review #34 P1 v3.
            getCurrentSession: (sessionId, namespace) => {
                const s = this.sessionCache.getSessionByNamespace(sessionId, namespace)
                if (!s) return null
                return {
                    active: s.active === true,
                    lifecycleState: typeof s.metadata?.lifecycleState === 'string' ? s.metadata.lifecycleState : undefined,
                    cursorSessionProtocol: typeof s.metadata?.cursorSessionProtocol === 'string' ? s.metadata.cursorSessionProtocol : undefined
                }
            },
            updateSessionAfterMigrate: (sessionId, namespace, lastUsedModel) => {
                const result = this.flipCursorSessionProtocolToAcp(sessionId, namespace, lastUsedModel)
                if (result.result === 'success') return { ok: true }
                if (result.result === 'session-active') return { ok: false, reason: 'session_active' as const }
                return { ok: false, reason: 'version_mismatch_or_missing' as const }
            },
            // tiann/hapi#872: size sanity check needs to compare HAPI's known
            // message history against the candidate legacy store's blob
            // count. The store-handle stays on the engine; we only thread
            // the count through so the migrator stays free of a direct
            // hub.Store dependency.
            getHapiMessageCount: (sessionId, _namespace) => {
                try {
                    return this.store.messages.countMessages(sessionId)
                } catch (err) {
                    // tiann/hapi#873 cold review: a silent 0 here trips
                    // the migrator's "skip sanity" branch and chronically
                    // disables the floor. Warn so a broken countMessages
                    // (lock contention pattern, schema drift) is visible
                    // in journalctl.
                    console.warn('[auto-migrate] countMessages threw; size sanity skipped', {
                        sessionId,
                        err: err instanceof Error ? err.message : String(err)
                    })
                    return 0
                }
            }
        })
    }

    async switchSession(sessionId: string, to: 'remote' | 'local'): Promise<void> {
        await this.rpcGateway.switchSession(sessionId, to)