discordeno/src/controllers/channels.ts

import { eventHandlers } from "../module/client.ts";
import { structures } from "../structures/mod.ts";
import type { ChannelCreatePayload } from "../types/channel.ts";
import { ChannelTypes } from "../types/channel.ts";
import type { DiscordPayload } from "../types/discord.ts";
import { cacheHandlers } from "./cache.ts";

export async function handleInternalChannelCreate(data: DiscordPayload) {
  if (data.t !== "CHANNEL_CREATE") return;

  const payload = data.d as ChannelCreatePayload;
  const channel = await structures.createChannel(payload);
  await cacheHandlers.set("channels", channel.id, channel);

  if (channel.guildID) {
    const guild = await cacheHandlers.get("guilds", channel.guildID);
    guild?.channels.set(channel.id, channel);
  }

  eventHandlers.channelCreate?.(channel);
}

export async function handleInternalChannelDelete(data: DiscordPayload) {
  if (data.t !== "CHANNEL_DELETE") return;

  const payload = data.d as ChannelCreatePayload;

  const cachedChannel = await cacheHandlers.get("channels", payload.id);
  if (!cachedChannel) return;

  if (cachedChannel.type === ChannelTypes.GUILD_VOICE && payload.guild_id) {
    const guild = await cacheHandlers.get("guilds", payload.guild_id);

    if (guild) {
      guild.voiceStates.forEach((vs, key) => {
        if (vs.channelID !== payload.id) return;

        // Since this channel was deleted all voice states for this channel should be deleted
        guild.voiceStates.delete(key);

        const member = guild.members.get(vs.userID);
        if (!member) return;

        eventHandlers.voiceChannelLeave?.(member, vs.channelID);
      });
    }

    guild?.channels.delete(payload.id);
  }

  cacheHandlers.delete("channels", payload.id);
  cacheHandlers.forEach("messages", (message) => {
    if (message.channelID === payload.id) {
      cacheHandlers.delete("messages", message.id);
    }
  });
  eventHandlers.channelDelete?.(cachedChannel);
}

export async function handleInternalChannelUpdate(data: DiscordPayload) {
  if (data.t !== "CHANNEL_UPDATE") return;

  const payload = data.d as ChannelCreatePayload;
  const cachedChannel = await cacheHandlers.get("channels", payload.id);
  const channel = await structures.createChannel(payload);
  cacheHandlers.set("channels", channel.id, channel);

  if (!cachedChannel) return;

  if (channel.guildID) {
    const guild = await cacheHandlers.get("guilds", channel.guildID);
    guild?.channels.set(channel.id, channel);
  }

  eventHandlers.channelUpdate?.(channel, cachedChannel);
}