Server and client in node

Author: gzukowski

raspberry-pi/cl_seq/index.js

@@ -0,0 +1,24 @@
+const { PassThrough } = require("stream");
+const ws = require('ws');
+
+
+
+module.exports = [
+    { requires: "pipe", contentType: 'text/plain' },
+    function(input) {
+		const client = new ws('ws://localhost:3000');
+        const out = new PassThrough({ objectMode: true });
+
+		async function reader(client) {
+			for await (const chunk of input) {
+				client.send(chunk);
+			}
+		  }
+		client.on('open', () => {
+			reader(client);
+		});
+        
+
+        return out;
+    }
+];

raspberry-pi/cl_seq/package.json

@@ -0,0 +1,26 @@
+{
+  "name": "cl_seq",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "predeploy": "mkdir -p dist/ && cp index.js package.json dist/ && (cd dist && npm i --omit=dev)"
+  },
+  "engines": {
+    "node": ">=16"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/scramjetorg/create-sequence.git"
+  },
+  "bugs": {
+    "url": "https://github.com/scramjetorg/create-sequence/issues"
+  },
+  "homepage": "https://github.com/scramjetorg/create-sequence#readme",
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "JSONStream": "^1.3.5",
+    "scramjet": "^4.36.6"
+  }
+}

raspberry-pi/ser_seq/index.js

@@ -0,0 +1,23 @@
+const express = require('express');
+const expressWs = require('express-ws');
+const ws = require('ws');
+var http = require('http');
+
+
+module.exports = async function(input) {
+const app = express();
+
+const wsServer = new ws.Server({ noServer: true });
+wsServer.on('connection', socket => {
+  console.log("connected");
+  socket.on('message', message => console.log('received: %s', message));
+});
+
+const server = app.listen(3000);
+server.on('upgrade', (request, socket, head) => {
+  wsServer.handleUpgrade(request, socket, head, socket => {
+    wsServer.emit('connection', socket, request);
+  });
+});
+return input;
+};

raspberry-pi/ser_seq/package.json

@@ -0,0 +1,28 @@
+{
+  "name": "ser_seq",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "predeploy": "mkdir -p dist/ && cp index.js package.json dist/ && (cd dist && npm i --omit=dev)"
+  },
+  "engines": {
+    "node": ">=16"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/scramjetorg/create-sequence.git"
+  },
+  "bugs": {
+    "url": "https://github.com/scramjetorg/create-sequence/issues"
+  },
+  "homepage": "https://github.com/scramjetorg/create-sequence#readme",
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "express" : "*",
+    "express-ws" : "*",
+    "http" : "*"
+  }
+
+}