Method pullAllSessions

packages/sync/src/pull-engine.ts:485–498

(ds: DataSource)

  }

  async pullAllSessions(ds: DataSource): Promise<void> {
    if (this.pullingSourceIds.has(ds.id)) {
      this.logger.info(`[Pull] Skipping pullAllSessions for "${ds.baseUrl}": pull already in progress`)
      return
    }
    this.pullingSourceIds.add(ds.id)
    try {
      for (const sess of ds.sessions) {
        await this.executePullSession(ds.id, ds, sess)
      }
    } finally {
      this.pullingSourceIds.delete(ds.id)
    }
  }

  async triggerPull(sourceId: string, sessionId?: string): Promise<{ success: boolean; error?: string }> {
    const ds = this.dsManager.get(sourceId)