Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found

Target

Select target project
  • osdu/platform/domain-data-mgmt-services/seismic/seismic-dms-suite/seismic-store-service
1 result
Show changes
Commits on Source (6)
......@@ -2,6 +2,7 @@ include:
# pipeline logic
- project: "osdu/platform/ci-cd-pipelines"
file: "standard-setup.yml"
ref: v0.13.2
# global
# gcp
......
......@@ -87,7 +87,4 @@ sdms_ibm-preship-promote:
- oc project $IBM_OPENSHIFT_PRESHIP_PROJECT
- oc start-build og-$SDMS_PROJECT_NAME-ibm
rules:
- if: '$CI_COMMIT_BRANCH == "master"'
changes:
- devops/**/*
- app/sdms/**/*
- if: '$CI_COMMIT_BRANCH == $IBM_PRESHIP_RELEASE_BRANCH'
......@@ -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
......