Function startBots

src/bot/start.ts:28–89

(deps: StartBotsDeps, opts: StartBotsOptions = {})

export interface StartBotsOptions { telegram?: boolean; discord?: boolean; slack?: boolean }

export async function startBots(deps: StartBotsDeps, opts: StartBotsOptions = {}): Promise<void> {
  const cwd = deps.cwd ?? process.cwd();
  const botCfg: any = (deps.config as any).bot ?? {};
  const allow: AllowConfig = {
    telegram: { allowedUsers: botCfg.telegram?.allowedUsers ?? [] },
    discord: { allowedUsers: botCfg.discord?.allowedUsers ?? [] },
    slack: { allowedUsers: botCfg.slack?.allowedUsers ?? [] },
  };
  // No platform flag ⇒ start every platform that's enabled in config.
  const want = (p: 'telegram' | 'discord' | 'slack') => (!opts.telegram && !opts.discord && !opts.slack) || !!opts[p];

  const transports: Transport[] = [];
  const notes: string[] = [];

  if (want('telegram') && (botCfg.telegram?.enabled ?? false)) {
    const token = process.env.TELEGRAM_BOT_TOKEN;
    if (!token) notes.push('telegram is enabled but TELEGRAM_BOT_TOKEN is missing — add it to ~/.qodex/.env');
    else if (!allow.telegram!.allowedUsers!.length) notes.push('telegram allowlist is empty — set bot.telegram.allowedUsers (deny-by-default means nobody can use it)');
    else transports.push(new TelegramTransport(token));
  }

  if (want('discord') && (botCfg.discord?.enabled ?? false)) {
    const token = process.env.DISCORD_TOKEN;
    if (!token) notes.push('discord is enabled but DISCORD_TOKEN is missing — add it to ~/.qodex/.env');
    else if (!allow.discord!.allowedUsers!.length) notes.push('discord allowlist is empty — set bot.discord.allowedUsers');
    else {
      try {
        const { createDiscordTransport } = await import('./adapters/discord.js');
        transports.push(await createDiscordTransport(token));
      } catch (e: any) { notes.push(e?.message ?? 'discord transport failed'); }
    }
  }

  if (want('slack') && (botCfg.slack?.enabled ?? false)) {
    const appToken = process.env.SLACK_APP_TOKEN;
    const botToken = process.env.SLACK_BOT_TOKEN;
    if (!appToken || !botToken) notes.push('slack is enabled but SLACK_APP_TOKEN / SLACK_BOT_TOKEN is missing — add both to ~/.qodex/.env');
    else if (!allow.slack!.allowedUsers!.length) notes.push('slack allowlist is empty — set bot.slack.allowedUsers');
    else {
      try {
        const { createSlackTransport } = await import('./adapters/slack.js');
        transports.push(await createSlackTransport(appToken, botToken));
      } catch (e: any) { notes.push(e?.message ?? 'slack transport failed'); }
    }
  }

  for (const n of notes) console.error('⚠️  ' + n);
  if (!transports.length) {
    console.error('No bot transports started. Enable bot.telegram/discord/slack in config, put the token(s) in ~/.qodex/.env, and add allowed user ids.');
    return;
  }

  const runner = new QodexAgentRunner({ config: deps.config, router: deps.router, registry: deps.registry, permissions: deps.permissions, cwd });
  const gateway = new BotGateway({ transports, agent: runner, allow });
  await gateway.start();
  console.error(`🤖 QodeX bot running on: ${transports.map(t => t.platform).join(', ')} · project=${cwd} · Ctrl-C to stop`);

  const shutdown = () => void gateway.stop().finally(() => process.exit(0));