SB-0MNGPWAET002LCGD: Post OpenBrain summaries to Discord threads

Author: Sorra

.env.example

@@ -8,5 +8,15 @@ DISCORD_CHANNEL_ID=your_channel_id_here
 # Optional: Log level (debug, info, warn, error)
 LOG_LEVEL=info
 
+# Optional: post a generated summary to Discord after successful `ob add`
+SEND_SUMMARY_ON_INSERT=true
+
+# Optional: fallback target channel ID when no thread is available
+# DEFAULT_DISCORD_CHANNEL_ID=123456789012345678
+
+# Optional: OpenBrain item URL template used in summary messages
+# Supports placeholders: {id} and {url}
+# OPENBRAIN_ITEM_URL_TEMPLATE=https://openbrain.local/items/{id}
+
 # Optional: Comma-separated list of Discord user IDs allowed to submit file:// URLs
 ALLOWED_FILE_URL_USERS=

README.md

@@ -76,6 +76,11 @@ See [Local Setup](#local-setup) below for detailed instructions.
    - `YOUTUBE_CAPTION_LANGUAGE` - Preferred caption language (default: `en`)
    - `ENABLE_YOUTUBE_CAPTIONS` - Enable/disable captions (default: `true`)
 
+   Optional (for summary posting in Discord threads):
+   - `SEND_SUMMARY_ON_INSERT` - Post generated summary after successful `ob add` (default: `true`)
+   - `DEFAULT_DISCORD_CHANNEL_ID` - Fallback channel if thread posting is not available
+   - `OPENBRAIN_ITEM_URL_TEMPLATE` - Template for OpenBrain item link in summary messages, supports `{id}` and `{url}` placeholders
+
 4. **Set up the database:**
 
    ```bash
@@ -230,19 +235,28 @@ $ sb add --ndjson https://example.com/article
 **Webhook Events:**
 When using `--format webhook`, each progress event is POSTed as JSON to the provided URL. The webhook receives the same JSON structure as NDJSON output.
 
-### Context Flags for Bot Integration
+### Context Tags for Bot Integration
 
-When the Discord bot invokes the CLI, it passes context via flags:
+When the Discord bot invokes OpenBrain CLI commands, it passes Discord context as metadata tags:
 
 ```bash
-sb add \
-  --channel-id "123456789" \
-  --message-id "987654321" \
-  --author-id "111222333" \
+ob add \
+  --tag "discord_channel_id:123456789" \
+  --tag "discord_message_id:987654321" \
+  --tag "discord_author_id:111222333" \
   https://example.com/article
 ```
 
-These flags associate the operation with Discord entities but are optional for standalone CLI usage.
+These tags associate operations with Discord entities for traceability while remaining valid OpenBrain CLI arguments.
+
+### Automatic Summary Posting
+
+After a successful URL add, the bot can call `ob summary <url>` and post the generated summary into the processing thread (or a configured fallback channel).
+
+- Retries summary generation up to 3 times with exponential backoff
+- Includes metadata in the message: OpenBrain item link, source URL, item id, author, timestamp
+- Uses item-id deduplication in-process to avoid posting duplicate summaries
+- Posts a manual-review notice if summary generation fails after retries
 
 ### Global Options
 

src/bot/cli-runner.ts

@@ -52,6 +52,8 @@ export interface AddProgressEvent {
   title?: string;
   /** Optional timestamp */
   timestamp?: string;
+  /** Optional OpenBrain item id */
+  id?: number | string;
 }
 
 /**
@@ -90,6 +92,10 @@ export interface AddResult {
   error?: string;
   /** Title of the page if successful */
   title?: string;
+  /** OpenBrain item id if provided by CLI events */
+  id?: number;
+  /** Timestamp if provided by CLI events */
+  timestamp?: string;
 }
 
 /**
@@ -106,6 +112,20 @@ export interface QueueResult {
   id?: number;
 }
 
+/**
+ * Result of summary command
+ */
+export interface SummaryResult {
+  /** Whether the operation succeeded */
+  success: boolean;
+  /** URL that was summarized */
+  url: string;
+  /** Generated summary text */
+  summary?: string;
+  /** Error message if failed */
+  error?: string;
+}
+
 /**
  * Statistics result from CLI
  */
@@ -293,18 +313,23 @@ function runCliSubprocess(
     timeoutMs = DEFAULT_TIMEOUT_MS,
   } = options;
 
+  const supportsDiscordContextTags = command === "add" || command === "queue";
+
   // Build command arguments
   const cmdArgs = [command];
 
-  // Add context flags if provided
-  if (channelId) {
-    cmdArgs.push("--channel-id", channelId);
-  }
-  if (messageId) {
-    cmdArgs.push("--message-id", messageId);
-  }
-  if (authorId) {
-    cmdArgs.push("--author-id", authorId);
+  // Add context tags for commands that support metadata tags.
+  // OpenBrain CLI does not support --channel-id/--message-id/--author-id flags.
+  if (supportsDiscordContextTags) {
+    if (channelId) {
+      cmdArgs.push("--tag", `discord_channel_id:${channelId}`);
+    }
+    if (messageId) {
+      cmdArgs.push("--tag", `discord_message_id:${messageId}`);
+    }
+    if (authorId) {
+      cmdArgs.push("--tag", `discord_author_id:${authorId}`);
+    }
   }
 
   // Add remaining args
@@ -443,19 +468,31 @@ export async function* runAddCommand(
       return result;
     }
 
+    const rawId = (lastEvent as { id?: unknown } | null)?.id;
+    const eventId =
+      typeof rawId === "number"
+        ? rawId
+        : typeof rawId === "string" && /^\d+$/.test(rawId)
+          ? parseInt(rawId, 10)
+          : undefined;
+
     // Determine result from last event
     if (lastEvent?.phase === "completed") {
       const result: AddResult = {
         success: true,
         url,
         title: lastEvent.title,
+        id: eventId,
+        timestamp: lastEvent.timestamp,
       };
       return result;
     } else if (lastEvent?.phase === "failed") {
       const result: AddResult = {
         success: false,
         url,
         error: lastEvent.message || "Unknown error during ingestion",
+        id: eventId,
+        timestamp: lastEvent.timestamp,
       };
       return result;
     }
@@ -539,6 +576,54 @@ export async function runQueueCommand(
   };
 }
 
+/**
+ * Run the `ob summary` command
+ *
+ * @param url - URL to summarize
+ * @param options - Context and runner options
+ * @returns Promise that resolves with summary result
+ */
+export async function runSummaryCommand(
+  url: string,
+  options: RunnerOptions = {}
+): Promise<SummaryResult> {
+  const { stdoutIterator, exitPromise } = runCliSubprocess(
+    "summary",
+    [url],
+    options
+  );
+
+  const stdoutLines: string[] = [];
+  for await (const line of stdoutIterator) {
+    stdoutLines.push(line);
+  }
+
+  const { exitCode, stderr } = await exitPromise;
+
+  if (exitCode !== 0) {
+    return {
+      success: false,
+      url,
+      error: stderr.trim() || `CLI exited with code ${exitCode}`,
+    };
+  }
+
+  const summary = stdoutLines.join("\n").trim();
+  if (!summary) {
+    return {
+      success: false,
+      url,
+      error: "No summary output received",
+    };
+  }
+
+  return {
+    success: true,
+    url,
+    summary,
+  };
+}
+
 /**
  * Run the `sb stats` command
  *

src/config/bot.ts

@@ -3,6 +3,28 @@ import { z } from "zod";
 
 dotenv.config();
 
+const envBoolean = z.preprocess((value) => {
+  if (value === undefined || value === null || value === "") {
+    return undefined;
+  }
+
+  if (typeof value === "boolean") {
+    return value;
+  }
+
+  if (typeof value === "string") {
+    const normalized = value.trim().toLowerCase();
+    if (["1", "true", "yes", "on"].includes(normalized)) {
+      return true;
+    }
+    if (["0", "false", "no", "off"].includes(normalized)) {
+      return false;
+    }
+  }
+
+  return value;
+}, z.boolean());
+
 // Bot configuration schema - only includes what the bot actually needs
 // CLI-related config has been moved to the openBrain repository
 export const botConfigSchema = z.object({
@@ -12,6 +34,11 @@ export const botConfigSchema = z.object({
 
   // Optional configuration
   LOG_LEVEL: z.string().optional().default("info"),
+
+  // Summary posting behavior
+  SEND_SUMMARY_ON_INSERT: envBoolean.optional().default(true),
+  DEFAULT_DISCORD_CHANNEL_ID: z.string().optional(),
+  OPENBRAIN_ITEM_URL_TEMPLATE: z.string().optional(),
 
   // File URL configuration
   ALLOWED_FILE_URL_USERS: z.string().optional().transform(v => v ? v.split(',').map(id => id.trim()) : []),