@@ -11,6 +11,8 @@ const { Validators } = require('./validators');
1111const { HealthChecker } = require ( './health-checker' ) ;
1212const { displayValidationResults, displayTopicSummary } = require ( './utils' ) ;
1313const { SupabaseAnalytics } = require ( './analytics' ) ;
14+ const { NATSObjectStore } = require ( './nats-object-store' ) ;
15+ const { log } = require ( 'console' ) ;
1416
1517class CLI {
1618 constructor ( options = { } ) {
@@ -21,6 +23,7 @@ class CLI {
2123 } ;
2224 this . kafkaClient = null ;
2325 this . fileService = null ;
26+ this . natsObjectStore = null ;
2427 this . analytics = new SupabaseAnalytics ( ) ;
2528
2629 // Handle bootstrap-servers option mapping to brokers
@@ -115,6 +118,39 @@ class CLI {
115118 }
116119 }
117120
121+ async loadNATSConfig ( natsConfigPath ) {
122+ try {
123+ const fullPath = path . resolve ( natsConfigPath ) ;
124+ if ( ! fs . existsSync ( fullPath ) ) {
125+ throw new Error ( `NATS config file not found: ${ fullPath } ) ;
126+ }
127+
128+ const configContent = fs . readFileSync ( fullPath , 'utf8' ) ;
129+ const natsConfig = JSON . parse ( configContent ) ;
130+
131+ // Create NATS object store
132+ this . natsObjectStore = new NATSObjectStore ( natsConfig ) ;
133+
134+ // Connect to NATS
135+ const connected = await this . natsObjectStore . connect ( ) ;
136+ if ( ! connected ) {
137+ throw new Error ( 'Failed to connect to NATS' ) ;
138+ }
139+
140+ // Setup object store bucket
141+ const bucketReady = await this . natsObjectStore . getOrCreateBucket ( ) ;
142+ if ( ! bucketReady ) {
143+ throw new Error ( 'Failed to setup Object Store bucket' ) ;
144+ }
145+
146+ console . log ( chalk . green ( `✅ NATS configuration loaded from: ${ fullPath } ) ) ;
147+ return true ;
148+ } catch ( error ) {
149+ console . error ( chalk . red ( `❌ Failed to load NATS config file: ${ error . message } ) ) ;
150+ return false ;
151+ }
152+ }
153+
118154 async promptForConfig ( ) {
119155 console . log ( chalk . blue ( '\n🚀 Superstream Kafka Analyzer\n' ) ) ;
120156 console . log ( chalk . gray ( 'Configure your analysis settings:\n' ) ) ;
@@ -177,6 +213,7 @@ class CLI {
177213
178214 // Authentication configuration based on vendor
179215 let saslConfig = null ;
216+ let sslConfig = null ;
180217 if ( vendorAnswer . vendor === 'aws-msk' ) {
181218 console . log ( chalk . yellow ( '\n🔐 AWS MSK Authentication' ) ) ;
182219 const authType = await inquirer . prompt ( [
@@ -268,27 +305,50 @@ class CLI {
268305 {
269306 type : 'input' ,
270307 name : 'username' ,
271- message : 'Username:' ,
308+ message : 'Username (leave empty is using SSL only) :' ,
272309 validate : ( input ) => {
273- if ( ! input . trim ( ) ) return 'Username is required for Aiven' ;
274310 return true ;
275311 }
276312 } ,
277313 {
278314 type : 'password' ,
279315 name : 'password' ,
280- message : 'Password:' ,
316+ message : 'Password (leave empty if using SSL only) :' ,
281317 validate : ( input ) => {
282- if ( ! input . trim ( ) ) return 'Password is required for Aiven' ;
283318 return true ;
284319 }
320+ } ,
321+ {
322+ type : 'input' ,
323+ name : 'caPath' ,
324+ message : 'CA Certificate path (optional, e.g., "./certs/ca.pem"):' ,
325+ default : './certs/ca.pem'
326+ } ,
327+ {
328+ type : 'input' ,
329+ name : 'certPath' ,
330+ message : 'Client Certificate path (optional, eg. "./certs/service.cert"):' ,
331+ default : './certs/service.cert' ,
332+ } ,
333+ {
334+ type : 'input' ,
335+ name : 'keyPath' ,
336+ message : 'Client Private Key path (optional, eg. "./certs/service.key"):' ,
337+ default : './certs/service.key' ,
285338 }
286339 ] ) ;
340+
287341 saslConfig = {
288342 mechanism : 'scram-sha-256' ,
289343 username : aivenAnswers . username ,
290344 password : aivenAnswers . password
291345 } ;
346+
347+ sslConfig = {
348+ ca : aivenAnswers . caPath ,
349+ cert : aivenAnswers . certPath ,
350+ key : aivenAnswers . keyPath
351+ } ;
292352 } else {
293353 // For other vendors, ask if SASL is needed
294354 const useSasl = await inquirer . prompt ( [
@@ -346,7 +406,8 @@ class CLI {
346406 brokers : kafkaAnswers . brokers . split ( ',' ) . map ( broker => broker . trim ( ) ) , // Convert string to array
347407 vendor : vendorAnswer . vendor ,
348408 useSasl : ! ! saslConfig ,
349- sasl : saslConfig
409+ sasl : saslConfig ,
410+ ssl : sslConfig
350411 } ;
351412
352413 // File Output Configuration
@@ -417,6 +478,7 @@ class CLI {
417478
418479 // Use Commander.js options
419480 const configPath = this . options . config ;
481+ const natsConfigPath = this . options . natsConfig ;
420482
421483 if ( configPath ) {
422484 console . log ( chalk . gray ( `Debug: Loading config from: ${ configPath } ) ) ;
@@ -430,6 +492,16 @@ class CLI {
430492 await this . promptForConfig ( ) ;
431493 }
432494
495+ // Load NATS config if provided
496+ if ( natsConfigPath ) {
497+ console . log ( chalk . gray ( `Debug: Loading NATS config from: ${ natsConfigPath } ) ) ;
498+ const natsConfigLoaded = await this . loadNATSConfig ( natsConfigPath ) ;
499+ if ( ! natsConfigLoaded ) {
500+ process . exit ( 1 ) ;
501+ }
502+ console . log ( chalk . gray ( 'Debug: NATS config loaded successfully' ) ) ;
503+ }
504+
433505 // Initialize services without validation
434506 console . log ( chalk . yellow ( '\n⚠️ Validation skipped - proceeding directly to analysis' ) ) ;
435507 this . kafkaClient = new KafkaClient ( this . config . kafka ) ;
@@ -582,6 +654,16 @@ class CLI {
582654 if ( healthResults ) {
583655 analysisResults . healthChecks = healthResults ;
584656 }
657+
658+ // Store results in NATS
659+ if ( this . options . natsConfig ) {
660+ spinner . text = 'Saving results to NATS...' ;
661+ spinner . render ( ) ;
662+ await this . natsObjectStore . storeObject ( analysisResults ) ;
663+ spinner . stop ( ) ;
664+ console . log ( chalk . green ( '\n✅ Analysis completed and stored to NATS!' ) ) ;
665+ process . exit ( 0 ) ;
666+ }
585667
586668 // Check if email is provided for file generation
587669 if ( this . config . email && this . config . email . trim ( ) ) {
0 commit comments