1 files changed, 29 insertions, 0 deletions

diff --git a/assets/js/serialUtil.js b/assets/js/serialUtil.js
new file mode 100644
index 0000000..8ce3c6e
--- /dev/null
+++ b/assets/js/serialUtil.js
@@ -0,0 +1,29 @@
+function delay(ms) {
+    return new Promise(resolve => setTimeout(resolve, ms));
+}
+
+async function openPortLineBreak(port, baudRate, outputErrorCallback) {
+    try {
+        await port.open({ baudRate: baudRate });
+    } catch (err) {
+        outputErrorCallback(`Error: ${err.message}`);
+        return;
+    }
+
+    const textDecoder = new TextDecoderStream();
+    const readableStreamClosed = port.readable.pipeTo(textDecoder.writable);
+    const reader = await textDecoder.readable.pipeThrough(new TransformStream(new LineBreakTransformer())).getReader();
+    const textEncoderStream = new TextEncoderStream();
+    const writerStreamClosed = textEncoderStream.readable.pipeTo(port.writable);
+    const writer = await textEncoderStream.writable.getWriter();
+
+    return { reader, writer, readableStreamClosed, writerStreamClosed };
+}
+
+async function closePortLineBreak(port, reader, writer, readableStreamClosed, writerStreamClosed) {
+    reader.cancel();
+    await readableStreamClosed.catch(() => { /* Ignore the error */ });
+    writer.close();
+    await writerStreamClosed;
+    await port.close();
+}