Disable utapi

To be re-enabled when utapi is compatible with node 22

Issue: CLDSRV-553

.github/workflows/tests.yaml

@@ -414,7 +414,7 @@ jobs:
         user: ${{ secrets.ARTIFACTS_USER }}
         password: ${{ secrets.ARTIFACTS_PASSWORD }}
         source: /tmp/artifacts
-      if: always()
+      if: false
 
   quota-tests:
     runs-on: ubuntu-latest

lib/Config.js

@@ -20,7 +20,11 @@ const {
     allowedUtapiEventFilterStates,
     supportedLifecycleRules,
 } = require('../constants');
-const { utapiVersion } = require('utapi');
+
+// TODO CLDSRV-610: re-enable utapi
+// const { utapiVersion } = require('utapi');
+const utapiVersion = null;
+
 const { scaleMsPerDay } = s3middleware.objectUtils;
 
 const constants = require('../constants');

lib/utapi/utapi.js

@@ -1,9 +1,12 @@
 require('werelogs').stderrUtils.catchAndTimestampStderr();
 const _config = require('../Config').config;
-const { utapiVersion, UtapiServer: utapiServer } = require('utapi');
+// TODO CLDSRV-610 re-enable utapi
+/* eslint-disable */
+// const { utapiVersion, UtapiServer: utapiServer } = require('utapi');
 
 // start utapi server
