Class DirectImporter

apps/cli/src/sync/adapters.ts:52–147

// ==================== DirectImporter ====================

export class DirectImporter implements DataImporter {
  private dbManager: DatabaseManager
  private logger: SyncLogger

  constructor(dbManager: DatabaseManager, logger?: SyncLogger) {
    this.dbManager = dbManager
    this.logger = logger ?? NOOP_LOGGER
  }

  sessionExists(sessionId: string): boolean {
    const dbPath = this.dbManager.getDbPath(sessionId)
    if (!fs.existsSync(dbPath)) return false
    try {
      const db = this.dbManager.openRawSessionDatabase(sessionId, { readonly: true })
      const row = db
        .prepare("SELECT COUNT(*) as cnt FROM sqlite_master WHERE type='table' AND name='message'")
        .get() as { cnt: number }
      db.close()
      if (row.cnt === 0) {
        this.logger.warn(`[DirectImporter] DB file exists but has no message table: ${sessionId}, removing`)
        try {
          fs.unlinkSync(dbPath)
        } catch {
          /* ignore */
        }
        return false
      }
      return true
    } catch (error) {
      if (error instanceof DataDirCompatibilityError) throw error

      this.logger.warn(`[DirectImporter] Cannot validate DB file: ${sessionId}, removing`)
      try {
        fs.unlinkSync(dbPath)
      } catch {
        /* ignore */
      }
      return false
    }
  }

  async importFile(tempFile: string, targetSessionId: string | undefined, externalId: string): Promise<ImportResult> {
    if (targetSessionId && this.sessionExists(targetSessionId)) {
      return this.incrementalImportFile(targetSessionId, tempFile)
    }

    if (targetSessionId) {
      this.logger.info(`[DirectImporter] Session ${targetSessionId} not found locally, need full resync`)
      return { success: false, newMessageCount: 0, needFullResync: true }
    }

    return this.fullImportFile(tempFile, externalId)
  }

  private async incrementalImportFile(sessionId: string, tempFile: string): Promise<ImportResult> {
    try {
      this.dbManager.close(sessionId)
      const result = await incrementalImport(this.dbManager, sessionId, tempFile)