ION_Archive/custom_discordjs
1
0
Fork 0
mirror of https://github.com/ION606/custom_discordjs.git synced 2026-05-14 22:26:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

backup push before migration to BaseStruct

Browse Source
This commit is contained in:
ION606
2023-04-07 19:13:15 -04:00
parent 1a048a01db
commit e6b32cc115
15 changed files with 248 additions and 68 deletions
Download Patch File Download Diff File Expand all files Collapse all files
structures/client/client.js
+80 -33
View File
@@ -8,6 +8,7 @@ import axios from 'axios';
import { exit } from 'process';
import Guild from '../guilds/Guild.js';
import user from '../messages/User.js';
import { Thread } from '../guilds/ThreadManager.js';
@@ -39,6 +40,8 @@ export class Client extends EventEmitter {
/** @type {Map<String, Guild>} */
guilds;
/** @type {import('axios').AxiosInstance} */
axiosCustom;
/**
* @param {opts} input
@@ -74,16 +77,24 @@ export class Client extends EventEmitter {
this.emit("messageRecieved", msg);
}
ready() {
ready(response) {
this.user_profile = response.profile;
this.user_settings = response.config;
this.id = response.profile.id;
this.emit('ready');
}
customError(err) {
this.emit('error', err);
}
customError(err) { this.emit('error', err); }
interactionRecieved(interaction) {
this.emit('interactionRecieved', interaction);
interactionRecieved(data, response) {
if (data["d"]["member"] && data["d"]["member"]["id"] != this.user_profile.id) {
response.interaction.guild = this.guilds.get(response.interaction.guild_id);
response.interaction.user = new user(data["d"]["member"]["user"]);
this.emit('interactionRecieved', response.interaction);
}
else if (data["d"]["user"]["id"] != this.user_profile.id) {
this.emit('interactionRecieved', response.interaction);
}
}
/**
@@ -103,6 +114,30 @@ export class Client extends EventEmitter {
guildMemberAdd(member) {
this.emit('guildMemberAdd', member);
}
threadCreate(threadRaw) {
const guild = this.guilds.get(threadRaw.guild_id);
const newThread = new Thread(threadRaw, guild, this.#token);
guild.threads.cache.set(newThread.id, newThread);
}
threadEdit(threadRaw) {
if (!this.guilds.has(threadRaw.guild_id)) return;
const guild = this.guilds.get(threadRaw.guild_id);
if (!guild.threads.cache.has(threadRaw.id)) return;
console.log(threadRaw);
}
ThreadDelete(threadRaw) {
if (!this.guilds.has(threadRaw.guild_id)) return;
const guild = this.guilds.get(threadRaw.guild_id);
if (!guild.threads.cache.has(threadRaw.id)) return;
guild.threads.cache.delete()
}
//#endregion
@@ -111,6 +146,10 @@ export class Client extends EventEmitter {
*/
async login(token, isUser = false) {
if (!isUser) token = "Bot " + token;
this.axiosCustom = axios.create({
baseURL: "https://discord.com/api/",
headers: { Authorization: this.#token }
});
return new Promise((resolve, reject) => {
this.ws = new WebSocket("wss://gateway.discord.gg/?v=10&encoding=json");
@@ -143,35 +182,43 @@ export class Client extends EventEmitter {
const data = JSON.parse(msg.toString());
const response = await handleResponses(data, token, this.id);
if (response.op == 10) { this.#startHeartBeat(response.heartBeat, token); }
if (response.op == 10) { return this.#startHeartBeat(response.heartBeat, token); }
else if (response.op == 0) {
if (response.t == gateWayEvents.Ready) {
this.user_profile = response.profile;
this.user_settings = response.config;
this.id = response.profile.id;
// console.log(response.guilds);
this.ready();
switch(response.t) {
case gateWayEvents.Ready: this.ready(response);
break;
case gateWayEvents.MessageCreate:
if (data["d"]["author"]["id"] != this.user_profile.id){
response.message.guild = this.guilds.get(response.message.guild_id);
this.messageRecieved(response.message);
}
break;
case gateWayEvents.InteractionCreate: this.interactionRecieved(data, response);
break;
case gateWayEvents.GuildCreate: this.guildCreate(response.guild);
break;
case gateWayEvents.GuildDelete: this.guildDelete(response.guild);
break;
case gateWayEvents.GuildMemberAdd: this.guildMemberAdd(response.member);
break;
case gateWayEvents.ThreadCreate: this.threadCreate(response.threadRaw);
break;
case gateWayEvents.ThreadUpdate: this.threadEdit(response.threadRaw);
break;
case gateWayEvents.ThreadDelete: this.ThreadDelete(response.threadRaw);
break;
default: // console.log(response.t);
}
else if (response.t == gateWayEvents.MessageCreate) {
if (data["d"]["author"]["id"] != this.user_profile.id){
response.message.guild = this.guilds.get(response.message.guild_id);
this.messageRecieved(response.message);
}
}
else if (response.t == gateWayEvents.InteractionCreate) {
if (data["d"]["member"] && data["d"]["member"]["id"] != this.user_profile.id) {
response.interaction.guild = this.guilds.get(response.interaction.guild_id);
response.interaction.user = new user(data["d"]["member"]["user"]);
this.interactionRecieved(response.interaction);
}
else if (data["d"]["user"]["id"] != this.user_profile.id) {
this.interactionRecieved(response.interaction);
}
}
else if (response.t == gateWayEvents.GuildCreate) this.guildCreate(response.guild);
else if (response.t == gateWayEvents.GuildDelete) this.guildDelete(response.guild);
else if (response.t == gateWayEvents.GuildMemberAdd) this.guildMemberAdd(response.member);
// else console.log(response.t);
} else {
// commmented to avoid heartbeats
// console.log(response.t);
structures/client/handleEvents.js
+31 -17
View File
@@ -15,25 +15,39 @@ export default async function handleEvents(msgObj, token, id) {
const t = msgObj["t"];
if (op == 10) return resolve({op: op, heartBeat: msgObj["d"]["heartbeat_interval"]});
else if (op != 0) { return resolve(false); } // https://discord.com/developers/docs/topics/opcodes-and-status-codes#gateway-gateway-opcodes
else if (op != 0) { resolve(false); }
switch(t) {
case gateWayEvents.Ready:
resolve({op: op, t: t, config: msgObj["d"]["user_settings"], profile: msgObj["d"]["user"]}); //, guilds: msgObj["d"]["guilds"]
break;
else if (t == gateWayEvents.Ready) {
resolve({op: op, t: t, config: msgObj["d"]["user_settings"], profile: msgObj["d"]["user"]}); //, guilds: msgObj["d"]["guilds"]
}
else if (t == gateWayEvents.MessageCreate) {
const msg = new message(msgObj["d"], token);
resolve({op: op, t: t, message: msg});
}
else if (t == gateWayEvents.InteractionCreate) {
resolve({op: op, t: t, interaction: new Interaction(msgObj["d"], token, id)});
}
else if (t == gateWayEvents.GuildCreate) {
resolve({op: op, t: t, guild: new Guild(msgObj["d"], token)});
}
else {
// console.log(t);
case gateWayEvents.MessageCreate:
const msg = new message(msgObj["d"], token);
resolve({op: op, t: t, message: msg});
break;
case gateWayEvents.InteractionCreate:
resolve({op: op, t: t, interaction: new Interaction(msgObj["d"], token, id)});
break;
case gateWayEvents.GuildCreate:
resolve({op: op, t: t, guild: new Guild(msgObj["d"], token)});
break;
case gateWayEvents.ThreadCreate:
resolve({op: op, t: t, threadRaw: msgObj["d"]});
break;
case gateWayEvents.ThreadDelete:
resolve({op: op, t: t, threadRaw: msgObj["d"]});
break;
case gateWayEvents.ThreadUpdate:
resolve({op: op, t: t, threadRaw: msgObj["d"]});
break;
default: console.log(t);
}
});
}