-if (utapiVersion === 1 && _config.utapi) {
+// TODO CLDSRV-610 re-enable utapi
+if (utapiVersion === 1 && _config.utapi && false) {
     const fullConfig = Object.assign({}, _config.utapi,
         { redis: _config.redis });
     if (_config.vaultd) {

lib/utapi/utapiReindex.js

@@ -1,11 +1,16 @@
 require('werelogs').stderrUtils.catchAndTimestampStderr();
-const UtapiReindex = require('utapi').UtapiReindex;
+// TODO CLDSRV-610 re-enable utapi
+/* eslint-disable */
+// const UtapiReindex = require('utapi').UtapiReindex;
 const { config } = require('../Config');
 
-const reindexConfig = config.utapi && config.utapi.reindex;
-if (reindexConfig && reindexConfig.password === undefined) {
-    reindexConfig.password = config.utapi && config.utapi.redis
-    && config.utapi.redis.password;
+// TODO CLDSRV-610 re-enable utapi
+if (false) {
+    const reindexConfig = config.utapi && config.utapi.reindex;
+    if (reindexConfig && reindexConfig.password === undefined) {
+        reindexConfig.password = config.utapi && config.utapi.redis
+        && config.utapi.redis.password;
+    }
+    const reindex = new UtapiReindex(reindexConfig);
+    reindex.start();    
 }
-const reindex = new UtapiReindex(reindexConfig);
-reindex.start();

lib/utapi/utapiReplay.js

@@ -1,8 +1,13 @@
 require('werelogs').stderrUtils.catchAndTimestampStderr();
-const UtapiReplay = require('utapi').UtapiReplay;
+// TODO CLDSRV-610 re-enable utapi
+/* eslint-disable */
+// const UtapiReplay = require('utapi').UtapiReplay;
 const _config = require('../Config').config;
 
-const utapiConfig = _config.utapi &&
-    Object.assign({}, _config.utapi, { redis: _config.redis });
-const replay = new UtapiReplay(utapiConfig); // start utapi server
-replay.start();
+// TODO CLDSRV-610 re-enable utapi
+if (false) {
+    const utapiConfig = _config.utapi &&
+        Object.assign({}, _config.utapi, { redis: _config.redis });
+    const replay = new UtapiReplay(utapiConfig); // start utapi server
+    replay.start();
+}

lib/utapi/utilities.js

@@ -2,27 +2,30 @@ const http = require('http');
 const https = require('https');
 const commander = require('commander');
 const { auth } = require('arsenal');
-const { UtapiClient, utapiVersion } = require('utapi');
+// TODO CLDSRV-610 re-enable utapi
+/* eslint-disable */
+// const { UtapiClient, utapiVersion } = require('utapi');
 const logger = require('../utilities/logger');
 const _config = require('../Config').config;
 const { suppressedUtapiEventFields: suppressedEventFields } = require('../../constants');
 // setup utapi client
 let utapiConfig;
 
-if (utapiVersion === 1 && _config.utapi) {
-    if (_config.utapi.redis === undefined) {
-        utapiConfig = Object.assign({}, _config.utapi, { redis: _config.redis });
-    } else {
-        utapiConfig = Object.assign({}, _config.utapi);
-    }
-} else if (utapiVersion === 2) {
-    utapiConfig = Object.assign({
-        tls: _config.https,
-        suppressedEventFields,
-    }, _config.utapi || {});
-}
+// TODO CLDSRV-610 re-enable utapi
+// if (utapiVersion === 1 && _config.utapi) {
+//     if (_config.utapi.redis === undefined) {
+//         utapiConfig = Object.assign({}, _config.utapi, { redis: _config.redis });
+//     } else {
+//         utapiConfig = Object.assign({}, _config.utapi);
+//     }
+// } else if (utapiVersion === 2) {
+//     utapiConfig = Object.assign({
+//         tls: _config.https,
+//         suppressedEventFields,
+//     }, _config.utapi || {});
+// }
 
-const utapi = new UtapiClient(utapiConfig);
+// const utapi = new UtapiClient(utapiConfig);
 
 const bucketOwnerMetrics = [
     'completeMultipartUpload',
@@ -257,6 +260,8 @@ function listMetrics(metricType) {
  * filtered out and not pushed to utapi.
  */
 function pushMetric(action, log, metricObj) {
+    // TODO CLDSRV-610 re-enable utapi
+    return;
     const {
         bucket,
         keys,
@@ -355,6 +360,8 @@ function pushMetric(action, log, metricObj) {
  * @return {string} - location unique ID
  */
 function _getLocationId(location) {
+    // TODO CLDSRV-610 re-enable utapi
+    return;
     return _config.locationConstraints[location].objectId;
 }
 
@@ -367,6 +374,8 @@ function _getLocationId(location) {
  * @return {function} - `utapi.getLocationMetric`
  */
 function getLocationMetric(location, log, cb) {
+    // TODO CLDSRV-610 re-enable utapi
+    return;
     const locationId = _getLocationId(location);
     return utapi.getLocationMetric(locationId, log.getSerializedUids(), cb);
 }
@@ -381,6 +390,8 @@ function getLocationMetric(location, log, cb) {
  * @return {function} - `utapi.pushLocationMetric`
  */
 function pushLocationMetric(location, byteLength, log, cb) {
+    // TODO CLDSRV-610 re-enable utapi
+    return;
     const locationId = _getLocationId(location);
     return utapi.pushLocationMetric(locationId, byteLength,
         log.getSerializedUids(), cb);

tests/unit/Config.js

@@ -470,7 +470,8 @@ describe('Config', () => {
             process.env.S3_CONFIG_FILE = oldConfig;
         });
 
-        it('should set up utapi local cache', () => {
+        // TODO CLDSRV-610 re-enable utapi
+        it.skip('should set up utapi local cache', () => {
             const { ConfigObject } = require('../../lib/Config');
             const config = new ConfigObject();
 
@@ -484,7 +485,8 @@ describe('Config', () => {
             );
         });
 
-        it('should set up utapi redis', () => {
+        // TODO CLDSRV-610 re-enable utapi
+        it.skip('should set up utapi redis', () => {
             const { ConfigObject } = require('../../lib/Config');
             const config = new ConfigObject();
 

tests/utapi/utilities.js

@@ -480,7 +480,8 @@ const testEvents = [{
     },
 }];
 
-describe('utapi v2 pushmetrics utility', () => {
+// TODO CLDSRV-610 re-enable utapi
+describe.skip('utapi v2 pushmetrics utility', () => {
     const log = new werelogs.Logger('utapi-utility');
     const { UtapiClient, utapiVersion } = require('utapi');
     let pushMetric;