feat: support toast notifications via notificationType config option

.github/FUNDING.yml

@@ -0,0 +1 @@
+ko_fi: dansmolsky

README.md

@@ -1,10 +1,11 @@
 # Dynamic Context Pruning Plugin
 
+[![ko-fi](https://ko-fi.com/img/githubbutton_sm.svg)](https://ko-fi.com/dansmolsky)
 [![npm version](https://img.shields.io/npm/v/@tarquinen/opencode-dcp.svg)](https://www.npmjs.com/package/@tarquinen/opencode-dcp)
 
 Automatically reduces token usage in OpenCode by removing obsolete tools from conversation history.
 
-![DCP in action](dcp-demo5.png)
+![DCP in action](assets/images/dcp-demo5.png)
 
 ## Installation
 
@@ -31,6 +32,8 @@ DCP uses multiple tools and strategies to reduce context size:
 
 **Extract** — Exposes an `extract` tool that the AI can call to distill valuable context into concise summaries before removing the tool content.
 
+**Squash** — Exposes a `squash` tool that the AI can call to collapse a large section of conversation (messages and tools) into a single summary.
+
 ### Strategies
 
 **Deduplication** — Identifies repeated tool calls (e.g., reading the same file multiple times) and keeps only the most recent output. Runs automatically on every request with zero LLM cost.
@@ -105,6 +108,12 @@ DCP uses its own config file:
             // Show distillation content as an ignored message notification
             "showDistillation": false,
         },
+        // Collapses a range of conversation content into a single summary
+        "squash": {
+            "enabled": true,
+            // Show summary content as an ignored message notification
+            "showSummary": true,
+        },
     },
     // Automatic pruning strategies
     "strategies": {
@@ -148,7 +157,7 @@ When enabled, turn protection prevents tool outputs from being pruned for a conf
 ### Protected Tools
 
 By default, these tools are always protected from pruning across all strategies:
-`task`, `todowrite`, `todoread`, `discard`, `extract`, `batch`, `write`, `edit`
+`task`, `todowrite`, `todoread`, `discard`, `extract`, `squash`, `batch`, `write`, `edit`, `plan_enter`, `plan_exit`
 
 The `protectedTools` arrays in each section add to this default list.
 

dcp.schema.json

@@ -26,6 +26,12 @@
             "default": "detailed",
             "description": "Level of notification shown when pruning occurs"
         },
+        "notificationType": {
+            "type": "string",
+            "enum": ["chat", "toast"],
+            "default": "chat",
+            "description": "Where to display prune notifications (chat message or toast notification)"
+        },
         "commands": {
             "type": "object",
             "description": "Configuration for DCP slash commands (/dcp)",
@@ -100,16 +106,7 @@
                             "items": {
                                 "type": "string"
                             },
-                            "default": [
-                                "task",
-                                "todowrite",
-                                "todoread",
-                                "discard",
-                                "extract",
-                                "batch",
-                                "write",
-                                "edit"
-                            ],
+                            "default": [],
                             "description": "Tool names that should be protected from automatic pruning"
                         }
                     }
@@ -142,6 +139,23 @@
                             "description": "Show distillation output in the UI"
                         }
                     }
+                },
+                "squash": {
+                    "type": "object",
+                    "description": "Configuration for the squash tool",
+                    "additionalProperties": false,
+                    "properties": {
+                        "enabled": {
+                            "type": "boolean",
+                            "default": true,
+                            "description": "Enable the squash tool"
+                        },
+                        "showSummary": {
+                            "type": "boolean",
+                            "default": true,
+                            "description": "Show summary output in the UI"
+                        }
+                    }
                 }
             }
         },
@@ -165,16 +179,7 @@
                             "items": {
                                 "type": "string"
                             },
-                            "default": [
-                                "task",
-                                "todowrite",
-                                "todoread",
-                                "discard",
-                                "extract",
-                                "batch",
-                                "write",
-                                "edit"
-                            ],
+                            "default": [],
                             "description": "Tool names excluded from deduplication"
                         }
                     }
