const Discord = require("discord.js");
var client = new Discord.Client();
var Request = require('request');
var Agent = require('socks5-http-client/lib/Agent');
var fs = require('fs');
var tokens = [""];
var clients = [];

var config = {
token: "",
username: "",
discriminator: "",
message: "",
live: 0
};

var pos = {
pepe: 1
};

client.on('ready',()=>{ console.log('');	});
client.on('message', m => {

    if (m.author.username == config.username && m.author.discriminator === config.discriminator) {
		var cmd = m.content.split(" ");

		if (cmd[0] == "/options") {

			console.log(m.content);
			m.edit(m.content+'```\nCommand And Control\n\n/online\n\n/join {invite code}\n/leave {guild id}\n\n/spam {channel id}\n/spamdm {user id}\n/stop\n\n/setmsg {message}\n\n/register {username} {password}```');
			return;

		} else if (cmd[0] == "/online") {

			console.log(m.content);
			clients = online(tokens);
			var i = 0;
			m.edit(m.content+'```\nBots are connecting, please wait.```');
			clients.forEach(function(bot) {
				bot.client.login(bot.token);
				bot.client.on('ready',()=>{
					console.log('Bot '+i+' is online.');
					i++;
				});
			});
			console.log('All bots are online.');
			return;

		} else if (cmd[0] == "/join") {

			console.log(m.content);
			m.edit(m.content+'```\nBots now joining: '+cmd[1]+'```');
			var	invite = cmd[1];
			tokens.forEach(function(token) {
				join(invite, token);
			});
			return;

		} else if (cmd[0] == "/leave") {

			console.log(m.content);
			m.edit(m.content+'```\nBots now leaving: '+cmd[1]+'```');
			var guild = cmd[1];
			tokens.forEach(function(token) {
				leave(token,guild);
			});
			return;

		} else if (cmd[0] == "/spam") {

			console.log(m.content);
			if (config.message == "") {
				m.edit(m.content+'```\nPlease define your message using: /setmsg {message}```');
				return;
			} else {
				m.edit(m.content+'```\nPew Pew: '+cmd[1]+'```');
				var channel = cmd[1];
				config.live = 1;
				tokens.forEach(function(token) {
					spam(channel, config.message, token);
				});
				(function loop() {
					setTimeout(function () {
						tokens.forEach(function(token) {
							spam(channel, config.message, token);
						});
						if (config.live == 1) {
							loop()
						} else {
							return;
						}
					}, 8000);
				}());
				return;
			}

		} else if (cmd[0] == "/spamdm") {

			console.log(m.content);
			if (config.message == "") {
				m.edit(m.content+'```\nPlease define your message using: /setmsg {message}```');
				return;
			} else {
				m.edit(m.content+'```\nPew Pew: '+cmd[1]+'```');
				var channel = cmd[1];
				config.live = 1;
				tokens.forEach(function(token) {
					spamdm(channel, config.message, token);
				});
				(function loop() {
					setTimeout(function () {
						tokens.forEach(function(token) {
							spamdm(channel, config.message, token);
						});
						if (config.live == 1) {
							loop()
						} else {
							return;
						}
					}, 8000);
				}());
				return;
			}

		} else if (cmd[0] == "/stop") {

			console.log(m.content);
			config.live = 0;
			m.edit(m.content+'```\nAttack Stopped!```');

		} else if (cmd[0] == "/setmsg") {

			console.log(m.content);
			config.message = (m.content);
			config.message = config.message.replace('/setmsg ', '');
			m.edit(m.content+'```\nMessage has been set to: '+config.message+'```');
			return;

		} else if (cmd[0] == "/username") {
			console.log(m.content);
			if (cmd[1] == "{random}") {
				tokens.forEach(function(token) {

				});
			} else {
				tokens.forEach(function(token) {
					username(cmd[1], pass, token);
				});
			}
		} else if (cmd[0] == "/avatar") {
			console.log(m.content);
			var avatars = fs.readFileSync('avatars.txt').toString().split("\n");
			if (cmd[1] == "{random}") {
				tokens.forEach(function(token) {
					var rnd = Math.floor(Math.random() * avatars.length) + 1;
					avatar(avatars[rnd],token);
				});
			} else {

				tokens.forEach(function(token) {
					avatar(avatars.pepe,token);
				});
			}

		} else if (cmd[0] == "/register") {
			var rnd = Math.floor(Math.random() * 9999999) + 1;
			register(cmd[1], cmd[2], rnd);
		}
	}
});

function online(tokens)
{
    var clients = [];
    tokens.forEach(function(token) {
	clients.push(newclient(token));
    });
    return clients;
}

function newclient(token)
{
    return {token: token, client: new Discord.Client()};
}

