"use strict";

import request from "superagent";
import WebSocket from "ws";
import ConnectionState from "./ConnectionState";
import qs from "querystring";

import {Endpoints, PacketType, Permissions} from "../Constants";

import Cache from "../Util/Cache";
import Resolver from "./Resolver/Resolver";

import User from "../Structures/User";
import Channel from "../Structures/Channel";
import TextChannel from "../Structures/TextChannel";
import VoiceChannel from "../Structures/VoiceChannel";
import PMChannel from "../Structures/PMChannel";
import Server from "../Structures/Server";
import Message from "../Structures/Message";
import Role from "../Structures/Role";
import Invite from "../Structures/Invite";
import VoiceConnection from "../Voice/VoiceConnection";
import TokenCacher from "../Util/TokenCacher";

var zlib;
var libVersion = require('../../package.json').version;

function waitFor(condition, value = condition, interval = 20) {
	return new Promise(resolve => {
		var int = setInterval(() => {
			var isDone = condition();
			if(isDone) {
				if(condition === value) {
					resolve(isDone);
				} else {
					resolve(value(isDone));
				}
				return clearInterval(int);
			}
		}, interval);
	});
}

function delay(ms) {
	return new Promise(resolve => setTimeout(resolve, ms));
}

export default class InternalClient {
	constructor(discordClient) {
		this.setup(discordClient);
	}

	apiRequest(method, url, useAuth, data, file) {
		let ret = request[method](url);
		if(useAuth) {
			ret.set("authorization", this.token);
		}
		if(data) {
			ret.send(data);
		}
		if(file) {
			ret.attach("file", file.file, file.name);
		}
		ret.set('User-Agent', this.userAgentInfo.full);
		return new Promise((resolve, reject) => {
			ret.end((error, data) => {
				if (error) {
					if (!this.client.options.rate_limit_as_error &&
						error.response &&
						error.response.error &&
						error.response.error.status
						&& error.response.error.status === 429
					) {

						if(data.headers["retry-after"] || data.headers["Retry-After"]){
							var toWait = data.headers["retry-after"] || data.headers["Retry-After"];
							toWait = parseInt(toWait);
							setTimeout(() => {
								this.apiRequest.apply(this, arguments).then(resolve).catch(reject);
							}, toWait);
						} else {
							return reject(error);
						}

					} else {
						return reject(error);
					}
				} else {
					resolve(data.body);
				}
			});
		});
	}

	setup(discordClient) {
		discordClient = discordClient || this.client;
		this.client = discordClient;
		this.state = ConnectionState.IDLE;
		this.websocket = null;
		this.userAgent = {
			url: 'https://github.com/hydrabolt/discord.js',
			version: require('../../package.json').version
		};

		if (this.client.options.compress) {
			zlib = require("zlib");
		}

		// creates 4 caches with discriminators based on ID
		this.users = new Cache();
		this.channels = new Cache();
		this.servers = new Cache();
		this.private_channels = new Cache();

		this.intervals = {
			typing : [],
			kai : null,
			misc : []
		};

		this.voiceConnection = null;
		this.resolver = new Resolver(this);
		this.readyTime = null;
		this.messageAwaits = {};

		this.tokenCacher = new TokenCacher(this.client);
		this.tokenCacher.init(0);
	}

	cleanIntervals(){
		for(let interval of this.intervals.typing.concat(this.intervals.misc).concat(this.intervals.kai)){
			if(interval){
				clearInterval(interval);
			}
		}
	}

	disconnected(forced = false){

		this.cleanIntervals();

		this.leaveVoiceChannel();

		if(this.client.options.revive && !forced){
			this.setup();

			// Check whether the email is set (if not, only a token has been used for login)
			if(this.email) {
				this.login(this.email, this.password);
			} else {
				this.loginWithToken(this.token);
			}
		}

		this.client.emit("disconnected");
	}

	get uptime() {
		return (this.readyTime ? Date.now() - this.readyTime : null);
	}

	set userAgent(info) {
		info.full = `DiscordBot (${info.url}, ${info.version})`;
		this.userAgentInfo = info;
	}

	get userAgent() {
		return this.userAgentInfo;
	}

	//def leaveVoiceChannel
	leaveVoiceChannel() {
		if (this.voiceConnection) {
			this.voiceConnection.destroy();
			this.voiceConnection = null;
		}
		return Promise.resolve();
	}

	//def awaitResponse
	awaitResponse(msg){
		return new Promise((resolve, reject) => {

			msg = this.resolver.resolveMessage(msg);

			if(!msg){
				reject(new Error("message undefined"));
				return;
			}

			var awaitID = msg.channel.id + msg.author.id;

			if( !this.messageAwaits[awaitID] ){
				this.messageAwaits[awaitID] = [];
			}

			this.messageAwaits[awaitID].push(resolve);
		});
	}

