Improve msp send

src/js/main.js

@@ -18,6 +18,16 @@ import { updateTabList } from "./utils/updateTabList.js";
 import * as THREE from "three";
 import NotificationManager from "./utils/notifications.js";
 
+import("./msp/debug/msp_debug_tools.js")
+    .then(() => {
+        console.log("🔧 MSP Debug Tools loaded for development environment");
+        console.log("• Press Ctrl+Shift+M to toggle debug dashboard");
+        console.log("• Use MSPTestRunner.help() for all commands");
+    })
+    .catch((err) => {
+        console.warn("Failed to load MSP debug tools:", err);
+    });
+
 if (typeof String.prototype.replaceAll === "undefined") {
     String.prototype.replaceAll = function (match, replace) {
         return this.replace(new RegExp(match, "g"), () => replace);
@@ -118,7 +128,8 @@ function startProcess() {
     console.log(`Libraries: jQuery - ${$.fn.jquery}, three.js - ${THREE.REVISION}`);
 
     // Check if this is the first visit
-    if (getConfig("firstRun").firstRun === undefined) {
+    const firstRunCfg = getConfig("firstRun") ?? {};
+    if (firstRunCfg.firstRun === undefined) {
         setConfig({ firstRun: true });
         import("./tabs/static_tab.js").then(({ staticTab }) => {
             staticTab.initialize("options", () => {

src/js/msp.js

@@ -51,16 +51,13 @@ const MSP = {
     message_buffer: null,
     message_buffer_uint8_view: null,
     message_checksum: 0,
-    messageIsJumboFrame: false,
     crcError: false,
 
     callbacks: [],
     packet_error: 0,
     unsupported: 0,
 
-    MIN_TIMEOUT: 200,
-    MAX_TIMEOUT: 2000,
-    timeout: 200,
+    TIMEOUT: 1000,
 
     last_received_timestamp: null,
     listeners: [],
@@ -378,28 +375,19 @@ const MSP = {
         serial.send(bufferOut);
     },
     send_message(code, data, callback_sent, callback_msp, doCallbackOnError) {
-        const connected = serial.connected;
-
-        if (code === undefined || !connected || CONFIGURATOR.virtualMode) {
+        if (code === undefined || !serial.connected || CONFIGURATOR.virtualMode) {
             if (callback_msp) {
                 callback_msp();
             }
             return false;
         }
 
-        let requestExists = false;
-        for (const instance of this.callbacks) {
-            if (instance.code === code) {
-                requestExists = true;
-
-                break;
-            }
-        }
+        const requestExists = this.callbacks.some((instance) => instance.code === code);
 
         const bufferOut = code <= 254 ? this.encode_message_v1(code, data) : this.encode_message_v2(code, data);
 
         const obj = {
-            code: code,
+            code,
             requestBuffer: bufferOut,
             callback: callback_msp,
             callbackOnError: doCallbackOnError,
@@ -416,31 +404,31 @@ const MSP = {
                 serial.send(bufferOut, (_sendInfo) => {
                     obj.stop = performance.now();
                     const executionTime = Math.round(obj.stop - obj.start);
-                    this.timeout = Math.max(this.MIN_TIMEOUT, Math.min(executionTime, this.MAX_TIMEOUT));
+                    // We should probably give up connection if the request takes too long ?
+                    if (executionTime > 5000) {
+                        console.warn(
+                            `MSP: data request took too long: ${code} ID: ${serial.connectionId} TAB: ${GUI.active_tab} EXECUTION TIME: ${executionTime}ms`,
+                        );
+                    }
+
+                    clearTimeout(obj.timer); // prevent leaks
                 });
-            }, this.timeout);
+            }, this.TIMEOUT);
         }
 
         this.callbacks.push(obj);
 
         // always send messages with data payload (even when there is a message already in the queue)
         if (data || !requestExists) {
-            if (this.timeout > this.MIN_TIMEOUT) {
-                this.timeout--;
-            }
-
             serial.send(bufferOut, (sendInfo) => {
-                if (sendInfo.bytesSent === bufferOut.byteLength) {
-                    if (callback_sent) {
-                        callback_sent();
-                    }
+                if (sendInfo.bytesSent === bufferOut.byteLength && callback_sent) {
+                    callback_sent();
                 }
             });
         }
 
         return true;
     },
-
     /**
      * resolves: {command: code, data: data, length: message_length}
      */