Working fairly well

This commit is contained in:
Bryan Ashby 2020-05-17 22:35:03 -06:00
parent 1018485e8e
commit e517e31b94
1 changed files with 65 additions and 7 deletions

View File

@ -20,8 +20,6 @@ const ModuleInfo = exports.moduleInfo = {
packageName : 'codes.l33t.enigma.telnet.server.v2', packageName : 'codes.l33t.enigma.telnet.server.v2',
}; };
class TelnetClient { class TelnetClient {
constructor(socket) { constructor(socket) {
Client.apply(this, socket, socket); Client.apply(this, socket, socket);
@ -37,6 +35,33 @@ class TelnetClient {
this.clientReady(); this.clientReady();
}, 3000); }, 3000);
this.socket.on('data', data => {
this.emit('data', data);
});
this.socket.on('error', err => {
// :TODO: Log me
return this.emit('end');
});
this.socket.on('end', () => {
this.emit('end');
});
this.socket.on('DO', command => {
switch (command.option) {
case Options.ECHO :
return this.socket.will.echo();
default :
return this.socket.command(Commands.WONT, command.option);
}
});
this.socket.on('DONT', command => {
// :TODO: Log me
});
this.socket.on('WILL', command => { this.socket.on('WILL', command => {
switch (command.option) { switch (command.option) {
case Options.LINEMODE : case Options.LINEMODE :
@ -53,6 +78,10 @@ class TelnetClient {
} }
}); });
this.socket.on('WONT', command => {
// :TODO: see telnet.js handling
});
this.socket.on('SB', command => { this.socket.on('SB', command => {
switch (command.option) { switch (command.option) {
case Options.TTYPE : case Options.TTYPE :
@ -78,18 +107,39 @@ class TelnetClient {
break; break;
case Options.NAWS : case Options.NAWS :
this.term.termWidth = command.optionData.width; {
this.term.termHeight = command.optionData.height; const { width, height } = command.optionData;
// :TODO: update env, see old telnet.js this.term.termWidth = width;
this.term.termHeight = height;
this.clearMciCache(); if (width) {
this.term.env.COLUMNS = width;
}
// :TODO: Log negotiation if (height) {
this.term.env.ROWS = height;
}
this.clearMciCache();
// :TODO: Log negotiation
}
break; break;
} }
}); });
this.socket.on('IP', command => {
// :TODO: Log me
return this.disconnect();
});
this.socket.on('AYT', () => {
// :TODO: Log me
return this.socket.write('\b');
});
// kick off negotiations
this.banner(); this.banner();
} }
@ -102,6 +152,14 @@ class TelnetClient {
this.emit('ready', { firstMenu : Config().loginServers.telnet.firstMenu } ); this.emit('ready', { firstMenu : Config().loginServers.telnet.firstMenu } );
} }
disconnect() {
try {
return this.socket.rawSocket.end();
} catch (e) {
// ignored
}
}
banner() { banner() {
this.socket.do.echo(); this.socket.do.echo();
this.socket.will.echo(); // we'll echo back this.socket.will.echo(); // we'll echo back