Merge feature/SB-0MN3UDQFM0LB0LAH-modularize-bootstrap into main (SB-0MNODSVMD000AGXO)

Author: Sorra

src/discord/cli-error-report.ts

@@ -0,0 +1,39 @@
+const DISCORD_CONTENT_LIMIT = 1900;
+
+export async function postCliErrorReport(target: any, report: string, shortIntro?: string): Promise<void> {
+  try {
+    if (!report) return;
+
+    if (report.length <= DISCORD_CONTENT_LIMIT) {
+      if (typeof target.send === "function") {
+        await target.send(report);
+        return;
+      }
+      if (typeof target.reply === "function") {
+        await target.reply(report);
+        return;
+      }
+      return;
+    }
+
+    const intro = shortIntro || "Detailed CLI diagnostic attached.";
+    const content = `${intro}\n\n(Full report attached as cli-error-report.txt)`;
+    const file = { attachment: Buffer.from(report, "utf8"), name: "cli-error-report.txt" };
+
+    if (typeof target.send === "function") {
+      await target.send({ content, files: [file] } as any);
+      return;
+    }
+    if (typeof target.reply === "function") {
+      await target.reply({ content, files: [file] } as any);
+      return;
+    }
+  } catch {
+    try {
+      const truncated = report.slice(0, Math.max(0, DISCORD_CONTENT_LIMIT - 50)) + "...";
+      if (typeof target.send === "function") await target.send(truncated);
+      else if (typeof target.reply === "function") await target.reply(truncated);
+    } catch {
+    }
+  }
+}

src/formatters/progress.ts

@@ -0,0 +1,48 @@
+import type { AddProgressEvent } from "../bot/cli-runner.js";
+
+export function formatProgressMessage(event: AddProgressEvent): string {
+  const phase = typeof event.phase === "string" && event.phase.trim() !== "" ? event.phase : undefined;
+
+  if (!phase) {
+    if (event.message) {
+      const m = String(event.message).trim();
+      const truncated = m.length > 1500 ? `${m.slice(0, 1500)}...` : m;
+      if (event.title) return `❌ ${truncated} (${event.title})`;
+      if (event.url) return `❌ ${truncated} (<${event.url}>)`;
+      return `❌ ${truncated}`;
+    }
+
+    const parts: string[] = [];
+    if (event.id !== undefined) parts.push(`id:${event.id}`);
+    if (event.title) parts.push(`title:${event.title}`);
+    if (event.url) parts.push(`url:${event.url}`);
+    if (event.timestamp) parts.push(`ts:${event.timestamp}`);
+
+    if (parts.length > 0) {
+      return `⏳ Processing: unknown (${parts.join(", ")})`;
+    }
+
+    return "⏳ Processing: unknown event";
+  }
+
+  switch (phase) {
+    case "downloading":
+      return "⏳ Downloading content...";
+    case "extracting":
+      return "📝 Extracting text content...";
+    case "embedding":
+      return "🧠 Generating embeddings...";
+    case "completed":
+      return `✅ Added to OpenBrain: ${event.title || "URL processed"}`;
+    case "failed":
+      return `❌ Failed: ${event.message || "Unknown error"}`;
+    default:
+      const base = `⏳ Processing: ${phase}`;
+      if (event.message) {
+        const m = String(event.message).trim();
+        const truncated = m.length > 1200 ? `${m.slice(0, 1200)}...` : m;
+        return `${base}\n\n${truncated}`;
+      }
+      return base;
+  }
+}

src/handlers/CrawlCommandHandler.ts

@@ -0,0 +1,57 @@
+import type { Message } from "discord.js";
+import { runQueueCommand, type QueueResult } from "../bot/cli-runner.js";
+import type { MessageCommandHandler } from "../interfaces/command-handler.js";
+
+export interface CrawlCommandParseResult {
+  isCrawlCommand: boolean;
+  seedUrl: string | null;
+}
+
+export interface CrawlCommandHandlerDependencies {
+  runQueue?: typeof runQueueCommand;
+}
+
+export class CrawlCommandHandler implements MessageCommandHandler {
+  private readonly queue: typeof runQueueCommand;
+
+  constructor(dependencies: CrawlCommandHandlerDependencies = {}) {
+    this.queue = dependencies.runQueue ?? runQueueCommand;
+  }
+
+  parse(content: string): CrawlCommandParseResult {
+    const isCrawl = /^\s*crawl\s+/i.test(content);
+    if (!isCrawl) {
+      return {
+        isCrawlCommand: false,
+        seedUrl: null,
+      };
+    }
+
+    const match = content.match(/^\s*crawl\s+(https?:\/\/[^\s]+)/i);
+    return {
+      isCrawlCommand: true,
+      seedUrl: match ? match[1] : null,
+    };
+  }
+
+  async queueSeed(message: Message, seedUrl: string): Promise<QueueResult> {
+    return this.queue(seedUrl, {
+      channelId: message.channelId,
+      messageId: message.id,
+      authorId: message.author.id,
+    });
+  }
+
+  async handleMessage(message: Message): Promise<boolean> {
+    const parsed = this.parse(message.content);
+    if (!parsed.isCrawlCommand) {
+      return false;
+    }
+    if (!parsed.seedUrl) {
+      return true;
+    }
+
+    await this.queueSeed(message, parsed.seedUrl);
+    return true;
+  }
+}

src/handlers/StatsCommandHandler.ts

@@ -0,0 +1,25 @@
+import type { CommandInteraction } from "discord.js";
+import type { SlashCommandHandler } from "../interfaces/command-handler.js";
+
+const DEFAULT_UNAVAILABLE_MESSAGE = "Stats functionality temporarily unavailable - CLI has been extracted to openBrain repository.";
+
+export interface StatsCommandHandlerDependencies {
+  unavailableMessage?: string;
+}
+
+export class StatsCommandHandler implements SlashCommandHandler {
+  private readonly unavailableMessage: string;
+
+  constructor(dependencies: StatsCommandHandlerDependencies = {}) {
+    this.unavailableMessage = dependencies.unavailableMessage ?? DEFAULT_UNAVAILABLE_MESSAGE;
+  }
+
+  async handleCommand(command: CommandInteraction): Promise<boolean> {
+    if (command.commandName !== "stats") {
+      return false;
+    }
+
+    await command.reply(this.unavailableMessage);
+    return true;
+  }
+}