Skip to content

Commit

Permalink
chore: Refactor socket connection handling to pass port number and da…
Browse files Browse the repository at this point in the history
…ta to onData function
  • Loading branch information
drazisil committed May 31, 2024
1 parent c8ff736 commit 609aa01
Showing 1 changed file with 10 additions and 8 deletions.
18 changes: 10 additions & 8 deletions packages/main/src/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -28,20 +28,23 @@ let loginServer;
let personaServer;

/**
*
* @param {number} port
* @param {Buffer} data
*/
function onData(data) {
function onData(port, data) {
const hex = data.toString("hex");
console.log(`Data received: ${hex}`);
}

/**
* @param {NodeJS.Socket} socket
* @param {import("node:net").Socket} socket
* @param {(port:number, data: Buffer) => void} onData
*/
function onSocketConnection(socket) {
function onSocketConnection(socket, onData) {
console.log("Connection established");
socket.on("data", onData);
socket.on("data", (data) => {
onData(socket.localPort ?? -1, data);
});
}

/**
Expand Down Expand Up @@ -102,7 +105,6 @@ function onSocketListening(s) {
const port = getPort(s);

console.log(`Server listening on port ${port}`);
s.on("connection", onSocketConnection);
s.on("close", () => {
console.log(`Server on port ${port} closed`);
});
Expand Down Expand Up @@ -133,13 +135,13 @@ export default function main() {
loginServer = new TCPServer(
8226,
onSocketListening,
onSocketConnection,
(socket) => onSocketConnection(socket, onData),
onServerError
);
personaServer = new TCPServer(
8228,
onSocketListening,
onSocketConnection,
(socket) => onSocketConnection(socket, onData),
onServerError
);

Expand Down

0 comments on commit 609aa01

Please sign in to comment.