feat: Add config-manager push connector-mappings command

src/cli/config-manager/config-manager-push/config-manager-push-connector-mappings.ts

@@ -0,0 +1,59 @@
+import { frodo } from '@rockcarver/frodo-lib';
+import { Option } from 'commander';
+
+import { configManagerImportMappings } from '../../../configManagerOps/FrConfigConnectorMappingOps';
+import { getTokens } from '../../../ops/AuthenticateOps';
+import { printMessage, verboseMessage } from '../../../utils/Console';
+import { FrodoCommand } from '../../FrodoCommand';
+
+const { CLOUD_DEPLOYMENT_TYPE_KEY, FORGEOPS_DEPLOYMENT_TYPE_KEY } =
+  frodo.utils.constants;
+
+const deploymentTypes = [
+  CLOUD_DEPLOYMENT_TYPE_KEY,
+  FORGEOPS_DEPLOYMENT_TYPE_KEY,
+];
+
+export default function setup() {
+  const program = new FrodoCommand(
+    'frodo config-manager push connector-mappings',
+    [],
+    deploymentTypes
+  );
+
+  program
+    .description('Import connector mappings.')
+    .addOption(
+      new Option(
+        '-n, --name <name>',
+        'Connector mapping name; imports only the connector mapping with the specified name.'
+      )
+    )
+    .action(async (host, realm, user, password, options, command) => {
+      command.handleDefaultArgsAndOpts(
+        host,
+        realm,
+        user,
+        password,
+        options,
+        command
+      );
+
+      if (await getTokens(false, true, deploymentTypes)) {
+        verboseMessage('Importing connector mappings');
+        const outcome = await configManagerImportMappings(options.name);
+        if (!outcome) process.exitCode = 1;
+      }
+      // unrecognized combination of options or no options
+      else {
+        printMessage(
+          'Unrecognized combination of options or no options...',
+          'error'
+        );
+        program.help();
+        process.exitCode = 1;
+      }
+    });
+
+  return program;
+}

src/cli/config-manager/config-manager-push/config-manager-push.ts

@@ -3,6 +3,7 @@ import AccessConfig from './config-manager-push-access-config';
 import Audit from './config-manager-push-audit';
 import Authentication from './config-manager-push-authentication';
 import ConnectorDefinitions from './config-manager-push-connector-definitions';
+import ConnectorMappings from './config-manager-push-connector-mappings';
 import CookieDomains from './config-manager-push-cookie-domain';
 import EmailProvider from './config-manager-push-email-provider';
 import EmailTemplates from './config-manager-push-email-templates';
@@ -43,6 +44,7 @@ export default function setup() {
   program.addCommand(UiConfig().name('ui-config'));
   program.addCommand(Authentication().name('authentication'));
   program.addCommand(ConnectorDefinitions().name('connector-definitions'));
+  program.addCommand(ConnectorMappings().name('connector-mappings'));
 
   return program;
 }

src/configManagerOps/FrConfigConnectorMappingOps.ts

@@ -1,10 +1,13 @@
 import { frodo } from '@rockcarver/frodo-lib';
+import fs from 'fs';
+import path from 'path';
 
 import { extractFrConfigDataToFile } from '../utils/Config';
 import { printError } from '../utils/Console';
 
 const { getFilePath, saveJsonToFile } = frodo.utils;
