feat: send hello ech 10 seconds

eslint.config.mjs

@@ -2,7 +2,7 @@ import globals from "globals";
 import pluginJs from "@eslint/js";
 
 export default [
-  { files: ["**/*.js"], languageOptions: { sourceType: "commonjs" }, },
+  { files: ["**/*.js"], languageOptions: { sourceType: "commonjs" } },
   { languageOptions: { globals: globals.node } },
   pluginJs.configs.recommended,
 ];

index.js

@@ -69,28 +69,29 @@ function broadcastMessage(message) {
 }
 
 wss.on("connection", function connection(ws /*, req*/) {
-  //console.log('New connection');
-
   /*ws.on('open', function incoming(open) {
     //console.log('Open : %s', message);
   });*/
 
+  const interval_id = setInterval(function () {
+    ws.send(
+      JSON.stringify({
+        msg_type: "control:hello",
+        connection_timeout: 10000,
+      }),
+    );
+  }, 10000);
+
   ws.on("message", function incoming(message) {
     console.log("Data : %s", message);
     const js = JSON.parse(message);
     if (js.msg_type == "data:subscribe_oauth") {
       tags[js.tag] = ws;
     }
-    ws.send(
-      JSON.stringify({
-        msg_type: "control:hello",
-        connection_timeout: 600000,
-      }),
-    );
   });
 
-  ws.on("close", function close() {
-    //console.log('Close');
+  ws.once("close", function close() {
+    clearInterval(interval_id);
     let keys = Object.keys(tags);
     for (let i = 0; i < keys.length; i++) {
       if (this == tags[keys[i]]) {