mirror of
https://github.com/discordeno/discordeno.git
synced 2026-06-16 11:28:15 +00:00
Update THREAD_DELETE.ts
This commit is contained in:
@@ -2,20 +2,24 @@ import { eventHandlers } from "../../bot.ts";
|
|||||||
import { cacheHandlers } from "../../cache.ts";
|
import { cacheHandlers } from "../../cache.ts";
|
||||||
import { Channel } from "../../types/channels/channel.ts";
|
import { Channel } from "../../types/channels/channel.ts";
|
||||||
import { DiscordGatewayPayload } from "../../types/gateway/gateway_payload.ts";
|
import { DiscordGatewayPayload } from "../../types/gateway/gateway_payload.ts";
|
||||||
|
import { snowflakeToBigint } from "../../util/bigint.ts";
|
||||||
|
|
||||||
export async function handleThreadDelete(data: DiscordGatewayPayload) {
|
export async function handleThreadDelete(data: DiscordGatewayPayload) {
|
||||||
const payload = data.d as Channel;
|
const payload = data.d as Channel;
|
||||||
|
|
||||||
const cachedChannel = await cacheHandlers.get("channels", payload.id);
|
const cachedChannel = await cacheHandlers.get(
|
||||||
|
"channels",
|
||||||
|
snowflakeToBigint(payload.id),
|
||||||
|
);
|
||||||
if (!cachedChannel) return;
|
if (!cachedChannel) return;
|
||||||
|
|
||||||
await cacheHandlers.delete("channels", payload.id);
|
await cacheHandlers.delete("channels", snowflakeToBigint(payload.id));
|
||||||
cacheHandlers.forEach("messages", (message) => {
|
cacheHandlers.forEach("messages", (message) => {
|
||||||
eventHandlers.debug?.(
|
eventHandlers.debug?.(
|
||||||
"loop",
|
"loop",
|
||||||
`Running forEach messages loop in CHANNEL_DELTE file.`,
|
`Running forEach messages loop in CHANNEL_DELTE file.`,
|
||||||
);
|
);
|
||||||
if (message.channelId === payload.id) {
|
if (message.channelId === snowflakeToBigint(payload.id)) {
|
||||||
cacheHandlers.delete("messages", message.id);
|
cacheHandlers.delete("messages", message.id);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user