	//def joinVoiceChannel
	joinVoiceChannel(chann) {
		return this.resolver.resolveChannel(chann).then(channel => {
			if (!channel) {
				return Promise.reject(new Error("voice channel does not exist"));
			}

			if (channel.type !== 'voice') {
				return Promise.reject(new Error("channel is not a voice channel!"));
			}

			return this.leaveVoiceChannel()
			.then(() => {
				return new Promise((resolve, reject) => {
					var session, token, server = channel.server, endpoint;

					var check = m => {
						var data = JSON.parse(m);
						if (data.t === "VOICE_STATE_UPDATE") {
							session = data.d.session_id;
						} else if (data.t === "VOICE_SERVER_UPDATE") {
							token = data.d.token;
							endpoint = data.d.endpoint;
							var chan = this.voiceConnection = new VoiceConnection(
								channel, this.client, session, token, server, endpoint
							);

							chan.on("ready", () => resolve(chan));
							chan.on("error", reject);

							this.client.emit("debug", "removed temporary voice websocket listeners");
							this.websocket.removeListener("message", check);

						}
					};

					this.websocket.on("message", check);
					this.sendWS({
						op: 4,
						d: {
							"guild_id": server.id,
							"channel_id": channel.id,
							"self_mute": false,
							"self_deaf": false
						}
					});
				});
			});
		});
	}

	// def createServer
	createServer(name, region = "london") {
		name = this.resolver.resolveString(name);

		return this.apiRequest('post', Endpoints.SERVERS, true, { name, region })
		.then(res => {
			// valid server, wait until it is cached
			return waitFor(() => this.servers.get("id", res.id));
		});
	}

	//def joinServer
	joinServer(invite) {
		invite = this.resolver.resolveInviteID(invite);
		if(!invite) {
			return Promise.reject(new Error("Not a valid invite"));
		}

		return this.apiRequest("post", Endpoints.INVITE(invite), true)
		.then(res => {
			// valid server, wait until it is received via ws and cached
			return waitFor(() => this.servers.get("id", res.guild.id));
		});
	}

	//def updateServer
	updateServer(server, name, region) {
		var server = this.resolver.resolveServer(server);
		if(!server) {
			return Promise.reject(new Error("server did not resolve"));
		}

		return this.apiRequest("patch", Endpoints.SERVER(server.id), true, { name: name || server.name, region: region || server.region })
		.then(res => {
			// wait until the name and region are updated
			return waitFor(() =>
				(this.servers.get("name", res.name) ? ((this.servers.get("name", res.name).region === res.region) ? this.servers.get("id", res.id) : false) : false));
		});
	}

	//def leaveServer
	leaveServer(srv) {
		var server = this.resolver.resolveServer(srv);
		if(!server) {
			return Promise.reject(new Error("server did not resolve"));
		}

		return this.apiRequest("del", Endpoints.SERVER(server.id), true)
		.then(() => {
			// remove channels of server then the server
			for (var chan of server.channels) {
				this.channels.remove(chan);
			}
			// remove server
			this.servers.remove(server);
		});
	}

	// def loginWithToken
	// email and password are optional
	loginWithToken(token, email, password) {
		this.state = ConnectionState.LOGGED_IN;
		this.token = token;
		this.email = email;
		this.password = password;

		return this.getGateway()
		.then(url => {
			this.createWS(url);
			return token;
		});
	}

	// def login
	login(email, password) {
		var client = this.client;

		if(!this.tokenCacher.done){
			return new Promise((resolve, reject) => {
				setTimeout(() => {
					this.login(email, password).then(resolve).catch(reject);
				}, 20);
			});
		} else {
			var tk = this.tokenCacher.getToken(email, password);
			if( tk ){
				this.client.emit("debug", "bypassed direct API login, used cached token");
				return this.loginWithToken(tk, email, password);
			}
		}

		if(this.state !== ConnectionState.DISCONNECTED && this.state !== ConnectionState.IDLE) {
			return Promise.reject(new Error("already logging in/logged in/ready!"));
		}

		this.state = ConnectionState.LOGGING_IN;

		return this.apiRequest("post", Endpoints.LOGIN, false, {
			email,
			password
		})
		.then(res => {
			this.client.emit("debug", "direct API login, cached token was unavailable");
			var token = res.token;
			this.tokenCacher.setToken(email, password, token);
			return this.loginWithToken(token, email, password);
		}, error => {
			this.websocket = null;
			throw error;
		})
		.catch(error => {
			this.state = ConnectionState.DISCONNECTED;
			client.emit("disconnected");
			throw error;
		});
	}

	// def logout
	logout() {
		if (this.state === ConnectionState.DISCONNECTED || this.state === ConnectionState.IDLE) {
			return Promise.reject(new Error("Client is not logged in!"));
		}

		return this.apiRequest("post", Endpoints.LOGOUT, true)
		.then(() => {
			if (this.websocket) {
				this.websocket.close();
				this.websocket = null;
			}
			this.token = null;
			this.email = null;
			this.password = null;
			this.state = ConnectionState.DISCONNECTED;
		});
	}

	// def startPM
	startPM(resUser) {
		var user = this.resolver.resolveUser(resUser);
		if(!user) {
			return Promise.reject(new Error("Unable to resolve resUser to a User"));
		}
				// start the PM
		return this.apiRequest("post", Endpoints.USER_CHANNELS(user.id), true, {
			recipient_id: user.id
		})
		.then(res => {
			return this.private_channels.add(new PMChannel(res, this.client));
		});
	}

	// def getGateway
	getGateway() {
		return this.apiRequest("get", Endpoints.GATEWAY, true)
		.then(res => res.url);
	}

