Class CloudApiClient

console/src/api/apiClient.ts:318–379

}

export class CloudApiClient
  implements IApiClientBase, ICloudApiClient, IFronteggApiClient
{
  #appConfig: Readonly<CloudAppConfig>;
  cloudGlobalApiBasePath: string;
  fronteggApiBasePath: string;
  type = "cloud" as const;
  isImpersonating = false as const;
  mzHttpUrlScheme: HttpScheme;
  mzWebsocketUrlScheme: WebsocketScheme;

  constructor({ appConfig }: { appConfig: Readonly<CloudAppConfig> }) {
    this.#appConfig = appConfig;
    this.cloudGlobalApiBasePath = this.#appConfig.cloudGlobalApiUrl;
    this.fronteggApiBasePath = this.#appConfig.fronteggUrl;
    this.mzHttpUrlScheme = this.#appConfig.environmentdScheme;
    this.mzWebsocketUrlScheme = this.#appConfig.environmentdWebsocketScheme;
  }

  #getAccessToken() {
    // Get the access token from Frontegg's context holder
    const accessToken = ContextHolder.for("default").getAccessToken();

    // The token will most likely always exist since this function
    // will be called when logged in. If not, we should alert Sentry.
    if (!accessToken) {
      Sentry.addBreadcrumb({
        level: "error",
        category: "auth",
        message: "Failed to refresh auth token",
      });
    }
    return accessToken;
  }

  #authMiddleware: Middleware = (next) => {
    return async (...fetchArgs) => {
      const [input, options = {}] = fetchArgs;
      const accessToken = this.#getAccessToken();

      const headers = copyHeaders(fetchArgs);
      if (accessToken) {
        headers.set("Authorization", `Bearer ${accessToken}`);
        if (this.#appConfig.sentryConfig?.release) {
          Object.entries(
            buildConsoleVersionHeaders(this.#appConfig.sentryConfig?.release),
          ).forEach(([key, value]) => {
            headers.set(key, value);
          });
        }
      }

      const request = new Request(input, { ...options, headers });
      return next(request);
    };
  };

  mzApiFetch = withMiddleware(globalFetch, this.#authMiddleware);