Function triggerPullAll

src/stores/apiServer.ts:488–512

(sourceId: string)

  }

  async function triggerPullAll(sourceId: string) {
    const ds = dataSources.value.find((s) => s.id === sourceId)
    const ids = [sourceId, ...(ds?.sessions.map((s) => s.id) ?? [])]
    for (const id of ids) pullingIds.value.add(id)
    pullingIds.value = new Set(pullingIds.value)
    const progressTimer = startProgressPolling()
    try {
      const result = await transport.triggerPullAll(sourceId)
      await fetchDataSources()
      await useSessionStore().loadSessions()
      generateIndexForSource(sourceId)
      return result
    } catch (err) {
      console.error('[ApiServerStore] Failed to trigger pull all:', err)
      return { success: false, error: String(err) }
    } finally {
      clearInterval(progressTimer)
      for (const id of ids) {
        pullingIds.value.delete(id)
        syncProgress.value.delete(id)
      }
      pullingIds.value = new Set(pullingIds.value)
      syncProgress.value = new Map(syncProgress.value)
    }
  }

  function startProgressPolling(): ReturnType<typeof setInterval> {
    return setInterval(fetchSyncProgress, 3000)