	// def sendMessage
	sendMessage(where, _content, options = {}) {

		return this.resolver.resolveChannel(where)
		.then(destination => {
			//var destination;
			var content = this.resolver.resolveString(_content);

			return this.apiRequest("post", Endpoints.CHANNEL_MESSAGES(destination.id), true, {
				content: content,
				tts: options.tts
			})
			.then(res =>
				destination.messages.add(new Message(res, destination, this.client))
			);
		});

	}
	// def deleteMessage
	deleteMessage(_message, options = {}) {

		var message = this.resolver.resolveMessage(_message);
		if(!message) {
			return Promise.reject(new Error("Supplied message did not resolve to a message!"));
		}

		var chain = options.wait ? delay(options.wait) : Promise.resolve();
		return chain.then(() =>
			this.apiRequest("del", Endpoints.CHANNEL_MESSAGE(message.channel.id, message.id), true)
		)
		.then(() => message.channel.messages.remove(message));
	}

	// def updateMessage
	updateMessage(msg, _content, options = {}) {

		var message = this.resolver.resolveMessage(msg);

		if(!message) {
			return Promise.reject(new Error("Supplied message did not resolve to a message!"));
		}

		var content = this.resolver.resolveString(_content);

		return this.apiRequest(
			"patch",
			Endpoints.CHANNEL_MESSAGE(message.channel.id, message.id),
			true,
			{
				content: content,
				tts: options.tts
			}
		)
		.then(res => message.channel.messages.update(
			message,
			new Message(res, message.channel, this.client)
		));
	}

	// def sendFile
	sendFile(where, _file, name) {
		if (!name) {
			if (_file instanceof String || typeof _file === "string") {
				name = require("path").basename(_file);
			} else if (_file.path) {
				// fs.createReadStream()'s have .path that give the path. Not sure about other streams though.
				name = require("path").basename(_file.path);
			} else {
				name = "default.png"; // Just have to go with default filenames.
			}
		}

		return this.resolver.resolveChannel(where)
		.then(channel =>
			this.resolver.resolveFile(_file)
			.then(file =>
				this.apiRequest("post", Endpoints.CHANNEL_MESSAGES(channel.id), true, null, {
					name,
					file
				}).then(res => channel.messages.add(new Message(res, channel, this.client)))
			)
		);
	}

	// def getChannelLogs
	getChannelLogs(_channel, limit = 50, options = {}) {
		return this.resolver.resolveChannel(_channel)
		.then(channel => {
			var qsObject = {limit};
			if (options.before) {
				const res = this.resolver.resolveMessage(options.before);
				if(res) {
					qsObject.before = res.id;
				}
			}
			if (options.after) {
				const res = this.resolver.resolveMessage(options.after);
				if(res) {
					qsObject.after = res.id;
				}
			}

			return this.apiRequest(
				"get",
				`${Endpoints.CHANNEL_MESSAGES(channel.id)}?${qs.stringify(qsObject)}`,
				true
			)
			.then(res => res.map(
				msg => channel.messages.add(new Message(msg, channel, this.client))
			));
		});
	}

	// def getBans
	getBans(server) {
		server = this.resolver.resolveServer(server);

		return this.apiRequest("get", Endpoints.SERVER_BANS(server.id), true)
			.then(res => res.map(
				ban => this.users.add(new User(ban.user, this.client))
			));
	}

	// def createChannel
	createChannel(server, name, type = "text") {

		server = this.resolver.resolveServer(server);

		return this.apiRequest("post", Endpoints.SERVER_CHANNELS(server.id), true, {
			name,
			type
		})
		.then(res => {
			var channel;
			if (res.type === "text") {
				channel = new TextChannel(res, this.client, server);
			} else {
				channel = new VoiceChannel(res, this.client, server);
			}
			return server.channels.add(this.channels.add(channel));
		});
	}

	// def deleteChannel
	deleteChannel(_channel) {

		return this.resolver.resolveChannel(_channel)
		.then(channel =>
			this.apiRequest("del", Endpoints.CHANNEL(channel.id), true)
			.then(() => {
				channel.server.channels.remove(channel);
				this.channels.remove(channel);
			})
		);
	}

	// def banMember
	banMember(user, server, length = 1) {
		user = this.resolver.resolveUser(user);
		server = this.resolver.resolveServer(server);

		return this.apiRequest(
			"put",
			`${Endpoints.SERVER_BANS(server.id)}/${user.id}?delete-message-days=${length}`,
			true
		);
	}

	// def unbanMember
	unbanMember(user, server) {

		server = this.resolver.resolveServer(server);
		user = this.resolver.resolveUser(user);

		return this.apiRequest("del", `${Endpoints.SERVER_BANS(server.id)}/${user.id}`, true)
	}

	// def kickMember
	kickMember(user, server) {
		user = this.resolver.resolveUser(user);
		server = this.resolver.resolveServer(server);

		return this.apiRequest("del", `${Endpoints.SERVER_MEMBERS(server.id) }/${user.id}`, true);
	}

