Function processReactions

apps/web/services/slack/sync/reactions.ts:4–33

(
  m: ConversationHistoryMessage,
  message: messages
)

import type { ConversationHistoryMessage } from '@linen/types';

export async function processReactions(
  m: ConversationHistoryMessage,
  message: messages
) {
  const promises = [];

  if (m.reactions && m.reactions.length) {
    promises.push(
      ...m.reactions.map((reaction) => {
        const serializedReaction = {
          messagesId: message.id,
          name: reaction.name,
          count: reaction.count,
          users: reaction.users,
        };
        return prisma.messageReactions.upsert({
          where: {
            messagesId_name: {
              messagesId: message.id,
              name: reaction.name,
            },
          },
          create: serializedReaction,
          update: serializedReaction,
        });
      })
    );
  }
  return await Promise.all(promises);
}