Function slackChatSync

apps/web/services/slack/api/postMessage.ts:86–182

({
  channel,
  threadId,
  messageId,
  isThread,
  isReply,
  logger,
}: {
  channel:
    | channels & {
        channelsIntegration: channelsIntegration[];
        account:
          | (accounts & {
              slackAuthorizations: slackAuthorizations[];
              discordAuthorizations: discordAuthorizations[];
            })
          | null;
      };
  threadId?: string;
  messageId: string;
  isThread?: boolean;
  isReply?: boolean;
  logger: Logger;
})

}

export async function slackChatSync({
  channel,
  threadId,
  messageId,
  isThread,
  isReply,
  logger,
}: {
  channel:
    | channels & {
        channelsIntegration: channelsIntegration[];
        account:
          | (accounts & {
              slackAuthorizations: slackAuthorizations[];
              discordAuthorizations: discordAuthorizations[];
            })
          | null;
      };
  threadId?: string;
  messageId: string;
  isThread?: boolean;
  isReply?: boolean;
  logger: Logger;
}) {
  logger.log({ threadId, messageId });
  // check if has enough permissions
  const slackToken = channel.account?.slackAuthorizations.find((s) =>
    isAllowToSendMessages(s)
  );
  if (!slackToken?.accessToken) {
    return 'missing scope on slack token';
  }

  const message = await prisma.messages.findUnique({
    where: { id: messageId },
    include: {
      author: true,
      threads: true,
      attachments: true,
      mentions: {
        include: {
          users: true,
        },
      },
    },
  });
  if (!message) {
    return 'message not found';
  }
  if (!message.threads) {
    return 'thread is missing from message';
  }
  if (!!message.externalMessageId) {
    return 'message has externalId already';
  }

  const token = slackToken.accessToken;
  const externalChannelId = channel.externalChannelId!;