nats script

nats.js

@@ -0,0 +1,73 @@
+// const nats = require('nats');
+// const fs = require('fs');
+
+// const privateKey = fs.readFileSync('clientCertificate/client-key.pem');
+// const certificate = fs.readFileSync('clientCertificate/client-cert.pem');
+
+// const nc = nats.connect({
+//   servers: ['nats://nanodgx.in:4222'],
+//   token: 'SUADA3R4HRQG5ZEGR7E65P5P2JUQ2LMVLEOGJWEIKLEYOZEPQES2WHW2KU',
+//   tls: {
+//     key: privateKey,
+//     cert: certificate,
+//   },
+//   connect: function() {
+//     console.log('Connected to NATS server');
+
+//     // Subscribe to a subject
+//     const subscription = nc.subscribe('your-subject');
+
+//     // Listen for incoming messages
+//     subscription.on('message', function(msg) {
+//       console.log(`Received message: ${msg.getData()}`);
+//     });
+
+//     // Publish a message
+//     nc.publish('your-subject', 'Hello NATS!');
+//   },
+//   error: function(err) {
+//     console.error(`Error connecting to NATS server: ${err}`);
+//   },
+//   close: function() {
+//     console.log('Connection to NATS server closed');
+//   },
+// });
+
+
+const NATS = require('nats');
+const sc = NATS.StringCodec();
+const seed = new TextEncoder().encode(
+  "SUADA3R4HRQG5ZEGR7E65P5P2JUQ2LMVLEOGJWEIKLEYOZEPQES2WHW2KU",
+);
+const servers = [
+  {
+    servers: "nats://nanodgx.in:4222",
+
+    authenticator: NATS.nkeyAuthenticator(seed),
+    tls: {
+      keyFile: "certificate_path/client-key.pem",
+      certFile: "certificate_path/client-cert.pem",
+    },
+  },
+];
+
+servers.forEach(async (v) => {
+  try {
+    // console.log(v);
+    const nc = await NATS.connect(v);
+
+    // Subscribe to a subject
+    const subscription = await nc.subscribe("server.hpos.HCV-000-3001.ping");
+
+    // // Handler for incoming messages
+    // subscription.on('message', (msg) => {
+    //   console.log(`Received message: ${sc.decode(msg.data)}`);
+    // });
+    //console.log(subscription.);
+
+    // nc.publish("server.hpos.HPP1-000-2001.ping", "ALIVE");
+
+  } catch (err) {
+    console.log(`error connecting to ${JSON.stringify(v)} ${err}`);
+  }
+});