Function cleanUp

packages/queue/src/tasks/remove-community.ts:39–127

({
  accountId,
  logger,
}: {
  accountId: string;
  logger: Logger;
})

}

async function cleanUp({
  accountId,
  logger,
}: {
  accountId: string;
  logger: Logger;
}) {
  const channels = await prisma.channels.findMany({
    select: { id: true, channelName: true },
    where: { accountId },
  });

  for (const channel of channels) {
    logger.info({ channel });
    logger.setPrefix(channel.channelName);

    const mentionsCount = await prisma.mentions.deleteMany({
      where: { messages: { channelId: channel.id } },
    });
    logger.info({ mentionsCount });
    const attachments = await prisma.messageAttachments.findMany({
      where: { messages: { channelId: channel.id } },
    });
    logger.info({ attachmentsCount: attachments.length });
    await processAttachments({ attachments, logger });

    const messageCount = await prisma.messages.deleteMany({
      where: { channelId: channel.id },
    });
    logger.info({ messageCount });
    const threadCount = await prisma.threads.deleteMany({
      where: { channel: { id: channel.id } },
    });
    logger.info({ threadCount });

    const channelMembershipCount = await prisma.memberships.deleteMany({
      where: { channelsId: channel.id },
    });
    logger.info({ channelMembershipCount });

    const channelIntegrationsCount =
      await prisma.channelsIntegration.deleteMany({
        where: { channelId: channel.id },
      });
    logger.info({ channelIntegrationsCount });

    await prisma.channels.delete({
      where: { id: channel.id },
    });
  }
  logger.cleanPrefix();
  logger.info({ channelsCount: channels.length });

  const invitesCount = await prisma.invites.deleteMany({
    where: { accountsId: accountId },
  });
  logger.info({ invitesCount });