API tools faq
paste
Guest User

Discord.IO

a guest
May 23rd, 2017
120
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
JavaScript 63.57 KB | None | 0 0
raw download clone embed print report
  1. "use strict";(function discordio(Discord){var isNode=typeof(window)==="undefined"&&typeof(navigator)==="undefined";var CURRENT_VERSION="2.x.x",GATEWAY_VERSION=5,LARGE_THRESHOLD=250,CONNECT_WHEN=null,Endpoints,Payloads;if(isNode){var Util=require('util'),FS=require('fs'),UDP=require('dgram'),Zlib=require('zlib'),DNS=require('dns'),Stream=require('stream'),BN=require('path').basename,EE=require('events').EventEmitter,requesters={http:require('http'),https:require('https')},ChildProc=require('child_process'),URL=require('url'),NACL=require('tweetnacl'),Opus=null}try{CURRENT_VERSION=require('../package.json').version}catch(e){}if(!isNode)CURRENT_VERSION=CURRENT_VERSION+"-browser";Discord.Client=function DiscordClient(options){if(!isNode)Emitter.call(this);if(!options||options.constructor.name!=='Object')return console.error("An Object is required to create the discord.io client.");applyProperties(this,[["_ws",null],["_uIDToDM",{}],["_ready",false],["_vChannels",{}],["_messageCache",{}],["_connecting",false],["_mainKeepAlive",null],["_req",APIRequest.bind(this)],["_shard",validateShard(options.shard)],["_messageCacheLimit",typeof(options.messageCacheLimit)==='number'?options.messageCacheLimit:50],]);this.presenceStatus="offline";this.connected=false;this.inviteURL=null;this.connect=this.connect.bind(this,options);if(options.autorun===true)this.connect()};if(isNode)Emitter.call(Discord.Client);var DCP=Discord.Client.prototype;DCP.connect=function(){var opts=arguments[0];if(!this.connected&&!this._connecting)return setTimeout(function(){init(this,opts);CONNECT_WHEN=Math.max(CONNECT_WHEN,Date.now())+6000}.bind(this),Math.max(0,CONNECT_WHEN-Date.now()))};DCP.disconnect=function(){if(this._ws)return this._ws.close(),log(this,"Manual disconnect called, websocket closed");return log(this,Discord.LogLevels.Warn,"Manual disconnect called with no WebSocket active, ignored")};DCP.getUser=function(input,callback){if(!this.bot)return handleErrCB("[getUser] This account is a 'user' type account, and cannot use 'getUser'. Only bots can use this endpoint.",callback);this._req('get',Endpoints.USER(input.userID),function(err,res){handleResCB("Could not get user",err,res,callback)})};DCP.editUserInfo=function(input,callback){var payload={avatar:this.avatar,email:this.email,new_password:null,password:null,username:this.username},plArr=Object.keys(payload);for(var key in input){if(plArr.indexOf(key)<0)return handleErrCB(("[editUserInfo] '"+key+"' is not a valid key. Valid keys are: "+plArr.join(", ")),callback);payload[key]=input[key]}if(input.avatar)payload.avatar="data:image/jpg;base64,"+input.avatar;this._req('patch',Endpoints.ME,payload,function(err,res){handleResCB("Unable to edit user information",err,res,callback)})};DCP.setPresence=function(input){var payload=Payloads.STATUS(input);send(this._ws,payload);if(payload.d.idle_since===null)return void(this.presenceStatus='online');this.presenceStatus='idle'};DCP.getOauthInfo=function(callback){this._req('get',Endpoints.OAUTH,function(err,res){handleResCB("Error GETing OAuth information",err,res,callback)})};DCP.getAccountSettings=function(callback){this._req('get',Endpoints.SETTINGS,function(err,res){handleResCB("Error GETing client settings",err,res,callback)})};DCP.uploadFile=function(input,callback){var file,client,multi,message,isBuffer,isString;client=this;multi=new Multipart();message=generateMessage(input.message||"");isBuffer=(input.file instanceof Buffer);isString=(type(input.file)==='string');if(!isBuffer&&!isString)return handleErrCB("uploadFile requires a String or Buffer as the 'file' value",callback);if(isBuffer){if(!input.filename)return handleErrCB("uploadFile requires a 'filename' value to be set if using a Buffer",callback);file=input.filename}if(isString)try{file=FS.readFileSync(input.file)}catch(e){return handleErrCB("File does not exist: "+input.file,callback)}[["content",message.content],["mentions",""],["tts",false],["nonce",message.nonce],["file",file,input.filename||BN(input.file)]].forEach(multi.append,multi);multi.finalize();resolveID(client,input.to,function(channelID){client._req('post',Endpoints.MESSAGES(channelID),multi,function(err,res){handleResCB("Unable to upload file",err,res,callback)})})};DCP.sendMessage=function(input,callback){var message=generateMessage(input.message||'',input.embed);message.tts=(input.tts===true);message.nonce=input.nonce||message.nonce;if(input.typing===true){return simulateTyping(this,input.to,message,((message.content.length*0.12)*1000),callback)}sendMessage(this,input.to,message,callback)};DCP.getMessage=function(input,callback){this._req('get',Endpoints.MESSAGES(input.channelID,input.messageID),function(err,res){handleResCB("Unable to get message",err,res,callback)})};DCP.getMessages=function(input,callback){var client=this,qs={},messages=[],lastMessageID="";var total=typeof(input.limit)!=='number'?50:input.limit;if(input.before)qs.before=input.before;if(input.after)qs.after=input.after;(function getMessages(){if(total>100){qs.limit=100;total=total-100}else{qs.limit=total}if(messages.length>=input.limit)return call(callback,[null,messages]);client._req('get',Endpoints.MESSAGES(input.channelID)+qstringify(qs),function(err,res){if(err)return handleErrCB("Unable to get messages",callback);messages=messages.concat(res.body);lastMessageID=messages[messages.length-1]&&messages[messages.length-1].id;if(lastMessageID)qs.before=lastMessageID;if(!res.body.length<qs.limit)return call(callback,[null,messages]);return setTimeout(getMessages,1000)})})()};DCP.editMessage=function(input,callback){this._req('patch',Endpoints.MESSAGES(input.channelID,input.messageID),generateMessage(input.message||'',input.embed),function(err,res){handleResCB("Unable to edit message",err,res,callback)})};DCP.deleteMessage=function(input,callback){this._req('delete',Endpoints.MESSAGES(input.channelID,input.messageID),function(err,res){handleResCB("Unable to delete message",err,res,callback)})};DCP.deleteMessages=function(input,callback){this._req('post',Endpoints.BULK_DELETE(input.channelID),{messages:input.messageIDs.slice(0,100)},function(err,res){handleResCB("Unable to delete messages",err,res,callback)})};DCP.pinMessage=function(input,callback){this._req('put',Endpoints.PINNED_MESSAGES(input.channelID,input.messageID),function(err,res){handleResCB("Unable to pin message",err,res,callback)})};DCP.getPinnedMessages=function(input,callback){this._req('get',Endpoints.PINNED_MESSAGES(input.channelID),function(err,res){handleResCB("Unable to get pinned messages",err,res,callback)})};DCP.deletePinnedMessage=function(input,callback){this._req('delete',Endpoints.PINNED_MESSAGES(input.channelID,input.messageID),function(err,res){handleResCB("Unable to delete pinned message",err,res,callback)})};DCP.simulateTyping=function(channelID,callback){this._req('post',Endpoints.TYPING(channelID),function(err,res){handleResCB("Unable to simulate typing",err,res,callback)})};DCP.fixMessage=function(message){var client=this;return message.replace(/<@&(\d*)>|<@!(\d*)>|<@(\d*)>|<#(\d*)>/g,function(match,RID,NID,UID,CID){var k,i;if(UID||CID){if(client.users[UID])return"@"+client.users[UID].username;if(client.channels[CID])return"#"+client.channels[CID].name}if(RID||NID){k=Object.keys(client.servers);for(i=0;i<k.length;i++){if(client.servers[k[i]].roles[RID])return"@"+client.servers[k[i]].roles[RID].name;if(client.servers[k[i]].members[NID])return"@"+client.servers[k[i]].members[NID].nick}}})};DCP.addReaction=function(input,callback){this._req('put',Endpoints.USER_REACTIONS(input.channelID,input.messageID,stringifyEmoji(input.reaction)),function(err,res){handleResCB("Unable to add reaction",err,res,callback)})};DCP.getReaction=function(input,callback){var qs={limit:(typeof(input.limit)!=='number'?100:input.limit)};this._req('get',Endpoints.MESSAGE_REACTIONS(input.channelID,input.messageID,stringifyEmoji(input.reaction))+qstringify(qs),function(err,res){handleResCB("Unable to get reaction",err,res,callback)})};DCP.removeReaction=function(input,callback){this._req('delete',Endpoints.USER_REACTIONS(input.channelID,input.messageID,stringifyEmoji(input.reaction),input.userID),function(err,res){handleResCB("Unable to remove reaction",err,res,callback)})};DCP.removeAllReactions=function(input,callback){this._req('delete',Endpoints.MESSAGE_REACTIONS(input.channelID,input.messageID),function(err,res){handleResCB("Unable to remove reactions",err,res,callback)})};DCP.kick=function(input,callback){this._req('delete',Endpoints.MEMBERS(input.serverID,input.userID),function(err,res){handleResCB("Could not kick user",err,res,callback)})};DCP.ban=function(input,callback){if(input.lastDays){input.lastDays=Number(input.lastDays);input.lastDays=Math.min(input.lastDays,7);input.lastDays=Math.max(input.lastDays,1)}this._req('put',Endpoints.BANS(input.serverID,input.userID)+(input.lastDays?"?delete-message-days="+input.lastDays:""),function(err,res){handleResCB("Could not ban user",err,res,callback)})};DCP.unban=function(input,callback){this._req('delete',Endpoints.BANS(input.serverID,input.userID),function(err,res){handleResCB("Could not unban user",err,res,callback)})};DCP.moveUserTo=function(input,callback){this._req('patch',Endpoints.MEMBERS(input.serverID,input.userID),{channel_id:input.channelID},function(err,res){handleResCB("Could not move the user",err,res,callback)})};DCP.mute=function(input,callback){this._req('patch',Endpoints.MEMBERS(input.serverID,input.userID),{mute:true},function(err,res){handleResCB("Could not mute user",err,res,callback)})};DCP.unmute=function(input,callback){this._req('patch',Endpoints.MEMBERS(input.serverID,input.userID),{mute:false},function(err,res){handleResCB("Could not unmute user",err,res,callback)})};DCP.deafen=function(input,callback){this._req('patch',Endpoints.MEMBERS(input.serverID,input.userID),{deaf:true},function(err,res){handleResCB("Could not deafen user",err,res,callback)})};DCP.undeafen=function(input,callback){this._req('patch',Endpoints.MEMBERS(input.serverID,input.userID),{deaf:false},function(err,res){handleResCB("Could not undeafen user",err,res,callback)})};DCP.createServer=function(input,callback){var payload,client=this;payload={icon:null,name:null,region:null};for(var key in input){if(Object.keys(payload).indexOf(key)<0)continue;payload[key]=input[key]}if(input.icon)payload.icon="data:image/jpg;base64,"+input.icon;client._req('post',Endpoints.SERVERS(),payload,function(err,res){try{client.servers[res.body.id]={};copyKeys(res.body,client.servers[res.body.id])}catch(e){}handleResCB("Could not create server",err,res,callback)})};DCP.editServer=function(input,callback){var payload,serverID=input.serverID,server,client=this;if(!client.servers[serverID])return handleErrCB(("[editServer] Server "+serverID+" not found."),callback);server=client.servers[serverID];payload={name:server.name,icon:server.icon,region:server.region,afk_channel_id:server.afk_channel_id,afk_timeout:server.afk_timeout};for(var key in input){if(Object.keys(payload).indexOf(key)<0)continue;if(key==='afk_channel_id'){if(server.channels[input[key]]&&server.channels[input[key]].type==='voice')payload[key]=input[key];continue}if(key==='afk_timeout'){if([60,300,900,1800,3600].indexOf(Number(input[key]))>-1)payload[key]=input[key];continue}payload[key]=input[key]}if(input.icon)payload.icon="data:image/jpg;base64,"+input.icon;client._req('patch',Endpoints.SERVERS(input.serverID),payload,function(err,res){handleResCB("Unable to edit server",err,res,callback)})};DCP.editServerWidget=function(input,callback){var client=this,payload,url=Endpoints.SERVERS(input.serverID)+"/embed";client._req('get',url,function(err,res){if(err)return handleResCB("Unable to GET server widget settings. Can not edit without retrieving first.",err,res,callback);payload={enabled:('enabled'in input?input.enabled:res.body.enabled),channel_id:('channelID'in input?input.channelID:res.body.channel_id)};client._req('patch',url,payload,function(err,res){handleResCB("Unable to edit server widget",err,res,callback)})})};DCP.addServerEmoji=function(input,callback){var payload={name:input.name,image:"data:image/png;base64,"+input.image};this._req('post',Endpoints.SERVER_EMOJIS(input.serverID),payload,function(err,res){handleResCB("Unable to add emoji to the server",err,res,callback)})}DCP.editServerEmoji=function(input,callback){var emoji,payload={};if(!this.servers[input.serverID])return handleErrCB(("[editServerEmoji] Server not available: "+input.serverID),callback);if(!this.servers[input.serverID].emojis[input.emojiID])return handleErrCB(("[editServerEmoji] Emoji not available: "+input.emojiID),callback);emoji=this.servers[input.serverID].emojis[input.emojiID];payload.name=input.name||emoji.name;payload.roles=input.roles||emoji.roles;this._req('patch',Endpoints.SERVER_EMOJIS(input.serverID,input.emojiID),payload,function(err,res){handleResCB("[editServerEmoji] Could not edit server emoji",err,res,callback)})};DCP.deleteServerEmoji=function(input,callback){this._req('delete',Endpoints.SERVER_EMOJIS(input.serverID,input.emojiID),function(err,res){handleResCB("[deleteServerEmoji] Could not delete server emoji",err,res,callback)})};DCP.leaveServer=function(serverID,callback){this._req('delete',Endpoints.SERVERS_PERSONAL(serverID),function(err,res){handleResCB("Could not leave server",err,res,callback)})};DCP.deleteServer=function(serverID,callback){this._req('delete',Endpoints.SERVERS(serverID),function(err,res){handleResCB("Could not delete server",err,res,callback)})};DCP.transferOwnership=function(input,callback){this._req('patch',Endpoints.SERVERS(input.serverID),{owner_id:input.userID},function(err,res){handleResCB("Could not transfer server ownership",err,res,callback)})};DCP.acceptInvite=function(NUL,callback){return handleErrCB("acceptInvite can no longer be used",callback)};DCP.createInvite=function(NUL,callback){var payload,client=this;payload={max_age:0,max_users:0,temporary:false};if(Object.keys(input).length===1&&input.channelID){payload={validate:client.internals.lastInviteCode||null}}for(var key in input){if(Object.keys(payload).indexOf(key)<0)continue;payload[key]=input[key]}this._req('post',Endpoints.CHANNEL(input.channelID)+"/invites",payload,function(err,res){try{client.internals.lastInviteCode=res.body.code}catch(e){}handleResCB('Unable to create invite',err,res,callback)})};DCP.deleteInvite=function(inviteCode,callback){this._req('delete',Endpoints.INVITES(inviteCode),function(err,res){handleResCB('Unable to delete invite',err,res,callback)})};DCP.queryInvite=function(inviteCode,callback){this._req('get',Endpoints.INVITES(inviteCode),function(err,res){handleResCB('Unable to get information about invite',err,res,callback)})};DCP.getServerInvites=function(serverID,callback){this._req('get',Endpoints.SERVERS(serverID)+"/invites",function(err,res){handleResCB('Unable to get invite list for server'+serverID,err,res,callback)})};DCP.getChannelInvites=function(channelID,callback){this._req('get',Endpoints.CHANNEL(channelID)+"/invites",function(err,res){handleResCB('Unable to get invite list for channel'+channelID,err,res,callback)})};DCP.createChannel=function(input,callback){var client=this,payload={name:input.name,type:(['text','voice'].indexOf(input.type)<0)?'text':input.type};this._req('post',Endpoints.SERVERS(input.serverID)+"/channels",payload,function(err,res){try{var serverID=res.body.guild_id;var channelID=res.body.id;client.channels[channelID]=new Channel(client,client.servers[serverID],res.body)}catch(e){}handleResCB('Unable to create channel',err,res,callback)})};DCP.createDMChannel=function(userID,callback){var client=this;this._req('post',Endpoints.USER(client.id)+"/channels",{recipient_id:userID},function(err,res){if(!err&&goodResponse(res))client._uIDToDM[res.body.recipient.id]=res.body.id;handleResCB("Unable to create DM Channel",err,res,callback)})};DCP.deleteChannel=function(channelID,callback){this._req('delete',Endpoints.CHANNEL(channelID),function(err,res){handleResCB("Unable to delete channel",err,res,callback)})};DCP.editChannelInfo=function(input,callback){var channel,payload;try{channel=this.channels[input.channelID];payload={name:channel.name,topic:channel.topic,bitrate:channel.bitrate,position:channel.position,user_limit:channel.user_limit};for(var key in input){if(Object.keys(payload).indexOf(key)<0)continue;if(+input[key]){if(key==='bitrate'){payload.bitrate=Math.min(Math.max(input.bitrate,8000),96000);continue}if(key==='user_limit'){payload.user_limit=Math.min(Math.max(input.user_limit,0),99);continue}}payload[key]=input[key]}this._req('patch',Endpoints.CHANNEL(input.channelID),payload,function(err,res){handleResCB("Unable to edit channel",err,res,callback)})}catch(e){return handleErrCB(e,callback)}};DCP.editChannelPermissions=function(input,callback){var payload,pType,ID,channel,permissions,allowed_values;if(!input.userID&&!input.roleID)return handleErrCB("[editChannelPermissions] No userID or roleID provided",callback);if(!this.channels[input.channelID])return handleErrCB(("[editChannelPermissions] No channel found for ID: "+input.channelID),callback);if(!input.allow&&!input.deny&&!input.default)return handleErrCB("[editChannelPermissions] No allow, deny or default array provided.",callback);pType=input.userID?'user':'role';ID=input[pType+"ID"];channel=this.channels[input.channelID];permissions=channel.permissions[pType][ID]||{allow:0,deny:0};allowed_values=[0,4,28].concat((channel.type==='text'?[10,11,12,13,14,15,16,17,18]:[20,21,22,23,24,25]));if(type(input.allow)==='array'){input.allow.forEach(function(perm){if(allowed_values.indexOf(perm)<0)return;if(hasPermission(perm,permissions.deny)){permissions.deny=removePermission(perm,permissions.deny)}permissions.allow=givePermission(perm,permissions.allow)})}if(type(input.deny)==='array'){input.deny.forEach(function(perm){if(allowed_values.indexOf(perm)<0)return;if(hasPermission(perm,permissions.allow)){permissions.allow=removePermission(perm,permissions.allow)}permissions.deny=givePermission(perm,permissions.deny)})}if(type(input.default)==='array'){input.default.forEach(function(perm){if(allowed_values.indexOf(perm)<0)return;permissions.allow=removePermission(perm,permissions.allow);permissions.deny=removePermission(perm,permissions.deny)})}payload={type:(pType==='user'?'member':'role'),id:ID,deny:permissions.deny,allow:permissions.allow};this._req('put',Endpoints.CHANNEL(input.channelID)+"/permissions/"+ID,payload,function(err,res){handleResCB('Unable to edit permission',err,res,callback)})};DCP.deleteChannelPermission=function(input,callback){var payload,pType,ID;if(!input.userID&&!input.roleID)return handleErrCB("[deleteChannelPermission] No userID or roleID provided",callback);if(!this.channels[input.channelID])return handleErrCB(("[deleteChannelPermission] No channel found for ID: "+input.channelID),callback);pType=input.userID?'user':'role';ID=input[pType+"ID"];payload={type:(pType==='user'?'member':'role'),id:ID};this._req('delete',Endpoints.CHANNEL(input.channelID)+"/permissions/"+ID,payload,function(err,res){handleResCB('Unable to delete permission',err,res,callback)})};DCP.createRole=function(serverID,callback){var client=this;this._req('post',Endpoints.ROLES(serverID),function(err,res){try{client.servers[serverID].roles[res.body.id]=new Role(res.body)}catch(e){}handleResCB("Unable to create role",err,res,callback)})};DCP.editRole=function(input,callback){var role,payload;try{role=new Role(this.servers[input.serverID].roles[input.roleID]);payload={name:role.name,color:role.color,hoist:role.hoist,permissions:role._permissions,mentionable:role.mentionable,position:role.position};for(var key in input){if(Object.keys(payload).indexOf(key)<0)continue;if(key==='permissions'){for(var perm in input[key]){role[perm]=input[key][perm];payload.permissions=role._permissions}continue}if(key==='color'){if(String(input[key])[0]==='#')payload.color=parseInt(String(input[key]).replace('#','0x'),16);if(Discord.Colors[input[key]])payload.color=Discord.Colors[input[key]];if(type(input[key])==='number')payload.color=input[key];continue}payload[key]=input[key]}this._req('patch',Endpoints.ROLES(input.serverID,input.roleID),payload,function(err,res){handleResCB("Unable to edit role",err,res,callback)})}catch(e){return handleErrCB(('[editRole] '+e),callback)}};DCP.deleteRole=function(input,callback){this._req('delete',Endpoints.ROLES(input.serverID,input.roleID),function(err,res){handleResCB("Could not remove role",err,res,callback)})};DCP.addToRole=function(input,callback){this._req('put',Endpoints.MEMBER_ROLES(input.serverID,input.userID,input.roleID),function(err,res){handleResCB("Could not add role",err,res,callback)})};DCP.removeFromRole=function(input,callback){this._req('delete',Endpoints.MEMBER_ROLES(input.serverID,input.userID,input.roleID),function(err,res){handleResCB("Could not remove role",err,res,callback)})};DCP.editNickname=function(input,callback){var payload={nick:String(input.nick?input.nick:"")};var url=input.userID===this.id?Endpoints.MEMBERS(input.serverID)+"/@me/nick":Endpoints.MEMBERS(input.serverID,input.userID);this._req('patch',url,payload,function(err,res){handleResCB("Could not change nickname",err,res,callback)})};DCP.editNote=function(input,callback){this._req('put',Endpoints.NOTE(input.userID),{note:input.note},function(err,res){handleResCB("Could not edit note",err,res,callback)})};DCP.getMember=function(input,callback){this._req('get',Endpoints.MEMBERS(input.serverID,input.userID),function(err,res){handleResCB("Could not get member",err,res,callback)})};DCP.getMembers=function(input,callback){var qs={};qs.limit=(typeof(input.limit)!=='number'?50:input.limit);if(input.after)qs.after=input.after;this._req('get',Endpoints.MEMBERS(input.serverID)+qstringify(qs),function(err,res){handleResCB("Could not get members",err,res,callback)})};DCP.getBans=function(serverID,callback){this._req('get',Endpoints.BANS(serverID),function(err,res){handleResCB("Could not get ban list",err,res,callback)})};DCP.getServerWebhooks=function(serverID,callback){this._req('get',Endpoints.SERVER_WEBHOOKS(serverID),function(err,res){handleResCB("Could not get server Webhooks",err,res,callback)})};DCP.getChannelWebhooks=function(channelID,callback){this._req('get',Endpoints.CHANNEL_WEBHOOKS(channelID),function(err,res){handleResCB("Could not get channel Webhooks",err,res,callback)})};DCP.createWebhook=function(serverID,callback){this._req('post',Endpoints.SERVER_WEBHOOKS(serverID),function(err,res){handleResCB("Could not create a Webhook",err,res,callback)})};DCP.editWebhook=function(input,callback){var client=this,payload={},allowed=['avatar','name'];this._req('get',Endpoints.WEBHOOKS(input.webhookID),function(err,res){if(err||!goodResponse(res))return handleResCB("Couldn't get webhook, do you have permissions to access it?",err,res,callback);allowed.forEach(function(key){payload[key]=(key in input?input[key]:res.body[key])});payload.channel_id=input.channelID||res.body.channel_id;client._req('patch',Endpoints.WEBHOOKS(input.webhookID),payload,function(err,res){return handleResCB("Couldn't update webhook",err,res,callback)})})};DCP.joinVoiceChannel=function(channelID,callback){var serverID,server,channel,voiceSession;try{serverID=this.channels[channelID].guild_id;server=this.servers[serverID];channel=server.channels[channelID]}catch(e){}if(!serverID)return handleErrCB(("Cannot find the server related to the channel provided: "+channelID),callback);if(channel.type!=='voice')return handleErrCB(("Selected channel is not a voice channel: "+channelID),callback);if(this._vChannels[channelID])return handleErrCB(("Voice channel already active: "+channelID),callback);voiceSession=getVoiceSession(this,channelID,server);checkVoiceReady(voiceSession,callback);return send(this._ws,Payloads.UPDATE_VOICE(serverID,channelID))};DCP.leaveVoiceChannel=function(channelID,callback){if(!this._vChannels[channelID])return handleErrCB(("Not in the voice channel: "+channelID),callback);return leaveVoiceChannel(this,channelID,callback)};DCP.getAudioContext=function(channelObj,callback){if(!isNode)return handleErrCB("Using audio in the browser is currently not supported.",callback);var channelID=channelObj.channelID||channelObj,voiceSession=this._vChannels[channelID],encoder=chooseAudioEncoder(['ffmpeg','avconv']);if(!voiceSession)return handleErrCB(("You have not joined the voice channel: "+channelID),callback);if(voiceSession.ready!==true)return handleErrCB(("The connection to the voice channel "+channelID+" has not been initialized yet."),callback);if(!encoder)return handleErrCB("You need either 'ffmpeg' or 'avconv' and they need to be added to PATH",callback);voiceSession.audio=voiceSession.audio||new AudioCB(voiceSession,channelObj.stereo===false?1:2,encoder,Math.abs(Number(channelObj.maxStreamSize)));return call(callback,[null,voiceSession.audio])};DCP.getAllUsers=function(callback){var servers=Object.keys(this.servers).filter(function(s){s=this.servers[s];if(s.members)return s.member_count!==Object.keys(s.members).length&&(this.bot?s.large:true)},this);if(!servers[0]){this.emit('allUsers');return handleErrCB("There are no users to be collected",callback)}if(!this.bot)send(this._ws,Payloads.ALL_USERS(this));return getOfflineUsers(this,servers,callback)};function handleErrCB(err,callback){if(!err)return false;return call(callback,[new Error(err)])}function handleResCB(errMessage,err,res,callback){if(typeof(callback)!=='function')return;res=res||{};if(!err&&goodResponse(res))return(callback(null,res.body),true);var e=new Error(err||errMessage);e.name="ResponseError";e.statusCode=res.statusCode;e.statusMessage=res.statusMessage;e.response=res.body;return(callback(e),false)}function goodResponse(response){return(response.statusCode/100|0)===2}function stringifyError(response){if(!response)return null;return response.statusCode+" "+response.statusMessage+"\n"+JSON.stringify(response.body)}function sendMessage(client,to,message,callback){resolveID(client,to,function(channelID){client._req('post',Endpoints.MESSAGES(channelID),message,function(err,res){handleResCB("Unable to send messages",err,res,callback)})})}function cacheMessage(cache,limit,channelID,message){if(!cache[channelID])cache[channelID]={};if(limit===-1)return void(cache[channelID][message.id]=message);var k=Object.keys(cache[channelID]);if(k.length>limit)delete(cache[channelID][k[0]]);cache[channelID][message.id]=message}function generateMessage(message,embed){return{content:String(message),nonce:Math.floor(Math.random()*Number.MAX_SAFE_INTEGER),embed:embed||{}}}function messageHeaders(client){var r={"accept":"*/*","accept-language":"en-US;q=0.8",};if(isNode){r["accept-encoding"]="gzip, deflate";r.user_agent="DiscordBot (https://github.com/izy521/discord.io, "+CURRENT_VERSION+")";r.dnt=1}try{r.authorization=(client.bot?"Bot ":"")+client.internals.token}catch(e){}return r}function simulateTyping(client,to,message,time,callback){if(time<=0)return sendMessage(client,to,message,callback);client.simulateTyping(to,function(){setTimeout(simulateTyping,Math.min(time,5000),client,to,message,time-5000,callback)})}function stringifyEmoji(emoji){if(typeof emoji==='object')return emoji.name+':'+emoji.id;if(emoji.indexOf(':')>-1)return emoji;return encodeURIComponent(decodeURIComponent(emoji))}function APIRequest(method,url){var data,callback,opts,req,headers=messageHeaders(this);callback=(typeof(arguments[2])==='function'?arguments[2]:(data=arguments[2],arguments[3]));if(isNode){opts=URL.parse(url);opts.method=method;opts.headers=headers;req=requesters[opts.protocol.slice(0,-1)].request(opts,function(res){var chunks=[];res.on('data',function(c){chunks[chunks.length]=c});res.once('end',function(){chunks=Buffer.concat(chunks);Zlib.gunzip(chunks,function(err,uc){if(!err)uc=uc.toString();try{res.body=JSON.parse(uc||chunks)}catch(e){}return callback(null,res)})})});if(type(data)==='object'||method.toLowerCase()==='get')req.setHeader("Content-Type","application/json; charset=utf-8");if(data instanceof Multipart)req.setHeader("Content-Type","multipart/form-data; boundary="+data.boundary);if(data)req.write(data.result||JSON.stringify(data),data.result?'binary':'utf-8');req.end();return req.once('error',function(e){return callback(e.message)})}req=new XMLHttpRequest();req.open(method.toUpperCase(),url,true);for(var key in headers){req.setRequestHeader(key,headers[key])}req.onreadystatechange=function(){if(req.readyState==4){req.statusCode=req.status;req.statusMessage=req.statusText;try{req.body=JSON.parse(req.responseText)}catch(e){return handleErrCB(e,callback)}callback(null,req)}};if(type(data)==='object'||method.toLowerCase()==='get')req.setRequestHeader("Content-Type","application/json; charset=utf-8");if(data instanceof Multipart)req.setRequestHeader("Content-Type","multipart/form-data; boundary="+data.boundary);if(data)return req.send(data.result?data.result:JSON.stringify(data));req.send(null)}function send(ws,data){if(ws&&ws.readyState==1)ws.send(JSON.stringify(data))}function copy(obj){try{return JSON.parse(JSON.stringify(obj))}catch(e){}}function copyKeys(from,to,omit){if(!omit)omit=[];for(var key in from){if(omit.indexOf(key)>-1)continue;to[key]=from[key]}}function applyProperties(object,properties){properties.forEach(function(t){Object.defineProperty(object,t[0],{configurable:true,writable:true,value:t[1]})},object)}function type(v){return Object.prototype.toString.call(v).match(/ (.*)]/)[1].toLowerCase()}function call(f,a){if(typeof(f)!='function')return;return f.apply(null,a)}function qstringify(obj){var i=0,s="",k=Object.keys(obj);for(i;i<k.length;i++){s+=k[i]+"="+obj[k[i]]+"&"}return"?"+s.slice(0,-1)}function emit(client,message){if(!message.t)return;var t=message.t.split("_"),i=1,args=[t[0].toLowerCase()];for(i;i<t.length;i++){args[0]+=t[i][0]+t[i].slice(1).toLowerCase()}for(i=2;i<arguments.length;i++){args.push(arguments[i])}args.push(message);client.emit.apply(client,args)}function decompressWSMessage(m,f){f=f||{};return f.binary?JSON.parse(Zlib.inflateSync(m).toString()):JSON.parse(m)}function removeAllListeners(emitter,type){if(!emitter)return;var e=emitter._evts,i,k,o,s,z;if(isNode)return type?emitter.removeAllListeners(type):emitter.removeAllListeners();if(type&&e[type]){for(i=0;i<e[type].length;i++){emitter.removeListener(type,e[type][i])}}if(!type){k=Object.keys(e);for(o=0;o<k.length;o++){s=e[k[o]];for(z=0;z<s.length;z++){emitter.removeListener(k[o],s[z])}}}}function colorFromRole(server,member){return member.roles.reduce(function(array,ID){var role=server.roles[ID];if(!role)return array;return role.position>array[0]&&role.color?[role.position,role.color]:array},[-1,null])[1]}function log(client,level_message){var level,message;if(arguments.length===2){level=Discord.LogLevels.Info;message=level_message}else{level=level_message;message=arguments[2]}return client.emit('log',level,message)}function givePermission(bit,permissions){return permissions|(1<<bit)}function removePermission(bit,permissions){return permissions&~(1<<bit)}function hasPermission(bit,permissions){return((permissions>>bit)&1)==1}function getPerm(bit){return function(){return((this._permissions>>bit)&1)==1}}function setPerm(bit){return function(v){if(v===true)return this._permissions|=(1<<(bit));if(v===false)return this._permissions&=~(1<<bit)}}function getServerInfo(client,servArr){for(var server=0;server<servArr.length;server++){client.servers[servArr[server].id]=new Server(client,servArr[server])}}function getDirectMessages(client,DMArray){for(var DM=0;DM<DMArray.length;DM++){client.directMessages[DMArray[DM].id]=new DMChannel(client._uIDToDM,DMArray[DM])}}function resolveID(client,ID,callback){if(client._uIDToDM[ID])return callback(client._uIDToDM[ID]);if(client.users[ID])return client.createDMChannel(ID,function(err,res){if(err)return console.log("Internal ID resolver error: "+JSON.stringify(err));callback(res.id)});return callback(ID)}function resolveEvent(e){return e.detail||([e.data][0]?[e.data]:[e.code])}function init(client,opts){client.servers={};client.channels={};client.users={};client.directMessages={};client.internals={oauth:{},version:CURRENT_VERSION,settings:{}};client._connecting=true;setupPing(client.internals);return getToken(client,opts)}function getToken(client,opts){if(opts.token)return getGateway(client,opts.token);if(!isNode){}}function getGateway(client,token){client.internals.token=token;return APIRequest('get',Endpoints.GATEWAY,function(err,res){if(err||!goodResponse(res)){client._connecting=false;return client.emit("disconnect","Error GETing gateway:\n"+stringifyError(res),0)}return startConnection(client,(res.body.url+"/?encoding=json&v="+GATEWAY_VERSION))})}function startConnection(client,gateway){client._ws=new Websocket(gateway);client.internals.gatewayUrl=gateway;client._ws.once('close',handleWSClose.bind(client));client._ws.once('error',handleWSClose.bind(client));client._ws.on('message',handleWSMessage.bind(client))}function getOfflineUsers(client,servArr,callback){if(!servArr[0])return call(callback);send(client._ws,Payloads.OFFLINE_USERS(servArr));return setTimeout(getOfflineUsers,0,client,servArr,callback)}function checkForAllServers(client,ready,message){var all=Object.keys(client.servers).every(function(s){return!client.servers[s].unavailable});if(all||ready[0])return void(client._ready=true&&client.emit('ready',message));return setTimeout(checkForAllServers,0,client,ready,message)}function setupPing(obj){applyProperties(obj,[["_pings",[]],["_lastHB",0]]);Object.defineProperty(obj,'ping',{get:function(){return((obj._pings.reduce(function(p,c){return p+c},0)/obj._pings.length)||0)|0},set:function(){}})}function validateShard(shard){return(type(shard)==='array'&&shard.length===2&&shard[0]<=shard[1]&&shard[1]>1)?shard:null}function identifyOrResume(client){var payload,internals=client.internals;if(internals.sequence&&internals.token&&internals.sessionID){payload=Payloads.RESUME(client)}else{payload=Payloads.IDENTIFY(client);if(client._shard)payload.d.shard=client._shard}client._connecting=false;return send(client._ws,payload)}function handleWSMessage(data,flags){var message=decompressWSMessage(data,flags);var _data=message.d;var client=this,user,server,member,old,userID,serverID,channelID,currentVCID;client.internals.sequence=message.s;switch(message.op){case 10:identifyOrResume(client);client.presenceStatus='online';client.connected=true;client._mainKeepAlive=setInterval(function(){client.internals.heartbeat=setTimeout(function(){client._ws&&client._ws.close(1e3,'No heartbeat received')},15e3);client.internals._lastHB=Date.now();send(client._ws,Payloads.HEARTBEAT(client))},_data.heartbeat_interval);break;case 11:clearTimeout(client.internals.heartbeat);client.internals._pings.unshift(Date.now()-client.internals._lastHB);client.internals._pings=client.internals._pings.slice(0,10);break}client.emit('any',message);client.emit('debug',message);switch(message.t){case"READY":copyKeys(_data.user,client);client.internals.sessionID=_data.session_id;getServerInfo(client,_data.guilds);getDirectMessages(client,_data.private_channels);if(client.bot)client.getOauthInfo(function(err,res){if(err)return console.log(err);client.internals.oauth=res;client.inviteURL="https://discordapp.com/oauth2/authorize?client_id="+res.id+"&scope=bot"});if(!client.bot)client.getAccountSettings(function(err,res){if(err)return console.log(err);client.internals.settings=res});return(function(){if(client._ready)return;var ready=[false];setTimeout(function(){ready[0]=true},3500);checkForAllServers(client,ready,message)})();case"MESSAGE_CREATE":client.emit('message',_data.author.username,_data.author.id,_data.channel_id,_data.content,message);emit(client,message,_data.author.username,_data.author.id,_data.channel_id,_data.content);return cacheMessage(client._messageCache,client._messageCacheLimit,_data.channel_id,_data);case"MESSAGE_UPDATE":try{emit(client,message,client._messageCache[_data.channel_id][_data.id],_data)}catch(e){emit(client,message,undefined,_data)}return cacheMessage(client._messageCache,client._messageCacheLimit,_data.channel_id,_data);case"PRESENCE_UPDATE":if(!_data.guild_id)break;serverID=_data.guild_id;userID=_data.user.id;if(!client.users[userID])client.users[userID]=new User(_data.user);user=client.users[userID];member=client.servers[serverID].members[userID]||{};copyKeys(_data.user,user);user.game=_data.game;copyKeys(_data,member,['user','guild_id','game']);client.emit('presence',user.username,user.id,member.status,user.game,message);break;case"USER_UPDATE":copyKeys(_data,client);break;case"USER_SETTINGS_UPDATE":copyKeys(_data,client.internals);break;case"GUILD_CREATE":client.servers[_data.id]=new Server(client,_data);return emit(client,message,client.servers[_data.id]);case"GUILD_UPDATE":old=copy(client.servers[_data.id]);Server.update(client,_data);return emit(client,message,old,client.servers[_data.id]);case"GUILD_DELETE":emit(client,message,client.servers[_data.id]);return delete(client.servers[_data.id]);case"GUILD_MEMBER_ADD":client.users[_data.user.id]=new User(_data.user);client.servers[_data.guild_id].members[_data.user.id]=new Member(client,client.servers[_data.guild_id],_data);client.servers[_data.guild_id].member_count+=1;return emit(client,message,client.servers[_data.guild_id].members[_data.user.id]);case"GUILD_MEMBER_UPDATE":old=copy(client.servers[_data.guild_id].members[_data.user.id]);Member.update(client,client.servers[_data.guild_id],_data);return emit(client,message,old,client.servers[_data.guild_id].members[_data.user.id]);case"GUILD_MEMBER_REMOVE":if(_data.user&&_data.user.id===client.id)return;client.servers[_data.guild_id].member_count-=1;emit(client,message,client.servers[_data.guild_id].members[_data.user.id]);return delete(client.servers[_data.guild_id].members[_data.user.id]);case"GUILD_ROLE_CREATE":client.servers[_data.guild_id].roles[_data.role.id]=new Role(_data.role);return emit(client,message,client.servers[_data.guild_id].roles[_data.role.id]);case"GUILD_ROLE_UPDATE":server=client.servers[_data.guild_id];old=copy(server.roles[_data.role.id]);Role.update(server,_data);Object.keys(server.members).forEach(function(memberID){var member=server.members[memberID];if(member.roles.indexOf(_data.role.id)<0)return;member.color=colorFromRole(server,member)});return emit(client,message,old,server.roles[_data.role.id]);case"GUILD_ROLE_DELETE":emit(client,message,client.servers[_data.guild_id].roles[_data.role_id]);return delete(client.servers[_data.guild_id].roles[_data.role_id]);case"CHANNEL_CREATE":channelID=_data.id;if(_data.is_private){if(client.directMessages[channelID])return;client.directMessages[channelID]=new DMChannel(client._uIDToDM,_data);return emit(client,message,client.directMessages[channelID])}if(client.channels[channelID])return;client.channels[channelID]=new Channel(client,client.servers[_data.guild_id],_data);return emit(client,message,client.channels[channelID]);case"CHANNEL_UPDATE":old=copy(client.channels[_data.id]);Channel.update(client,_data);return emit(client,message,old,client.channels[_data.id]);case"CHANNEL_DELETE":if(_data.is_private===true){emit(client,message,client.directMessages[_data.id]);delete(client.directMessages[_data.id]);return delete(client._uIDToDM[_data.recipient.id])}emit(client,message,client.servers[_data.guild_id].channels[_data.id]);delete(client.servers[_data.guild_id].channels[_data.id]);return delete(client.channels[_data.id]);case"GUILD_EMOJIS_UPDATE":old=copy(client.servers[_data.guild_id].emojis);Emoji.update(client.servers[_data.guild_id],_data.emojis);return emit(client,message,old,client.servers[_data.guild_id].emojis);case"VOICE_STATE_UPDATE":serverID=_data.guild_id;channelID=_data.channel_id;userID=_data.user_id;server=client.servers[serverID];try{currentVCID=server.members[userID].voice_channel_id;if(currentVCID)delete(server.channels[currentVCID].members[userID]);if(channelID)server.channels[channelID].members[userID]=_data;server.members[userID].voice_channel_id=channelID}catch(e){}if(userID===client.id){if(channelID===null){if(server.voiceSession)leaveVoiceChannel(client,server.voiceSession.channelID);return void(server.voiceSession=null)}if(!server.voiceSession){server.voiceSession=getVoiceSession(client,channelID,server)}if(channelID!==server.voiceSession.channelID){delete(client._vChannels[server.voiceSession.channelID]);getVoiceSession(client,channelID,server).channelID=channelID}server.voiceSession.session=_data.session_id}break;case"VOICE_SERVER_UPDATE":serverID=_data.guild_id;server=client.servers[serverID];server.voiceSession.token=_data.token;server.voiceSession.severID=serverID;server.voiceSession.endpoint=_data.endpoint;joinVoiceChannel(client,server.voiceSession);break;case"GUILD_MEMBERS_CHUNK":serverID=_data.guild_id;if(!client.servers[serverID].members)client.servers[serverID].members={};_data.members.forEach(function(member){var uID=member.user.id;var members=client.servers[serverID].members;if(members[uID])return;if(!client.users[uID])client.users[uID]=new User(member.user);members[uID]=new Member(client,client.servers[serverID],member)});var all=Object.keys(client.servers).every(function(server){server=client.servers[server];return server.member_count===Object.keys(server.members).length});if(all)return client.emit("allUsers");break;case"GUILD_SYNC":_data.members.forEach(function(member){var uID=member.user.id;if(!client.users[uID])client.users[uID]=new User(member.user);client.servers[_data.id].members[uID]=new Member(client,client.servers[_data.id],member)});_data.presences.forEach(function(presence){var uID=presence.user.id;var members=client.servers[_data.id].members;if(!members[uID])return void(new User(presence.user));delete(presence.user);copyKeys(presence,members[uID])});client.servers[_data.id].large=_data.large;break}return emit(client,message)}function handleWSClose(code,data){var client=this;var eMsg=Discord.Codes.WebSocket[code];clearInterval(client._mainKeepAlive);client.connected=false;client.presenceStatus="offline";removeAllListeners(client._ws,'message');if([1001,1006].indexOf(code)>-1)return getGateway(client,client.internals.token);client._ready=false;client._ws=null;client.emit("disconnect",eMsg,code)}function joinVoiceChannel(client,voiceSession){var vWS,vUDP,endpoint=voiceSession.endpoint.split(":")[0];voiceSession.ws={};voiceSession.udp={};voiceSession.members={};voiceSession.error=null;voiceSession.ready=false;voiceSession.joined=false;voiceSession.translator={};voiceSession.wsKeepAlive=null;voiceSession.udpKeepAlive=null;voiceSession.keepAlivePackets=0;voiceSession.emitter=new Emitter();if(isNode)voiceSession.keepAliveBuffer=new Buffer(8).fill(0);vWS=voiceSession.ws.connection=new Websocket("wss://"+endpoint);if(isNode)return DNS.lookup(endpoint,function(err,address){if(err)return void(voiceSession.error=err);voiceSession.address=address;vUDP=voiceSession.udp.connection=UDP.createSocket("udp4");vUDP.bind({exclusive:true});vUDP.once('message',handleUDPMessage.bind(client,voiceSession));vWS.once('open',handlevWSOpen.bind(client,voiceSession));vWS.on('message',handlevWSMessage.bind(client,voiceSession));vWS.once('close',handlevWSClose.bind(client,voiceSession))});vWS.once('open',handlevWSOpen.bind(client,voiceSession));vWS.on('message',handlevWSMessage.bind(client,voiceSession));vWS.once('close',handlevWSClose.bind(client,voiceSession));return void(voiceSession.joined=true)}function leaveVoiceChannel(client,channelID,callback){if(!client._vChannels[channelID])return;try{client._vChannels[channelID].ws.connection.close();client._vChannels[channelID].udp.connection.close()}catch(e){}send(client._ws,Payloads.UPDATE_VOICE(client.channels[channelID].guild_id,null));return call(callback,[null])}function keepUDPAlive(VS){if(!VS.keepAliveBuffer)return;if(VS.keepAlivePackets>4294967294){VS.keepAlivePackets=0;VS.keepAliveBuffer.fill(0)}VS.keepAliveBuffer.writeUIntLE(++VS.keepAlivePackets,0,6);try{return VS.udp.connection.send(VS.keepAliveBuffer,0,VS.keepAliveBuffer.length,VS.ws.port,VS.address)}catch(e){}}function getVoiceSession(client,channelID,server){if(!channelID)return null;return client._vChannels[channelID]?client._vChannels[channelID]:client._vChannels[channelID]=(server&&server.voiceSession)||{serverID:(server&&server.id)||null,channelID:channelID,token:null,session:null,endpoint:null}}function checkVoiceReady(voiceSession,callback){return setTimeout(function(){if(voiceSession.error)return call(callback,[error]);if(voiceSession.joined)return call(callback,[null,voiceSession.emitter]);return checkVoiceReady(voiceSession,callback)},1)}function handlevWSOpen(voiceSession){return send(voiceSession.ws.connection,Payloads.VOICE_IDENTIFY(this.id,voiceSession))}function handlevWSMessage(voiceSession,vMessage,vFlags){var client=this,vData=decompressWSMessage(vMessage,vFlags);switch(vData.op){case 2:copyKeys(vData.d,voiceSession.ws);voiceSession.wsKeepAlive=setInterval(send,vData.d.heartbeat_interval,voiceSession.ws.connection,{"op":3,"d":null});if(!isNode)return;var udpDiscPacket=new Buffer(70);udpDiscPacket.writeUIntBE(vData.d.ssrc,0,4);voiceSession.udp.connection.send(udpDiscPacket,0,udpDiscPacket.length,vData.d.port,voiceSession.address,function(err){if(err){leaveVoiceChannel(client,voiceSession.channelID);handleErrCB("UDP discovery error",callback)}});voiceSession.udpKeepAlive=setInterval(keepUDPAlive,5000,voiceSession);break;case 4:voiceSession.selectedMode=vData.d.mode;voiceSession.secretKey=vData.d.secret_key;voiceSession.joined=true;voiceSession.ready=true;break;case 5:voiceSession.emitter.emit('speaking',vData.d.user_id,vData.d.ssrc,vData.d.speaking);break}}function handlevWSClose(voiceSession){voiceSession.emitter.emit("disconnect",voiceSession.channelID);voiceSession.emitter=null var audio=voiceSession.audio,members=voiceSession.members;if(audio){if(audio._systemEncoder)audio._systemEncoder.kill();if(audio._mixedDecoder)audio._mixedDecoder.destroy()}Object.keys(members).forEach(function(ID){var member=members[ID];if(member.decoder)member.decoder.destroy()});clearInterval(voiceSession.wsKeepAlive);clearInterval(voiceSession.udpKeepAlive);removeAllListeners(voiceSession.emitter);removeAllListeners(voiceSession.udp.connection,'message');removeAllListeners(voiceSession.ws.connection,'message');return delete(this._vChannels[voiceSession.channelID])}function handleUDPMessage(voiceSession,msg,rinfo){var buffArr=JSON.parse(JSON.stringify(msg)).data,client=this,vDiscIP="",vDiscPort;for(var i=4;i<buffArr.indexOf(0,i);i++){vDiscIP+=String.fromCharCode(buffArr[i])}vDiscPort=msg.readUIntLE(msg.length-2,2).toString(10);return send(voiceSession.ws.connection,Payloads.VOICE_DISCOVERY(vDiscIP,vDiscPort,'xsalsa20_poly1305'))}function AudioCB(voiceSession,audioChannels,encoder,maxStreamSize){if(maxStreamSize&&!Opus)Opus=require('cjopus');Stream.Duplex.call(this);var ACBI=this;this.audioChannels=audioChannels;this.members=voiceSession.members;applyProperties(this,[["_sequence",0],["_timestamp",0],["_readable",false],["_streamRef",null],["_startTime",null],["_systemEncoder",null],["_playingAudioFile",false],["_voiceSession",voiceSession],["_port",voiceSession.ws.port],["_address",voiceSession.address],["_decodeNonce",new Uint8Array(24)],["_vUDP",voiceSession.udp.connection],["_secretKey",new Uint8Array(voiceSession.secretKey)],["_mixedDecoder",Opus&&new Opus.OpusEncoder(48000,audioChannels)||null]]);createAudioEncoder(this,encoder);this._write=function _write(chunk,encoding,callback){ACBI._systemEncoder.stdin.write(chunk);return callback()};this._read=function _read(){};this.stop=function stop(){return this._systemEncoder.stdout.read=function(){return null}};if(maxStreamSize){voiceSession.ws.connection.on('message',function(data,flags){data=decompressWSMessage(data,flags);if(data.op!==5)return;if(!voiceSession.members[data.d.user_id]){voiceSession.members[data.d.user_id]=new Stream.Readable({highWaterMark:maxStreamSize,read:function(s){}});voiceSession.members[data.d.user_id].decoder=new Opus.OpusEncoder(48000,ACBI.audioChannels);ACBI.emit('newMemberStream',data.d.user_id,voiceSession.members[data.d.user_id])}voiceSession.members[data.d.user_id].ssrc=data.d.ssrc;voiceSession.translator[data.d.ssrc]=voiceSession.members[data.d.user_id]});this._vUDP.on('message',handleIncomingAudio.bind(this))}}if(isNode)Util.inherits(AudioCB,Stream.Duplex);AudioCB.VoicePacket=(function(){if(!isNode)return;var header=new Buffer(12),nonce=new Uint8Array(24),output=new Buffer(2048);header[0]=0x80;header[1]=0x78;return function(packet,ssrc,sequence,timestamp,key){header.writeUIntBE(sequence,2,2);header.writeUIntBE(timestamp,4,4);header.writeUIntBE(ssrc,8,4);nonce.set(header);var encrypted=new Buffer(NACL.secretbox(new Uint8Array(packet),nonce,key));header.copy(output);encrypted.copy(output,12);return output.slice(0,header.length+encrypted.length)}})();var ACBP=AudioCB.prototype;ACBP.playAudioFile=function(location,callback){if(!this._mixedDecoder){if(!Opus)Opus=require('cjopus');this._mixedDecoder=new Opus.OpusEncoder(48000,this.audioChannels)}if(this._playingAudioFile)return handleErrCB("There is already a file being played.",callback);var encs=['ffmpeg','avconv'],selection,enc,ACBI=this;this._playingAudioFile=true;selection=chooseAudioEncoder(encs);if(!selection)return console.log("You need either 'ffmpeg' or 'avconv' and they need to be added to PATH");enc=ChildProc.spawn(selection,['-i',location,'-f','s16le','-ar','48000','-ac',ACBI.audioChannels,'pipe:1'],{stdio:['pipe','pipe','ignore']});enc.stdout.once('end',function(){enc.kill();send(ACBI._voiceSession.ws.connection,Payloads.VOICE_SPEAK(0));ACBI._playingAudioFile=false;ACBI.emit('fileEnd')});enc.stdout.once('error',function(e){enc.stdout.emit('end')});enc.stdout.once('readable',function(){send(ACBI._voiceSession.ws.connection,Payloads.VOICE_SPEAK(1));ACBI._startTime=new Date().getTime();prepareAudioOld(ACBI,enc.stdout,1)});this._streamRef=enc};ACBP.stopAudioFile=function(callback){if(!this._playingAudioFile)return handleErrCB("There is no file being played",callback);this._streamRef.stdout.end();this._streamRef.kill();this._playingAudioFile=false;call(callback)};ACBP.send=function(stream){if(!this._mixedDecoder){if(!Opus)Opus=require('cjopus');this._mixedDecoder=new Opus.OpusEncoder(48000,this.audioChannels)}send(this._voiceSession.ws.connection,Payloads.VOICE_SPEAK(1));this._startTime=new Date().getTime();prepareAudioOld(this,stream,1)};function prepareAudio(ACBI,readableStream,cnt){var data=readableStream.read(320)||readableStream.read();if(!data){send(ACBI._voiceSession.ws.connection,Payloads.VOICE_SPEAK(0));ACBI._readable=false;return readableStream.emit('end')}return setTimeout(function(){sendAudio(ACBI,data);prepareAudio(ACBI,readableStream,cnt+1)},20+((ACBI._startTime+cnt*20)-Date.now()))}function prepareAudioOld(ACBI,readableStream){var done=false;readableStream.on('end',function(){done=true;send(ACBI._voiceSession.ws.connection,Payloads.VOICE_SPEAK(0))});_prepareAudio(ACBI,readableStream,1);function _prepareAudio(ACBI,readableStream,cnt){if(done)return;var buffer,encoded;buffer=readableStream.read(1920*ACBI.audioChannels);encoded=[0xF8,0xFF,0xFE];if((buffer&&buffer.length===1920*ACBI.audioChannels)&&!ACBI._mixedDecoder.destroyed){encoded=ACBI._mixedDecoder.encode(buffer)}return setTimeout(function(){sendAudio(ACBI,encoded);_prepareAudio(ACBI,readableStream,cnt+1)},20+((ACBI._startTime+cnt*20)-Date.now()))}}function sendAudio(ACBI,buffer){ACBI._sequence=(ACBI._sequence+1)<0xFFFF?ACBI._sequence+1:0;ACBI._timestamp=(ACBI._timestamp+960)<0xFFFFFFFF?ACBI._timestamp+960:0;var audioPacket=AudioCB.VoicePacket(buffer,ACBI._voiceSession.ws.ssrc,ACBI._sequence,ACBI._timestamp,ACBI._secretKey);try{ACBI._vUDP.send(audioPacket,0,audioPacket.length,ACBI._port,ACBI._address)}catch(e){return}}function handleIncomingAudio(msg){if(msg.length===8)return;var header=msg.slice(0,12),audio=msg.slice(12),ssrc=header.readUIntBE(8,4),member=this._voiceSession.translator[ssrc],decrypted,decoded;this._decodeNonce.set(header);try{decrypted=new Buffer(NACL.secretbox.open(new Uint8Array(audio),this._decodeNonce,this._secretKey));if(member){decoded=member.decoder.decode(decrypted);addToStreamBuffer(member,decoded)}else{decoded=this._mixedDecoder.decode(decrypted)}addToStreamBuffer(this,decoded);this.emit('incoming',ssrc,decoded)}catch(e){}}function addToStreamBuffer(RStream,data){return RStream.push(new Buffer(data))||!!RStream.read(data.length)}function chooseAudioEncoder(players){if(!players[0])return null;var s=ChildProc.spawnSync(players.shift());return s.error?chooseAudioEncoder(players):s.file}function createAudioEncoder(ACBI,encoder){var enc=ACBI._systemEncoder;if(enc){enc.stdout.emit('end');enc.kill();ACBI._systemEncoder=null}enc=ACBI._systemEncoder=ChildProc.spawn(encoder,['-hide_banner','-loglevel','error','-i','pipe:0','-map','0:a','-acodec','libopus','-f','data','-sample_fmt','s16','-vbr','off','-compression_level','10','-ar','48000','-ac',ACBI.audioChannels,'-b:a','128000','pipe:1'],{stdio:['pipe','pipe','pipe']});enc.stderr.once('data',function(d){if(ACBI.listeners('error').length>0)ACBI.emit('error',d.toString())});enc.stdin.once('error',function(e){enc.stdout.emit('end');enc.kill()});enc.stdout.once('error',function(e){enc.stdout.emit('end');enc.kill()});enc.stdout.once('end',function(){createAudioEncoder(ACBI,encoder);ACBI.emit('done')});enc.stdout.on('readable',function(){if(ACBI._readable)return;ACBI._readable=true;send(ACBI._voiceSession.ws.connection,Payloads.VOICE_SPEAK(1));ACBI._startTime=new Date().getTime();prepareAudio(ACBI,enc.stdout,1)})}function Resource(){}Object.defineProperty(Resource.prototype,"creationTime",{get:function(){return(+this.id/4194304)+1420070400000},set:function(){}});[Server,Channel,DMChannel,User,Member,Role].forEach(function(p){p.prototype=Object.create(Resource.prototype);Object.defineProperty(p.prototype,'constructor',{value:p,enumerable:false})});function Server(client,data){var server=this;copyKeys(data,this);this.large=this.large||this.member_count>LARGE_THRESHOLD;this.voiceSession=null;if(data.unavailable)return;this.channels={};this.members={};this.roles={};this.emojis={};data.channels.forEach(function(channel){client.channels[channel.id]=new Channel(client,server,channel)});data.roles.forEach(function(role){server.roles[role.id]=new Role(role)});data.members.forEach(function(member){client.users[member.user.id]=new User(member.user);server.members[member.user.id]=new Member(client,server,member)});data.presences.forEach(function(presence){var id=presence.user.id;if(!client.users[id]||!server.members[id])return;delete(presence.user);client.users[id].game=presence.game;server.members[id].status=presence.status});data.emojis.forEach(function(emoji){server.emojis[emoji.id]=new Emoji(emoji)});data.voice_states.forEach(function(vs){var cID=vs.channel_id;var uID=vs.user_id;if(!server.channels[cID]||!server.members[uID])return;server.channels[cID].members[uID]=vs;server.members[uID].voice_channel_id=cID});delete(this.voice_states);delete(this.presences)}function Channel(client,server,data){var channel=this;this.members={};this.permissions={user:{},role:{}};this.guild_id=server.id;copyKeys(data,this,['permission_overwrites','emojis']);Object.defineProperty(server.channels,channel.id,{get:function(){return client.channels[channel.id]},set:function(v){client.channels[channel.id]=v},enumerable:true,configurable:true});data.permission_overwrites.forEach(function(p){var type=(p.type==='member'?'user':'role');this.permissions[type][p.id]={allow:p.allow,deny:p.deny}},this);delete(this.is_private)}function DMChannel(translator,data){copyKeys(data,this);translator[data.recipient.id]=data.id;delete(this.is_private)}function User(data){copyKeys(data,this);this.bot=this.bot||false}function Member(client,server,data){copyKeys(data,this,['user','joined_at',]);this.id=data.user.id;this.joined_at=Date.parse(data.joined_at);this.color=colorFromRole(server,this);['username','discriminator','bot','avatar','game'].forEach(function(k){if(k in Member.prototype)return;Object.defineProperty(Member.prototype,k,{get:function(){return client.users[this.id][k]},set:function(v){client.users[this.id][k]=v},enumerable:true,})})}function Role(data){copyKeys(data,this,['permissions']);this._permissions=data._permissions||data.permissions}function Emoji(data){copyKeys(data,this)}function Multipart(){this.boundary="NodeDiscordIO"+"-"+CURRENT_VERSION;this.result=""}Multipart.prototype.append=function(data){var str="\r\n--";str+=this.boundary+"\r\n";str+='Content-Disposition: form-data; name="'+data[0]+'"';if(data[2]){str+='; filename="'+data[2]+'"\r\n';str+='Content-Type: application/octet-stream'}str+="\r\n\r\n"+(data[1]instanceof Buffer?data[1]:new Buffer(String(data[1]),'utf-8')).toString('binary');this.result+=str};Multipart.prototype.finalize=function(){this.result+="\r\n--"+this.boundary+"--"};Server.update=function(client,data){if(!client.servers[data.id])client.servers[data.id]={};for(var key in data){if(key==='roles'){data[key].forEach(function(r){client.servers[data.id].roles[r.id]=new Role(r)});continue}if(key==='emojis')continue;client.servers[data.id][key]=data[key]}};Channel.update=function(client,data){if(!client.channels[data.id])client.channels[data.id]={};for(var key in data){if(key==='permission_overwrites'){data[key].forEach(function(p){var type=(p.type==='member'?'user':'role');client.channels[data.id].permissions[type][p.id]={allow:p.allow,deny:p.deny}});continue}client.channels[data.id][key]=data[key]}delete(client.channels[data.id].is_private)};Member.update=function(client,server,data){if(!server.members[data.user.id])return server.members[data.user.id]=new Member(client,server,data);var member=server.members[data.user.id];copyKeys(data,member,['user']);member.color=colorFromRole(server,member)};Role.update=function(server,data){if(!server.roles[data.role.id])server.roles[data.role.id]={};server.roles[data.role.id]._permissions=data.role.permissions;copyKeys(data.role,server.roles[data.role.id],['permissions'])};Emoji.update=function(server,data){server.emojis={};data.forEach(function(emoji){server.emojis[emoji.id]=new Emoji(emoji)})}Object.defineProperty(Role.prototype,"permission_values",{get:function(){return this},set:function(){},enumerable:true});Object.defineProperty(User.prototype,'avatarURL',{get:function(){if(!this.avatar)return null;var animated=this.avatar.indexOf("a_")>-1;return Discord.Endpoints.CDN+"/avatars/"+this.id+"/"+this.avatar+(animated?".gif":".webp")},set:function(){}});Discord.version=CURRENT_VERSION;Discord.Emitter=Emitter;Discord.Codes={};Discord.Codes.WebSocket={"0":"Gateway Error","4000":"Unknown Error","4001":"Unknown Opcode","4002":"Decode Error","4003":"Not Authenticated","4004":"Authentication Failed","4005":"Already Authenticated","4006":"Session Not Valid","4007":"Invalid Sequence Number","4008":"Rate Limited","4009":"Session Timeout","4010":"Invalid Shard"};Discord.Colors={DEFAULT:0,AQUA:1752220,GREEN:3066993,BLUE:3447003,PURPLE:10181046,GOLD:15844367,ORANGE:15105570,RED:15158332,GREY:9807270,DARKER_GREY:8359053,NAVY:3426654,DARK_AQUA:1146986,DARK_GREEN:2067276,DARK_BLUE:2123412,DARK_PURPLE:7419530,DARK_GOLD:12745742,DARK_ORANGE:11027200,DARK_RED:10038562,DARK_GREY:9936031,LIGHT_GREY:12370112,DARK_NAVY:2899536};Discord.Permissions={GENERAL_CREATE_INSTANT_INVITE:0,GENERAL_KICK_MEMBERS:1,GENERAL_BAN_MEMBERS:2,GENERAL_ADMINISTRATOR:3,GENERAL_MANAGE_CHANNELS:4,GENERAL_MANAGE_GUILD:5,GENERAL_MANAGE_ROLES:28,GENERAL_MANAGE_NICKNAMES:27,GENERAL_CHANGE_NICKNAME:26,GENERAL_MANAGE_WEBHOOKS:29,GENERAL_MANAGE_EMOJIS:30,TEXT_ADD_REACTIONS:6,TEXT_READ_MESSAGES:10,TEXT_SEND_MESSAGES:11,TEXT_SEND_TTS_MESSAGE:12,TEXT_MANAGE_MESSAGES:13,TEXT_EMBED_LINKS:14,TEXT_ATTACH_FILES:15,TEXT_READ_MESSAGE_HISTORY:16,TEXT_MENTION_EVERYONE:17,TEXT_EXTERNAL_EMOJIS:18,VOICE_CONNECT:20,VOICE_SPEAK:21,VOICE_MUTE_MEMBERS:22,VOICE_DEAFEN_MEMBERS:23,VOICE_MOVE_MEMBERS:24,VOICE_USE_VAD:25,};Discord.LogLevels={Verbose:0,Info:1,Warn:2,Error:3};Object.keys(Discord.Permissions).forEach(function(pn){Object.defineProperty(Role.prototype,pn,{get:getPerm(Discord.Permissions[pn]),set:setPerm(Discord.Permissions[pn]),enumerable:true})});function Emitter(){var emt=this;if(isNode){EE.call(this);if(this.prototype)return Util.inherits(this,EE);return new EE()}function _Emitter(){var eventTarget=document.createDocumentFragment();["addEventListener","dispatchEvent","removeEventListener"].forEach(function(method){if(!this[method])this[method]=eventTarget[method].bind(eventTarget)},this)}_Emitter.call(this);this._evts={};this.on=function(eName,eFunc){if(!emt._evts[eName])emt._evts[eName]=[];emt._evts[eName].push(eOn);return this.addEventListener(eName,eOn);function eOn(e){return eFunc.apply(null,resolveEvent(e))}};this.once=function(eName,eFunc){if(!emt._evts[eName])emt._evts[eName]=[];emt._evts[eName].push(eOnce);return this.addEventListener(eName,eOnce);function eOnce(e){eFunc.apply(null,resolveEvent(e));return emt.removeListener(eName,eOnce)}};this.removeListener=function(eName,eFunc){if(emt._evts[eName])emt._evts[eName].splice(emt._evts[eName].lastIndexOf(eFunc),1);return this.removeEventListener(eName,eFunc)};this.emit=function(eName){return this.dispatchEvent(new CustomEvent(eName,{'detail':Array.prototype.slice.call(arguments,1)}))};return this}function Websocket(url,opts){if(isNode)return new(require('ws'))(url,opts);return Emitter.call(new WebSocket(url))}(function(){var API="https://discordapp.com/api";var CDN="http://cdn.discordapp.com";var ME=API+"/users/@me";Endpoints=Discord.Endpoints={API:API,CDN:CDN,ME:ME,NOTE:function(userID){return ME+"/notes/"+userID},LOGIN:API+"/auth/login",OAUTH:API+"/oauth2/applications/@me",GATEWAY:API+"/gateway",SETTINGS:ME+"/settings",SERVERS:function(serverID){return API+"/guilds"+(serverID?"/"+serverID:"")},SERVERS_PERSONAL:function(serverID){return this.ME+"/guilds"+(serverID?"/"+serverID:"")},SERVER_EMOJIS:function(serverID,emojiID){return this.SERVERS(serverID)+"/emojis"+(emojiID?"/"+emojiID:"")},CHANNEL:function(channelID){return API+"/channels/"+channelID},MEMBERS:function(serverID,userID){return this.SERVERS(serverID)+"/members"+(userID?"/"+userID:"")},MEMBER_ROLES:function(serverID,userID,roleID){return this.MEMBERS(serverID,userID)+"/roles"+(roleID?"/"+roleID:"")},USER:function(userID){return API+"/users/"+userID},ROLES:function(serverID,roleID){return this.SERVERS(serverID)+"/roles"+(roleID?"/"+roleID:"")},BANS:function(serverID,userID){return this.SERVERS(serverID)+"/bans"+(userID?"/"+userID:"")},MESSAGES:function(channelID,messageID){return this.CHANNEL(channelID)+"/messages"+(messageID?"/"+messageID:"")},PINNED_MESSAGES:function(channelID,messageID){return this.CHANNEL(channelID)+"/pins"+(messageID?"/"+messageID:"")},MESSAGE_REACTIONS:function(channelID,messageID,reaction){return this.MESSAGES(channelID,messageID)+"/reactions"+(reaction?("/"+reaction):"")},USER_REACTIONS:function(channelID,messageID,reaction,userID){return this.MESSAGE_REACTIONS(channelID,messageID,reaction)+'/'+((!userID||userID===this.id)?'@me':userID)},INVITES:function(inviteCode){return API+"/invite/"+inviteCode},SERVER_WEBHOOKS:function(serverID){return this.SERVERS(serverID)+"/webhooks"},CHANNEL_WEBHOOKS:function(channelID){return this.CHANNEL(channelID)+"/webhooks"},WEBHOOKS:function(webhookID){return API+"/webhooks/"+webhookID},BULK_DELETE:function(channelID){return this.CHANNEL(channelID)+"/messages/bulk-delete"},TYPING:function(channelID){return this.CHANNEL(channelID)+"/typing"}}})();(function(){Payloads={IDENTIFY:function(client){return{op:2,d:{token:client.internals.token,v:GATEWAY_VERSION,compress:isNode&&!!Zlib.inflateSync,large_threshold:LARGE_THRESHOLD,properties:{$os:isNode?require('os').platform():navigator.platform,$browser:"discord.io",$device:"discord.io",$referrer:"",$referring_domain:""}}}},RESUME:function(client){return{op:6,d:{seq:client.internals.s,token:client.internals.token,session_id:client.internals.sessionID}}},HEARTBEAT:function(client){return{op:1,d:client.internals.sequence}},ALL_USERS:function(client){return{op:12,d:Object.keys(client.servers)}},STATUS:function(input){return{op:3,d:{idle_since:input.idle_since||null,game:type(input.game)==='object'?{name:input.game.name?String(input.game.name):null,type:input.game.type?Number(input.game.type):null,url:input.game.url?String(input.game.url):null}:null}}},UPDATE_VOICE:function(serverID,channelID){return{op:4,d:{guild_id:serverID,channel_id:channelID,self_mute:false,self_deaf:false}}},OFFLINE_USERS:function(array){return{op:8,d:{guild_id:array.splice(0,50),query:"",limit:0}}},VOICE_SPEAK:function(v){return{op:5,d:{speaking:!!v,delay:0}}},VOICE_IDENTIFY:function(clientID,voiceSession){return{op:0,d:{server_id:voiceSession.serverID,user_id:clientID,session_id:voiceSession.session,token:voiceSession.token}}},VOICE_DISCOVERY:function(ip,port,mode){return{op:1,d:{protocol:"udp",data:{address:ip,port:Number(port),mode:mode}}}}}})()})(typeof exports==='undefined'?this.Discord={}:exports);
Add Comment
Please, Sign In to add comment
Public Pastes
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!