path: root/assets/js/serialUtil.js

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();
}