feat: add monitor sync command

workflow-cli/src/commands/opensearch-sync-monitors.ts

@@ -0,0 +1,56 @@
+import 'reflect-metadata';
+import { Command } from '@oclif/core';
+import AwsService from '../services/aws.service';
+import { bindBroker, bindVault, vsContainer } from '../inversify.config';
+import {
+  accessId,
+  accessKey,
+  accountNumber,
+  arn,
+  brokerApiUrl,
+  brokerToken,
+  domainName,
+  help,
+  hostname,
+  region,
+  vaultAddr,
+  vaultToken,
+  dryRun,
+} from '../flags';
+import OpenSearchController from '../controller/opensearch.controller';
+import { TYPES } from '../inversify.types';
+
+export default class OpenSearchSync extends Command {
+  static description = 'Sync OpenSearch settings';
+
+  static examples = ['<%= config.bin %> <%= command.id %>'];
+
+  static flags = {
+    ...hostname,
+    ...domainName,
+    ...region,
+    ...accessId,
+    ...accessKey,
+    ...accountNumber,
+    ...arn,
+    ...brokerApiUrl,
+    ...brokerToken,
+    ...vaultAddr,
+    ...vaultToken,
+    ...help,
+    ...dryRun,
+  };
+
+  public async run(): Promise<void> {
+    const { flags } = await this.parse(OpenSearchSync);
+
+    await AwsService.assumeIdentity(flags);
+
+    bindBroker(flags['broker-api-url'], flags['broker-token']);
+    bindVault(flags['vault-addr'], flags['vault-token']);
+
+    await vsContainer
+      .get<OpenSearchController>(TYPES.OpenSearchController)
+      .syncMonitors(flags);
+  }
+}

workflow-cli/src/controller/opensearch.controller.ts

@@ -44,8 +44,10 @@
         )
       ).data.data,
     );
+  }
 
-    // console.log('======= Monitor Sync');
+  public async syncMonitors(flags: any) {
+    console.log('======= Monitor Sync');
     // await this.monitorService.sync(flags);
   }
 }

workflow-cli/src/flags.ts

@@ -92,8 +92,8 @@ export const vaultToken = {
 
 export const dryRun = {
   dryRun: Flags.boolean({
-    description: 'Disable deletion of messages',
-    env: 'AWS_SQS_DRY_RUN',
+    description: 'Enables dry run',
+    env: 'DRY_RUN',
     default: false,
   }),
 };

workflow-cli/src/services/opensearch-monitor.service.ts

@@ -9,6 +9,7 @@ import { BrokerApi } from '../broker/broker.api';
 import { GraphServerInstallInstanceDto } from '../broker/dto/graph-server-installs-rest.dto';
 import { inject, injectable } from 'inversify';
 import { TYPES } from '../inversify.types';
+import { dryRun } from '../flags';
 
 const ID_MAX_LENGTH = 20;
 
@@ -160,16 +161,18 @@ export default class OpenSearchMonitorService extends AwsService {
     // return;
     for (const removeHit of removeHits) {
       console.log(`Remove monitor: ${removeHit._source.name}`);
-      // DELETE _plugins/_alerting/monitors/<monitor_id>
-      await this.executeSignedHttpRequest({
-        method: 'DELETE',
-        headers: {
-          'Content-Type': 'application/json',
-          host: settings.hostname,
-        },
-        hostname: settings.hostname,
-        path: `/_plugins/_alerting/monitors/${removeHit._id}`,
-      }).then((res) => this.waitAndReturnResponseBody(res, [404]));
+      if (!dryRun) {
+        // DELETE _plugins/_alerting/monitors/<monitor_id>
+        await this.executeSignedHttpRequest({
+          method: 'DELETE',
+          headers: {
+            'Content-Type': 'application/json',
+            host: settings.hostname,
+          },
+          hostname: settings.hostname,
+          path: `/_plugins/_alerting/monitors/${removeHit._id}`,
+        }).then((res) => this.waitAndReturnResponseBody(res, [404]));
+      }
     }
 
     for (const monitor of monitors) {
@@ -196,34 +199,38 @@ export default class OpenSearchMonitorService extends AwsService {
         // Add
         // POST _plugins/_alerting/monitors
         console.log(`Add monitor: ${monitor.name}`);
-        await this.executeSignedHttpRequest({
-          method: 'POST',
-          headers: {
-            'Content-Type': 'application/json',
-            host: settings.hostname,
-          },
-          hostname: settings.hostname,
-          path: '/_plugins/_alerting/monitors',
-          body: JSON.stringify(monitor),
-        }).then((res) => this.waitAndReturnResponseBody(res, [404]));
+        if (!dryRun) {
+          await this.executeSignedHttpRequest({
+            method: 'POST',
+            headers: {
+              'Content-Type': 'application/json',
+              host: settings.hostname,
+            },
+            hostname: settings.hostname,
+            path: '/_plugins/_alerting/monitors',
+            body: JSON.stringify(monitor),
+          }).then((res) => this.waitAndReturnResponseBody(res, [404]));
+        }
       } else {
         // Update
         // PUT _plugins/_alerting/monitors/<monitor_id>
         console.log(`Update monitor: ${monitor.name}`);
-        if (!body.hits.hits[0]._source.enabled) {
-          // Do not re-enable
-          monitor.enabled = false;
+        if (!dryRun) {
+          if (!body.hits.hits[0]._source.enabled) {
+            // Do not re-enable
+            monitor.enabled = false;
+          }
+          await this.executeSignedHttpRequest({
+            method: 'PUT',
+            headers: {
+              'Content-Type': 'application/json',
+              host: settings.hostname,
+            },
+            hostname: settings.hostname,
+            path: `/_plugins/_alerting/monitors/${body.hits.hits[0]._id}`,
+            body: JSON.stringify(monitor),
+          }).then((res) => this.waitAndReturnResponseBody(res, [404]));
         }
-        await this.executeSignedHttpRequest({
-          method: 'PUT',
-          headers: {
-            'Content-Type': 'application/json',
-            host: settings.hostname,
-          },
-          hostname: settings.hostname,
-          path: `/_plugins/_alerting/monitors/${body.hits.hits[0]._id}`,
-          body: JSON.stringify(monitor),
-        }).then((res) => this.waitAndReturnResponseBody(res, [404]));
       }
     }
   }