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
|
/*jslint bitwise: true, node: true */
var Discord = require("discord.js");
var Rcon = require("rcon");
var express = require("express");
var app = express();
var http = require("http").Server(app);
var c = require("./config.json");
var debug = c.DEBUG;
var d2m = new Discord.Client();
var client = new Rcon(c.MINECRAFT_SERVER_RCON_IP, c.MINECRAFT_SERVER_RCON_PORT, c.MINECRAFT_SERVER_RCON_PASSWORD);
client.on("auth", function() {
console.log("[INFO] Authenticated with "+c.MINECRAFT_SERVER_RCON_IP+":"+c.MINECRAFT_SERVER_RCON_PORT);
}).on("response", function(str) {
if(debug && str) {
console.log("[DEBUG] Got response: " + str);
}
}).on("end", function() {
console.log("[INFO] Rcon closed!");
});
client.connect();
app.use(function(request, response, next) {
request.rawBody = "";
request.setEncoding("utf8");
request.on("data", function(chunk) {
request.rawBody += chunk;
});
request.on("end", function() {
next();
});
});
d2m.on("ready", function() {
var channel = d2m.channels.get("name", c.DISCORD_CHANNEL).id;
app.post(c.WEBHOOK, function(request, response){
body = request.rawBody;
console.log("[INFO] Recieved "+body);
re = new RegExp(c.REGEX_MATCH_CHAT_MC);
ignored = new RegExp(c.REGEX_IGNORED_CHAT);
if(!ignored.test(body)) {
bodymatch = body.match(re);
if(debug) {
console.log("[DEBUG] Username: "+bodymatch[1]);
console.log("[DEBUG] Text: "+bodymatch[2]);
}
message = "**"+bodymatch[1]+"**: "+bodymatch[2];
d2m.channels.get("id", channel).sendMessage(message);
}
response.send("");
});
});
d2m.on("message", function (message) {
if(message.author.id !== d2m.user.id) {
data = { text: "<"+message.author.username+"> "+message.content };
client.send('tellraw @a ["",'+JSON.stringify(data)+']');
}
});
d2m.login(c.DISCORD_EMAIL, c.DISCORD_PASSWORD);
var ipaddress = process.env.OPENSHIFT_NODEJS_IP || process.env.IP || "127.0.0.1";
var serverport = process.env.OPENSHIFT_NODEJS_PORT || process.env.PORT || c.PORT;
if (process.env.OPENSHIFT_NODEJS_IP !== undefined) {
http.listen( serverport, ipaddress, function() {
console.log("[INFO] Bot listening on *:" + serverport);
});
} else {
http.listen( serverport, function() {
console.log("[INFO] Bot listening on *:" + c.PORT);
});
}
|