@@ -10,6 +10,8 @@ const UtilizationService = require('../../utilization/instance');
1010const metadata = require ( '../../metadata/wrapper' ) ;
1111
1212const pipeline = promisify ( streamPipeline ) ;
13+ const getUtilizationMetrics = promisify ( UtilizationService . getUtilizationMetrics . bind ( UtilizationService ) ) ;
14+ metadata . getBucketPromised = promisify ( metadata . getBucket ) ;
1315
1416/**
1517 * Decodes an URI and return the result.
@@ -217,12 +219,7 @@ function getFileToBuild(request, data, inlineLastModified = false) {
217219async function fetchCapacityMetrics ( bucketMd , request , log , method ) {
218220 const bucketKey = `${ bucketMd . _name } _${ new Date ( bucketMd . _creationDate ) . getTime ( ) } ` ;
219221 try {
220- return await new Promise ( ( resolve , reject ) =>
221- UtilizationService . getUtilizationMetrics ( 'bucket' , bucketKey , null , { } , ( err , bucketMetrics ) => {
222- if ( err ) { return reject ( err ) ; }
223- return resolve ( bucketMetrics ) ;
224- } )
225- ) ;
222+ return await getUtilizationMetrics ( 'bucket' , bucketKey , null , { } ) ;
226223 } catch ( err ) {
227224 const statusCode = err . response ?. status || err . statusCode || err . code ;
228225 if ( statusCode === 404 ) {
@@ -255,12 +252,7 @@ async function fetchCapacityMetrics(bucketMd, request, log, method) {
255252async function buildVeeamFileData ( request , bucketMd , log , name ) {
256253 let data ;
257254 try {
258- data = await new Promise ( ( resolve , reject ) =>
259- metadata . getBucket ( request . bucketName , log , ( err , result ) => {
260- if ( err ) { return reject ( err ) ; }
261- return resolve ( result ) ;
262- } )
263- ) ;
255+ data = await metadata . getBucketPromised ( request . bucketName , log ) ;
264256 } catch {
265257 throw errors . InternalError ;
266258 }
0 commit comments