wafrn / packages / backend / utils / activitypub / processUserEmojis.ts

import { Emoji, UserEmojiRelation } from "../../models/index.js";
import { v4 as uuidv4, v6 as uuidv6 } from "uuid";

async function processUserEmojis(user: any, fediEmojis: any[]) {
  await UserEmojiRelation.destroy({
    where: {
      userId: user.id,
    },
  });
  await user.removeEmojis();
  await user.save();
  const emojis: any[] = [];
  if (fediEmojis) {
    for await (const emoji of fediEmojis) {
      const emojiId = emoji.id ? emoji.id : emoji.icon?.url;
      const emojiName = emoji.name.startsWith(":")
        ? emoji.name
        : `:${emoji.name}:`;
      let emojiToAdd = await Emoji.findByPk(emojiId);
      if (
        emojiToAdd &&
        new Date(emojiToAdd.updatedAt).getTime() <
          new Date(emoji.updated).getTime()
      ) {
        emojiToAdd.name = emojiName;
        emojiToAdd.updatedAt = new Date();
        emojiToAdd.url = emoji.icon.url;
        await emojiToAdd.save();
      }
      if (!emojiToAdd) {
        emojiToAdd = await Emoji.create({
          id: emojiId,
          name: emojiName,
          url: emoji.icon.url,
          external: true,
          uuid: uuidv4(),
        });
      }
      emojis.push(emojiToAdd);
    }
  }
  return await user.setEmojis([
    ...new Set(emojis.map((emoji: any) => emoji.id)),
  ]);
}

export { processUserEmojis };