Function blobNameToMetadata

client/src/api/metadata/blob-client.ts:23–60

(blobName: string, containerClient: ContainerClient)

}

async function blobNameToMetadata(blobName: string, containerClient: ContainerClient): Promise<SigMFMetadata> {
  const fName = blobName.split('.')[0];
  const blobClient = containerClient.getBlobClient(fName + '.sigmf-meta');
  let blobBody = await (await blobClient.download()).blobBody;
  let recording: SigMFMetadata | null = null;
  try {
    let jsonString = await readBlobAsText(blobBody);
    let objectFromJson = JSON.parse(jsonString);
    recording = Object.assign(new SigMFMetadata(), objectFromJson);
  } catch (e) {
    console.error(e);
  }
  if (!recording) {
    return null;
  }
  const blobDataClient = containerClient.getBlobClient(fName + '.sigmf-data');
  recording.dataClient = blobDataClient;
  let properties = await blobDataClient.getProperties();
  if (!recording) {
    return null;
  }
  if (!recording.global['traceability:sample_length']) {
    recording.global['traceability:sample_length'] = Math.round(
      properties.contentLength / recording.getBytesPerIQSample()
    );
  }
  if (!recording.global['traceability:origin']) {
    recording.global['traceability:origin'] = {
      type: 'azure_blob',
      account: containerClient.accountName,
      container: containerClient.containerName,
      file_path: fName,
    };
  }
  recording.annotations = recording.annotations.map((annotation) => Object.assign(new Annotation(), annotation));
  recording.captures = recording.captures.map((capture) => Object.assign(new CaptureSegment(), capture));
  return recording;
}

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