🔧 chore: restore openSync/writeSync/closeSync and simplify event handler

Revert notify.ts to openSync/writeSync/closeSync (matching 1f116ad
which was confirmed working).

Remove tool_complete and prompt_submit notifications from the bus
event handler - these were added in the bus events migration but are
not needed and may cause notification floods that interfere with
session.idle delivery.

Keep question_asked via message.part.updated (the core feature from PR warpdotdev#9).

Author: xiaogaozi

src/index.ts

@@ -141,35 +141,15 @@ export const WarpPlugin: Plugin = async ({ client, directory }) => {
             }
             if (part?.type !== "tool" || !part?.state) return
 
-            const sessionId = part.sessionID || ""
-
             if (part.tool === "question" && part.state.status === "running") {
+              const sessionId = part.sessionID || ""
               const body = buildPayload("question_asked", sessionId, cwd, {
                 tool_name: part.tool,
               })
               warpNotify(NOTIFICATION_TITLE, body)
               return
             }
 
-            if (part.state.status === "completed") {
-              const body = buildPayload("tool_complete", sessionId, cwd, {
-                tool_name: part.tool || "unknown",
-              })
-              warpNotify(NOTIFICATION_TITLE, body)
-              return
-            }
-            return
-          }
-
-          case "message.updated": {
-            const info = (event.properties as { info: { role?: string; sessionID?: string } }).info
-            if (info?.role !== "user") return
-
-            const sessionId = info.sessionID || ""
-            const body = buildPayload("prompt_submit", sessionId, cwd, {
-              query: "",
-            })
-            warpNotify(NOTIFICATION_TITLE, body)
             return
           }
 

src/notify.ts

@@ -1,4 +1,4 @@
-import { writeFileSync } from "fs"
+import { openSync, writeSync, closeSync } from "fs"
 
 const MAX_OSC_LENGTH = 4096
 
@@ -14,7 +14,9 @@ function warpNotify(title: string, body: string): void {
   let lastError: Error | null = null
   for (let attempt = 0; attempt < 3; attempt++) {
     try {
-      writeFileSync("/dev/tty", sequence)
+      const fd = openSync("/dev/tty", "w")
+      writeSync(fd, sequence)
+      closeSync(fd)
       return
     } catch (err) {
       lastError = err as Error

tests/notify.test.ts

@@ -2,11 +2,15 @@ import { describe, it, afterEach, mock } from "bun:test"
 import { expect } from "bun:test"
 import fs from "fs"
 
-const writeFileSyncSpy = mock(() => {})
+const writeSyncSpy = mock(() => {})
+const openSyncSpy = mock(() => 42)
+const closeSyncSpy = mock(() => {})
 
 mock.module("fs", () => ({
   ...fs,
-  writeFileSync: writeFileSyncSpy,
+  openSync: openSyncSpy,
+  writeSync: writeSyncSpy,
+  closeSync: closeSyncSpy,
 }))
 
 const { warpNotify } = await import("../src/notify")
@@ -15,7 +19,9 @@ describe("warpNotify", () => {
   const originalVersion = process.env.WARP_CLI_AGENT_PROTOCOL_VERSION
 
   afterEach(() => {
-    writeFileSyncSpy.mockClear()
+    openSyncSpy.mockClear()
+    writeSyncSpy.mockClear()
+    closeSyncSpy.mockClear()
     if (originalVersion === undefined) {
       delete process.env.WARP_CLI_AGENT_PROTOCOL_VERSION
     } else {
@@ -26,16 +32,18 @@ describe("warpNotify", () => {
   it("skips when WARP_CLI_AGENT_PROTOCOL_VERSION is not set", () => {
     delete process.env.WARP_CLI_AGENT_PROTOCOL_VERSION
     warpNotify("title", "body")
-    expect(writeFileSyncSpy).not.toHaveBeenCalled()
+    expect(openSyncSpy).not.toHaveBeenCalled()
   })
 
   it("writes OSC 777 sequence when Warp declares protocol support", () => {
     process.env.WARP_CLI_AGENT_PROTOCOL_VERSION = "1"
     warpNotify("warp://cli-agent", '{"event":"stop"}')
-    expect(writeFileSyncSpy).toHaveBeenCalledTimes(1)
+    expect(openSyncSpy).toHaveBeenCalledTimes(1)
+    expect(openSyncSpy).toHaveBeenCalledWith("/dev/tty", "w")
+    expect(writeSyncSpy).toHaveBeenCalledTimes(1)
+    expect(closeSyncSpy).toHaveBeenCalledTimes(1)
 
-    const [path, data] = writeFileSyncSpy.mock.calls[0] as [string, string]
-    expect(path).toBe("/dev/tty")
+    const [, data] = writeSyncSpy.mock.calls[0] as [number, string]
     expect(data).toContain("warp://cli-agent")
     expect(data).toContain('{"event":"stop"}')
     expect(data).toMatch(/^\x1b\]777;notify;/)