fixing issues

This commit is contained in:
daniel muniz
2024-06-11 15:59:19 -03:00
parent 13f6aa8ecb
commit 91efaa8e5c
3 changed files with 21 additions and 9 deletions

1
.gitignore vendored Normal file
View File

@@ -0,0 +1 @@
node_modules

View File

@@ -1,10 +1,13 @@
const dgram = require('dgram'); const dgram = require('dgram');
const client = dgram.createSocket('udp4'); const client = dgram.createSocket('udp4');
const message = Buffer.from('facebook.com'); const message = 'bet365.com';
const serverHost = 'localhost'; const serverHost = '209.97.181.89';
const serverPort = 41234; const serverPort = 33333;
// const serverHost = 'localhost';
// const serverPort = 41234;
client.send(message, 0, message.length, serverPort, serverHost, (err) => { client.send(message, 0, message.length, serverPort, serverHost, (err) => {
if (err) { if (err) {
@@ -15,14 +18,11 @@ client.send(message, 0, message.length, serverPort, serverHost, (err) => {
} }
}); });
// Handle incoming messages from the server
client.on('message', (msg, rinfo) => { client.on('message', (msg, rinfo) => {
console.log(`Client received: ${msg} from ${rinfo.address}:${rinfo.port}`); console.log(`Client received: ${msg} from ${rinfo.address}:${rinfo.port}`);
// Close the client socket if you don't expect any more messages
client.close(); client.close();
}); });
// Optional: handle any errors
client.on('error', (err) => { client.on('error', (err) => {
console.log(`Client error: ${err.stack}`); console.log(`Client error: ${err.stack}`);
client.close(); client.close();

View File

@@ -10,9 +10,17 @@ server.on('error', (err) => {
server.on('message', async (msg, rinfo) => { server.on('message', async (msg, rinfo) => {
console.log(`Server got: ${msg} from ${rinfo.address}:${rinfo.port}`); console.log(`Server got: ${msg} from ${rinfo.address}:${rinfo.port}`);
const categories = await app(msg.toString()) const strMsg = msg.toString()
const categories = await app(strMsg)
server.send(categories, rinfo.port, rinfo.address, (err) => { let result = {}
if (categories)
result = {
result: categories
}
server.send(JSON.stringify(result), rinfo.port, rinfo.address, (err) => {
if (err) server.close(); if (err) server.close();
}); });
}); });
@@ -22,4 +30,7 @@ server.on('listening', () => {
console.log(`Server listening ${address.address}:${address.port}`); console.log(`Server listening ${address.address}:${address.port}`);
}); });
server.bind(41234); server.bind(41234);
// Response
// {"result":[10009]}