node-minecraft-protocol/examples/proxy.js

85 lines
2.3 KiB
JavaScript
Raw Normal View History

var mc = require('../');
var states = mc.protocol.states;
function print_help() {
console.log("usage: node proxy.js <target_srv> <user> [<password>]");
}
if (process.argv.length < 4) {
console.log("Too few arguments!");
print_help();
process.exit(1);
}
process.argv.forEach(function(val, index, array) {
if (val == "-h") {
print_help();
process.exit(0);
}
});
var host = process.argv[2];
var port = 25565;
var user = process.argv[3];
var passwd = process.argv[4];
if (host.indexOf(':') != -1) {
port = host.substring(host.indexOf(':')+1);
host = host.substring(0, host.indexOf(':'));
}
var srv = mc.createServer({
'online-mode': false,
port: 25566
});
srv.on('login', function (client) {
var addr = client.socket.remoteAddress;
console.log('Incoming connection', '('+addr+')');
var endedClient = false;
var endedTargetClient = false;
client.on('end', function() {
endedClient = true;
console.log('Connection closed by client', '('+addr+')');
if (!endedTargetClient)
targetClient.end("End");
});
client.on('error', function() {
endedClient = true;
console.log('Connection error by client', '('+addr+')');
if (!endedTargetClient)
targetClient.end("Error");
});
var targetClient = mc.createClient({
host: host,
port: port,
username: user,
password: passwd
});
client.on('packet', function(packet) {
if (targetClient.state == states.PLAY && packet.state == states.PLAY) {
console.log(`client->server: ${client.state}.${packet.id} : ${JSON.stringify(packet)}`);
if (!endedTargetClient)
targetClient.write(packet.id, packet);
}
});
targetClient.on('packet', function(packet) {
if (packet.state == states.PLAY && client.state == states.PLAY) {
console.log(`client<-server: ${targetClient.state}.${packet.id} : ${JSON.stringify(packet)}`);
if (!endedClient)
client.write(packet.id, packet);
}
});
targetClient.on('end', function() {
endedTargetClient = true;
console.log('Connection closed by server', '('+addr+')');
if (!endedClient)
client.end("End");
});
targetClient.on('error', function() {
endedTargetClient = true;
console.log('Connection error by server', '('+addr+')');
if (!endedClient)
client.end("Error");
});
});