-
Notifications
You must be signed in to change notification settings - Fork 0
/
tcpServer.js
73 lines (60 loc) · 1.81 KB
/
tcpServer.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
/* eslint-disable no-undef */
import net from "net";
import { turnOffChannel } from "./modbus.js";
import { accionador } from "./utils.js";
import { io } from "./index.js";
const tcpPort = process.env.TCP_SERVER_PORT || 3012;
let shouldListenForHello = false;
let shouldListenForPairing = false;
let rfid = "";
let emparejamientos = [];
let code = "";
export const startListeningForHello = (codigoGanador) => {
shouldListenForHello = true;
code = codigoGanador;
};
export const startPairingProcess = (rfidCode) => {
rfid = rfidCode;
shouldListenForPairing = true;
};
export const updateRFID = (newRFID) => {
rfid = newRFID;
};
const tcpServer = net.createServer((socket) => {
console.log("Conectado 🎗");
socket.on("data", async (data) => {
const message = data.toString().trim();
console.log("Datos:", message);
if (shouldListenForHello && message === code) {
setTimeout(async () => {
await turnOffChannel(1);
accionador();
}, 1000);
shouldListenForHello = false;
}
if (shouldListenForPairing) {
const nuevoEmparejamiento = { idHex: rfid, codigoProducto: message };
emparejamientos.push(nuevoEmparejamiento);
io.emit("nuevoEmparejamiento", nuevoEmparejamiento);
}
});
socket.write("Hola, cliente. Te has conectado exitosamente al servidor.");
socket.on("end", () => {
console.log("Cliente desconectado.");
});
socket.on("error", (error) => {
console.error("Se ha producido un error:", error);
});
});
tcpServer.listen(tcpPort, () => {
console.log(`Servidor TCP escuchando en el puerto ${tcpPort}`);
});
tcpServer.on("error", (error) => {
console.error("Error del servidor TCP:", error);
});
export const getPairings = () => {
return emparejamientos;
};
export const clearPairings = () => {
emparejamientos = [];
};