Function pollDataSourceUpdates

src/stores/apiServer.ts:413–433

(sourceId: string, sessionIds: string[], maxAttempts = 24, intervalMs = 5000)

  }

  function pollDataSourceUpdates(sourceId: string, sessionIds: string[], maxAttempts = 24, intervalMs = 5000) {
    let attempt = 0
    const timer = setInterval(async () => {
      attempt++
      await Promise.all([fetchDataSources(), fetchSyncProgress()])
      const ds = dataSources.value.find((s) => s.id === sourceId)
      const pending = sessionIds.filter((id) => {
        const sess = ds?.sessions.find((s) => s.id === id)
        return sess && sess.lastStatus === 'idle'
      })
      if (pending.length === 0 || attempt >= maxAttempts) {
        for (const id of sessionIds) {
          pullingIds.value.delete(id)
          syncProgress.value.delete(id)
        }
        pullingIds.value = new Set(pullingIds.value)
        syncProgress.value = new Map(syncProgress.value)
        clearInterval(timer)
      }
    }, intervalMs)
  }

  async function fetchSyncProgress() {
    if (!isWebMode.value) return