fixup

package.json

@@ -8,7 +8,7 @@
   "scripts": {
     "lint": "eslint $(git ls-files '*.js')",
     "test:unit": "LOCATION_CONFIG_FILE='tests/conf/locationConfig.json' yarn jest --verbose --logHeapUsage --projects jest.config.js --coverage --testPathPattern='tests/unit/[\\w/-]+\\.[tj]s'",
-    "test:functional": "LOCATION_CONFIG_FILE='tests/conf/locationConfig.json' yarn jest --verbose --logHeapUsage --projects jest.config.js  --coverage --testPathPattern='tests/functional/[\\w/-]+\\.[tj]s'"
+    "test:functional": "LOCATION_CONFIG_FILE='tests/conf/locationConfig.json' yarn jest --verbose --logHeapUsage --projects jest.config.js  --coverage --testPathPattern='tests/functional/collectBucketMetricsAndUpdateBucketCapacityInfo.js'"
   },
   "repository": {
     "type": "git",

utils/S3UtilsMongoClient.js

@@ -65,8 +65,10 @@ class S3UtilsMongoClient extends MongoClientInterface {
                     'value.creationDate': 1,
                 },
             });
-            const TEST = await this.getCollection(USERSBUCKET).find({});
-            console.log('TEST', TEST);
+            const TEST = await this.getCollection(USERSBUCKET).countDocuments({});
+            const TEST2 = await this.getCollection(METASTORE).countDocuments({});
+            const TEST3 = await this.getCollection(INFOSTORE).countDocuments({});
+            console.log('TEST', { TEST, TEST2, TEST3 });
             const usersBucketCreationDatesArray = await cursorUsersBucketCreationDates.toArray();
             console.log('USERS BUCKET CREATION DATES ARRAY', usersBucketCreationDatesArray);
             return usersBucketCreationDatesArray
@@ -85,6 +87,7 @@ class S3UtilsMongoClient extends MongoClientInterface {
 
     async updateInflightDeltas(allMetrics, log) {
         let cursor;
+        console.log('WE ARE HEEEEEEEEERE');
         try {
             if (!allMetrics || !Array.isArray(allMetrics) || allMetrics.length === 0) {
                 return allMetrics;
@@ -95,7 +98,8 @@ class S3UtilsMongoClient extends MongoClientInterface {
                     'usedCapacity._inflight': 1,
                 },
             });
-
+
+            console.log('CURSOR', cursor);
             const inflights = await cursor.toArray();
             // convert inflights to a map with _id: usedCapacity._inflight
             const inflightsMap = inflights.reduce((map, obj) => {
@@ -822,20 +826,20 @@ class S3UtilsMongoClient extends MongoClientInterface {
     }
 
     static convertNumberToLong(obj) {
-        console.log('ON EST ICIIII SA RACE');
         if (typeof obj !== 'object' || obj === null) {
-            return obj;
+          console.log('THIS IS THE OBJ', obj);
+          return obj;
         }
+
         const newObj = {};
         for (const key in obj) {
-            if (typeof obj[key] === 'number') {
-                // convert number to Long
-                newObj[key] = Long.fromNumber(obj[key]);
-            } else {
-                // recursively convert nested object properties to Long
-                newObj[key] = S3UtilsMongoClient.convertNumberToLong(obj[key]);
-            }
+          if (typeof obj[key] === 'bigint') {
+            newObj[key] = Long.fromString(obj[key].toString());
+          } else {
+            newObj[key] = S3UtilsMongoClient.convertNumberToLong(obj[key]);
+          }
         }
+        console.log('NEW OBJ', newObj);
         return newObj;
     }
 
@@ -856,13 +860,15 @@ class S3UtilsMongoClient extends MongoClientInterface {
             log.info('updateStorageConsumptionMetrics: updating storage metrics');
 
             // update the inflights
+            console.log('updatedStorageMetricsList', updatedStorageMetricsList);
             updatedStorageMetricsList = await this.updateInflightDeltas(updatedStorageMetricsList, log);
 
             // Drop the temporary collection if it exists
             try {
                 await this.getCollection(INFOSTORE_TMP).drop();
             } catch (err) {
                 if (err.codeName !== 'NamespaceNotFound') {
+                    console.log('we are actually heeeere');
                     throw err;
                 }
             }