discord.js/src/Client/Client.js

"use strict";

var InternalClient = require("./InternalClient.js");
var EventEmitter = require("events");

class Client extends EventEmitter {
	/*
		this class is an interface for the internal
		client.
	*/
	constructor(options) {
		super();
		this.options = options || {};
		this.internal = new InternalClient(this);
	}
	
	get users(){
		return this.internal.users;
	}
	
	get channels(){
		return this.internal.channels;
	}
	
	get servers(){
		return this.internal.servers;
	}
	
	get privateChannels(){
		return this.internal.private_channels;
	}
	
	// def login
	login(email, password, cb = function (err, token) { }) {
		var self = this;
		return new Promise((resolve, reject) => {

			self.internal.login(email, password)
				.then((token) => {
					cb(null, token);
					resolve(token);
				})
				.catch((e) => {
					cb(e);
					reject(e);
				});

		});
	}
	
	// def logout
	logout(cb = function (err) { }) {
		var self = this;
		return new Promise((resolve, reject) => {

			self.internal.logout()
				.then(() => {
					cb();
					resolve();
				})
				.catch((e) => {
					cb(e);
					reject(e);
				})

		})
	}
	// def sendMessage
	sendMessage(where, content, options = {}, callback = function (e, m) { }) {
		var self = this;
		return new Promise((resolve, reject) => {

			if (typeof options === "function") {
				// options is the callback
				callback = options;
			}

			self.internal.sendMessage(where, content, options)
				.then(m => {
					callback(null, m);
					resolve(m);
				}).catch(e => {
					callback(e);
					reject(e);
				});

		});
	}
	
	// def sendTTSMessage
	sendTTSMessage(where, content, callback = function (e, m) { }) {
		var self = this;
		return new Promise((resolve, reject) => {
			self.sendMessage(where, content, { tts: true })
				.then(m => {
					callback(null, m);
					resolve(m);
				}).catch(e => {
					callback(e);
					reject(e);
				});

		});
	}
	// def reply
	reply(where, content, options = {}, callback = function (e, m) { }) {
		var self = this;
		return new Promise((resolve, reject) => {

			if (typeof options === "function") {
				// options is the callback
				callback = options;
			}

			var msg = self.internal.resolver.resolveMessage(where);
			if (msg) {
				content = msg.author + ", " + content;
				self.internal.sendMessage(msg, content, options)
					.then(m => {
						callback(null, m);
						resolve(m);
					}).catch(e => {
						callback(e);
						reject(e);
					});
			} else {
				var err = new Error("Destination not resolvable to a message!");
				callback(err);
				reject(err);
			}

		});
	}
	
	// def replyTTS
	replyTTS(where, content, callback = function () { }) {
		return new Promise((resolve, reject) => {
			self.reply(where, content, { tts: true })
				.then(m => {
					callback(null, m);
					resolve(m);
				}).catch(e => {
					callback(e);
					reject(e);
				});
		});
	}
	// def deleteMessage
	deleteMessage(msg, options = {}, callback = function (e) { }) {
		var self = this;
		return new Promise((resolve, reject) => {
			if (typeof options === "function") {
				// options is the callback
				callback = options;
			}

			self.internal.deleteMessage(msg, options)
				.then(() => {
					callback();
					resolve();
				})
				.catch(e => {
					callback(e);
					reject(e);
				});

		});
	}
	//def updateMessage
	updateMessage(msg, content, options = {}, callback = function(err, msg){}) {
		var self = this;
		return new Promise((resolve, reject) => {
			if (typeof options === "function") {
				// options is the callback
				callback = options;
			}
			
			self.internal.updateMessage(msg, content, options)
				.then(msg => {
					callback(null, msg);
					resolve(msg);
				})
				.catch(e => {
					callback(e);
					reject(e);
				});
			
		});
	}
	
	// def getChannelLogs
	getChannelLogs(where, limit=500, options={}, callback=function(err, logs){}){
		
		var self = this;
		return new Promise((resolve, reject) => {
			if (typeof options === "function") {
				// options is the callback
				callback = options;
			}
			self.internal.getChannelLogs(where, limit, options)
				.then( logs => {
					callback(null, logs);
					resolve(logs);
				})
				.catch( e => {
					callback(e);
					reject(e);
				});
			
		});
		
	}
	
