Function processAttachments

apps/web/services/slack/sync/attachments.ts:10–58

(
  m: ConversationHistoryMessage,
  message: messages,
  token: string,
  logger: Logger
)

import { slugify } from '@linen/utilities/string';

export async function processAttachments(
  m: ConversationHistoryMessage,
  message: messages,
  token: string,
  logger: Logger
) {
  const promises = [];

  let files: Record<string, string>;
  if (m.files) {
    files = await processLinks(m.files, token, message.channelId, logger);
  }

  if (m.files && m.files.length) {
    promises.push(
      ...m.files
        .filter((file) => !!file.name)
        .map((file) => {
          const serializedFile = {
            messagesId: message.id,
            externalId: file.id,
            name: file.name,
            sourceUrl: file.url_private,
            internalUrl: files[file.id],
            mimetype: file.mimetype,
            permalink: file.permalink,
            title: file.title,
          };
          return prisma.messageAttachments
            .upsert({
              where: {
                messagesId_externalId: {
                  externalId: file.id,
                  messagesId: message.id,
                },
              },
              create: serializedFile,
              update: serializedFile,
            })
            .catch((error) => {
              logger.error({ 'attachment failure': error });
            });
        })
    );
  }
  return await Promise.all(promises).catch((error) => {
    logger.error(error);
  });
}

/**
 * this function will upload files to s3 and return the fileId and internalUrl (cdn or s3 url)