Notes

import { from, Observable } from 'rxjs';
import { switchMap } from 'rxjs/operators';

uploadFile(files: File[], uniqueNames: string[]): Observable<string[]> {
console.log('Files to upload:', files);
console.log('Unique names:', uniqueNames);

this.isUpload.next(true);

// Create an array of upload observables
const uploadObservables = files.map((file, i) => {
const containerClient = this.blobServiceClient.getContainerClient('reference-pitch-documents');
const blockBlobClient = containerClient.getBlockBlobClient(uniqueNames[i]);

const options = {
blobHTTPHeaders: {
blobContentType: file.type
}
};

console.log(`Uploading file ${i}:`, file.name, 'as', uniqueNames[i]);
console.log('BlockBlobClient URL:', blockBlobClient.url);

// Convert the Azure SDK promise to an observable
return from(blockBlobClient.uploadData(file, options)).pipe(
switchMap(() => {
console.log('File uploaded successfully:', blockBlobClient.url);
return blockBlobClient.url;
})
);
});

// Combine all uploads into a single observable
return forkJoin(uploadObservables).pipe(
tap({
next: () => this.isUpload.next(false),
error: (err) => {
this.isUpload.next(false);
console.error('Upload error:', err);
}
})
);
}