Added joinServer

src/Client/Client.js

@@ -41,6 +41,10 @@ class Client extends EventEmitter {
 	get uptime(){
 		return this.internal.uptime;
 	}
+	
+	get user() {
+		return this.internal.user;
+	}
 
 	// def login
 	login(email, password, cb = function (err, token) { }) {
@@ -259,6 +263,23 @@ class Client extends EventEmitter {
 		});
 	}
 
+	// def joinServer
+	joinServer(invite, callback = function (err, srv) { }) {
+		var self = this;
+		return new Promise((resolve, reject) => {
+			self.internal.joinServer(invite)
+				.then(srv => {
+					callback(null, srv);
+					resolve(srv);
+				})
+				.catch(e => {
+					callback(e);
+					reject(e);
+				});
+		});
+	}
+
+	// def createServer
 	createServer(name, region="london", callback=function(err, srv){}){
 		var self = this;
 		return new Promise((resolve, reject) => {

src/Client/InternalClient.js

@@ -143,17 +143,16 @@ class InternalClient {
 	joinServer(invite) {
 		var self = this;
 		return new Promise((resolve, reject) => {
-			
-			invite = self.resolver.resolveInvite(invite);
-			if(invite){
-				
+
+			invite = self.resolver.resolveInviteID(invite);
+			if (invite) {
 				request
-					.post(Endpoints.INVITE(invite.id))
+					.post(Endpoints.INVITE(invite))
 					.set("authorization", self.token)
 					.end((err, res) => {
-						if(err){
+						if (err) {
 							reject(err);
-						}else{
+						} else {
 							// valid server, wait until it is received via ws and cached
 							var inter = setInterval(() => {
 								if (self.servers.get("id", res.body.guild.id)) {
@@ -163,11 +162,11 @@ class InternalClient {
 							}, 20);
 						}
 					});
-				
-			}else{
+
+			} else {
 				reject(new Error("Not a valid invite"));
 			}
-			
+
 		});
 	}
 
@@ -1099,29 +1098,29 @@ class InternalClient {
 	}
 	
 	//def ack
-	ack(msg){
+	ack(msg) {
 		var self = this;
 		return new Promise((resolve, reject) => {
-			
+
 			msg = self.resolver.resolveMessage(msg);
-			
-			if(msg){
-				
-				request		
-					.post(Endpoints.CHANNEL_MESSAGE(msg.channel.id, msg.id)+"/ack")
+
+			if (msg) {
+
+				request
+					.post(Endpoints.CHANNEL_MESSAGE(msg.channel.id, msg.id) + "/ack")
 					.set("authorization", self.token)
 					.end((err) => {
-						if(err){
+						if (err) {
 							reject(err);
-						}else{
+						} else {
 							resolve();
 						}
 					});
-				
-			}else{
+
+			} else {
 				reject(new Error("Message does not exist"));
 			}
-			
+
 		});
 	}
 
@@ -1165,7 +1164,7 @@ class InternalClient {
 		}
 
 		this.websocket.onerror = (e) => {
-			console.log(e);
+			client.emit("error", e);
 		}
 
 		this.websocket.onmessage = (e) => {
@@ -1235,7 +1234,7 @@ class InternalClient {
 					break;
 				case PacketType.MESSAGE_UPDATE:
 					// format https://discordapi.readthedocs.org/en/latest/reference/channels/messages.html#message-format
-					var channel = self.channels.get("id", data.channel_id)|| self.private_channels.get("id", data.channel_id);
+					var channel = self.channels.get("id", data.channel_id) || self.private_channels.get("id", data.channel_id);
 					if (channel) {
 						// potentially blank
 						var msg = channel.messages.get("id", data.id);

src/Client/Resolver/Resolver.js

@@ -17,9 +17,9 @@ class Resolver {
 		this.internal = internal;
 	}
 	
-	resolveInvite(resource){
+	resolveInviteID(resource){
 		if(resource instanceof Invite){
-			return resource;
+			return resource.id;
 		}else if (typeof resource == "string" || resource instanceof String) {
 
 			if (resource.indexOf("http") === 0) {