🐛 fix(notification): add retry and error logging to warpNotify

xiaogaozi · xiaogaozi · commit ff1b1f96f407 · 2026-04-15T17:19:15.000+08:00
diff --git a/src/notify.ts b/src/notify.ts
@@ -1,20 +1,39 @@
 import { writeFileSync } from "fs"
 
-/**
- * Send a Warp notification via OSC 777 escape sequence.
- * Only emits when Warp declares cli-agent protocol support,
- * avoiding garbled output in other terminals (and working over SSH).
- */
+const MAX_OSC_LENGTH = 4096
+
+function escapeOSCString(str: string): string {
+  return str
+    .replace(/\x1b/g, "\x1b\x5d")
+    .replace(/\x07/g, "\x1b\x5c\x07")
+    .replace(/;/g, "\\;")
+}
+
 function warpNotify(title: string, body: string): void {
   if (!process.env.WARP_CLI_AGENT_PROTOCOL_VERSION) return
 
-  try {
-    // OSC 777 format: \033]777;notify;<title>;<body>\007
-    const sequence = `\x1b]777;notify;${title};${body}\x07`
-    writeFileSync("/dev/tty", sequence)
-  } catch {
-    // Silently ignore if /dev/tty is not available
+  const maxBodyLength = MAX_OSC_LENGTH - title.length - 20
+  const escapedBody = escapeOSCString(body)
+  const truncatedBody =
+    escapedBody.length > maxBodyLength
+      ? escapedBody.slice(0, maxBodyLength - 3) + "..."
+      : escapedBody
+
+  const sequence = `\x1b]777;notify;${title};${truncatedBody}\x07`
+
+  let lastError: Error | null = null
+  for (let attempt = 0; attempt < 3; attempt++) {
+    try {
+      writeFileSync("/dev/tty", sequence)
+      return
+    } catch (err) {
+      lastError = err as Error
+    }
   }
+
+  console.error(
+    `[opencode-warp] Failed to send Warp notification after 3 attempts: ${lastError?.message}`,
+  )
 }
 
-export { warpNotify }
+export { warpNotify }