	// def moveMember
	moveMember(user, channel) {
		user = this.resolver.resolveUser(user);
		return this.resolver.resolveChannel(channel).then(channel => {
			var server = channel.server;

			// Make sure `channel` is a voice channel
			if(channel.type !== "voice") {
				throw new Error("Can't moveMember into a non-voice channel");
			} else {
				return this.apiRequest("patch", `${Endpoints.SERVER_MEMBERS(server.id)}/${user.id}`, true, { channel_id: channel.id })
				.then(res => {
					user.voiceChannel = channel;
					return res;
				});
			}
		});
	}

	// def createRole
	createRole(server, data) {
		server = this.resolver.resolveServer(server);

		return this.apiRequest("post", Endpoints.SERVER_ROLES(server.id), true)
		.then(res => {
			var role = server.roles.add(new Role(res, server, this.client));

			if (data) {
				return this.updateRole(role, data);
			}
			return role;
		});
	}
	// def updateRole
	updateRole(role, data) {

		role = this.resolver.resolveRole(role);
		var server = this.resolver.resolveServer(role.server);

		var newData = {
			color: data.color || role.color,
			hoist: data.hoist || role.hoist,
			name: data.name || role.name,
			permissions: role.permissions || 0
		};

		if(data.permissions) {
			newData.permissions = 0;
			for (var perm of data.permissions) {
				if (perm instanceof String || typeof perm === "string") {
					newData.permissions |= (Permissions[perm] || 0);
				} else {
					newData.permissions |= perm;
				}
			}
		}

		return this.apiRequest("patch", `${Endpoints.SERVER_ROLES(server.id)}/${role.id}`, true, newData)
		.then(res => {
			return server.roles.update(role, new Role(res, server, this.client));
		});
	}

	// def deleteRole
	deleteRole(role) {
		return this.apiRequest("del", `${Endpoints.SERVER_ROLES(role.server.id)}/${role.id}`, true)
	}

	//def addMemberToRole
	addMemberToRole(member, roles) {
		member = this.resolver.resolveUser(member);

		if (!member) {
			return Promise.reject(new Error("user not found"));
		}

		if (!Array.isArray(roles) || roles.length === 0) {
			roles = this.resolver.resolveRole(roles);
			if (roles) {
				roles = [roles];
			} else {
				return Promise.reject(new Error("invalid array of roles"));
			}
		} else {
			roles = roles.map(r => this.resolver.resolveRole(r));
		}

		if (roles.some(role => !role.server.memberMap[member.id])) {
			return Promise.reject(new Error("Role does not exist on same server as member"));
		}

		var roleIDs = roles[0].server.memberMap[member.id].roles.map(r => r.id);

		for (var i = 0; i < roles.length; i++) {
			if (!~roleIDs.indexOf(roles[i].id)) {
				roleIDs.push(roles[i].id);
			};
		};

		return this.apiRequest(
			"patch",
			`${Endpoints.SERVER_MEMBERS(roles[0].server.id)}/${member.id}`,
			true,
			{
				roles: roleIDs
			}
		);
	}

	memberHasRole(member, role) {
		role = this.resolver.resolveRole(role);
		member = this.resolver.resolveUser(member);

		if (!role) {
			throw new Error("invalid role");
		}
		if (!member) {
			throw new Error("user not found");
		}

		return !!role.server.rolesOf(member).find(r => r.id == role.id);
	}

	//def removeMemberFromRole
	removeMemberFromRole(member, roles) {
		member = this.resolver.resolveUser(member);

		if (!member) {
			return Promise.reject(new Error("user not found"));
		}

		if (!Array.isArray(roles) || roles.length === 0) {
			roles = this.resolver.resolveRole(roles);
			if (roles) {
				roles = [roles];
			} else {
				return Promise.reject(new Error("invalid array of roles"));
			}
		} else {
			roles = roles.map(r => this.resolver.resolveRole(r));
		}

		var roleIDs = roles[0].server.memberMap[member.id].roles.map(r => r.id);

		for(var role of roles) {
			if (!role.server.memberMap[member.id]) {
				return Promise.reject(new Error("member not in server"));
			}
			for (var item in roleIDs) {
				if (roleIDs[item] === role.id) {
					roleIDs.splice(item, 1);
					break;
				}
			}
		}

		return this.apiRequest(
			"patch",
			`${Endpoints.SERVER_MEMBERS(roles[0].server.id)}/${member.id}`,
			true,
			{
				roles: roleIDs
			}
		);
	}

	// def createInvite
	createInvite(chanServ, options) {
		if (chanServ instanceof Channel) {
			// do something
		} else if (chanServ instanceof Server) {
			// do something
		} else {
			chanServ = this.resolver.resolveServer(chanServ) || this.resolver.resolveChannel(chanServ);
		}

		if (!chanServ) {
			throw new Error("couldn't resolve where");
		}

		if (!options) {
			options = {
				validate: null
			};
		} else {
			options.max_age = options.maxAge || 0;
			options.max_uses = options.maxUses || 0;
			options.temporary = options.temporary || false;
			options.xkcdpass = options.xkcd || false;
		}

		var epoint;
		if (chanServ instanceof Channel) {
			epoint = Endpoints.CHANNEL_INVITES(chanServ.id);
		} else {
			epoint = Endpoints.SERVER_INVITES(chanServ.id);
		}

		return this.apiRequest("post", epoint, true, options)
		.then(res => new Invite(res, this.channels.get("id", res.channel.id), this.client));
	}

