sync

Frank · Frank · commit 3ad182402483 · 2025-08-17T17:44:11.000+08:00
diff --git a/github/index.ts b/github/index.ts
@@ -232,10 +232,7 @@ function createOpencode() {
   const host = "127.0.0.1"
   const port = 4096
   const url = `http://${host}:${port}`
-  const proc = spawn(`opencode`, [`serve`, `--hostname=${host}`, `--port=${port}`], {
-    // TODO
-    stdio: "inherit",
-  })
+  const proc = spawn(`opencode`, [`serve`, `--hostname=${host}`, `--port=${port}`])
   const client = createOpencodeClient({ baseUrl: url })
 
   return {
@@ -248,8 +245,6 @@ async function assertOpencodeConnected() {
   let retry = 0
   let connected = false
   do {
-    // TODO
-    console.log("!@#!@#!@# TRYING")
     try {
       await client.app.get<true>()
       connected = true
@@ -459,50 +454,53 @@ async function subscribeSessionEvents() {
   let text = ""
   ;(async () => {
     while (true) {
-      const { done, value } = await reader.read()
-      if (done) break
-
-      const chunk = decoder.decode(value, { stream: true })
-      const lines = chunk.split("\n")
-
-      for (const line of lines) {
-        // TODO
-        console.log("!@#!@#!@#! line", line)
-        if (!line.startsWith("data: ")) continue
-
-        const jsonStr = line.slice(6).trim()
-        if (!jsonStr) continue
-
-        try {
-          const evt = JSON.parse(jsonStr)
-
-          if (evt.type !== "message.part.updated") continue
-          if (evt.properties.part.sessionID !== session.id) continue
-          const part = evt.properties.part
-
-          if (part.type === "tool" && part.state.status === "completed") {
-            const [tool, color] = TOOL[part.tool] ?? [part.tool, "\x1b[34m\x1b[1m"]
-            const title =
-              part.state.title || Object.keys(part.state.input).length > 0
-                ? JSON.stringify(part.state.input)
-                : "Unknown"
-            console.log()
-            console.log(color + `|`, "\x1b[0m\x1b[2m" + ` ${tool.padEnd(7, " ")}`, "", "\x1b[0m" + title)
-          }
+      try {
+        const { done, value } = await reader.read()
+        if (done) break
 
-          if (part.type === "text") {
-            text = part.text
+        const chunk = decoder.decode(value, { stream: true })
+        const lines = chunk.split("\n")
 
-            if (part.time?.end) {
-              console.log()
-              console.log(text)
+        for (const line of lines) {
+          if (!line.startsWith("data: ")) continue
+
+          const jsonStr = line.slice(6).trim()
+          if (!jsonStr) continue
+
+          try {
+            const evt = JSON.parse(jsonStr)
+
+            if (evt.type !== "message.part.updated") continue
+            if (evt.properties.part.sessionID !== session.id) continue
+            const part = evt.properties.part
+
+            if (part.type === "tool" && part.state.status === "completed") {
+              const [tool, color] = TOOL[part.tool] ?? [part.tool, "\x1b[34m\x1b[1m"]
+              const title =
+                part.state.title || Object.keys(part.state.input).length > 0
+                  ? JSON.stringify(part.state.input)
+                  : "Unknown"
               console.log()
-              text = ""
+              console.log(color + `|`, "\x1b[0m\x1b[2m" + ` ${tool.padEnd(7, " ")}`, "", "\x1b[0m" + title)
+            }
+
+            if (part.type === "text") {
+              text = part.text
+
+              if (part.time?.end) {
+                console.log()
+                console.log(text)
+                console.log()
+                text = ""
+              }
             }
+          } catch (e) {
+            // Ignore parse errors
           }
-        } catch (e) {
-          // Ignore parse errors
         }
+      } catch (e) {
+        console.log("Subscribing to session events done", e)
+        break
       }
     }
   })()
