From f18a23bb46dd3c8a1b501b4748e68d61d885a99c Mon Sep 17 00:00:00 2001
From: "M. Umar Shahbaz" <shahbazu628@gmail.com>
Date: Sat, 31 Aug 2024 22:56:30 +0500
Subject: [PATCH] trying USB?

---
 oscilloscope.html               | 76 +++++++++++++++++++++++++++++----
 scripts/Serial.js               |  0
 scripts/oscilloscope-setting.js |  5 +--
 3 files changed, 70 insertions(+), 11 deletions(-)
 delete mode 100644 scripts/Serial.js
diff --git a/oscilloscope.html b/oscilloscope.html
index bf4396e..feef91b 100644
--- a/oscilloscope.html
+++ b/oscilloscope.html
@@ -8,24 +8,56 @@
     <!--Add Stylesheet-->
     <link rel="stylesheet" type="text/css" href="css/home.css" />
 
-    <!--include custom scripts-->
-    <!--<script src="scripts/GPC.js"></script>-->
     <!--Graph Plotter Controller-->
     <script src="scripts/GraphPlotter.js"></script>
-    <!--Serial Communications Handler-->
-    <script src="scripts/Serial.js"></script>
-    <!--Oscilloscope Settings-->
     
-
     <meta charset="utf-8" />
     <title>Oscilloscope</title>
   </head>
   <body>
+    <button id="connect">Connect</button>
   </body>
-  <!--<script src="scripts/oscilloscope-setting.js"></script>
-  <script>console.log(window.settings);</script>-->
   <script>
     var settings;
+    let myPort;
+
+    async function readAndStoreSerialData(port, onDataCallback) {
+    try {
+        const textDecoder = new TextDecoderStream();
+        const readableStreamClosed = port.readable.pipeTo(textDecoder.writable);
+        const reader = textDecoder.readable.getReader();
+
+        let buffer = ''; // Buffer to accumulate incoming data
+
+        // Continuously read data from the port
+        while (true) {
+            const { value, done } = await reader.read();
+            if (done) {
+                reader.releaseLock();
+                break;
+            }
+            if (value) {
+                buffer += value; // Append the received chunk to the buffer
+                
+                // Check if the buffer contains a newline character
+                let newlineIndex;
+                while ((newlineIndex = buffer.indexOf('\n')) !== -1) {
+                    // Extract the message up to the newline
+                    const message = buffer.slice(0, newlineIndex).trim();
+
+                    // Process the complete message
+                    onDataCallback(message);
+
+                    // Remove the processed message from the buffer
+                    buffer = buffer.slice(newlineIndex + 1);
+                }
+            }
+        }
+    } catch (error) {
+        console.error('Error reading from serial port:', error);
+    }
+}
+
     window.addEventListener('DOMContentLoaded', (event) => {
         // Retrieve the settings from localStorage
         const storedSettings = sessionStorage.getItem('settings');
@@ -38,8 +70,16 @@
             console.log('No settings found');
         }
     });
+    document.getElementById('connect').addEventListener('click', async(event) => {
+      myPort = await navigator.serial.requestPort();
+      await myPort.open({ baudRate: 9600 });
+      readAndStoreSerialData(myPort, DataHandler);
+      console.log("opened port");
+    });
 
     let gp;
+    let readingNo = 0;
+    let a, b, c, d;
 
     function setup() {
       pixelDensity(2.5);
@@ -52,10 +92,30 @@
       gp.GraphSetup(settings.drawPoints, settings.drawSubGrid, settings.xAxisTitle, settings.yAxisTitle);
       gp.GridSetup(settings.minY, settings.maxY, settings.yGap, settings.minX, settings.maxX, settings.xGap);
       gp.SizeSetup(width, height);
+
+      a = new Array(gp.totalPoints).fill(0);
+      b = new Array(gp.totalPoints).fill(0);
+      c = new Array(gp.totalPoints).fill(0);
+      d = new Array(gp.totalPoints).fill(0);
+    }
+
+    function DataHandler(data) {
+      console.log(data);
+      a[readingNo] = float(data.substring(data.indexOf('a') + 1, data.indexOf('b')));
+      b[readingNo] = float(data.substring(data.indexOf('b') + 1, data.indexOf('c')));
+      c[readingNo] = float(data.substring(data.indexOf('c') + 1, data.indexOf('d')));
+      //d[readingNo] = float(data.substring(data.indexOf('d') + 1));
+
+      readingNo = (readingNo + 1) % (gp.totalPoints + 1);
+      draw();
     }
 
     function draw() {
       gp.DrawGrid();
+      gp.DrawGraph(a, color(255, 0, 0));
+      gp.DrawGraph(b, color(0, 0, 255));
+      gp.DrawGraph(c, color(0, 255, 0));
+      gp.DrawGraph(d, color(255, 190, 0));
     }
   </script>
 </html>
diff --git a/scripts/Serial.js b/scripts/Serial.js
deleted file mode 100644
index e69de29..0000000
diff --git a/scripts/oscilloscope-setting.js b/scripts/oscilloscope-setting.js
index fef40b9..0938ac7 100644
--- a/scripts/oscilloscope-setting.js
+++ b/scripts/oscilloscope-setting.js
@@ -4,7 +4,6 @@ if (!window.settings) {
 
 document.getElementById('settingsForm').addEventListener('submit', async(event) => {
     event.preventDefault();
-    const port = await navigator.serial.requestPort();
     const formData = new FormData(event.target);
     window.settings = {
         drawPoints: formData.get('drawPoints') !== null,
@@ -17,9 +16,9 @@ document.getElementById('settingsForm').addEventListener('submit', async(event)
         minX: parseInt(formData.get('minX')),
         maxX: parseInt(formData.get('maxX')),
         xGap: parseFloat(formData.get('xGap')),
-        baud: parseInt(formData.get('baudrate')),
-        port: port
+        baud: parseInt(formData.get('baudrate'))
     };
     sessionStorage.setItem('settings', JSON.stringify(settings));
+    //console.log(settings);
     window.location.href = "oscilloscope.html";     
 });
\ No newline at end of file
