fix some bugs

src/cli-sync-ot.ts

@@ -25,40 +25,37 @@ async function main(): Promise<void> {
     transcendAuth,
     transcendUrl,
     resource,
-    debug,
+    // debug,
     dryRun,
   } = parseCliSyncOtArguments();
 
   // use the hostname and auth token to instantiate a client to talk to OneTrust
   const oneTrust = createOneTrustGotInstance({ hostname, auth: oneTrustAuth });
 
-  try {
-    if (resource === OneTrustPullResource.Assessments) {
-      await syncOneTrustAssessments({
-        oneTrust,
-        file,
-        fileFormat,
-        dryRun,
-        ...(transcendAuth && transcendUrl
-          ? {
-              transcend: buildTranscendGraphQLClient(
-                transcendUrl,
-                transcendAuth,
-              ),
-            }
-          : {}),
-      });
-    }
-  } catch (err) {
-    logger.error(
-      colors.red(
-        `An error occurred syncing the resource ${resource} from OneTrust: ${
-          debug ? err.stack : err.message
-        }`,
-      ),
-    );
-    process.exit(1);
+  // try {
+  if (resource === OneTrustPullResource.Assessments) {
+    await syncOneTrustAssessments({
+      oneTrust,
+      file,
+      fileFormat,
+      dryRun,
+      ...(transcendAuth && transcendUrl
+        ? {
+            transcend: buildTranscendGraphQLClient(transcendUrl, transcendAuth),
+          }
+        : {}),
+    });
   }
+  // } catch (err) {
+  //   logger.error(
+  //     colors.red(
+  //       `An error occurred syncing the resource ${resource} from OneTrust: ${
+  //         debug ? err.stack : err.message
+  //       }`,
+  //     ),
+  //   );
+  //   process.exit(1);
+  // }
 
   // Indicate success
   logger.info(

src/codecs.ts

@@ -2093,9 +2093,11 @@ const OneTrustAssessmentRowInput = t.type({
 });
 
 /** Input for importing multiple OneTrust assessment forms into Transcend */
-export const ImportOnetrustAssessmentsInput = t.type({
+export const ImportOnetrustAssessmentsInput = t.partial({
   /** 'The rows of the CSV file.' */
   rows: t.array(OneTrustAssessmentRowInput),
+  /** 'The json record representing the assessment.' */
+  json: t.string,
 });
 /** Type override */
 export type ImportOnetrustAssessmentsInput = t.TypeOf<

src/oneTrust/helpers/oneTrustAssessmentToJson.ts

@@ -10,17 +10,20 @@ export const oneTrustAssessmentToJson = ({
   assessment,
   index,
   total,
+  wrap = true,
 }: {
   /** The assessment to convert */
   assessment: OneTrustEnrichedAssessment;
   /** The position of the assessment in the final Json object */
   index: number;
   /** The total amount of the assessments in the final Json object */
   total: number;
+  /** Whether to wrap every entry in brackets */
+  wrap?: boolean;
 }): string => {
   let jsonEntry = '';
   // start with an opening bracket
-  if (index === 0) {
+  if (index === 0 || wrap) {
     jsonEntry = '[\n';
   }
 
@@ -33,7 +36,7 @@ export const oneTrustAssessmentToJson = ({
   jsonEntry = jsonEntry + stringifiedAssessment + comma;
 
   // end with closing bracket
-  if (index === total - 1) {
+  if (index === total - 1 || wrap) {
     jsonEntry += ']';
   }
 

src/oneTrust/helpers/syncOneTrustAssessmentToTranscend.ts

@@ -1,12 +1,13 @@
 import { logger } from '../../logger';
-import { oneTrustAssessmentToCsvRecord } from './oneTrustAssessmentToCsvRecord';
+import colors from 'colors';
 import { GraphQLClient } from 'graphql-request';
 import {
   IMPORT_ONE_TRUST_ASSESSMENT_FORMS,
   makeGraphQLRequest,
 } from '../../graphql';
 import { ImportOnetrustAssessmentsInput } from '../../codecs';
 import { OneTrustEnrichedAssessment } from '@transcend-io/privacy-types';
+import { oneTrustAssessmentToJson } from './oneTrustAssessmentToJson';
 
 export interface AssessmentForm {
   /** ID of Assessment Form */
@@ -24,27 +25,35 @@ export interface AssessmentForm {
 export const syncOneTrustAssessmentToTranscend = async ({
   transcend,
   assessment,
+  total,
+  index,
 }: {
   /** the Transcend client instance */
   transcend: GraphQLClient;
   /** the assessment to sync to Transcend */
   assessment: OneTrustEnrichedAssessment;
+  /** The index of the assessment being written to the file */
+  index: number;
+  /** The total amount of assessments that we will write */
+  total: number;
 }): Promise<AssessmentForm | undefined> => {
-  logger.info();
+  logger.info(
+    colors.magenta(
+      `Writing enriched assessment ${index + 1} of ${total} to Transcend...`,
+    ),
+  );
 
   // convert the OneTrust assessment object into a CSV Record (a map from the csv header to values)
-  const csvRecord = oneTrustAssessmentToCsvRecord(assessment);
+  const json = oneTrustAssessmentToJson({
+    assessment,
+    index,
+    total,
+    wrap: true,
+  });
 
   // transform the csv record into a valid input to the mutation
   const input: ImportOnetrustAssessmentsInput = {
-    rows: [
-      {
-        columns: Object.entries(csvRecord).map(([key, value]) => ({
-          title: key,
-          value: value.toString(),
-        })),
-      },
-    ],
+    json,
   };
 
   const {

src/oneTrust/helpers/syncOneTrustAssessments.ts

@@ -189,11 +189,13 @@ export const syncOneTrustAssessments = async ({
             file,
             fileFormat,
           });
-        } else if (fileFormat === OneTrustFileFormat.Csv && transcend) {
+        } else if (fileFormat === OneTrustFileFormat.Json && transcend) {
           // sync to transcend
           await syncOneTrustAssessmentToTranscend({
             assessment: enrichedAssessment,
             transcend,
+            total: assessments.length,
+            index: trueIndex,
           });
         }
       },