mirror of
https://github.com/PrismarineJS/node-minecraft-protocol.git
synced 2024-12-04 21:11:04 -05:00
183 lines
6.1 KiB
JavaScript
183 lines
6.1 KiB
JavaScript
var mc = require('minecraft-protocol');
|
|
|
|
var states = mc.states;
|
|
function printHelpAndExit(exitCode) {
|
|
console.log("usage: node proxy.js [<options>...] <target_srv> [<version>]");
|
|
console.log("options:");
|
|
console.log(" --dump name");
|
|
console.log(" print to stdout messages with the specified name.");
|
|
console.log(" --dump-all");
|
|
console.log(" print to stdout all messages, except those specified with -x.");
|
|
console.log(" -x name");
|
|
console.log(" do not print messages with this name.");
|
|
console.log(" name");
|
|
console.log(" a packet name as defined in protocol.json");
|
|
console.log("examples:");
|
|
console.log(" node proxy.js --dump-all -x keep_alive -x update_time -x entity_velocity -x rel_entity_move -x entity_look -x entity_move_look -x entity_teleport -x entity_head_rotation -x position -x localhost Player");
|
|
console.log(" print all messages except for some of the most prolific.");
|
|
console.log(" node examples/proxy.js --dump open_window --dump close_window --dump set_slot --dump window_items --dump craft_progress_bar --dump transaction --dump close_window --dump window_click --dump set_creative_slot --dump enchant_item localhost Player");
|
|
console.log(" print messages relating to inventory management.");
|
|
|
|
process.exit(exitCode);
|
|
}
|
|
|
|
if(process.argv.length < 4) {
|
|
console.log("Too few arguments!");
|
|
printHelpAndExit(1);
|
|
}
|
|
|
|
process.argv.forEach(function(val, index, array) {
|
|
if(val == "-h") {
|
|
printHelpAndExit(0);
|
|
}
|
|
});
|
|
|
|
var args = process.argv.slice(2);
|
|
var host;
|
|
var port = 25565;
|
|
var version;
|
|
|
|
var printAllNames = false;
|
|
var printNameWhitelist = {};
|
|
var printNameBlacklist = {};
|
|
(function() {
|
|
for(var i = 0; i < args.length; i++) {
|
|
var option = args[i];
|
|
if(!/^-/.test(option)) break;
|
|
if(option == "--dump-all") {
|
|
printAllNames = true;
|
|
continue;
|
|
}
|
|
i++;
|
|
var name = args[i];
|
|
if(option == "--dump") {
|
|
printNameWhitelist[name] = "io";
|
|
} else if(option == "-x") {
|
|
printNameBlacklist[name] = "io";
|
|
} else {
|
|
printHelpAndExit(1);
|
|
}
|
|
}
|
|
if(!(i + 2 <= args.length && args.length <= i + 4)) printHelpAndExit(1);
|
|
host = args[i++];
|
|
version = args[i++];
|
|
})();
|
|
|
|
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,
|
|
keepAlive: false,
|
|
version:version
|
|
});
|
|
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: client.username,
|
|
keepAlive:false,
|
|
version:version
|
|
});
|
|
client.on('packet', function(data, meta) {
|
|
if(targetClient.state == states.PLAY && meta.state == states.PLAY) {
|
|
if(shouldDump(meta.name, "o")) {
|
|
console.log("client->server:",
|
|
client.state + " "+ meta.name + " :",
|
|
JSON.stringify(data));
|
|
}
|
|
if(!endedTargetClient)
|
|
targetClient.write(meta.name, data);
|
|
}
|
|
});
|
|
targetClient.on('packet', function(data, meta) {
|
|
if(meta.state == states.PLAY && client.state == states.PLAY) {
|
|
if(shouldDump(meta.name, "i")) {
|
|
console.log("client<-server:",
|
|
targetClient.state + "." + meta.name + " :" +
|
|
JSON.stringify(data));
|
|
}
|
|
if(!endedClient) {
|
|
client.write(meta.name, data);
|
|
if (meta.name === 'set_compression') // Set compression
|
|
client.compressionThreshold = data.threshold;
|
|
}
|
|
}
|
|
});
|
|
var bufferEqual = require('buffer-equal');
|
|
targetClient.on('raw', function(buffer, meta) {
|
|
if(client.state != states.PLAY || meta.state != states.PLAY)
|
|
return;
|
|
var packetData = targetClient.deserializer.parsePacketBuffer(buffer).data.params;
|
|
var packetBuff = client.serializer.createPacketBuffer({name:meta.name, params:packetData});
|
|
if(!bufferEqual(buffer, packetBuff)) {
|
|
console.log("client<-server: Error in packet " + state + "." + meta.name);
|
|
console.log(buffer.toString('hex'));
|
|
console.log(packetBuff.toString('hex'));
|
|
console.log(buffer.length);
|
|
console.log(packetBuff.length);
|
|
}
|
|
/*if (client.state == states.PLAY && brokenPackets.indexOf(packetId.value) !== -1)
|
|
{
|
|
console.log(`client<-server: raw packet);
|
|
console.log(packetData);
|
|
if (!endedClient)
|
|
client.writeRaw(buffer);
|
|
}*/
|
|
});
|
|
client.on('raw', function(buffer, meta) {
|
|
if(meta.state != states.PLAY || targetClient.state != states.PLAY)
|
|
return;
|
|
var packetData = client.deserializer.parsePacketBuffer(buffer).data.params;
|
|
var packetBuff = targetClient.serializer.createPacketBuffer({name:meta.name, params:packetData});
|
|
if(!bufferEqual(buffer, packetBuff)) {
|
|
console.log("client->server: Error in packet " + state + "." + meta.name);
|
|
console.log(buffer.toString('hex'));
|
|
console.log(packetBuff.toString('hex'));
|
|
console.log(buffer.length);
|
|
console.log(packetBuff.length);
|
|
}
|
|
});
|
|
targetClient.on('end', function() {
|
|
endedTargetClient = true;
|
|
console.log('Connection closed by server', '(' + addr + ')');
|
|
if(!endedClient)
|
|
client.end("End");
|
|
});
|
|
targetClient.on('error', function(err) {
|
|
endedTargetClient = true;
|
|
console.log('Connection error by server', '(' + addr + ') ',err);
|
|
console.log(err.stack);
|
|
if(!endedClient)
|
|
client.end("Error");
|
|
});
|
|
});
|
|
|
|
function shouldDump(name, direction) {
|
|
if(matches(printNameBlacklist[name])) return false;
|
|
if(printAllNames) return true;
|
|
if(matches(printNameWhitelist[name])) return true;
|
|
return false;
|
|
function matches(result) {
|
|
return result != null && result.indexOf(direction) !== -1;
|
|
}
|
|
}
|