feat: add showDistillation option to display extracted findings as notification

Author: Tarquinen

README.md

@@ -104,7 +104,9 @@ DCP uses its own config file:
       "nudge": {
         "enabled": true,
         "frequency": 10
-      }
+      },
+      // Show distillation content as an ignored message notification
+      "showDistillation": false
     },
     // (Legacy) Run an LLM to analyze what tool calls are no longer relevant on idle
     "onIdle": {

lib/config.ts

@@ -46,6 +46,7 @@ export interface ExtractTool {
     protectedTools: string[]
     turnProtection: PruneToolTurnProtection
     nudge: PruneToolNudge
+    showDistillation: boolean
 }
 
 export interface SupersedeWrites {
@@ -108,7 +109,8 @@ export const VALID_CONFIG_KEYS = new Set([
     'strategies.extractTool.turnProtection.turns',
     'strategies.extractTool.nudge',
     'strategies.extractTool.nudge.enabled',
-    'strategies.extractTool.nudge.frequency'
+    'strategies.extractTool.nudge.frequency',
+    'strategies.extractTool.showDistillation'
 ])
 
 // Extract all key paths from a config object for validation
@@ -234,6 +236,9 @@ function validateConfigTypes(config: Record<string, any>): ValidationError[] {
                     errors.push({ key: 'strategies.extractTool.nudge.frequency', expected: 'number', actual: typeof strategies.extractTool.nudge.frequency })
                 }
             }
+            if (strategies.extractTool.showDistillation !== undefined && typeof strategies.extractTool.showDistillation !== 'boolean') {
+                errors.push({ key: 'strategies.extractTool.showDistillation', expected: 'boolean', actual: typeof strategies.extractTool.showDistillation })
+            }
         }
 
         // supersedeWrites
@@ -327,7 +332,8 @@ const defaultConfig: PluginConfig = {
             nudge: {
                 enabled: true,
                 frequency: 10
-            }
+            },
+            showDistillation: false
         },
         onIdle: {
             enabled: false,
@@ -450,7 +456,9 @@ function createDefaultConfig(): void {
       "nudge": {
         "enabled": true,
         "frequency": 10
-      }
+      },
+      // Show distillation content as an ignored message notification
+      "showDistillation": false
     },
     // (Legacy) Run an LLM to analyze what tool calls are no longer relevant on idle
     "onIdle": {
@@ -555,7 +563,8 @@ function mergeStrategies(
             nudge: {
                 enabled: override.extractTool?.nudge?.enabled ?? base.extractTool.nudge.enabled,
                 frequency: override.extractTool?.nudge?.frequency ?? base.extractTool.nudge.frequency
-            }
+            },
+            showDistillation: override.extractTool?.showDistillation ?? base.extractTool.showDistillation
         },
         supersedeWrites: {
             enabled: override.supersedeWrites?.enabled ?? base.supersedeWrites.enabled
@@ -585,7 +594,8 @@ function deepCloneConfig(config: PluginConfig): PluginConfig {
                 ...config.strategies.extractTool,
                 protectedTools: [...config.strategies.extractTool.protectedTools],
                 turnProtection: { ...config.strategies.extractTool.turnProtection },
-                nudge: { ...config.strategies.extractTool.nudge }
+                nudge: { ...config.strategies.extractTool.nudge },
+                showDistillation: config.strategies.extractTool.showDistillation
             },
             supersedeWrites: {
                 ...config.strategies.supersedeWrites

lib/strategies/tools.ts

@@ -2,7 +2,7 @@ import { tool } from "@opencode-ai/plugin"
 import type { SessionState, ToolParameterEntry, WithParts } from "../state"
 import type { PluginConfig } from "../config"
 import { buildToolIdList } from "../messages/utils"
-import { PruneReason, sendUnifiedNotification } from "../ui/notification"
+import { PruneReason, sendUnifiedNotification, sendDistillationNotification } from "../ui/notification"
 import { formatPruningResultForTool } from "../ui/utils"
 import { ensureSessionInitialized } from "../state"
 import { saveSessionState } from "../state/persistence"
@@ -27,7 +27,8 @@ async function executePruneOperation(
     toolCtx: { sessionID: string },
     ids: string[],
     reason: PruneReason,
-    toolName: string
+    toolName: string,
+    distillation?: Record<string, any>
 ): Promise<string> {
     const { client, state, logger, config, workingDirectory } = ctx
     const sessionId = toolCtx.sessionID
@@ -113,6 +114,16 @@ async function executePruneOperation(
         workingDirectory
     )
 
+    if (distillation && config.strategies.extractTool.showDistillation) {
+        await sendDistillationNotification(
+            client,
+            logger,
+            sessionId,
+            distillation,
+            currentParams
+        )
+    }
+
     state.stats.totalPruneTokens += state.stats.pruneTokenCounter
     state.stats.pruneTokenCounter = 0
     state.nudgeCounter = 0
@@ -191,7 +202,8 @@ export function createExtractTool(
                 toolCtx,
                 args.ids,
                 "consolidation" as PruneReason,
-                "Extract"
+                "Extract",
+                args.distillation
             )
         },
     })

lib/ui/notification.ts

@@ -82,6 +82,37 @@ export async function sendUnifiedNotification(
     return true
 }
 
+function formatDistillationMessage(distillation: Record<string, any>): string {
+    const lines: string[] = ['▣ DCP | Extracted Distillation']
+
+    for (const [id, findings] of Object.entries(distillation)) {
+        lines.push(`\n─── ID ${id} ───`)
+        if (typeof findings === 'object' && findings !== null) {
+            lines.push(JSON.stringify(findings, null, 2))
+        } else {
+            lines.push(String(findings))
+        }
+    }
+
+    return lines.join('\n')
+}
+
+export async function sendDistillationNotification(
+    client: any,
+    logger: Logger,
+    sessionId: string,
+    distillation: Record<string, any>,
+    params: any
+): Promise<boolean> {
+    if (!distillation || Object.keys(distillation).length === 0) {
+        return false
+    }
+
+    const message = formatDistillationMessage(distillation)
+    await sendIgnoredMessage(client, sessionId, message, params, logger)
+    return true
+}
+
 export async function sendIgnoredMessage(
     client: any,
     sessionID: string,