	//def deleteInvite
	deleteInvite(invite) {
		invite = this.resolver.resolveInviteID(invite);
		if (!invite) {
			throw new Error("Not a valid invite");
		}
		return this.apiRequest("del", Endpoints.INVITE(invite), true);
	}

	//def getInvite
	getInvite(invite) {
		invite = this.resolver.resolveInviteID(invite);
		if (!invite) {
			return Promise.reject(new Error("Not a valid invite"));
		}

		return this.apiRequest("get", Endpoints.INVITE(invite), true)
		.then(res => {
			if (!this.channels.has("id", res.channel.id)) {
				return new Invite(res, null, this.client);
			}
			return this.apiRequest("post", Endpoints.CHANNEL_INVITES(res.channel.id), true, {validate: invite})
			.then(res2 => new Invite(res2, this.channels.get("id", res.channel.id), this.client));
		});
	}

	//def getInvites
	getInvites(channel) {
		if (!(channel instanceof Channel)) {
			var server = this.resolver.resolveServer(channel);
			if (server) {
				return this.apiRequest("get", Endpoints.SERVER_INVITES(server.id), true)
				.then(res => {
					return res.map(data => new Invite(data, this.channels.get("id", data.channel.id), this.client));
				});
			}
		}
		return this.resolver.resolveChannel(channel)
		.then(channel => {
			return this.apiRequest("get", Endpoints.CHANNEL_INVITES(channel.id), true)
			.then(res => {
				return res.map(data => new Invite(data, this.channels.get("id", data.channel.id), this.client));
			});
		});
	}

	//def overwritePermissions
	overwritePermissions(channel, role, updated) {
		return this.resolver.resolveChannel(channel)
		.then(channel => {
			var user;
			if (role instanceof User) {
				user = role;
			} else {
				role = this.resolver.resolveRole(role);
			}

			var data = {};
			data.allow = 0;
			data.deny = 0;

			updated.allow = updated.allow || [];
			updated.deny = updated.deny || [];

			if (role instanceof Role) {
				data.id = role.id;
				data.type = "role";
			} else if (user) {
				data.id = user.id;
				data.type = "member";
			} else {
				throw new Error("role incorrect");
			}

			for (var perm in updated) {
				if (updated[perm]) {
					if (perm instanceof String || typeof perm === "string") {
						data.allow |= (Permissions[perm] || 0);
					} else {
						data.allow |= perm;
					}
				} else {
					if (perm instanceof String || typeof perm === "string") {
						data.deny |= (Permissions[perm] || 0);
					} else {
						data.deny |= perm;
					}
				}
			}

			return this.apiRequest(
				"put",
				`${Endpoints.CHANNEL_PERMISSIONS(channel.id)}/${data.id}`,
				true,
				data
			);
		});
	}

	//def setStatus
	setStatus(idleStatus, game) {

		if(idleStatus === "online" || idleStatus === "here" || idleStatus === "available"){
			this.idleStatus = null;
		}
		else if (idleStatus === "idle" || idleStatus === "away") {
			this.idleStatus = Date.now();
		}
		else {
			this.idleStatus = this.idleStatus || null; //undefined
		}

		this.game = game === null ? null : game || this.game;

		var packet = {
			op: 3,
			d: {
				idle_since: this.idleStatus,
				game: {
					name: this.game
				}
			}
		};

		this.sendWS(packet);

		return Promise.resolve();

	}

	//def sendTyping
	sendTyping(channel) {
		return this.resolver.resolveChannel(channel).then(channel =>
			this.apiRequest("post", Endpoints.CHANNEL(channel.id) + "/typing", true)
		);
	}

	//def startTyping
	startTyping(channel){
		return this.resolver.resolveChannel(channel)
		.then(channel => {

			if(this.intervals.typing[channel.id]){
				// typing interval already exists, leave it alone
				throw new Error("Already typing in that channel");
			}

			this.intervals.typing[channel.id] = setInterval(
				() => this.sendTyping(channel)
				.catch(error => this.emit("error", error)),
				4000
			);

			return this.sendTyping(channel);
		});

	}

	//def stopTyping
	stopTyping(channel){
		return this.resolver.resolveChannel(channel)
		.then(channel => {

			if(!this.intervals.typing[channel.id]){
				// typing interval doesn"t exist
				throw new Error("Not typing in that channel");
			}

			clearInterval(this.intervals.typing[channel.id]);
			this.intervals.typing[channel.id] = false;

		});
	}

	//def updateDetails
	updateDetails(data) {
		if(!this.email) {
			throw new Error("Can't use updateDetails because only a token has been used for login!");
		}
		return this.apiRequest("patch", Endpoints.ME, true, {
			avatar: this.resolver.resolveToBase64(data.avatar) || this.user.avatar,
			email: data.email || this.email,
			new_password: data.newPassword || null,
			password: data.password || this.password,
			username: data.username || this.user.username
		});
	}

	//def setAvatar
	setAvatar(avatar) {
		return this.updateDetails({avatar});
	}

	//def setUsername
	setUsername(username) {
		return this.updateDetails({username});
	}

