Function initScheduler

packages/sync/src/scheduler.ts:63–79

(options: SchedulerOptions)

}

export function initScheduler(options: SchedulerOptions): void {
  if (initialized) return
  initialized = true

  _dsManager = options.dsManager
  _pullEngine = options.pullEngine
  _logger = options.logger ?? NOOP_LOGGER

  const sources = _dsManager.loadAll()
  for (const ds of sources) {
    if (ds.enabled && ds.sessions.length > 0) {
      startTimer(ds)
    }
  }

  _logger.info(`[Pull] Initialized with ${sources.filter((s) => s.enabled).length} active sources`)
}

export function stopAllTimers(): void {
  for (const [id] of timers) {