Function processLinkedMessage

apps/web/src/lib/bot/run.ts:9–69

({
  thread,
  message,
  platformIntegration,
  user,
}: {
  thread: Thread;
  message: Message;
  platformIntegration: PlatformIntegration;
  user: User;
})

import { captureException } from '@sentry/nextjs';

export async function processLinkedMessage({
  thread,
  message,
  platformIntegration,
  user,
}: {
  thread: Thread;
  message: Message;
  platformIntegration: PlatformIntegration;
  user: User;
}) {
  const botPlatform = botPlatforms.requireByAdapter(thread.adapter);
  const stopProcessingIndicator = await botPlatform.startProcessingIndicator({
    thread,
    messageId: message.id,
    status: 'Thinking...',
    platformIntegration,
  });

  let handedOff = false;
  try {
    let botRequestId: string;
    try {
      botRequestId = await createBotRequest({
        createdBy: user.id,
        organizationId: platformIntegration.owned_by_organization_id ?? null,
        platformIntegrationId: platformIntegration.id,
        platform: thread.adapter.name,
        platformThreadId: thread.id,
        platformMessageId: message.id,
        userMessage: message.text,
        modelUsed: undefined,
      });
    } catch (error) {
      captureException(error, {
        tags: { component: 'kilo-bot', op: 'create-bot-request' },
        extra: {
          platform: thread.adapter.name,
          platformIntegrationId: platformIntegration.id,
          userId: user.id,
          threadId: thread.id,
          messageId: message.id,
        },
      });
      await botPlatform.withAuthContext({
        platformIntegration,
        fn: () =>
          thread.post({
            markdown:
              'Sorry, I could not start processing your message because of an internal error. Please try again in a moment.',
          }),
      });
      return;
    }

    handedOff = await processMessage({
      thread,
      message,