	//def setChannelTopic
	setChannelTopic(chann, topic = "") {
		return this.resolver.resolveChannel(chann)
		.then(channel =>
			this.apiRequest("patch", Endpoints.CHANNEL(channel.id), true, {
				name: channel.name,
				position: channel.position,
				topic: topic
			})
			.then(res => channel.topic = res.topic)
		);
	}

	//def setChannelName
	setChannelName(chann, name = "discordjs_is_the_best") {
		return this.resolver.resolveChannel(chann)
		.then(channel =>
			this.apiRequest("patch", Endpoints.CHANNEL(channel.id), true, {
				name: name,
				position: channel.position,
				topic: channel.topic
			})
			.then(res => channel.name = res.name)
		);
	}

	//def setChannelNameAndTopic
	setChannelNameAndTopic(chann, name = "discordjs_is_the_best", topic = "") {
		return this.resolver.resolveChannel(chann)
		.then(channel =>
			this.apiRequest("patch", Endpoints.CHANNEL(channel.id), true, {
				name: name,
				position: channel.position,
				topic: topic
			})
			.then(res => {
				channel.name = res.name;
				channel.topic = res.topic;
			})
		);
	}

	//def setTopic
	setChannelPosition(chann, position = 0) {
		return this.resolver.resolveChannel(chann)
		.then(channel =>
			this.apiRequest("patch", Endpoints.CHANNEL(channel.id), true, {
				name: channel.name,
				position: position,
				topic: channel.topic
			})
			.then(res => channel.position = res.position)
		);
	}

	//def updateChannel
	updateChannel(chann, data) {
		return this.setChannelNameAndTopic(chann, data.name, data.topic);
	}

	//def ack
	ack(msg) {
		msg = this.resolver.resolveMessage(msg);

		if(!msg) {
			Promise.reject(new Error("Message does not exist"));
		}

		return this.apiRequest("post", Endpoints.CHANNEL_MESSAGE(msg.channel.id, msg.id) + "/ack", true);
	}

	sendWS(object) {
		if (this.websocket) {
			this.websocket.send(JSON.stringify(object));
		}
	}

	createWS(url) {
		var self = this;
		var client = self.client;

		if (this.websocket) {
			return false;
		}

		this.websocket = new WebSocket(url);

		this.websocket.onopen = () => {

			self.sendWS({
				op: 2,
				d: {
					token: self.token,
					v: 3,
					compress: self.client.options.compress,
					properties: {
						"$os": "discord.js",
						"$browser": "discord.js",
						"$device": "discord.js",
						"$referrer": "discord.js",
						"$referring_domain": "discord.js"
					}
				}
			});
		};

		this.websocket.onclose = () => {
			self.websocket = null;
			self.state = ConnectionState.DISCONNECTED;
			self.disconnected();
		};

		this.websocket.onerror = e => {
			client.emit("error", e);
		};

		this.websocket.onmessage = e => {
			if (e.data instanceof Buffer) {
				if (!zlib) zlib = require("zlib");
				e.data = zlib.inflateSync(e.data).toString();
			}

			var packet, data;
			try {
				packet = JSON.parse(e.data);
				data = packet.d;
			} catch (e) {
				client.emit("error", e);
				return;
			}

			client.emit("raw", packet);
			switch (packet.t) {

				case PacketType.READY:
					var startTime = Date.now();
					self.intervals.kai = setInterval(() => self.sendWS({ op: 1, d: Date.now() }), data.heartbeat_interval);

					self.user = self.users.add(new User(data.user, client));
					data.guilds.forEach(server => {
						if (!server.unavailable) {
							self.servers.add(new Server(server, client));
						} else {
							client.emit("warn", "server was unavailable, could not create (ready)");
						}
					});
					data.private_channels.forEach(pm => {
						self.private_channels.add(new PMChannel(pm, client));
					});
					self.state = ConnectionState.READY;

					client.emit("ready");
					client.emit("debug", `ready packet took ${Date.now() - startTime}ms to process`);
					client.emit("debug", `ready with ${self.servers.length} servers, ${self.channels.length} channels and ${self.users.length} users cached.`);

					self.readyTime = Date.now();
					break;

				case PacketType.MESSAGE_CREATE:
					// 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);
					if (channel) {
						var msg = channel.messages.add(new Message(data, channel, client));

						if(self.messageAwaits[channel.id + msg.author.id]){
							self.messageAwaits[channel.id + msg.author.id].map( fn => fn(msg) );
							self.messageAwaits[channel.id + msg.author.id] = null;
							client.emit("message", msg, true); //2nd param is isAwaitedMessage
						} else {
							client.emit("message", msg);
						}
					} else {
						client.emit("warn", "message created but channel is not cached");
					}
					break;
				case PacketType.MESSAGE_DELETE:
					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);
						client.emit("messageDeleted", msg, channel);
						if (msg) {
							channel.messages.remove(msg);
						} else {
							client.emit("warn", "message was deleted but message is not cached");
						}
					} else {
						client.emit("warn", "message was deleted but channel is not cached");
					}
					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);
					if (channel) {
						// potentially blank
						var msg = channel.messages.get("id", data.id);


						if (msg) {
							// old message exists
							data.nonce = data.nonce || msg.nonce;
							data.attachments = data.attachments || msg.attachments;
							data.tts = data.tts || msg.tts;
							data.embeds = data.embeds || msg.embeds;
							data.timestamp = data.timestamp || msg.timestamp;
							data.mention_everyone = data.mention_everyone || msg.everyoneMentioned;
							data.content = data.content || msg.content;
							data.mentions = data.mentions || msg.mentions;
							data.author = data.author || msg.author;
							var nmsg = new Message(data, channel, client);
							client.emit("messageUpdated", new Message(msg, channel, client), nmsg);
							channel.messages.update(msg, nmsg);
						}
					} else {
						client.emit("warn", "message was updated but channel is not cached");
					}
					break;
				case PacketType.SERVER_CREATE:
					var server = self.servers.get("id", data.id);
					if (!server) {
						if(!data.unavailable) {
							server = new Server(data, client)
							self.servers.add(server);
							client.emit("serverCreated", server);
						} else {
							client.emit("warn", "server was unavailable, could not create");
						}
					}
					break;
				case PacketType.SERVER_DELETE:
					var server = self.servers.get("id", data.id);
					if (server) {
						if(!data.unavailable) {
							for (var channel of server.channels) {
								self.channels.remove(channel);
							}

							self.servers.remove(server);
							client.emit("serverDeleted", server);
						} else {
							client.emit("warn", "server was unavailable, could not update");
						}
					} else {
						client.emit("warn", "server was deleted but it was not in the cache");
					}
					break;
				case PacketType.SERVER_UPDATE:
					var server = self.servers.get("id", data.id);
					if (server) {
						// server exists
						data.members = data.members || [];
						data.channels = data.channels || [];
						var newserver = new Server(data, client);
						newserver.members = server.members;
						newserver.memberMap = server.memberMap;
						newserver.channels = server.channels;
						if (newserver.equalsStrict(server)) {
							// already the same don't do anything
							client.emit("debug", "received server update but server already updated");
						} else {
							client.emit("serverUpdated", new Server(server, client), newserver);
							self.servers.update(server, newserver);
						}
					} else if (!server) {
						client.emit("warn", "server was updated but it was not in the cache");
						self.servers.add(new Server(data, client));
						client.emit("serverCreated", server);
					}
					break;
				case PacketType.CHANNEL_CREATE:

