fix: suppress all notifications for subagent sessions

Author: aqeelat

src/index.ts

@@ -73,13 +73,27 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
             console.error("[opencode-warp] failed to emit init log:", err)
         })
 
+    async function isSubagentSession(sessionId?: string): Promise<boolean> {
+        if (!sessionId) return false
+        try {
+            const session = await client.session.get({
+                path: { id: sessionId },
+            })
+            return !!session.data?.parentID
+        } catch {
+            // If we can't fetch the session, fall through and notify anyway
+            return false
+        }
+    }
+
     return {
         event: async ({ event }: { event: Event }) => {
             const cwd = directory || ""
 
             switch (event.type) {
                 case "session.created": {
                     const sessionId = event.properties.info.id
+                    if (await isSubagentSession(sessionId)) return
                     const body = buildPayload("session_start", sessionId, cwd, {
                         plugin_version: PLUGIN_VERSION,
                     })
@@ -90,17 +104,10 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
                 case "session.idle": {
                     const sessionId = event.properties.sessionID
 
-                    if (sessionId) {
-                        try {
-                            const session = await client.session.get({
-                                path: { id: sessionId },
-                            })
-                            if (session.data?.parentID) return
-                        } catch {
-                            // If we can't fetch the session, fall through and notify anyway
-                        }
-                    }
+                    if (await isSubagentSession(sessionId)) return
 
+                    // Fetch the conversation to extract last query and response
+                    // (port of on-stop.sh transcript parsing)
                     let query = ""
                     let response = ""
 
@@ -143,13 +150,15 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
                 }
 
                 case "permission.updated": {
+                    if (await isSubagentSession(event.properties.sessionID)) return
                     sendPermissionNotification(event.properties, cwd)
                     return
                 }
 
                 case "permission.replied": {
                     const { sessionID, response } = event.properties
                     if (response === "reject") return
+                    if (await isSubagentSession(sessionID)) return
                     const body = buildPayload("permission_replied", sessionID, cwd)
                     warpNotify(NOTIFICATION_TITLE, body)
                     return
@@ -159,6 +168,7 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
                     // permission.asked is listed in the opencode docs but has no SDK type.
                     // Handle it with the same logic as permission.updated.
                     if ((event as any).type === "permission.asked") {
+                        if (await isSubagentSession((event as any).properties?.sessionID)) return
                         sendPermissionNotification((event as any).properties, cwd)
                     }
                 }
@@ -171,6 +181,8 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
         // completion notification.)
         "chat.message": async (input, output) => {
             const cwd = directory || ""
+            if (await isSubagentSession(input.sessionID)) return
+
             const queryText = extractTextFromParts(output.parts)
             if (!queryText) return
 
@@ -184,6 +196,7 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
         // "question" tool so Warp can notify the user that input is needed.
         "tool.execute.before": async (input) => {
             if (input.tool !== "question") return
+            if (await isSubagentSession(input.sessionID)) return
 
             const cwd = directory || ""
             const body = buildPayload("question_asked", input.sessionID, cwd, {
@@ -198,6 +211,8 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
             const sessionId = input.sessionID
             const cwd = directory || ""
 
+            if (await isSubagentSession(sessionId)) return
+
             const body = buildPayload("tool_complete", sessionId, cwd, {
                 tool_name: toolName,
             })