-const { readConfigEntity } = frodo.idm.config;
+const { readConfigEntity, importConfigEntities, importSubConfigEntity } =
+  frodo.idm.config;
 
 function processMappings(mapping, targetDir, name) {
   try {
@@ -58,3 +61,80 @@ export async function configManagerExportMappings(): Promise<boolean> {
   }
   return false;
 }
+
+/**
+ * Helper that recursively reads in extracted files and stores them back in the connector
+ * @param {Record<string, any>} obj The connector configuration
+ * @param {string} connectorMappingDirectory The directory where the connector resides
+ */
+function getExtractedFiles(obj: any, connectorMappingDirectory: string): void {
+  if (!obj || typeof obj !== 'object') return;
+  for (const key of Object.keys(obj)) {
+    const value = obj[key];
+    if (value?.type === 'text/javascript' && value.file) {
+      const scriptPath = path.join(connectorMappingDirectory, value.file);
+      if (fs.existsSync(scriptPath)) {
+        value.source = fs.readFileSync(scriptPath, { encoding: 'utf-8' });
+        delete value.file;
+      }
+    } else if (typeof value === 'object') {
+      getExtractedFiles(value, connectorMappingDirectory);
+    }
+  }
+}
+
+/**
+ * Helper that returns the import data for a connector mapping given the file where it is saved
+ * @param {string} file The file where the connector mapping is saved
+ * @returns {object} The connector mapping data from the file, including data from any extracted files
+ */
+function getConnectorMappingImportData(file: string): object {
+  const readManagedObject = fs.readFileSync(file, 'utf-8');
+  const importData = JSON.parse(readManagedObject);
+  const connectorMappingDirectory = path.dirname(file);
+  getExtractedFiles(importData, connectorMappingDirectory);
+  return importData;
+}
+
+/**
+ * Import all mappings in fr-config-manager format
+ * @param {string} name optional connector name to import
+ * @returns {Promise<boolean>} true if successful, false otherwise
+ */
+export async function configManagerImportMappings(
+  name?: string
+): Promise<boolean> {
+  try {
+    if (name) {
+      const jsonFilePath = getFilePath(`sync/mappings/${name}/${name}.json`);
+      const importData = getConnectorMappingImportData(jsonFilePath) as any;
+      await importSubConfigEntity('sync', importData);
+      return true;
+    } else {
+      const mappingDir = getFilePath('sync/mappings');
+      const mappingFiles = fs.readdirSync(mappingDir);
+      const importMappingData = {
+        idm: { sync: { _id: 'sync', mappings: [] as any } },
+      };
+      for (const mappingFile of mappingFiles) {
+        const jsonFilePath = getFilePath(
+          `sync/mappings/${mappingFile}/${mappingFile}.json`
+        );
+        const importData = getConnectorMappingImportData(jsonFilePath) as any;
+        if (importData.file) {
+          const scriptPath = getFilePath(
+            `sync/mappings/${mappingFile}/${importData.file}`
+          );
+          importData.source = fs.readFileSync(scriptPath, 'utf8');
+          delete importData.file;
+        }
+        importMappingData.idm.sync.mappings.push(importData);
+      }
+      await importConfigEntities(importMappingData);
+    }
+    return true;
+  } catch (error) {
+    printError(error, `Error importing mappings from files`);
+  }
+  return false;
+}

test/client_cli/en/__snapshots__/config-manager-push-connector-mappings.test.js.snap

@@ -0,0 +1,27 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`CLI help interface for 'config-manager push connector-mappings' should be expected english 1`] = `
+"Usage: frodo config-manager push connector-mappings [options] [host] [realm] [username] [password]
+
+[Experimental] Import connector mappings.
+
+Arguments:
+  host               AM base URL, e.g.: https://cdk.iam.example.com/am. To use a
+                     connection profile, just specify a unique substring or
+                     alias.
+  realm              Realm. Specify realm as '/' for the root realm or 'realm'
+                     or '/parent/child' otherwise. (default: "alpha" for
+                     Identity Cloud tenants, "/" otherwise.)
+  username           Username to login with. Must be an admin user with
+                     appropriate rights to manage authentication journeys/trees.
+  password           Password.
+
+Options:
+  -n, --name <name>  Connector mapping name; imports only the connector mapping
+                     with the specified name.
+  -h, --help         Help
+  -hh, --help-more   Help with all options.
+  -hhh, --help-all   Help with all options, environment variables, and usage
+                     examples.
+"
+`;

test/client_cli/en/__snapshots__/config-manager-push.test.js.snap

@@ -17,6 +17,7 @@ Commands:
   audit                  [Experimental] Import audit configuration.
   authentication         [Experimental] Import authentication objects.
   connector-definitions  [Experimental] Import connector definitions.
+  connector-mappings     [Experimental] Import connector mappings.
   cookie-domains         [Experimental] Import cookie domains.
   email-provider         [Experimental] Import email provider configuration.
   email-templates        [Experimental] Import email template objects.

test/client_cli/en/config-manager-push-connector-mappings.test.js

@@ -0,0 +1,10 @@
+import cp from 'child_process';
+import { promisify } from 'util';
+
+const exec = promisify(cp.exec);
+const CMD = 'frodo config-manager push connector-mappings --help';
+const { stdout } = await exec(CMD);
+
+test("CLI help interface for 'config-manager push connector-mappings' should be expected english", async () => {
+    expect(stdout).toMatchSnapshot();
+});

test/e2e/__snapshots__/config-manager-push-connector-mappings.e2e.test.js.snap

@@ -0,0 +1,15 @@
+// Jest Snapshot v1, https://goo.gl/fbAQLP
+
+exports[`frodo config-manager push connector mappings "frodo config-manager push connector-mappings -D test/e2e/exports/fr-config-manager/forgeops -m forgeops ": should import the connector mappings into forgeops" 1`] = `""`;
+
+exports[`frodo config-manager push connector mappings "frodo config-manager push connector-mappings -D test/e2e/exports/fr-config-manager/forgeops -m forgeops ": should import the connector mappings into forgeops" 2`] = `
+"Experimental feature in use: 'frodo config-manager push connector-mappings'. This feature may change without notice.
+"
+`;
+
+exports[`frodo config-manager push connector mappings "frodo config-manager push connector-mappings -n UserToUserJavascriptSync -D test/e2e/exports/fr-config-manager/forgeops -m forgeops ": should import a specific connector mapping by name into forgeops" 1`] = `""`;
+
+exports[`frodo config-manager push connector mappings "frodo config-manager push connector-mappings -n UserToUserJavascriptSync -D test/e2e/exports/fr-config-manager/forgeops -m forgeops ": should import a specific connector mapping by name into forgeops" 2`] = `
+"Experimental feature in use: 'frodo config-manager push connector-mappings'. This feature may change without notice.
+"
+`;