Function initSync

apps/cli/src/sync/index.ts:32–71

(
  server: FastifyInstance,
  dbManager: DatabaseManager,
  pathProvider: PathProvider,
  serverInfo: { port: number; host: string; token: string }
)

let pullEngine: PullEngine | null = null

export function initSync(
  server: FastifyInstance,
  dbManager: DatabaseManager,
  pathProvider: PathProvider,
  serverInfo: { port: number; host: string; token: string }
): void {
  const settingsDir = pathProvider.getSettingsDir()

  dsManager = new DataSourceManager(settingsDir, syncLogger)

  const fetcher = new NodeFetcher()
  const importer = new DirectImporter(dbManager, syncLogger)
  const notifier = new NoopNotifier()

  const sessionAdapter = createDatabaseManagerAdapter(dbManager)
  const preferences = new PreferencesManager(pathProvider.getSystemDir())

  pullEngine = new PullEngine({
    fetcher,
    importer,
    notifier,
    dsManager,
    logger: syncLogger,
    onSessionImported: (localSessionId) => {
      preferences.invalidateCache()
      const result = ownerProfileService.tryApplyOwnerProfile(sessionAdapter, preferences, localSessionId)
      if (result.applied) {
        syncLogger.info(`[Pull] Applied owner profile to session ${localSessionId} (owner: ${result.ownerId})`)
      }
    },
  })

  registerAutomationRoutes(server, { dsManager, pullEngine, dbManager, serverInfo })

  initScheduler({
    dsManager,
    pullEngine,
    logger: syncLogger,
  })
}

export function cleanupSync(): void {
  stopAllTimers()