Function twoWaySyncJob

packages/queue/src/tasks/two-way-sync.ts:18–109

(
  { channelId, messageId, threadId, id, event }: TwoWaySyncType,
  logger: Logger
)

}

async function twoWaySyncJob(
  { channelId, messageId, threadId, id, event }: TwoWaySyncType,
  logger: Logger
) {
  logger.info({ event });

  const channel = await prisma.channels.findFirst({
    where: {
      id: channelId,
    },
    include: {
      account: {
        include: { slackAuthorizations: true, discordAuthorizations: true },
      },
      channelsIntegration: true,
    },
  });

  if (!channel) {
    return 'channel not found';
  }
  if (!channel.account) {
    return 'account not found';
  }

  // integration by channel
  if (channel.channelsIntegration.length) {
    for (const integration of channel.channelsIntegration) {
      if (integration.type === 'GITHUB') {
        return await processGithubIntegration({
          channelId,
          messageId,
          threadId,
          event,
          integration,
          id,
        });
      }
      if (integration.type === 'EMAIL') {
        return await processEmailIntegration({
          channelId,
          messageId,
          threadId,
          event,
          integration,
          id,
        });
      }
      if (integration.type === 'LINEAR') {
        return await processLinearIntegration({
          channelId,
          messageId,
          threadId,
          event,
          integration,
          id,
        });
      }