Function withDatabaseLockRetry

packages/core/src/sync/simple-sync.ts:141–162

(operation: () => Promise<T>, label: string)

}

async function withDatabaseLockRetry<T>(operation: () => Promise<T>, label: string): Promise<T> {
  let lastError: unknown;

  for (let attempt = 1; attempt <= DB_LOCK_MAX_RETRIES; attempt++) {
    try {
      return await operation();
    } catch (error) {
      lastError = error;
      if (!isDatabaseLockedError(error) || attempt === DB_LOCK_MAX_RETRIES) {
        throw error;
      }

      const delay = DB_LOCK_RETRY_DELAY_MS * attempt;
      console.warn(
        `[SimpleSync] ${label} hit a locked database, retrying (${attempt}/${DB_LOCK_MAX_RETRIES}) in ${delay}ms...`,
      );
      await sleep(delay);
    }
  }

  throw lastError instanceof Error ? lastError : new Error(String(lastError));
}

export interface TableChangeset {
  records: Record<string, unknown>[];