Function processQueue

src/lib/sync/auto-data-sync-queue.ts:950–1109

()

}

async function processQueue() {
  if (processing || queue.length === 0) {
    debugAutoDataSync('skip queue processing', {
      processing,
      pendingCount: queue.length,
    })
    return
  }

  if (!await isAutoDataSyncEnabled()) {
    queue = []
    debugAutoDataSync('clear queue because auto data sync is disabled')
    updateState({
      isSyncing: false,
      phase: 'idle',
      currentDomain: null,
      status: 'idle',
      lastError: null,
    })
    return
  }

  if (!await isAutoDataSyncProviderConfigured()) {
    queue = []
    debugAutoDataSync('clear queue because provider is not configured')
    updateState({
      isSyncing: false,
      phase: 'waiting_provider',
      currentDomain: null,
      syncMode: null,
      status: 'waiting_provider',
      lastError: null,
    })
    return
  }

  processing = true
  const uploadedDomains = new Set<AutoDataSyncDomain>()
  debugAutoDataSync('queue processing started', { pendingCount: queue.length })

  while (queue.length > 0) {
    const task = queue.shift()
    if (!task) {
      continue
    }

    debugAutoDataSync('task started', {
      id: task.id,
      seq: task.seq,
      domain: task.domain,
      reason: task.reason,
      mode: task.mode,
      retryCount: task.retryCount,
      remainingCount: queue.length,
    })
    const taskStartedAt = Date.now()

    try {