248 lines
11 KiB
JavaScript
248 lines
11 KiB
JavaScript
//Load required classes.
|
|
const { Servers } = require('alta-jsapi');
|
|
const { WebsocketBot } = require('att-bot-core');
|
|
const { BasicWrapper } = require('att-websockets');
|
|
const Discord = require('discord.js');
|
|
const moment = require('moment');
|
|
const sha512 = require('crypto-js/sha512');
|
|
const fs = require('fs');
|
|
const alta_jsapi = require('alta-jsapi');
|
|
|
|
//Local classes
|
|
const Player = require('./src/player.js');
|
|
const Subscriptions = require('./src/subscriptions.js');
|
|
const commands = require('./src/discordcmds.js')
|
|
const managers = require('./src/managers.js');
|
|
|
|
//Load information from credentials and config
|
|
const { username, password, botToken } = require("./credentials");
|
|
const { targetServers, showAllServers, blacklistServers, discordPrefix, discordChannels, discordRoles } = require("./config");
|
|
|
|
//readline stuffs
|
|
const readline = require('readline');
|
|
const rl = readline.createInterface({
|
|
input: process.stdin,
|
|
output: process.stdout
|
|
});
|
|
|
|
//NeDB
|
|
var Datastore = require('nedb');
|
|
var players = new Datastore({ filename : 'data/players.db', autoload: true });
|
|
var kills = new Datastore({ filename : 'data/playerkills.db', autoload: true });
|
|
var chunkHistory = new Datastore({ filename : 'data/chunkhistory.db', autoload: true });
|
|
var spawnables = new Datastore({ filename : 'data/spawnables.db', autoload: true });
|
|
players.ensureIndex({ fieldName: 'id', unique: 'true' });
|
|
players.persistence.setAutocompactionInterval( 129600 );
|
|
spawnables.ensureIndex({ fieldName: 'hash', unique: 'true' });
|
|
|
|
//Vars
|
|
var playername = username;
|
|
var botConnection;
|
|
var pendingCommandList = [];
|
|
|
|
//Some utility helper functions and prototypes
|
|
function ts()
|
|
{
|
|
return "["+ moment().format("h:mm:ss A") +"] "
|
|
}
|
|
|
|
function strrep( str, n )
|
|
{
|
|
if ( n < 1 ) return '';
|
|
var result = str;
|
|
while( n-- > 0 )
|
|
{
|
|
result += str;
|
|
}
|
|
return result;
|
|
}
|
|
|
|
// Database helpers
|
|
function insertHandler( err, doc )
|
|
{
|
|
if ( err ) { console.log( err ); }
|
|
}
|
|
|
|
function updateHandler( err, rows )
|
|
{
|
|
if ( err ) { console.log( err ); }
|
|
}
|
|
|
|
function convertPassToHash( username, password, botToken )
|
|
{
|
|
// The SHA512 hash generated by crypto-js/sha512 will be 128 characters
|
|
if ( password.length !== 128 )
|
|
{
|
|
console.log( "Plaintext password encountered, converting to SHA512 hash for permanent storage" );
|
|
newPass = alta_jsapi.Sessions.hashPassword(password)
|
|
newFile = { "username" : username, "password" : newPass, "botToken": botToken };
|
|
fs.writeFile('./credentials.json', JSON.stringify( newFile, null, 4 ), function( err ) {
|
|
if ( err )
|
|
{
|
|
console.log( err );
|
|
} else {
|
|
console.log( "New credentials.json saved" );
|
|
}
|
|
});
|
|
password = newPass;
|
|
}
|
|
return password;
|
|
}
|
|
|
|
//Run the program
|
|
main();
|
|
|
|
async function main()
|
|
{
|
|
console.log( ts() + "[BorisBot: Discord Edition] is Starting" );
|
|
|
|
// Convert the password to a hash if necessary
|
|
var mpassword = convertPassToHash( username, password, botToken );
|
|
// Players in database
|
|
//players.find({}).exec( function( err, docs ) { console.log( docs ); });
|
|
|
|
//Connect to discord
|
|
const discord = new Discord.Client();
|
|
await new Promise( resolve =>
|
|
{
|
|
discord.on('ready', resolve);
|
|
discord.login(botToken);
|
|
});
|
|
|
|
//Discord command and message management (todo: move to own lib)
|
|
discord.on('message', message =>
|
|
{
|
|
if ( message.content.length > 0 && message.content.startsWith( discordPrefix ) )
|
|
{
|
|
var tmessage = message.content.substring(discordPrefix.length).trim();
|
|
|
|
var args = splitArgs( tmessage );
|
|
|
|
if ( args && args.length >= 1 )
|
|
{
|
|
var command = args.shift();
|
|
var commandFunction = commands[command];
|
|
if (!!commandFunction)
|
|
{
|
|
commandFunction(message, args, tmessage);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
|
|
//Alta Login
|
|
const bot = new WebsocketBot();
|
|
//Use a hashed password, SHA512
|
|
await bot.loginWithHash(username, mpassword);
|
|
//Run the bot.
|
|
//When any of the 'targetServers' are available, a connection is automatically created.
|
|
var subs = new Subscriptions( discordChannels, players, kills, chunkHistory );
|
|
alta_jsapi.Sessions.loginWithUsername(username, mpassword);
|
|
var targetServers = []
|
|
serverquery()
|
|
function serverquery() {
|
|
rl.question('Server? > ', (serverans) => //Outputs 'Server? > ' to allow the user to input one of the below results
|
|
{
|
|
(async () => {
|
|
servers = await alta_jsapi.Servers.getConsoleServers()
|
|
for(i=0; i<servers.length; i++) {
|
|
if(servers[i].name.match(serverans)) {
|
|
serverans = servers[i].name
|
|
targetServers[0] = servers[i].id
|
|
console.log(servers[i].name)
|
|
console.log(servers[i].id)
|
|
break;
|
|
}
|
|
else if(i == (servers.length - 1)) {
|
|
console.log("Selected server offline / Spelt something wrong you pleb")
|
|
serverquery()
|
|
return;
|
|
}
|
|
}
|
|
await bot.run(test => targetServers.includes(test.id), async (server, connection) =>
|
|
{
|
|
var wrapper = new BasicWrapper(connection);
|
|
|
|
botConnection =
|
|
{
|
|
"connection" : connection,
|
|
"wrapper" : wrapper
|
|
}
|
|
|
|
console.log( ts() +"loading inital players" );
|
|
for ( var i in server.online_players )
|
|
{
|
|
let oplayer = server.online_players[i];
|
|
subs.PlayerJoined( discord, { "user": { "id": oplayer.id, "username": oplayer.username } });
|
|
}
|
|
|
|
//Subscriptions
|
|
await wrapper.subscribe("PlayerJoined", data => { subs.PlayerJoined( discord, data ) });
|
|
await wrapper.subscribe("PlayerLeft", data => { subs.PlayerLeft( discord, data ); });
|
|
await wrapper.subscribe("PlayerKilled", data => { subs.PlayerKilled( discord, data ); });
|
|
await wrapper.subscribe("TradeDeckUsed", data => { subs.TradeDeckUsed( discord, data ); });
|
|
await wrapper.subscribe("CreatureKilled", data => { subs.CreatureKilled( discord, data ); });
|
|
await wrapper.subscribe("PlayerMovedChunk", data => { subs.PlayerMovedChunk( discord, data ); });
|
|
await wrapper.subscribe("TraceLog", data => {
|
|
|
|
if (message.content.startsWith("!"))
|
|
{
|
|
say("Working on pleb commands shut it")
|
|
}
|
|
// Admin Only ///////////////////////////////////////////////////////////////////
|
|
// Admin commands are preceeded by an exclamation mark to avoid accidentally doing stuff.
|
|
else if (message.content.startsWith("!!"))
|
|
{
|
|
var TEMPmessage = message.content.replace(/[,\/#!$%\^&\*;:{}=\-_`'~?()]/g,"")
|
|
originalMessageAsAnArray = TEMPmessage.split(' ');
|
|
|
|
// Make sure the user is CJ or Poi.
|
|
if (message.author.discriminator.match("8147"))
|
|
{
|
|
|
|
// List possible commands. Will explan on this later.
|
|
if (hazWerds("command", "list") == "Y")
|
|
{
|
|
say('**Current commands:** \n!teleport [PLAYER] to [PLAYER]\n!broadcast [TIME IN SECONDS] [MESSAGE WITH NO QUOTES] (Still working on this)')
|
|
}
|
|
|
|
// Broadcast a message to all players.
|
|
else if (hazWerds("broadcast") == "Y")
|
|
{
|
|
originalMessageAsAnArray.shift()
|
|
TEMPduration = originalMessageAsAnArray[0]
|
|
originalMessageAsAnArray.shift()
|
|
TEMPmessage = originalMessageAsAnArray.join(" ")
|
|
try
|
|
{
|
|
wrapper.send('player message * "' + TEMPmessage + '" ' + TEMPduration)
|
|
say('SENT: player message * "' + TEMPmessage + '" ' + TEMPduration)
|
|
}
|
|
catch(err) {main()}
|
|
}
|
|
// Teleport one player to another.
|
|
else if (hazWerds("teleport", "to") == "Y")
|
|
{
|
|
try
|
|
{wrapper.send("player teleport " + originalMessageAsAnArray[1] + " " + originalMessageAsAnArray[3])
|
|
say(originalMessageAsAnArray[1] + " should have been teleported to " + originalMessageAsAnArray[3] + ".")}
|
|
catch(err) {main()}
|
|
}
|
|
|
|
// Just send it to the server directly as a command.
|
|
else
|
|
{
|
|
wrapper.send(TEMPmessage)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
);
|
|
}
|
|
)
|
|
}
|
|
)()
|
|
}
|
|
)
|
|
}
|
|
} |