96 lines
1.7 KiB
JavaScript
96 lines
1.7 KiB
JavaScript
const fs = require("fs");
|
|
const path = require("path");
|
|
const https = require("https");
|
|
const express = require("express");
|
|
const WebSocket = require("ws");
|
|
|
|
const config = require("./config/config");
|
|
const FluidNCClient = require("./fluidnc/FluidNCClient");
|
|
|
|
const app = express();
|
|
|
|
app.use(express.static(path.join(__dirname,"../web")));
|
|
|
|
const server = https.createServer({
|
|
key: fs.readFileSync(path.join(__dirname,"../cert/key.pem")),
|
|
cert: fs.readFileSync(path.join(__dirname,"../cert/cert.pem"))
|
|
},app);
|
|
|
|
const wss = new WebSocket.Server({server});
|
|
|
|
const fluid = new FluidNCClient();
|
|
|
|
let clients = [];
|
|
|
|
wss.on("connection",(ws)=>{
|
|
|
|
console.log("[WS] Client connected");
|
|
|
|
clients.push(ws);
|
|
|
|
ws.on("message",(msg)=>{
|
|
|
|
try{
|
|
|
|
const data = JSON.parse(msg);
|
|
|
|
console.log("[WS] Received message:", data);
|
|
|
|
if(data.type==="jog"){
|
|
|
|
fluid.jog(data.axis,data.value);
|
|
|
|
}
|
|
|
|
if(data.type==="gcode"){
|
|
|
|
fluid.sendGcode(data.cmd);
|
|
|
|
}
|
|
|
|
if(data.type==="zero"){
|
|
|
|
fluid.setZero();
|
|
|
|
}
|
|
|
|
}catch(e){
|
|
|
|
console.log("[WS] Error parsing message:", e);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
ws.on("close",()=>{
|
|
|
|
clients = clients.filter(c=>c!==ws);
|
|
|
|
console.log("[WS] Client disconnected");
|
|
|
|
});
|
|
|
|
});
|
|
|
|
fluid.onMessage((msg)=>{
|
|
|
|
const json = JSON.stringify(msg);
|
|
|
|
clients.forEach(c=>{
|
|
|
|
if(c.readyState===WebSocket.OPEN){
|
|
|
|
c.send(json);
|
|
|
|
}
|
|
|
|
});
|
|
|
|
});
|
|
|
|
server.listen(config.server.port,()=>{
|
|
|
|
console.log("[Server] Running at:");
|
|
console.log(`https://localhost:${config.server.port}`);
|
|
|
|
}); |