Class ApiClient

client/src/api/metadata/api-client.ts:6–109

import { AuthUtil } from '@/api/utils/Auth-Utils';

export class ApiClient implements MetadataClient {
  private authUtil: AuthUtil;

  constructor(instance: IPublicClientApplication, account: AccountInfo) {
    this.authUtil = new AuthUtil(instance, account);
  }

  async getMeta(account: string, container: string, filePath: string): Promise<SigMFMetadata> {
    const response = await this.authUtil.requestWithAuthIfRequired({
      method: 'get',
      url: `/api/datasources/${account}/${container}/${filePath}/meta`
    });
    let responseMetaData: SigMFMetadata | null = null;
    responseMetaData = Object.assign(new SigMFMetadata(), response.data);
    responseMetaData.annotations = responseMetaData.annotations?.map((annotation) =>
      Object.assign(new Annotation(), annotation)
    );
    responseMetaData.captures = responseMetaData.captures?.map((capture) =>
      Object.assign(new CaptureSegment(), capture)
    );
    return responseMetaData;
  }

  async getDataSourceMetaPaths(account: string, container: string): Promise<string[]> {
    const response = await this.authUtil.requestWithAuthIfRequired({
      method: 'get',
      url: `/api/datasources/${account}/${container}/meta/paths`
    });
    return response.data;
  }

  async updateMeta(account: string, container: string, filePath: string, meta: SigMFMetadata): Promise<SigMFMetadata> {
    try {
      const config = {
        method: 'PUT',
        url: `/api/datasources/${account}/${container}/${filePath}/meta`,
        data: meta
      };

      await this.authUtil.requestWithAuthIfRequired(config);

      return meta as SigMFMetadata;
    } catch (error) {
      console.error(error);
      throw new Error('Failed to update metadata.');
    }
  }

  async track(account: string, container: string, filepath: string, signal: AbortSignal): Promise<number[][]> {
    if (!account || !container || !filepath) {
      return null;
    }
    const response = await this.authUtil.requestWithAuthIfRequired({
      method: 'get',
      url: `/api/datasources/${account}/${container}/${filepath}/track`,
      signal: signal,
    });
    if (response.status !== 200) {