Function syncBookmarksGraphQL

src/graphql-bookmarks.ts:584–849

(
  options: SyncOptions = {}
)

}

export async function syncBookmarksGraphQL(
  options: SyncOptions = {}
): Promise<SyncResult> {
  const incremental = options.incremental ?? true;
  const maxPages = options.maxPages ?? Infinity;
  const delayMs = options.delayMs ?? 600;
  const maxMinutes = options.maxMinutes ?? 30;
  const stalePageLimit = options.stalePageLimit ?? 3;
  const checkpointEvery = options.checkpointEvery ?? 25;
  const pageSize = Math.max(1, Math.min(options.pageSize ?? 20, 100));

  let csrfToken: string;
  let cookieHeader: string | undefined;

  if (options.csrfToken) {
    csrfToken = options.csrfToken;
    cookieHeader = options.cookieHeader;
  } else {
    const config = loadChromeSessionConfig({ browserId: options.browser });

    if (config.browser.cookieBackend === 'firefox') {
      const cookies = extractFirefoxXCookies(options.firefoxProfileDir);
      csrfToken = cookies.csrfToken;
      cookieHeader = cookies.cookieHeader;
    } else {
      const chromeDir = options.chromeUserDataDir ?? config.chromeUserDataDir;
      const chromeProfile = options.chromeProfileDirectory ?? config.chromeProfileDirectory;
      const cookies = extractChromeXCookies(chromeDir, chromeProfile, config.browser);
      csrfToken = cookies.csrfToken;
      cookieHeader = cookies.cookieHeader;
    }
  }

  ensureDataDir();
  const cachePath = twitterBookmarksCachePath();
  const metaPath = twitterBookmarksMetaPath();
  const statePath = twitterBackfillStatePath();
  const loaded = await loadExistingBookmarks();
  let existing = loaded.records;
  const bookmarkedAtRepaired = loaded.repaired;
  const newestKnownId = incremental ? existing[0]?.id : undefined;
  const previousMeta = (await pathExists(metaPath))
    ? await readJson<BookmarkCacheMeta>(metaPath)
    : undefined;
  const prevState: BookmarkBackfillState = (await pathExists(statePath))
    ? await readJson<BookmarkBackfillState>(statePath)
    : { provider: 'twitter', totalRuns: 0, totalAdded: 0, lastAdded: 0, lastSeenIds: [] };

  const started = Date.now();
  let page = 0;
  let totalAdded = 0;
  let stalePages = 0;
  let cursor: string | undefined = options.resumeCursor;
  const allSeenIds: string[] = [];
  let stopReason = 'unknown';
  let retryAfterSec: number | undefined;

  const fetchNextPage = async (): Promise<PageResult | undefined> => {