Big Michael in a channel

Trace an @BigMichael mention from Teams or Slack: the shared dispatcher parses the command, answers instantly or dispatches async work to the orchestrator, and proactive notifications post results back when the matter task completes.
src/bots/dispatcher.ts196 lines · parseCommand L61–66
Outline 7 symbolsBotPlatform type export
BotMessage interface export
BotResponse interface export
BOT_NAME_RE const
stripControls function
parseCommand function export
dispatch function export
1// SPDX-License-Identifier: AGPL-3.0-only
2// Copyright (C) 2026 Discover Legal
3
4/**
* Bot command dispatcher — shared by Teams and Slack bots.
*
* Parses `@BigMichael <command> [args]` messages, dispatches to the
* orchestrator, and returns a formatted Markdown response.
*
* Commands:
*   status  [matter]      → matter health score + active tasks
*   briefing [client]     → generate client intelligence briefing
*   search  [query]       → semantic search across the knowledge store
*   task    [description] → submit a new roundtable task
*   run     [template]    → run a named workflow template
*   help                  → list available commands
*
* Design: synchronous where possible (Teams Outgoing Webhook needs a
* response in < 5 s). Long-running commands return "Working on it…" and
* post back via the channel client once the task completes.
*/
22
23import { logger } from "../logger.js";
24import type { Orchestrator } from "../orchestrator.js";
25
26// ─── Types ────────────────────────────────────────────────────────────────────
27
28export type BotPlatform = "teams" | "slack";
29
30export interface BotMessage {
/** Raw @-mention stripped, trimmed */
text: string;
/** Who sent the message */
senderName: string;
senderEmail?: string;
/** Channel or conversation context */
channelId?: string;
teamId?: string;
/** For threading a reply back (Slack thread_ts, Teams reply-to id) */
threadId?: string;
platform: BotPlatform;
42}
43
44export interface BotResponse {
/** Immediate reply text (Markdown) — sent in the same turn */
immediate: string;
/** If set, dispatch this async work and post back when done */
asyncWork?: () => Promise<string>;
49}
50
51// ─── Dispatcher ───────────────────────────────────────────────────────────────
52
53const BOT_NAME_RE = /^@?big[-_]?michael[\s:,]*/i;
54
55/** Strip ASCII control characters (0x00–0x1F, 0x7F) from a string. */
56function stripControls(s: string): string {
// eslint-disable-next-line no-control-regex
return s.replace(/[\x00-\x1F\x7F]/g, "");
59}
60
61export function parseCommand(raw: string): { command: string; args: string } {
const text = raw.replace(BOT_NAME_RE, "").trim();
const space = text.indexOf(" ");
if (space === -1) return { command: text.toLowerCase(), args: "" };
return { command: text.slice(0, space).toLowerCase(), args: text.slice(space + 1).trim().slice(0, 2000) };
66}
67
68export async function dispatch(
msg: BotMessage,
orch: Orchestrator,
71): Promise<BotResponse> {
const { command, args } = parseCommand(msg.text);
73
switch (command) {
75
  case "status": {
    const matterNumber = stripControls(args.trim()).toUpperCase();
    if (!matterNumber) {
      return { immediate: "Usage: `@BigMichael status [matter-number]`" };
    }
    const tasks = orch.listTasks().filter((t) => t.matterNumber === matterNumber);
    if (tasks.length === 0) {
      return { immediate: `No tasks found for matter **${matterNumber}**.` };
    }
    const health = orch.matterHealth.compute(
      matterNumber,
      tasks,
      orch.time,
      orch.budgetMonitor,
    );
    const signal = health.signal === "green" ? "🟢" : health.signal === "amber" ? "🟡" : "🔴";
    const lines = [
      `**Matter ${matterNumber}** — Health ${signal} ${health.score}/100`,
      "",
      `Budget: ${health.dimensions.budgetHealth}/100 | Deadline: ${health.dimensions.deadlineHealth}/100 | Activity: ${health.dimensions.activityFreshness}/100`,
      "",
      `**Active tasks:** ${tasks.filter((t) => t.status === "running").length}`,
      `**Pending gates:** ${tasks.reduce((s, t) => s + (t.pendingGates?.length ?? 0), 0)}`,
    ];
    if (health.riskFactors.length > 0) {
      lines.push("", "**Risks:**");
      for (const r of health.riskFactors.slice(0, 3)) lines.push(`• ${r.message}`);
    }
    return { immediate: lines.join("\n") };
  }
106
  case "briefing": {
    const clientRef = stripControls(args.trim()).toUpperCase();
    if (!clientRef) {
      return { immediate: "Usage: `@BigMichael briefing [client-name-or-number]`" };
    }
    const clientRecord = orch.clients.getByClientNumber(clientRef)
      ?? orch.clients.list().find((c) => c.name.toUpperCase().includes(clientRef));
    if (!clientRecord) {
      return { immediate: `Client not found: **${clientRef}**. Check the client number or name.` };
    }
    return {
      immediate: `Assembling briefing for **${clientRecord.name}** — scanning all sources…`,
      asyncWork: async () => {
        const allTasks = orch.listTasks();
        const allEntries = await orch.time.list({});
        const briefing = await orch.briefing.generate(
          clientRecord,
          allTasks,
          allEntries as import("../types.js").TimeEntry[],
          { knowledge: orch.knowledge },
        );
        return briefing.document;
      },
    };
  }
132
  case "search": {
    if (!args) return { immediate: "Usage: `@BigMichael search [query]`" };
    const results = await orch.knowledge.search(args, { topK: 5 });
    const arr = Array.isArray(results) ? results as unknown as Array<Record<string, unknown>> : [];
    if (arr.length === 0) return { immediate: `No results found for: **${args}**` };
    const lines = [`**Knowledge search:** ${args}`, ""];
    for (const r of arr.slice(0, 5)) {
      const title = String(r["title"] ?? r["documentTitle"] ?? "Result");
      const snippet = String(r["content"] ?? r["text"] ?? "").slice(0, 150);
      lines.push(`**${title}**`, snippet, "");
    }
    return { immediate: lines.join("\n") };
  }
146
  case "task": {
    if (!args) return { immediate: "Usage: `@BigMichael task [description]`" };
    return {
      immediate: `Submitting task: _${args.slice(0, 80)}_…`,
      asyncWork: async () => {
        const task = await orch.submitTask({
          description: args,
          workflowType: "roundtable",
        });
        return `Task submitted ✓\n**ID:** \`${task.id}\`\nUse \`@BigMichael status\` to follow progress.`;
      },
    };
  }
160
  case "run": {
    const templateId = args.trim();
    if (!templateId) {
      const templates = await orch.listTemplates();
      const list = templates.map((t) => `• \`${t.id}\` — ${t.name}`).join("\n");
      return { immediate: `**Available templates:**\n${list}\n\nUsage: \`@BigMichael run [template-id]\`` };
    }
    return {
      immediate: `Running template \`${templateId}\`…`,
      asyncWork: async () => {
        const task = await orch.submitFromTemplate(templateId);
        return `Template \`${templateId}\` started ✓\n**Task ID:** \`${task.id}\``;
      },
    };
  }
176
  case "help":
  case "":
  default:
    return {
      immediate: [
        "**Big Michael** — multi-agent legal AI",
        "",
        "| Command | Description |",
        "|---------|-------------|",
        "| `status [matter]` | Matter health score + active tasks |",
        "| `briefing [client]` | Client intelligence briefing (all sources) |",
        "| `search [query]` | Semantic search across the knowledge store |",
        "| `task [description]` | Submit a new roundtable AI task |",
        "| `run [template-id]` | Run a named workflow template |",
        "| `help` | Show this message |",
      ].join("\n"),
    };
}
195}
196
No results