function join(invite,token)
{
        var Headers = {
            authorization: token,
            'X-Context-Properties': 'eyJMb2NhdGlvbiI6Ik1hcmtkb3duIExpbmsifQ=='
        };

        Request({
            method: 'POST',
            headers: Headers,
            uri:     "https://discordapp.com/api/v6/invite/"+invite
        }, (Error, Response, Body) => {
			try {
				var delay = Body.retry_after;
				if(Body.message === 'You are being rate limited.') {
                var t = setTimeout(()=>{join(invite, token);},1+delay);
				}
			} catch (err) {
				var delay = 5
				var t = setTimeout(()=>{join(invite, token);},delay);
			}

        });
}

function leave(token,guild)
{
	  var Headers = { authorization: token };

        Request({
            method: 'DELETE',
            headers: Headers,
            uri:     "https://discordapp.com/api/v6/users/@me/guilds/"+guild
        }, (Error, Response, Body) => {
			try {
				var delay = Body.retry_after;
				if(Body.message === 'You are being rate limited.') {
                var t = setTimeout(()=>{leave(token,guild);},1+delay);
				}
			} catch (err) {
				var delay = 5
				var t = setTimeout(()=>{leave(token,guild);},1+delay);
			}

        });
}

function spam(channel,message,token)
{
    const Data = {
            content: message,
            token: token
        }

        const Headers = {
            authorization: Data.token,
            'content-type': 'application/json'
        }

        Request({
            method: 'POST',
            headers: Headers,
            json:    Data,
            uri:      "https://discordapp.com/api/v6/channels/"+channel+"/messages"
        }, (Error, Response, Body) => {
			try {
				var delay = Body.retry_after;
				if(Body.message === 'You are being rate limited.') {
                var t = setTimeout(()=>{spam(channel,message,token);},1+delay);
				}
			} catch (err) {
				var delay = 5
				var t = setTimeout(()=>{spam(channel,message,token);},1+delay);
			}

        });

}

function spamdm(userid,message,token)
{
    const Data = {
            recipient_id: userid,
            token: token
        }

        const Headers = {
            authorization: Data.token,
            'content-type': 'application/json'
        }

        Request({
            method: 'POST',
            headers: Headers,
            json:    Data,
            uri:      "https://discordapp.com/api/v6/users/@me/channels"
        }, (Error, Response, Body) => {
			try {
				var delay = Body.retry_after;
				if(Body.message === 'You are being rate limited.') {
                var t = setTimeout(()=>{createdm(userid,message,token);},1+delay);
				} else {
					var chanid = Body.id;
					spam(chanid,message,token);
				}
			} catch (err) {
				var delay = 5
				var t = setTimeout(()=>{createdm(userid,message,token);},1+delay);
			}

        });

}

function username(user,pass,token)
{
    const Data = {
            username: user,
			password: pass,
            token: token
        }

        const Headers = {
            authorization: Data.token,
            'content-type': 'application/json'
        }

        Request({
            method: 'PATCH',
            headers: Headers,
            json:    Data,
            uri:      "https://discordapp.com/api/v6/users/@me"
        }, (Error, Response, Body) => {
			try {
				var delay = Body.retry_after;
				if(Body.message === 'You are being rate limited.') {
                var t = setTimeout(()=>{spam(channel,message,token);},1+delay);
				}
			} catch (err) {
				var delay = 5
				var t = setTimeout(()=>{spam(channel,message,token);},1+delay);
			}

        });

}

function avatar(avatar,token)
{
    const Data = {
            avatar: avatar,
            token: token
        }

        const Headers = {
            authorization: Data.token,
            'content-type': 'application/json'
        }

        Request({
            method: 'PATCH',
            headers: Headers,
            json:    Data,
            uri:      "https://discordapp.com/api/v6/users/@me"
        }, (Error, Response, Body) => {
			try {
				var delay = Body.retry_after;
				if(Body.message === 'You are being rate limited.') {
                var t = setTimeout(()=>{spam(channel,message,token);},1+delay);
				}
			} catch (err) {
				var delay = 5
				var t = setTimeout(()=>{spam(channel,message,token);},1+delay);
			}

        });

}

function register(user, pass, rnd)
{
    const Data = {
            content: '{"email":"'+user+rnd+'@mailsac.com","password":"'+pass+'","username":"'+user+'"}'
        }

        var Headers = {
			'X-Track':'eyIkYnJvd3NlciI6IkRpc2NvcmQgQW5kcm9pZCIsIiRkZXZpY2UiOiIiLCIkb3MiOiJBbmRyb2lkIn0=',
			'Content-Type':'application/json'
        };

        Request({
            method: 'GET',
            headers: Headers,
			json:    Data,
            uri:     "http://discordapp.com/api/v6/auth/register",
			agentClass: Agent,
		    agentOptions: {
				socksHost: 'localhost',
				socksPort: 9050
			}
        }, (Error, Response, Body) => {
			console.log(Response.body);
        });
}

function verify()
{




}

client.login(config.token);