Function useRunStatuses

packages/react/src/statuses.ts:42–100

(
  runId: string | undefined,
  options?: RunStatusesOptions
)

    } & GetRunStatuses);

export function useRunStatuses(
  runId: string | undefined,
  options?: RunStatusesOptions
): UseRunStatusesResult {
  const { apiUrl, publicApiKey, queryClient } = useTriggerProvider();

  const queryResult = useQuery(
    {
      queryKey: [`triggerdotdev-run-statuses-${runId}`],
      queryFn: async () => {
        return await zodfetch(GetRunStatusesSchema, `${apiUrl}/api/v2/runs/${runId}/statuses`, {
          method: "GET",
          headers: {
            Authorization: `Bearer ${publicApiKey}`,
          },
        });
      },
      enabled: !!runId,
      refetchInterval: (data) => {
        if (data?.run.status && runResolvedStatuses.includes(data.run.status)) {
          return false;
        }
        if (options?.refreshIntervalMs !== undefined) {
          return Math.max(options.refreshIntervalMs, 500);
        }

        return defaultRefreshInterval;
      },
    },
    queryClient
  );

  switch (queryResult.status) {
    case "pending": {
      return {
        fetchStatus: "loading",
        error: undefined,
        statuses: undefined,
        run: undefined,
      };
    }
    case "error": {
      return {
        fetchStatus: "error",
        error: queryResult.error,
        statuses: undefined,
        run: undefined,
      };
    }
    case "success": {
      return {
        fetchStatus: "success",
        error: undefined,
        run: queryResult.data.run,
        statuses: queryResult.data.statuses,
      };
    }
  }