1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
// Credits to M4GNV5 for this library to reduce dependancies
var net = require("net");
var c = require("../config.json");
var debug = c.DEBUG;
module.exports = Rcon;
function Rcon(ip, port)
{
var self = this;
self.rconTimeout = undefined;
self.nextId = 0;
self.connected = false;
self.authed = false;
self.packages = [];
self.socket = net.connect(port, ip, function() {
self.connected = true;
console.log("[INFO] Authenticated with " + ip + ":" + port);
});
self.socket.on("data", function(data)
{
var length = data.readInt32LE(0);
var id = data.readInt32LE(4);
var type = data.readInt32LE(8);
var response = data.toString("ascii", 12, data.length - 2);
if(self.packages[id])
{
self.packages[id](type, response);
}
else
{
console.log("unexpected rcon response", id, type, response);
}
}).on("end", function()
{
if(debug) {
console.log("[DEBUG] Rcon closed!");
}
});
}
Rcon.timeout = 5000;
Rcon.prototype.close = function()
{
this.connected = false;
this.socket.end();
}
Rcon.prototype.auth = function(pw, cb)
{
var self = this;
self.pass = pw;
self.cb = cb;
if(self.authed)
throw new Error("already authed");
if(self.connected)
doAuth();
else
self.socket.on("connect", doAuth);
function doAuth()
{
self.sendPackage(3, pw, cb);
}
};
Rcon.prototype.command = function(cmd, cb)
{
this.sendPackage(2, cmd, cb);
};
Rcon.prototype.sendPackage = function(type, payload, cb)
{
var self = this;
var id = self.nextId;
self.nextId++;
if(!self.connected)
throw new Error("Cannot send package while not connected");
var length = 14 + payload.length;
var buff = new Buffer(length);
buff.writeInt32LE(length - 4, 0);
buff.writeInt32LE(id, 4);
buff.writeInt32LE(type, 8);
buff.write(payload, 12);
buff.writeInt8(0, length - 2);
buff.writeInt8(0, length - 1);
self.socket.write(buff);
var timeout = setTimeout(function()
{
delete self.packages[id];
cb("Server sent no request in " + Rcon.timeout / 1000 + " seconds");
}, Rcon.timeout);
self.packages[id] = function(type, response)
{
clearTimeout(timeout);
var err = type >= 0 ? false : "Server sent package code " + type;
if(debug)
{
console.log("[DEBUG] Recieved response: "+response);
}
cb(err, response, type);
}
}
|