@@ -211,16 +216,7 @@
                             "items": {
                                 "type": "string"
                             },
-                            "default": [
-                                "task",
-                                "todowrite",
-                                "todoread",
-                                "discard",
-                                "extract",
-                                "batch",
-                                "write",
-                                "edit"
-                            ],
+                            "default": [],
                             "description": "Tool names excluded from error purging"
                         }
                     }

index.ts

@@ -2,12 +2,13 @@ import type { Plugin } from "@opencode-ai/plugin"
 import { getConfig } from "./lib/config"
 import { Logger } from "./lib/logger"
 import { createSessionState } from "./lib/state"
-import { createDiscardTool, createExtractTool } from "./lib/strategies"
+import { createDiscardTool, createExtractTool, createSquashTool } from "./lib/strategies"
 import {
     createChatMessageTransformHandler,
     createCommandExecuteHandler,
     createSystemPromptHandler,
 } from "./lib/hooks"
+import { configureClientAuth, isSecureMode } from "./lib/auth"
 
 const plugin: Plugin = (async (ctx) => {
     const config = getConfig(ctx)
@@ -19,6 +20,11 @@ const plugin: Plugin = (async (ctx) => {
     const logger = new Logger(config.debug)
     const state = createSessionState()
 
+    if (isSecureMode()) {
+        configureClientAuth(ctx.client)
+        // logger.info("Secure mode detected, configured client authentication")
+    }
+
     logger.info("DCP initialized", {
         strategies: config.strategies,
     })
@@ -73,6 +79,15 @@ const plugin: Plugin = (async (ctx) => {
                     workingDirectory: ctx.directory,
                 }),
             }),
+            ...(config.tools.squash.enabled && {
+                squash: createSquashTool({
+                    client: ctx.client,
+                    state,
+                    logger,
+                    config,
+                    workingDirectory: ctx.directory,
+                }),
+            }),
         },
         config: async (opencodeConfig) => {
             if (config.commands.enabled) {
@@ -86,6 +101,7 @@ const plugin: Plugin = (async (ctx) => {
             const toolsToAdd: string[] = []
             if (config.tools.discard.enabled) toolsToAdd.push("discard")
             if (config.tools.extract.enabled) toolsToAdd.push("extract")
+            if (config.tools.squash.enabled) toolsToAdd.push("squash")
 
             if (toolsToAdd.length > 0) {
                 const existingPrimaryTools = opencodeConfig.experimental?.primary_tools ?? []

lib/auth.ts

@@ -0,0 +1,37 @@
+export function isSecureMode(): boolean {
+    return !!process.env.OPENCODE_SERVER_PASSWORD
+}
+
+export function getAuthorizationHeader(): string | undefined {
+    const password = process.env.OPENCODE_SERVER_PASSWORD
+    if (!password) return undefined
+
+    const username = process.env.OPENCODE_SERVER_USERNAME ?? "opencode"
+    // Use Buffer for Node.js base64 encoding (btoa may not be available in all Node versions)
+    const credentials = Buffer.from(`${username}:${password}`).toString("base64")
+    return `Basic ${credentials}`
+}
+
+export function configureClientAuth(client: any): any {
+    const authHeader = getAuthorizationHeader()
+
+    if (!authHeader) {
+        return client
+    }
+
+    // The SDK client has an internal client with request interceptors
+    // Access the underlying client to add the interceptor
+    const innerClient = client._client || client.client
+
+    if (innerClient?.interceptors?.request) {
+        innerClient.interceptors.request.use((request: Request) => {
+            // Only add auth header if not already present
+            if (!request.headers.has("Authorization")) {
+                request.headers.set("Authorization", authHeader)
+            }
+            return request
+        })
+    }
+
+    return client
+}

lib/commands/context.ts

@@ -62,6 +62,7 @@ interface TokenBreakdown {
     toolCount: number
     prunedTokens: number
     prunedCount: number
+    prunedMessageCount: number
     total: number
 }
 
@@ -74,6 +75,7 @@ function analyzeTokens(state: SessionState, messages: WithParts[]): TokenBreakdo
         toolCount: 0,
         prunedTokens: state.stats.totalPruneTokens,
         prunedCount: state.prune.toolIds.length,
+        prunedMessageCount: state.prune.messageIds.length,
         total: 0,
     }
 
@@ -112,43 +114,54 @@ function analyzeTokens(state: SessionState, messages: WithParts[]): TokenBreakdo
     const toolOutputParts: string[] = []
     let firstUserText = ""
     let foundFirstUser = false
+    const foundToolIds = new Set<string>()
 
     for (const msg of messages) {
-        if (isMessageCompacted(state, msg)) continue
-        if (msg.info.role === "user" && isIgnoredUserMessage(msg)) continue
-
         const parts = Array.isArray(msg.parts) ? msg.parts : []
+        const isCompacted = isMessageCompacted(state, msg)
+        const isIgnoredUser = msg.info.role === "user" && isIgnoredUserMessage(msg)
+
         for (const part of parts) {
-            if (part.type === "text" && msg.info.role === "user") {
+            if (part.type === "tool") {
+                const toolPart = part as ToolPart
+                if (toolPart.callID && !foundToolIds.has(toolPart.callID)) {
+                    breakdown.toolCount++
+                    foundToolIds.add(toolPart.callID)
+                }
+
+                if (!isCompacted) {
+                    if (toolPart.state?.input) {
+                        const inputStr =
+                            typeof toolPart.state.input === "string"
+                                ? toolPart.state.input
+                                : JSON.stringify(toolPart.state.input)
+                        toolInputParts.push(inputStr)
+                    }
+
+                    if (toolPart.state?.status === "completed" && toolPart.state?.output) {
+                        const outputStr =
+                            typeof toolPart.state.output === "string"
+                                ? toolPart.state.output
+                                : JSON.stringify(toolPart.state.output)
+                        toolOutputParts.push(outputStr)
+                    }
+                }
+            } else if (
+                part.type === "text" &&
+                msg.info.role === "user" &&
+                !isCompacted &&
+                !isIgnoredUser
+            ) {
                 const textPart = part as TextPart
                 const text = textPart.text || ""
                 userTextParts.push(text)
                 if (!foundFirstUser) {
                     firstUserText += text
                 }
-            } else if (part.type === "tool") {
-                const toolPart = part as ToolPart
-                breakdown.toolCount++
-
-                if (toolPart.state?.input) {
-                    const inputStr =
-                        typeof toolPart.state.input === "string"
-                            ? toolPart.state.input
-                            : JSON.stringify(toolPart.state.input)
-                    toolInputParts.push(inputStr)
-                }
-
-                if (toolPart.state?.status === "completed" && toolPart.state?.output) {
-                    const outputStr =
-                        typeof toolPart.state.output === "string"
-                            ? toolPart.state.output
-                            : JSON.stringify(toolPart.state.output)
-                    toolOutputParts.push(outputStr)
-                }
             }
         }
 
-        if (msg.info.role === "user" && !isIgnoredUserMessage(msg) && !foundFirstUser) {
+        if (msg.info.role === "user" && !isIgnoredUser && !foundFirstUser) {
             foundFirstUser = true
         }
     }
@@ -221,8 +234,10 @@ function formatContextMessage(breakdown: TokenBreakdown): string {
 
     if (breakdown.prunedTokens > 0) {
         const withoutPruning = breakdown.total + breakdown.prunedTokens
+        const messagePrunePart =
+            breakdown.prunedMessageCount > 0 ? `, ${breakdown.prunedMessageCount} messages` : ""
         lines.push(
-            `  Pruned:          ${breakdown.prunedCount} tools (~${formatTokenCount(breakdown.prunedTokens)})`,
+            `  Pruned:          ${breakdown.prunedCount} tools${messagePrunePart} (~${formatTokenCount(breakdown.prunedTokens)})`,
         )
         lines.push(`  Current context: ~${formatTokenCount(breakdown.total)}`)
         lines.push(`  Without DCP:     ~${formatTokenCount(withoutPruning)}`)