	// def sendFile
	sendFile(where, attachment, name="image.png", callback=function(err, m){}){
		var self = this;
		return new Promise((resolve, reject) => {
			self.internal.sendFile(where, attachment, name)
				.then( m => {
					callback(null, m);
					resolve(m);
				})
				.catch( e => {
					callback(e);
					reject(e);
				});
			
		});
	}
	
	createServer(name, region="london", callback=function(err, srv){}){
		var self = this;
		return new Promise((resolve, reject) => {
			self.internal.createServer(name, region)
				.then(srv => {
					callback(null, srv);
					resolve(srv);
				})
				.catch(e => {
					callback(e);
					reject(e);
				})
		});
	}
	
	// def leaveServer
	leaveServer(server, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.leaveServer(server)
				.then(() => {
					callback(); resolve();
				})
				.catch(e => {
					callback(e); reject(e);
				})
			
		});
	}
	
	// def createChannel
	createChannel(server, name, type="text", callback=function(err,channel){}){
		var self = this;
		return new Promise((resolve, reject) => {
			if (typeof type === "function") {
				// options is the callback
				callback = type;
			}
			self.internal.createChannel(server, name, type)
				.then((channel) => {
					callback(channel); resolve(channel);
				})
				.catch(e => {
					callback(e); reject(e);
				})
			
		});
	}
	
	// def deleteChannel
	deleteChannel(channel, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.deleteChannel(channel)
				.then( () => {
					callback();
					resolve();
				})
				.catch( e => {
					callback(e); reject(e);
				})
			
		});
	}
	
	//def banMember
	banMember(user, server, length=1, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			if (typeof length === "function") {
				// length is the callback
				callback = length;
			}
			self.internal.banMember(user, server, length)
				.then( () => {
					callback();
					resolve();
				})
				.catch( e => {
					callback(e); reject(e);
				})
			
		});
	}
	
	//def createRole
	createRole(server, data=null, callback=function(err,res){}){
		var self = this;
		return new Promise((resolve, reject)=>{
			if (typeof data === "function") {
				// data is the callback
				callback = data;
			}
			self.internal.createRole(server, data)
				.then((role) => {
					callback(null, role);
					resolve(role);
				})
				.catch(e => {
					callback(e);
					reject(e);
				});
			
		});
	}
	
	//def deleteRole
	deleteRole(role, callback=function(err){}){
		
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.deleteRole(role)
				.then(() => {
					callback();
					resolve();
				})
				.catch(e => {
					callback(e);
					reject(e);	
				});
			
		});
		
	}
	
	//def addMemberToRole
	addMemberToRole(member, role, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.addMemberToRole(member, role)
				.then(() => {
					callback();
					resolve();
				})
				.catch(e => {
					callback(e);
					reject(e);	
				});
			
		});
	}
	
	// def addUserToRole
	addUserToRole(member, role, callback=function(err){}){
		return this.addMemberToRole(member, role, callback);
	}
	
	// def removeMemberFromRole
	removeMemberFromRole(member, role, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.removeMemberFromRole(member, role)
				.then(() => {
					callback();
					resolve();
				})
				.catch(e => {
					callback(e);
					reject(e);	
				});
			
		});
	}
	
	// def removeUserFromRole
	removeUserFromRole(member, role, callback=function(err){}){
		return this.removeUserFromRole(member, role, callback);
	}
	
	// def createInvite
	createInvite(chanServ, options, callback=function(err,invite){}){
		var self = this;
		return new Promise((resolve, reject) => {
			if (typeof options === "function") {
				// length is the callback
				callback = options;
			}
			
			self.internal.createInvite(chanServ, options)
				.then(invite => {
					callback(null, invite);
					resolve(invite);
				})
				.catch(e => {
					callback(e);
					reject(e);	
				});
			
		});
	}
	
	// def overwritePermissions
	overwritePermissions(channel, role, options={}, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.overwritePermissions(channel, role, options)
				.then(() => {
					callback();
					resolve();
				})
				.catch(e => {
					callback(e);
					reject(e);
				})
			
		});
	}
	
	// def setTopic
	setTopic(channel, topic, callback=function(err){}){
		var self = this;
		return new Promise((resolve, reject) => {
			
			self.internal.setTopic(channel, topic)
				.then(() => {
					callback();
					resolve();
				})
				.catch(e => {
					callback(e);
					reject(e);
				});
			
		})
	}
}

module.exports = Client;