Neptune Analytics Support & Logger

package.json

@@ -64,7 +64,9 @@
     "graphql": "^16.8.1",
     "graphql-tag": "2.12.6",
     "ora": "7.0.1",
-    "semver": "7.5.4"
+    "semver": "7.5.4",
+    "pino": "9.4.0",
+    "pino-pretty": "11.2.2"
   },
   "devDependencies": {
     "@jest/test-sequencer": "^29.7.0",

samples/todo.schema.graphql

@@ -10,8 +10,4 @@ type Todo {
 
 type Comment {
     content: String
-}
-
-input Options {
-    limit: Int
 }

src/CDKPipelineApp.js

@@ -16,6 +16,7 @@ import { readFile, writeFile } from 'fs/promises';
 import fs from 'fs';
 import archiver from 'archiver';
 import ora from 'ora';
+import { loggerDebug, loggerError, loggerInfo, yellow } from "./logger.js";
 
 let NAME = '';
 let REGION = '';
@@ -33,11 +34,7 @@ let APPSYNC_ATTACH_QUERY = [];
 let APPSYNC_ATTACH_MUTATION = [];
 let SCHEMA_MODEL = null;
 let thisOutputFolderPath = './output';
-
-
-function yellow(text) {
-    return '\x1b[33m' + text + '\x1b[0m';
-}
+let msg = '';
 
 async function getSchemaFields(typeName) {
     /*  To be updated as:
@@ -69,7 +66,7 @@ async function createDeploymentFile(folderPath, zipFilePath) {
         archive.file('./output/output.resolver.graphql.js', { name: 'output.resolver.graphql.js' })
         await archive.finalize();
     } catch (err) {
-        console.error('Creating deployment zip file: ' + err); 
+        loggerError('Creating deployment zip file: ' + err);
     }
 }
 
@@ -107,32 +104,32 @@ async function createAWSpipelineCDK({
 
     if (neptuneType === 'neptune-db') {
         try {
-            if (!quiet) console.log('Get Neptune Cluster Info');
+            loggerInfo('Getting Neptune Cluster Info');
             if (!quiet) spinner = ora('Getting ...').start();
             neptuneClusterInfo = await getNeptuneClusterDbInfoBy(NEPTUNE_DB_NAME, REGION);
             if (!quiet) spinner.succeed('Got Neptune Cluster Info');
             if (isNeptuneIAMAuth) {
                 if (!neptuneClusterInfo.isIAMauth) {
-                    console.error("The Neptune database authentication is set to VPC.");
-                    console.error("Remove the --output-aws-pipeline-cdk-neptune-IAM option.");
+                    loggerError("The Neptune database authentication is set to VPC.");
+                    loggerError("Remove the --output-aws-pipeline-cdk-neptune-IAM option.");
                     process.exit(1);
                 }
             } else {
                 if (neptuneClusterInfo.isIAMauth) {
-                    console.error("The Neptune database authentication is set to IAM.");
-                    console.error("Add the --output-aws-pipeline-cdk-neptune-IAM option.");
+                    loggerError("The Neptune database authentication is set to IAM.");
+                    loggerError("Add the --output-aws-pipeline-cdk-neptune-IAM option.");
                     process.exit(1);
                 } else {
-                    if (!quiet) console.log(`Subnet Group: ` + yellow(neptuneClusterInfo.dbSubnetGroup));
+                    loggerDebug(`Subnet Group: ` + neptuneClusterInfo.dbSubnetGroup, {toConsole: true});
                 }
             }
 
             if (neptuneClusterInfo.version != '') {
                 const v = neptuneClusterInfo.version;
                 if (lambdaFilesPath.includes('SDK') == true && //semver.satisfies(v, '>=1.2.1.0') ) {
-                    (v == '1.2.1.0' || v == '1.2.0.2' || v == '1.2.0.1' ||  v == '1.2.0.0' || v == '1.1.1.0' || v == '1.1.0.0')) {
-                    console.error("Neptune SDK query is supported starting with Neptune versions 1.2.1.0.R5");
-                    console.error("Switch to Neptune HTTPS query with option --output-resolver-query-https");
+                    (v == '1.2.1.0' || v == '1.2.0.2' || v == '1.2.0.1' || v == '1.2.0.0' || v == '1.1.1.0' || v == '1.1.0.0')) {
+                    loggerError("Neptune SDK query is supported starting with Neptune versions 1.2.1.0.R5");
+                    loggerError("Switch to Neptune HTTPS query with option --output-resolver-query-https");
                     process.exit(1);
                 }
             }
@@ -143,13 +140,15 @@ async function createAWSpipelineCDK({
             NEPTUNE_IAM_POLICY_RESOURCE = neptuneClusterInfo.iamPolicyResource;
 
         } catch (error) {
+            msg = 'Error getting Neptune Cluster Info: ' + JSON.stringify(error);
+            loggerError(msg);
             if (!quiet) spinner.fail("Error getting Neptune Cluster Info.");
             if (!isNeptuneIAMAuth) {
                 spinner.clear();
-                console.error("VPC data is not available to proceed.");
+                loggerError("VPC data is not available to proceed.");
                 process.exit(1);
             } else {
-                if (!quiet) console.log("Proceeding without getting Neptune Cluster info.");
+                loggerInfo("Proceeding without getting Neptune Cluster info.", {toConsole: true});
             }
         }
     }