Function refresh

packages/cli/src/commands/dev.ts:204–285

(options: RefreshOptions)

};

async function refresh(options: RefreshOptions) {
  //stop any existing refreshes
  options.abortController.abort();
  options.abortController = new AbortController();

  // Read from env file to get the TRIGGER_API_KEY and TRIGGER_API_URL
  const apiDetails = await getTriggerApiDetails(options.path, options.resolvedOptions.envFile);
  if (!apiDetails) {
    options.spinner.fail("[trigger.dev] Failed to connect: Missing API Key");
    return;
  }

  const { apiKey, apiUrl } = apiDetails;
  const apiClient = new TriggerApi(apiKey, apiUrl);

  try {
    const index = await pRetry(() => startIndexing({ ...options, apiClient }), {
      retries: 5,
      signal: options.abortController.signal,
      maxTimeout: 5000,
    });
    options.spinner.text = `[trigger.dev] Refreshing ${formattedDate.format(index.updatedAt)}`;

    if (!options.hasConnected) {
      options.hasConnected = true;
      telemetryClient.dev.connected(options.path, options.resolvedOptions);
    }

    //this is for backwards-compatibility with older servers
    if (index.id === undefined) {
      options.spinner.succeed(`[trigger.dev] Refreshed ${formattedDate.format(index.updatedAt)}`);
      return;
    }

    //wait 750ms before attempting to get the indexing result
    await wait(750);

    const indexResult = await pRetry(() => fetchIndexResult({ indexId: index.id, apiClient }), {
      //this means we're polling, same distance between each attempt
      factor: 1,
      retries: 10,
      signal: options.abortController.signal,
    });

    if (indexResult.status === "FAILURE") {
      options.spinner.fail(
        `[trigger.dev] Refreshing failed ${formattedDate.format(indexResult.updatedAt)}`
      );
      logger.error(
        boxen(indexResult.error.message, {
          padding: 1,
          borderStyle: "double",
        })
      );
      return;
    }

    options.spinner.succeed(