AstralTransRocketries/node-minecraft-protocol
1
0
Fork 0
mirror of https://github.com/unmojang/node-minecraft-protocol.git synced 2025-09-28 05:35:56 -04:00
Code Issues Packages Projects Releases Wiki Activity

Break client/caseCorrect dependence on TCP/IP host/port; generalize options.connect(client)

Browse Source
This commit is contained in:
deathcap 2016-01-25 23:47:23 -08:00
parent 9c2112802a
commit de36de8496
3 changed files with 17 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/client/caseCorrect.js
View File

@ -16,7 +16,7 @@ module.exports = function(client, options) {
client.username = session.selectedProfile.name;
accessToken = session.accessToken;
client.emit('session');
client.connect(options.port, options.host);
options.connect(client);
}
};
@ -38,6 +38,6 @@ module.exports = function(client, options) {
} else {
// assume the server is in offline mode and just go for it.
client.username = options.username;
client.connect(options.port, options.host);
options.connect(client);
}
};

29
src/createClient.js
View File

@ -12,26 +12,25 @@ var play = require('./client/play');
module.exports=createClient;
Client.prototype.connect = function(port, host) {
var self = this;
if(port == 25565 && net.isIP(host) === 0) {
dns.resolveSrv("_minecraft._tcp." + host, function(err, addresses) {
if(addresses && addresses.length > 0) {
self.setSocket(net.connect(addresses[0].port, addresses[0].name));
} else {
self.setSocket(net.connect(port, host));
}
});
} else {
self.setSocket(net.connect(port, host));
}
};
function createClient(options) {
assert.ok(options, "options is required");
options.port = options.port || 25565;
options.host = options.host || 'localhost';
options.connect = (client) => {
if(options.port == 25565 && net.isIP(host) === 0) {
dns.resolveSrv("_minecraft._tcp." + options.host, function(err, addresses) {
if(addresses && addresses.length > 0) {
client.setSocket(net.connect(addresses[0].port, addresses[0].name));
} else {
client.setSocket(net.connect(options.port, options.host));
}
});
} else {
client.setSocket(net.connect(options.port, options.host));
}
};
assert.ok(options.username, "username is required");
var optVersion = options.version || require("./version").defaultVersion;

1
src/ping.js
View File

@ -42,5 +42,6 @@ function ping(options, cb) {
client.state = states.STATUS;
});
// TODO: update
client.connect(port, host);
}