opensource/kilocode
3
0
Fork 0
mirror of https://github.com/Kilo-Org/kilocode.git synced 2026-09-21 14:07:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: address the comments

Browse Source
This commit is contained in:
Catriel Müller
2026-05-21 14:04:39 -03:00
parent 06a6bf715d
commit 1f24a39ae9
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/opencode/src/kilocode/background-process/index.ts
+8 -2
View File
@@ -192,12 +192,14 @@ export namespace BackgroundProcess {
active.scan = (active.scan ?? refresh(active))
.then(() => {
active.scan = undefined
if (active.disposed) return false
emit(active)
poll(active)
return false
})
.catch((err) => {
active.scan = undefined
if (active.disposed) return false
log.debug("failed to refresh process ports", { err, id: active.info.id })
emit(active)
poll(active)
@@ -216,12 +218,14 @@ export namespace BackgroundProcess {
active.scan = (active.scan ?? refresh(active))
.then((changed) => {
active.scan = undefined
if (active.disposed) return false
if (changed) emit(active)
poll(active)
return changed
})
.catch((err) => {
active.scan = undefined
if (active.disposed) return false
log.debug("failed to refresh process ports", { err, id: active.info.id })
poll(active)
return false
@@ -264,8 +268,10 @@ export namespace BackgroundProcess {
if (active.poll) clearTimeout(active.poll)
active.notify = undefined
active.poll = undefined
active.info.exitCode = code
active.info.signal = signal
if (code === null) delete active.info.exitCode
else active.info.exitCode = code
if (signal === null) delete active.info.signal
else active.info.signal = signal
active.info.ports = []
active.info.ready = active.info.ready && code === 0
active.info.status = active.info.status === "stopping" ? "stopped" : code === 0 ? "exited" : "failed"
packages/opencode/test/kilocode/background-process.test.ts
+2
View File
@@ -56,6 +56,8 @@ describe("BackgroundProcess", () => {
const stopped = yield* Effect.promise(() => BackgroundProcess.stop(info.id))
expect(stopped?.status).toBe("stopped")
expect(stopped?.exitCode).toBeUndefined()
expect(stopped?.signal).toBe("SIGTERM")
yield* Effect.promise(() => BackgroundProcess.stopSession(sessionID))
const next = yield* Effect.promise(() => BackgroundProcess.list({ sessionID }))