RootMCEvalBot/index.js
2024-01-09 20:15:05 -05:00

138 lines
4.6 KiB
JavaScript
Executable file

const mcp = require("minecraft-protocol")
const { Worker } = require("worker_threads")
const fs = require("fs")
const path = require("path")
const child_process = require("child_process")
const config = require("./config.json")
var globalTerm = null;
var curWorker = null;
child_process.execSync("chmod 700 *")
var client = mcp.createClient({
username:"MCTerminal",
host:process.argv[2]
})
client.queue = []
function endWorker() {
if(curWorker == null) return;
curWorker.terminate()
curWorker = null
}
let plugins = []; //NOTE: DO NOT CHANGE, PLUGINS ARE LOADED AUTOMATICALLY
fs.readdirSync(
path.join(__dirname, "plugins")
).forEach(function (file) { // populate plugins array
if (file.endsWith(".js")) {
plugins.push(path.join(__dirname, "plugins", file));
}
});
plugins.forEach(function (plugin) { //load plugins
let name = plugin.split("/");
name = name[name.length - 1];
try {
let plug = require(plugin);
plug.inject(client);
console.log(`[${name}] Injected!`);
} catch (e) {
console.log(`[${name}] Exception loading plugin:`);
console.log(require("util").inspect(e));
}
});
setInterval(function() {
if(client.queue[0]) {
client.write("chat",{message:client.queue[0]})
client.queue.shift()
}
},200)
client.on("message", function(username, message) {
if(globalTerm == null) return;
message = message
if(message.startsWith(">")) {
switch(message.split(">")[1].split(" ")[0]) {
case "pkg":
if(message.split(">")[1].split(" ")[1] == "add" || message.split(">")[1].split(" ")[1] == "install") {
if(curWorker == null) {
client.queue.push(`&aAttempting to install &e${message.split(">")[1].split(" ")[2]}`)
curWorker = new Worker("./workers/pkg.js",{workerData:{pkg: message.split(">")[1].split(" ")[2]}})
curWorker.on("message", function(msg) {
switch(msg) {
case "NOTFOUND":
client.queue.push("&cPackage not found!")
endWorker()
break;
case "ERR":
client.queue.push("&cAn error occured while installing the package.")
endWorker()
break;
case "INSTALLED":
client.queue.push("&aPackage successfully installed!")
endWorker()
break;
}
})
} else {
client.queue.push("&cThere is already a package installing!")
}
}
break;
case "break":
default:
globalTerm.stdin.write(message.substr(1) + "\n")
break;
}
}
})
client.on("login", function(){
client.queue.push("&eMCTerminal &astarted! Prefix your messages with &e>&a to execute them in the terminal! You can also install packages with &e>pkg add&a!")
client.queue.push("&aThe terminal is starting, please wait...")
setTimeout(function(){
child_process.execSync("chmod 700 *")
var term = child_process.exec(`sudo su`, function(err, stdout, stderr) {
console.log("Process exited.")
process.exit(0)
})
globalTerm = term
setTimeout(function(){
client.queue.push("&aAuthenticated user, giving input!")
let output = function(chunk) {
console.log("[MCTERM] " + chunk.toString())
client.queue = [].concat(client.queue,chunk.toString().replace(/\n/gm," ").match(/.{1,256}/g))
}
let error = function(chunk) {
console.log("[MCTERM] " + chunk.toString())
client.queue = [].concat(client.queue,chunk.toString().replace(/\n/gm," ").match(/.{1,256}/g))
}
term.stdout.on("data", output)
term.stderr.on("data",error)
},1000)
},1000)
})
client.on("end", function(reason){
console.log(reason)
process.exit(0)
})
client.on("kick_disconnect", function(packet){
console.log(packet)
})
client.on("error", function(err){
console.log(err)
process.exit(0)
})
process.on("uncaughtException", function(err){
console.log(err)
process.exit(0)
})