					var channel = self.channels.get("id", data.id);

					if (!channel) {

						var server = self.servers.get("id", data.guild_id);
						if (server) {
								var chan = null;
								if (data.type === "text") {
									chan = self.channels.add(new TextChannel(data, client, server));
								} else {
									chan = self.channels.add(new VoiceChannel(data, client, server));
								}
								client.emit("channelCreated", server.channels.add(chan));
						} else if(data.is_private){
							client.emit("channelCreated", self.private_channels.add(new PMChannel(data, client)));
						}else{
							client.emit("warn", "channel created but server does not exist");
						}

					} else {
						client.emit("warn", "channel created but already in cache");
					}

					break;
				case PacketType.CHANNEL_DELETE:
					var channel = self.channels.get("id", data.id);
					if (channel) {

						if (channel.server) // accounts for PMs
							channel.server.channels.remove(channel);

						self.channels.remove(channel);
						client.emit("channelDeleted", channel);

					} else {
						client.emit("warn", "channel deleted but already out of cache?");
					}
					break;
				case PacketType.CHANNEL_UPDATE:
					var channel = self.channels.get("id", data.id) || self.private_channels.get("id", data.id);
					if (channel) {

						if (channel instanceof PMChannel) {
							//PM CHANNEL
							client.emit("channelUpdated", new PMChannel(channel, client),
								self.private_channels.update(channel, new PMChannel(data, client)));
						} else {
							if (channel.server) {
								if (channel.type === "text") {
									//TEXT CHANNEL
									var chan = new TextChannel(data, client, channel.server);
									chan.messages = channel.messages;
									client.emit("channelUpdated", channel, chan);
									channel.server.channels.update(channel, chan);
									self.channels.update(channel, chan);
								} else {
									//VOICE CHANNEL
									var chan = new VoiceChannel(data, client, channel.server);
									client.emit("channelUpdated", channel, chan);
									channel.server.channels.update(channel, chan);
									self.channels.update(channel, chan);
								}
							} else {
								client.emit("warn", "channel updated but server non-existant");
							}
						}

					} else {
						client.emit("warn", "channel updated but not in cache");
					}
					break;
				case PacketType.SERVER_ROLE_CREATE:
					var server = self.servers.get("id", data.guild_id);
					if (server) {
						client.emit("serverRoleCreated", server.roles.add(new Role(data.role, server, client)), server);
					} else {
						client.emit("warn", "server role made but server not in cache");
					}
					break;
				case PacketType.SERVER_ROLE_DELETE:
					var server = self.servers.get("id", data.guild_id);
					if (server) {
						var role = server.roles.get("id", data.role_id);
						if (role) {
							server.roles.remove(role);
							client.emit("serverRoleDeleted", role);
						} else {
							client.emit("warn", "server role deleted but role not in cache");
						}
					} else {
						client.emit("warn", "server role deleted but server not in cache");
					}
					break;
				case PacketType.SERVER_ROLE_UPDATE:
					var server = self.servers.get("id", data.guild_id);
					if (server) {
						var role = server.roles.get("id", data.role.id);
						if (role) {
							var newRole = new Role(data.role, server, client);
							client.emit("serverRoleUpdated", new Role(role, server, client), newRole);
							server.roles.update(role, newRole);
						} else {
							client.emit("warn", "server role updated but role not in cache");
						}
					} else {
						client.emit("warn", "server role updated but server not in cache");
					}
					break;
				case PacketType.SERVER_MEMBER_ADD:
					var server = self.servers.get("id", data.guild_id);
					if (server) {

						server.memberMap[data.user.id] = {
							roles: data.roles.map(pid => server.roles.get("id", pid)),
							mute: false,
							self_mute: false,
							deaf: false,
							self_deaf: false,
							joinedAt: Date.parse(data.joined_at)
						};

						client.emit(
							"serverNewMember",
							server,
							server.members.add(self.users.add(new User(data.user, client)))
							);

					} else {
						client.emit("warn", "server member added but server doesn't exist in cache");
					}
					break;
				case PacketType.SERVER_MEMBER_REMOVE:
					var server = self.servers.get("id", data.guild_id);
					if (server) {
						var user = self.users.get("id", data.user.id);
						if (user) {
							server.memberMap[data.user.id] = null;
							server.members.remove(user);
							client.emit("serverMemberRemoved", server, user);
						} else {
							client.emit("warn", "server member removed but user doesn't exist in cache");
						}
					} else {
						client.emit("warn", "server member removed but server doesn't exist in cache");
					}
					break;
				case PacketType.SERVER_MEMBER_UPDATE:
					var server = self.servers.get("id", data.guild_id);
					if (server) {
						var user = self.users.get("id", data.user.id);
						if (user) {
							server.memberMap[data.user.id].roles = data.roles.map(pid => server.roles.get("id", pid));
							server.memberMap[data.user.id].mute = data.mute;
							server.memberMap[data.user.id].self_mute = data.self_mute;
							server.memberMap[data.user.id].deaf = data.deaf;
							server.memberMap[data.user.id].self_deaf = data.self_deaf;
							client.emit("serverMemberUpdated", server, user);
						} else {
							client.emit("warn", "server member removed but user doesn't exist in cache");
						}
					} else {
						client.emit("warn", "server member updated but server doesn't exist in cache");
					}
					break;
				case PacketType.PRESENCE_UPDATE:

