Add file based payload for reply operation

An advanced option to control printing visualization debug messages
SolaceLabs · Feb 6, 2024 · d3423b8 · d3423b8
1 parent 137edcb
commit d3423b8
Show file tree

Hide file tree

Showing 7 changed files with 11 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "stm",
-  "version": "0.0.28",
+  "version": "0.0.29",
   "description": "Solace Try-Me Command Line Tool",
   "keywords": [
     "solace",

diff --git a/src/common/visualize-client.ts b/src/common/visualize-client.ts
@@ -20,7 +20,7 @@ export class VisualizeClient {
       options.dmqEligible && message.setDMQEligible(false);
       options.messageId && message.setApplicationMessageId(options.messageId);
       options.messageType && message.setApplicationMessageType('VISUALIZATION_EVENT');
-      Logger.logSuccess(`visualize message published to topic ${topicName}`)
+      if (options.traceVisualization) Logger.logSuccess(`visualize message published to topic ${topicName}`)
       // Logger.printMessage(message.dump(0), message.getUserPropertyMap(), message.getBinaryAttachment(), options.outputMode);
       session.send(message);
     } catch (error:any) {

diff --git a/src/lib/reply.ts b/src/lib/reply.ts
@@ -36,7 +36,7 @@ const reply = async (
 
   try {
     await replier.connect();
-    replier.subscribe(options.topic, message, optionsSource.message === 'default');
+    replier.subscribe(options.topic, message, optionsSource.message === 'cli');
   } catch (error:any) {
     Logger.logError('exiting...')
     process.exit(1)

diff --git a/src/types/global.d.ts b/src/types/global.d.ts
@@ -101,6 +101,7 @@ declare global {
     waitBeforeExit?: number
     exitAfter?: number
     outputMode?: string
+    traceVisualization?: boolean
 
     // Help Examples
     helpMore?: boolean

diff --git a/src/utils/defaults.ts b/src/utils/defaults.ts
@@ -221,6 +221,7 @@ export const defaultMessageReplyConfig:any = {
 
   waitBeforeExit: 0,
   exitAfter: 0,
+  traceVisualization: false,
 
   command: 'reply',
   name: 'reply',

diff --git a/src/utils/instances.ts b/src/utils/instances.ts
@@ -56,6 +56,7 @@ export class MessageClientOptionsEmpty implements StmConfigOptions, MessageConne
   outputMode?: string | undefined
   waitBeforeExit?: number | undefined;
   exitAfter?: number | undefined
+  traceVisualization?: boolean | undefined;
   helpMore?: boolean | undefined
   visualization?: string | boolean | undefined
   visualizationPort?: number | undefined
@@ -117,6 +118,7 @@ export class MessageClientOptionsEmpty implements StmConfigOptions, MessageConne
     this.outputMode = ""
     this.waitBeforeExit = 0;
     this.exitAfter = 0
+    this.traceVisualization = false;
     this.helpMore = false
     this.visualization = false
     this.visualizationPort = 0

diff --git a/src/utils/options.ts b/src/utils/options.ts
@@ -98,6 +98,7 @@ export const addSendOptions = (cmd: Command, advanced: boolean) => {
     .addOption(new Option('--wait-before-exit <NUMBER>', chalk.whiteBright('[advanced] wait for the specified number of seconds before exiting')) .argParser(parseNumber) .hideHelp(true))
     .addOption(new Option('--exit-after <NUMBER>', chalk.whiteBright('[advanced] exit the session after specified number of seconds')) .argParser(parseNumber) .hideHelp(true))
     .addOption(new Option('--log-level <LEVEL>', chalk.whiteBright('[advanced] solace log level, one of values: FATAL, ERROR, WARN, INFO, DEBUG, TRACE')) .argParser(parseLogLevel) .default(defaultMessageConnectionConfig.logLevel) .hideHelp(!advanced))
+    .addOption(new Option('--trace-visualization [BOOLEAN]', chalk.whiteBright('[advanced] trace visualization events')) .argParser(parseBoolean) .default(defaultMessageConfig.traceVisualization) .hideHelp(true))
 
     // publish options
     .addOption(new Option(`\n/* ${chalk.whiteBright('PUBLISH SETTINGS')} */`) .hideHelp(!advanced))
@@ -161,6 +162,7 @@ export const addReceiveOptions = (cmd: Command, advanced: boolean) => {
     .addOption(new Option('--reapply-subscriptions [BOOLEAN]', chalk.whiteBright('[advanced] reapply subscriptions upon calling on a disconnected session')) .argParser(parseBoolean) .default(defaultMessageConnectionConfig.reapplySubscriptions) .hideHelp(!advanced))  
     .addOption(new Option('--output-mode <MODE>', chalk.whiteBright('[advanced] message print mode: COMPACT, PRETTY, NONE')) .argParser(parseOutputMode) .default(defaultMessageConfig.outputMode) .hideHelp(!advanced))
     .addOption(new Option('--log-level <LEVEL>', chalk.whiteBright('[advanced] solace log level, one of values: FATAL, ERROR, WARN, INFO, DEBUG, TRACE')) .argParser(parseLogLevel) .default(defaultMessageConnectionConfig.logLevel) .hideHelp(!advanced))
+    .addOption(new Option('--trace-visualization [BOOLEAN]', chalk.whiteBright('[advanced] trace visualization events')) .argParser(parseBoolean) .default(defaultMessageConfig.traceVisualization) .hideHelp(true))
 
     // consumer options
     .addOption(new Option('--acknowledge-mode <MODE>', chalk.whiteBright('[advanced] the acknowledgement mode - AUTO or CLIENT')) .argParser( parseReceiverAcknowledgeMode) .default(defaultMessageReceiveConfig.acknowledgeMode) .hideHelp(!advanced))
@@ -215,6 +217,7 @@ export const addRequestOptions = (cmd: Command, advanced: boolean) => {
     .addOption(new Option('--wait-before-exit <NUMBER>', chalk.whiteBright('[advanced] wait for the specified number of seconds before exiting')) .argParser(parseNumber) .hideHelp(true))
     .addOption(new Option('--exit-after <NUMBER>', chalk.whiteBright('[advanced] exit the session after specified number of seconds')) .argParser(parseNumber) .hideHelp(true))
     .addOption(new Option('--log-level <LEVEL>', chalk.whiteBright('[advanced] solace log level, one of values: FATAL, ERROR, WARN, INFO, DEBUG, TRACE')) .argParser(parseLogLevel) .default(defaultMessageConnectionConfig.logLevel) .hideHelp(!advanced))
+    .addOption(new Option('--trace-visualization [BOOLEAN]', chalk.whiteBright('[advanced] trace visualization events')) .argParser(parseBoolean) .default(defaultMessageConfig.traceVisualization) .hideHelp(true))
 
     // request options
     .addOption(new Option(`\n/* ${chalk.whiteBright('REQUEST SETTINGS')} */`) .hideHelp(!advanced))
@@ -281,6 +284,7 @@ export const addReplyOptions = (cmd: Command, advanced: boolean) => {
     .addOption(new Option('--generate-sequence-number [BOOLEAN]', chalk.whiteBright('[advanced] include sequence number on messages sent')) .argParser(parseBoolean) .default(defaultMessageConnectionConfig.generateSequenceNumber) .hideHelp(!advanced))
     .addOption(new Option('--exit-after <NUMBER>', chalk.whiteBright('[advanced] exit the session after specified number of seconds')) .argParser(parseNumber) .hideHelp(true))
     .addOption(new Option('--log-level <LEVEL>', chalk.whiteBright('[advanced] solace log level, one of values: FATAL, ERROR, WARN, INFO, DEBUG, TRACE')) .argParser(parseLogLevel) .default(defaultMessageConnectionConfig.logLevel) .hideHelp(!advanced))
+    .addOption(new Option('--trace-visualization [BOOLEAN]', chalk.whiteBright('[advanced] trace visualization events')) .argParser(parseBoolean) .default(defaultMessageConfig.traceVisualization) .hideHelp(true))
 
     // publish options
     .addOption(new Option(`\n/* ${chalk.whiteBright('REPLY SETTINGS')} */`) .hideHelp(!advanced))