Function createKiloBot

apps/web/src/lib/bot.ts:21–128

(
  slackAdapter: SlackAdapter,
  githubAdapter: GitHubAdapter,
  linearAdapter: LinearAdapter
)

import { createSlackWebhookHandler } from '@/lib/bot/platforms/slack-webhook';

function createKiloBot(
  slackAdapter: SlackAdapter,
  githubAdapter: GitHubAdapter,
  linearAdapter: LinearAdapter
) {
  const chatBot = new Chat({
    userName: process.env.NODE_ENV === 'production' ? 'Kilo' : 'Henk',
    adapters: {
      github: githubAdapter,
      slack: slackAdapter,
      linear: linearAdapter,
    },
    state: createChatState(),
    logger: process.env.NODE_ENV === 'production' ? 'info' : 'debug',
  });

  chatBot.webhooks.slack = createSlackWebhookHandler(chatBot, slackAdapter);
  chatBot.webhooks.linear = createLinearWebhookHandler(chatBot, linearAdapter);

  chatBot.onNewMention(async function handleIncomingMessage(
    thread: Thread,
    message: Message
  ): Promise<void> {
    const botPlatform = botPlatforms.requireByAdapter(thread.adapter);
    const identity = await botPlatform.getIdentity({ thread, message });
    const [platformIntegration, kiloUserId] = await Promise.all([
      getPlatformIntegration(identity),
      resolveKiloUserId(chatBot.getState(), identity),
    ]);

    if (!platformIntegration) {
      captureException(new Error('No active platform integration found'), {
        extra: { platform: identity.platform, teamId: identity.teamId },
      });
      return;
    }

    if (!botPlatform.isEnabledForBot(platformIntegration)) {
      return;
    }

    if (!(await botPlatform.canHandleMessage({ thread, message, platformIntegration }))) {
      return;
    }

    if (!kiloUserId) {
      await botPlatform.promptLinkAccount({
        thread,
        message,
        identity,
        platformIntegration,
        state: chatBot.getState(),
      });
      return;
    }

    const user = await findUserById(kiloUserId);