Skip to content
Snippets Groups Projects
Commit 6c9b842a authored by Walter D's avatar Walter D
Browse files

Merge branch 'ibm-delete-objects-fix' into 'master'

fix: Ibm delete objects fix

See merge request !313
parents a1630efa 599184c1
No related branches found
No related tags found
8 merge requests!393Fix Azure SDMS Pipeline,!390Fix Azure Tests in Pipeline,!379Removing File Metadata Service,!378Revert "Merge branch 'ibm-release-stage-fix' into 'release/0.13'",!375Merge M8 to azure/m10-master,!374Update SDMS in azure/m10-master with M8 Changes,!365Azure/osdu seismic ddms m8 master,!313fix: Ibm delete objects fix
Pipeline #91550 failed
......@@ -157,8 +157,42 @@ export class Cos extends AbstractStorage {
logger.info('This function deletes bulk data uploaded by SDAPI/SDUTIL. Not implemented yet.');
logger.debug(bucketName);
logger.debug(prefix);
logger.info('Returning from Cos.deleteObject.');
await Promise.resolve();
await cosStorage.listObjects({Bucket: bucketName, Prefix: prefix}, async (err: any, data: any) => {
if (err) {
logger.error('Error in listing objects.');
logger.error(err.stack);
throw err;
}
logger.info('Fetched objects.');
logger.debug(data);
const items = data.Contents;
const params = { Bucket: bucketName, Delete: {Objects: []} };
if(!items || items.length<=0) {
logger.info('No items to delete.');
}
else
{
items.forEach(({ Key }) => {
params.Delete.Objects.push({ Key });
});
await cosStorage.deleteObjects(params, (delErr: any, delData: any) => {
if (delErr)
logger.error(delErr, delErr.stack); // an error occurred
else
{
logger.info('data deleted');
logger.debug(delData); // successful response
}
});
}
});
logger.info('Returning from Cos.deleteObjects.');
}
// [TODO] Nothing is copied here! This method is not working
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment