discordeno/src/handlers/messages/MESSAGE_CREATE.ts

import { eventHandlers } from "../../bot.ts";
import { cacheHandlers } from "../../cache.ts";
import { structures } from "../../structures/mod.ts";
import { DiscordGatewayPayload } from "../../types/gateway/gateway_payload.ts";
import { DiscordMessage } from "../../types/messages/message.ts";

export async function handleMessageCreate(data: DiscordGatewayPayload) {
  const payload = data.d as DiscordMessage;
  const channel = await cacheHandlers.get("channels", payload.channel_id);
  if (channel) channel.lastMessageId = payload.id;

  const guild = payload.guild_id
    ? await cacheHandlers.get("guilds", payload.guild_id)
    : undefined;

  if (payload.member && guild) {
    // If in a guild cache the author as a member
    const discordenoMember = await structures.createDiscordenoMember(
      { ...payload.member, user: payload.author },
      guild.id,
    );
    await cacheHandlers.set("members", discordenoMember.id, discordenoMember);
  }

  await Promise.all(payload.mentions.map(async (mention) => {
    // Cache the member if its a valid member
    if (mention.member && guild) {
      const discordenoMember = await structures.createDiscordenoMember(
        { ...mention.member, user: mention },
        guild.id,
      );

      return cacheHandlers.set(
        "members",
        discordenoMember.id,
        discordenoMember,
      );
    }
  }));

  const message = await structures.createDiscordenoMessage(payload);
  // Cache the message
  await cacheHandlers.set("messages", payload.id, message);

  eventHandlers.messageCreate?.(message);
}