introduced connection and instance uuid for ris live

package.json

@@ -77,6 +77,7 @@
     "rpki-validator": "^2.7.4",
     "semver": "^7.3.5",
     "syslog-client": "^1.1.1",
+    "uuid": "^8.3.2",
     "ws": "^8.2.3",
     "yargs": "^17.2.1"
   },

src/connectors/connectorRIS.js

@@ -49,7 +49,8 @@ export default class ConnectorRIS extends Connector {
 
         this.url = brembo.build(this.params.url, {
             params: {
-                client: env.clientId
+                client: env.clientId,
+                instance: env.instanceId
             }
         });
         if (this.environment !== "research") { // The canary feature may impact performance if you are planning to get all the possible updates of RIS

src/env.js

@@ -39,6 +39,7 @@ import url from 'url';
 import RpkiUtils from './utils/rpkiUtils';
 import ConfigYml from './config/configYml';
 import Config from "./config/config";
+import { v4 as uuidv4 } from 'uuid';
 
 const configConnector = new (global.EXTERNAL_CONFIG_CONNECTOR || ConfigYml);
 const vector = {
@@ -192,5 +193,6 @@ vector.config = config;
 vector.logger = wlogger;
 vector.pubSub = new PubSub();
 vector.rpki = new RpkiUtils(vector);
+vector.instanceId = uuidv4();
 
 module.exports = vector;

src/utils/WebSocket.js

@@ -1,5 +1,7 @@
 import _ws from "ws";
 import PubSub from "../utils/pubSub";
+import brembo from "brembo";
+import { v4 as uuidv4 } from 'uuid';
 
 export default class WebSocket {
     constructor(host, options) {
@@ -53,7 +55,14 @@ export default class WebSocket {
     };
 
     _connect = () => {
-        this.ws = new _ws(this.host, this.options);
+        const url = brembo.build(this.host.split("?")[0], {
+            params: {
+                ...brembo.parse(this.host).params,
+                connection: uuidv4()
+            }
+        });
+
+        this.ws = new _ws(url, this.options);
 
         this.ws.on('message', (data) => {
             this.pubsub.publish("message", data);