Class BlobClient

client/src/api/metadata/blob-client.ts:62–103

}

export class BlobClient implements MetadataClient {
  dataSources: Record<string, DataSource>;

  constructor(dataSources: Record<string, DataSource>) {
    this.dataSources = dataSources;
  }

  track(account: string, container: string, filepath: string): Promise<Track> {
    throw new Error('track not supported for blob data sources');
  }

  async getMeta(account: string, container: string, filePath: string): Promise<SigMFMetadata> {
    const containerClient = getContainerClient(this.dataSources, account, container);
    return blobNameToMetadata(filePath, containerClient);
  }

  async getDataSourceMetaPaths(account: string, container: string): Promise<string[]> {
    const containerClient = getContainerClient(this.dataSources, account, container);
    const blobNames: Array<string> = [];
    for await (const i of containerClient.listBlobsFlat()) blobNames.push(i.name);
    const blobsToProcess = blobNames.filter(
      (blobName) =>
        blobName.split('.').pop() === 'sigmf-meta' && blobNames.includes(blobName.split('.')[0] + '.sigmf-data')
    );
    return blobsToProcess;
  }

  async updateMeta(account: string, container: string, filePath: string, meta: SigMFMetadata): Promise<any> {
    // Currently update meta doesnt even try to update the blob so we are just going to return here
    return meta;
  }

  async smartQuery(queryString: string): Promise<any> {
    throw new Error('smartQuery not supported for blob data sources');
  }

  features() {
    return {
      canUpdateMeta: false,
    };
  }
}