					var user = self.users.get("id", data.user.id);

					if (user) {
						data.user.username = data.user.username || user.username;
						data.user.id = data.user.id || user.id;
						data.user.avatar = data.user.avatar || user.avatar;
						data.user.discriminator = data.user.discriminator || user.discriminator;
						data.user.status = data.status || user.status;
						data.user.game = data.game || user.game;

						var presenceUser = new User(data.user, client);

						if(!presenceUser.equalsStrict(user)) {
							client.emit("presence", user, presenceUser);
							self.users.update(user, presenceUser);
						}

					} else {
						client.emit("warn", "presence update but user not in cache");
					}

					break;
				case PacketType.TYPING:

					var user = self.users.get("id", data.user_id);
					var channel = self.channels.get("id", data.channel_id) || self.private_channels.get("id", data.channel_id);

					if (user && channel) {
						if (user.typing.since) {
							user.typing.since = Date.now();
							user.typing.channel = channel;
						} else {
							user.typing.since = Date.now();
							user.typing.channel = channel;
							client.emit("userTypingStarted", user, channel);
						}
						setTimeout(() => {
							if (Date.now() - user.typing.since > 5500) {
								// they haven't typed since
								user.typing.since = null;
								user.typing.channel = null;
								client.emit("userTypingStopped", user, channel);
							}
						}, 6000);

					} else {
						client.emit("warn", "user typing but user or channel not existant in cache");
					}
					break;
				case PacketType.SERVER_BAN_ADD:
					var user = self.users.get("id", data.user.id);
					var server = self.servers.get("id", data.guild_id);

					if (user && server) {
						client.emit("userBanned", user, server);
					} else {
						client.emit("warn", "user banned but user/server not in cache.");
					}
					break;
				case PacketType.SERVER_BAN_REMOVE:
					var user = self.users.get("id", data.user.id);
					var server = self.servers.get("id", data.guild_id);

					if (user && server) {
						client.emit("userUnbanned", user, server);
					} else {
						client.emit("warn", "user unbanned but user/server not in cache.");
					}
					break;
				case PacketType.VOICE_STATE_UPDATE:

					var user = self.users.get("id", data.user_id);
					var server = self.servers.get("id", data.guild_id);

					if (user && server) {

						if (data.channel_id) {
							// in voice channel
							var channel = self.channels.get("id", data.channel_id);
							if (channel && channel.type === "voice") {
								server.eventVoiceStateUpdate(channel, user, data);
							} else {
								client.emit("warn", "voice state channel not in cache");
							}
						} else {
							// not in voice channel
							client.emit("voiceLeave", server.eventVoiceLeave(user), user);
						}

					} else {
						client.emit("warn", "voice state update but user or server not in cache");
					}

					break;
				default:
					client.emit("unknown", packet);
					break;
			}
		};
	}
}