diff --git a/index.js b/index.js index c32423e..5f82ab6 100644 --- a/index.js +++ b/index.js @@ -1,7 +1,7 @@ import * as server from './server.js'; console.log(server) -server.default( +server.recv( (res) => { console.log(`callback: ${res}`); }, diff --git a/server.js b/server.js index 2c50bd7..6ff566b 100644 --- a/server.js +++ b/server.js @@ -1,21 +1,36 @@ import * as net from 'net'; const hostname = '0.0.0.0'; -const port = 29997; +const port = 29999; -export default function recv(callback, errorCallback) { - let server = new net.Server(); - server.listen(port, hostname, () => { - server.on('connect', ()=>{ - console.log('connection recieved') - }) - server.on('data', (data) => { - callback(data) - }) - }); +export function recv(callback, errorCallback) { + let server = new net.Server(); + server.listen(port, hostname, () => { + server.on('connection', (con) => { + console.log('connection recieved: ' + + con.remoteAddress + ":" + con.remotePort); + con.on('data', (data) => { + callback(data); + }); + con.on('close', () => { + console.log('recieved close for ' + + con.remoteAddress + ":" + con.remotePort); + con.destroy(); + }); - server.on('error', (e) => { - server.close(); - errorCallback(e); - }); + server.getConnections((err, cons) => { + if (err) { + console.error(err); + } + else { + console.log(`connections: ${cons}`); + } + }) + }) + + server.on('error', (e) => { + server.close(); + errorCallback(e); + }); + }); }