From b8a15df6152121dd7095389272d74236b593fcae Mon Sep 17 00:00:00 2001
From: Ernesto Castellotti <mail@ernestocastellotti.it>
Date: Wed, 7 Jun 2023 23:15:28 +0200
Subject: Convert changeBaudrate, waitEndImageLoad and flashImageMtd to
 SerialReadWrite (#229)

* Convert changeBaudrate, waitEndImageLoad and flashImageMtd to SerialReadWrite

* fix
---
 assets/js/rootLantiq.js | 58 ++++++++++++++++++-------------------------------
 1 file changed, 21 insertions(+), 37 deletions(-)

diff --git a/assets/js/rootLantiq.js b/assets/js/rootLantiq.js
index f13690c..433b060 100644
--- a/assets/js/rootLantiq.js
+++ b/assets/js/rootLantiq.js
@@ -132,34 +132,31 @@ async function unlockHuaweiShell(port, outputMsgCallback, outputErrorCallback, b
 }
 
 async function changeBaudrate(port, newBaudrate, currBaudrate, outputErrorCallback) {
-    let reader,writer, readableStreamClosed, writerStreamClosed;
+    let serial = new SerialReadWrite(port, currBaudrate);
 
     try {
-        ({ reader, writer, readableStreamClosed, writerStreamClosed } = await openPortLineBreak(port, currBaudrate));
-        await writer.write(`setenv baudrate ${newBaudrate}\n`);
+        await serial.writeString(`setenv baudrate ${newBaudrate}\n`);
         await delay(1000);
-        await closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed);
-        ({ reader, writer, readableStreamClosed, writerStreamClosed } = await openPortLineBreak(port, newBaudrate));
+        await serial.closePort();
+        serial = new SerialReadWrite(port, newBaudrate);
 
         const interval = setInterval(function() {
-            writer.write(String.fromCharCode(13));
+            serial.writeString(String.fromCharCode(13));
         }, 10);
 
-        while (true) {
-            const { value, done } = await reader.read();
-
-            if (value.startsWith('FALCON')) {
+        await serial.readLine((line) => {
+            if (line.startsWith('FALCON')) {
                 clearInterval(interval);
-                break;
+                return true;
             }
-        }
+        });
 
-        await closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed);
         return true;
     } catch (err) {
         outputErrorCallback(`Error: ${err.message}`);
-        await closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed);
         return false;
+    } finally {
+        await serial.closePort();
     }
 }
 
@@ -197,48 +194,35 @@ async function sendImageMtd(port, data, baudRate, outputErrorCallback, progressC
 }
 
 async function waitEndImageLoad(port, baudRate, outputErrorCallback) {
-    let reader, writer, readableStreamClosed, writerStreamClosed;
+    const serial = new SerialReadWrite(port, baudRate);
 
     try {
-        ({ reader, writer, readableStreamClosed, writerStreamClosed } = await openPortLineBreak(port, baudRate));
-
-        while (true) {
-            const { value, done } = await reader.read();
-
-            if (value.includes('Total Size')) {
-                break;
+        await serial.readLine((line) => {
+            if (line.includes('Total Size')) {
+                return true;
             }
-        }
+        });
 
         await delay(1000);
-        await closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed);
         return true;
     } catch (err) {
         outputErrorCallback(`Error: ${err.message}`);
-        await closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed);
         return false;
+    } finally {
+        await serial.closePort();
     }
 }
 
 async function flashImageMtd(port, image, baudRate, outputErrorCallback) {
-    let reader, writer, readableStreamClosed, writerStreamClosed;
+    const serial = new SerialReadWrite(port, baudRate);
 
     try {
-        ({ reader, writer, readableStreamClosed, writerStreamClosed } = await openPortLineBreak(port, baudRate));
         if (image == "image0") {
-            await writer.write(`sf probe 0 && sf erase ${IMAGE0_ADDR} && sf write ${LOAD_ADDR} ${IMAGE0_ADDR} && setenv committed_image 0 && setenv image0_is_valid 1 && saveenv && reset\n`);
+            await serial.writeString(`sf probe 0 && sf erase ${IMAGE0_ADDR} && sf write ${LOAD_ADDR} ${IMAGE0_ADDR} && setenv committed_image 0 && setenv image0_is_valid 1 && saveenv && reset\n`);
         } else {
-            await writer.write(`sf probe 0 && sf erase ${IMAGE1_ADDR} && sf write ${LOAD_ADDR} ${IMAGE1_ADDR} && setenv committed_image 1 && setenv image1_is_valid 1 && saveenv && reset\n`);
+            await serial.writeString(`sf probe 0 && sf erase ${IMAGE1_ADDR} && sf write ${LOAD_ADDR} ${IMAGE1_ADDR} && setenv committed_image 1 && setenv image1_is_valid 1 && saveenv && reset\n`);
         }
-    } catch (err) {
-        outputErrorCallback(`Error: ${err.message}`);
-        return false;
-    } finally {
-        await closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed);
-    }
 
-    const serial = new SerialReadWrite(port, baudRate);
-    try {
         /* Wait to avoid the user from disconnecting the SFP while the image is being flashed */
         await delay(1000);
         await detectUboot(serial);
-- 
cgit v1.2.3