Function newThread

apps/web/services/slack/api/postMessage.ts:224–269

({
  threadId,
  token,
  body,
  externalChannelId,
  user,
  messageId,
  logger,
}: {
  threadId: string | undefined;
  token: string;
  body: string;
  externalChannelId: string;
  user: AuthorUser | undefined;
  messageId: string;
  logger: Logger;
})

}

async function newThread({
  threadId,
  token,
  body,
  externalChannelId,
  user,
  messageId,
  logger,
}: {
  threadId: string | undefined;
  token: string;
  body: string;
  externalChannelId: string;
  user: AuthorUser | undefined;
  messageId: string;
  logger: Logger;
}) {
  const thread = await prisma.threads.findUnique({ where: { id: threadId } });
  if (!thread) {
    return 'thread not found';
  }
  // new thread
  const response = await postMessage({
    token,
    body,
    externalChannelId,
    user,
    logger,
  });
  if (response.ok && response.message && response.message.ts) {
    await prisma.threads.update({
      where: { id: threadId },
      data: { externalThreadId: response.message.ts },
    });
    await prisma.messages.update({
      where: { id: messageId },
      data: { externalMessageId: response.message.ts },
    });
    return 'thread created';
  }
  if (!response.ok && response.error === 'channel_not_found') {
    return { slackResponse: response.error };
  }
  logger.error({ response });
  throw response.error || 'something went wrong';
}

function isAllowToSendMessages(s: slackAuthorizations): boolean {
  return s.scope.indexOf('chat:write') > -1;