Initial commit

Author: 190n

.gitignore

@@ -0,0 +1 @@
+node_modules

index.js

@@ -0,0 +1,53 @@
+const WebSocket = require('ws');
+const SerialPort = require('serialport');
+const Readline = require('@serialport/parser-readline');
+
+const wss = new WebSocket.Server({ port: 8000, clientTracking: true });
+
+function broadcast(message) {
+    for (const client of wss.clients) {
+        if (client.readyState == WebSocket.OPEN) {
+            client.send(message);
+        }
+    }
+}
+
+const port = new SerialPort(process.argv[2]),
+    parser = port.pipe(new Readline());
+
+port.on('open', () => {
+    broadcast(JSON.stringify({ type: 'status', status: 'open' }));
+    console.log('open');
+});
+
+port.on('close', err => {
+    broadcast(JSON.stringify({ type: 'status', status: 'closed' }));
+    broadcast(JSON.stringify({ type: 'error', error: err.toString() }));
+    console.log(`closed: ${err.toString()}`);
+    setTimeout(() => port.open(), 1000);
+});
+
+port.on('error', err => {
+    broadcast(JSON.stringify({ type: 'error', error: err.toString() }));
+    console.log(`serialport error: ${err.toString()}`);
+    if (!port.isOpen) {
+        setTimeout(() => port.open(), 1000);
+    }
+});
+
+parser.on('data', line => {
+    let message;
+
+    try {
+        const data = JSON.parse(line);
+        message = JSON.stringify({ type: 'json', data });
+    } catch (e) {
+        message = JSON.stringify({ type: 'text', data: line });
+    }
+
+    broadcast(message);
+});
+
+wss.on('connection', client => {
+    client.send(JSON.stringify({ type: 'status', status: port.isOpen ? 'open' : 'closed' }));
+});

mock-server.js

@@ -0,0 +1,56 @@
+const WebSocket = require('ws');
+const readline = require('readline');
+
+let connected = false;
+
+const wss = new WebSocket.Server({ port: 8000, clientTracking: true });
+
+function broadcast(message) {
+    for (const client of wss.clients) {
+        if (client.readyState == WebSocket.OPEN) {
+            client.send(message);
+        }
+    }
+}
+
+function sendData() {
+    setTimeout(sendData, 500);
+    if (!connected) return;
+
+    broadcast(JSON.stringify({ type: 'json', data: { altitude: Math.random() * 100 }}));
+    broadcast(JSON.stringify({
+        type: 'json',
+        data: {
+            position: {
+                latDeg: Math.floor(Math.random() * 360 - 180),
+                longDeg: Math.floor(Math.random() * 360 - 180),
+                latMin: Math.random() * 60,
+                longMin: Math.random() * 60,
+                satellites: Math.floor(Math.random() * 3 + 5),
+            },
+        },
+    }));
+    broadcast(JSON.stringify({ type: 'json', data: { airspeed: Math.random() * 50 }}));
+    // still need orientation...that may end up in a different format
+}
+
+wss.on('connection', client => {
+    client.send(JSON.stringify({ type: 'status', status: connected ? 'open' : 'closed' }));
+});
+
+console.log('Listening on port 8000. Press enter to toggle whether port is connected.');
+process.stdout.write('Port is disconnected.');
+
+const rl = readline.createInterface({
+    input: process.stdin,
+    output: process.stdout,
+    terminal: false,
+});
+
+rl.on('line', line => {
+    connected = !connected;
+    process.stdout.write(`Port is ${connected ? 'connected' : 'disconnected'}.`);
+    broadcast(JSON.stringify({ type: 'status', status: connected ? 'open' : 'closed' }));
+});
+
+sendData();

package.json

@@ -0,0 +1,11 @@
+{
+  "name": "serial-proxy",
+  "version": "1.0.0",
+  "main": "index.js",
+  "license": "MIT",
+  "dependencies": {
+    "@serialport/parser-readline": "^8.0.6",
+    "serialport": "^8.0.7",
+    "ws": "^7.2.3"
+  }
+}