Defines a debugging render func.

Author: Sinclert

src/cli.js

@@ -3,13 +3,14 @@
 import { Command } from "commander/esm.mjs";
 import { parseDataDiffs } from "./job_parse";
 import { publishDataDiffs } from "./job_publish";
-
-const program = new Command();
+import { renderDataDiffs } from "./job_publish";
 
 const DEFAULT_GCP_PROJECT = "ds3-dialect-map";
 const DEFAULT_GCP_PUBSUB = "data-diff";
 const DEFAULT_DEBUG_FLAG = "false";
 
+const program = new Command();
+
 program
     .command("publish")
     .description("Parses and publishes data diff JSON messages into a Pub/Sub topic")
@@ -22,7 +23,12 @@ program
         // Options unfold
         let gcpProject = options["gcpProject"];
         let gcpPubSub = options["gcpPubsub"];
-        let debugFlag = options["debugFlag"];
+        let debugFlag = options["debugFlag"].toLowerCase();
+
+        if (debugFlag !== "true" && debugFlag !== "false") {
+            console.error(`Invalid debug flag: ${debugFlag}`);
+            process.exit(1);
+        }
 
         console.info(`Received arguments and options:`);
         console.info(`Data file path: ${dataFile}`);
@@ -33,7 +39,10 @@ program
 
         let messages = parseDataDiffs(dataFile, diffFile);
 
-        if (debugFlag.toLowerCase() === "false") {
+        if (debugFlag === "true") {
+            renderDataDiffs(messages);
+        }
+        if (debugFlag === "false") {
             await publishDataDiffs(gcpProject, gcpPubSub, messages);
         }
     });

src/job_publish.js

@@ -1,5 +1,6 @@
 /* encoding: utf-8 */
 
+import { JSONParser } from "./parsers/parser_json";
 import { MSG_SOURCE_GHA } from "./models/pub_constants";
 import { MSG_TYPE_DIFF } from "./models/pub_constants";
 import { MessageMetadata } from "./models/pub_metadata";
@@ -13,10 +14,30 @@ export async function publishDataDiffs(projectID, pubSubTopic, messages) {
      * @param messages: array of DiffMessage objects
      */
 
+    let serializer = new JSONParser();
     let publisher = new PubSubPublisher(projectID, pubSubTopic);
-    let metadata = new MessageMetadata(MSG_SOURCE_GHA, MSG_TYPE_DIFF);
 
-    for (const msg of messages) {
-        await publisher.publishMessage(msg, metadata);
+    let metadataObject = new MessageMetadata(MSG_SOURCE_GHA, MSG_TYPE_DIFF);
+    let metadataFields = metadataObject.fields;
+
+    for (let msg of messages) {
+        let msgData = msg.fields;
+        let strData = serializer.printString(msgData);
+        await publisher.publishMessage(strData, metadataFields);
+    }
+}
+
+export function renderDataDiffs(messages) {
+    /**
+     * Renders the serialized data messages for debugging purposes
+     * @param messages: array of DiffMessage objects
+     */
+
+    let serializer = new JSONParser();
+
+    for (let msg of messages) {
+        let msgData = msg.fields;
+        let strData = serializer.printString(msgData);
+        console.debug(`Serialized message: ${strData}`);
     }
 }