Improve code from review

Issue: S3UTILS-188

Author: Seragonia

CountItems/utils/utils.js

@@ -82,7 +82,6 @@ function consolidateDataMetrics(target, source) {
     return resTarget;
 }
 
-
 function serializeBigInts(obj) {
     if (typeof obj !== 'object' || obj === null) {
         return typeof obj === 'bigint' ? { __bigint: obj.toString() } : obj;

tests/constants.js

@@ -24,6 +24,9 @@ module.exports = {
         _lifecycleConfiguration: null,
         _uid: '',
         _isNFS: null,
+        _capabilities: {
+            VeeamSOSApi: undefined,
+        },
         ingestion: null,
     },
     testAccountCanonicalId: 'd1d40abd2bd8250962f7f5774af1bbbeaec9b77a0853749d41ec46f142e66fe4',

tests/functional/collectBucketMetricsAndUpdateBucketCapacityInfo.js

@@ -94,8 +94,8 @@ describe('collectBucketMetricsAndUpdateBucketCapacityInfo', () => {
                 next();
             }),
             next => client.getBucketAttributes(testBucketName, logger, (err, bucketInfo) => {
-                assert.equal(err && err.message, 'InternalError');
-                assert.equal(bucketInfo, undefined);
+                assert.equal(err, null);
+                assert.strictEqual(bucketInfo.getCapabilities().VeeamSOSApi, undefined);
                 next();
             }),
         ], done);

tests/functional/utils/S3UtilsMongoClient.js

@@ -1613,7 +1613,7 @@ describe('S3UtilsMongoClient::getObjectMDStats', () => {
     });
 });
 
-describe.skip('S3UtilsMongoClient::updateBucketCapacityInfo', () => {
+describe('S3UtilsMongoClient::updateBucketCapacityInfo', () => {
     let client;
     let repl;
 
@@ -1676,7 +1676,7 @@ describe.skip('S3UtilsMongoClient::updateBucketCapacityInfo', () => {
     });
 });
 
-describe.skip('S3UtilsMongoClient::getBucketInfos', () => {
+describe('S3UtilsMongoClient::getBucketInfos', () => {
     let client;
     let repl;
 
@@ -1731,9 +1731,15 @@ describe.skip('S3UtilsMongoClient::getBucketInfos', () => {
         it('Should get correct bucket infos', done => client.getBucketInfos(logger, (err, data) => {
             assert.equal(err, null);
             assert.strictEqual(data.bucketCount, 3);
-            assert.strictEqual(JSON.stringify(data.bucketInfos.find(bucket => bucket._name === buckets[0]._name)), JSON.stringify(buckets[0]));
-            assert.strictEqual(JSON.stringify(data.bucketInfos.find(bucket => bucket._name === buckets[1]._name)), JSON.stringify(buckets[1]));
-            assert.strictEqual(JSON.stringify(data.bucketInfos.find(bucket => bucket._name === buckets[2]._name)), JSON.stringify(buckets[2]));
+            assert.strictEqual(
+                data.bucketInfos.find(bucket => bucket._name === buckets[0]._name).serialize(),
+                BucketInfo.fromObj(buckets[0]).serialize());
+            assert.strictEqual(
+                data.bucketInfos.find(bucket => bucket._name === buckets[1]._name).serialize(),
+                BucketInfo.fromObj(buckets[1]).serialize());
+            assert.strictEqual(
+                data.bucketInfos.find(bucket => bucket._name === buckets[2]._name).serialize(),
+                BucketInfo.fromObj(buckets[2]).serialize());
             done();
         }));
 
@@ -1758,9 +1764,9 @@ describe.skip('S3UtilsMongoClient::getBucketInfos', () => {
 
             // Perform the assertions
             assert.strictEqual(data.bucketCount, 2);
-            assert.strictEqual(JSON.stringify(data.bucketInfos.find(bucket => bucket._name === buckets[0]._name)), undefined);
-            assert.strictEqual(JSON.stringify(data.bucketInfos.find(bucket => bucket._name === buckets[1]._name)), JSON.stringify(buckets[1]));
-            assert.strictEqual(JSON.stringify(data.bucketInfos.find(bucket => bucket._name === buckets[2]._name)), JSON.stringify(buckets[2]));
+            assert.strictEqual(data.bucketInfos.find(bucket => bucket._name === buckets[0]._name), undefined);
+            assert.strictEqual(!!data.bucketInfos.find(bucket => bucket._name === buckets[1]._name), true);
+            assert.strictEqual(!!data.bucketInfos.find(bucket => bucket._name === buckets[2]._name), true);
         });
     });
 });

utils/S3UtilsMongoClient.js

@@ -14,8 +14,8 @@ const INFOSTORE_TMP = `${INFOSTORE}_tmp`;
 const __COUNT_ITEMS = 'countitems';
 
 const BigIntMax = (...args) => args.reduce((max, current) => {
-    const maxAsBigInt = typeof max === 'bigint' ? max : BigInt(max);
-    const currentAsBigInt = typeof current === 'bigint' ? current : BigInt(current);
+    const maxAsBigInt = BigInt(max);
+    const currentAsBigInt = BigInt(current);
     return maxAsBigInt > currentAsBigInt ? max : current;
 });
 
@@ -114,7 +114,7 @@ class S3UtilsMongoClient extends MongoClientInterface {
                 const id = entry._id;
                 if (id.startsWith('bucket_')) {
                     const inflightDocument = inflightsMap[id];
-                    const inflight = inflightDocument ? BigIntMax(0, inflightDocument - entry.usedCapacity._inflightsPreScan) : 0n;
+                    const inflight = inflightDocument ? BigIntMax(0n, inflightDocument - entry.usedCapacity._inflightsPreScan) : 0n;
                     if (inflight) {
                         // Inflights remaining after the scan are part of the "current" bytes,
                         // and stored in _inflightsDelta