Function processAttachments

packages/queue/src/tasks/remove-community.ts:129–155

({
  attachments,
  logger,
}: {
  attachments: messageAttachments[];
  logger: Logger;
})

}

async function processAttachments({
  attachments,
  logger,
}: {
  attachments: messageAttachments[];
  logger: Logger;
}) {
  const keys = attachments
    .filter((e) => !!e.internalUrl)
    .map((attachment) => ({
      Key: attachment
        .internalUrl!.split('/')
        .slice(3)
        .join('/')
        .replace(/\u0010/, ''),
    }));

  while (keys.length) {
    const slice = keys.splice(0, 1000);
    try {
      await deleteFiles(slice);
    } catch (error) {
      logger.error({ slice });
      throw error;
    }
  }
}