github-mirrors/opencode
1
0
Fork 0
mirror of https://fastgit.cc/https://github.com/anomalyco/opencode synced 2026-04-21 05:10:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

reduce repeated queue-change comparisons

Browse Source
This commit is contained in:
Simon Klee
2026-04-18 15:21:39 +02:00
parent 2c6c64fb9f
commit ccf32f45a7
1 changed files with 17 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
packages/opencode/src/cli/cmd/run/subagent-data.ts
View File

@@ -91,6 +91,17 @@ function sameQueue<T extends { id: string }>(left: T[], right: T[]) {
)
}
function queueSnapshot(data: SessionData) {
return {
permissions: data.permissions.slice(),
questions: data.questions.slice(),
}
}
function queueChanged(data: SessionData, before: ReturnType<typeof queueSnapshot>) {
return !sameQueue(before.permissions, data.permissions) || !sameQueue(before.questions, data.questions)
}
function sameCommit(left: StreamCommit, right: StreamCommit) {
return (
left.kind === right.kind &&
@@ -455,8 +466,7 @@ function applyChildEvent(input: {
thinking: boolean
limits: Record<string, number>
}) {
const beforePermissions = input.detail.data.permissions.slice()
const beforeQuestions = input.detail.data.questions.slice()
const before = queueSnapshot(input.detail.data)
const out = reduceSessionData({
data: input.detail.data,
event: input.event,
@@ -467,11 +477,7 @@ function applyChildEvent(input: {
const changed = appendCommits(input.detail, out.commits)
compactDetail(input.detail)
return (
changed ||
!sameQueue(beforePermissions, input.detail.data.permissions) ||
!sameQueue(beforeQuestions, input.detail.data.questions)
)
return changed || queueChanged(input.detail.data, before)
}
function knownSession(data: SubagentData, sessionID: string) {
@@ -575,8 +581,7 @@ export function bootstrapSubagentData(input: BootstrapSubagentInput) {
for (const sessionID of input.data.tabs.keys()) {
const detail = ensureDetail(input.data, sessionID)
const beforePermissions = detail.data.permissions.slice()
const beforeQuestions = detail.data.questions.slice()
const before = queueSnapshot(detail.data)
bootstrapSessionData({
data: detail.data,
@@ -590,10 +595,7 @@ export function bootstrapSubagentData(input: BootstrapSubagentInput) {
})
compactDetail(detail)
changed =
!sameQueue(beforePermissions, detail.data.permissions) ||
!sameQueue(beforeQuestions, detail.data.questions) ||
changed
changed = queueChanged(detail.data, before) || changed
}
return changed
@@ -605,8 +607,7 @@ export function bootstrapSubagentCalls(input: { data: SubagentData; sessionID: s
}
const detail = ensureDetail(input.data, input.sessionID)
const beforePermissions = detail.data.permissions.slice()
const beforeQuestions = detail.data.questions.slice()
const before = queueSnapshot(detail.data)
const beforeCallCount = detail.data.call.size
bootstrapSessionData({
data: detail.data,
@@ -616,11 +617,7 @@ export function bootstrapSubagentCalls(input: { data: SubagentData; sessionID: s
})
compactDetail(detail)
return (
beforeCallCount !== detail.data.call.size ||
!sameQueue(beforePermissions, detail.data.permissions) ||
!sameQueue(beforeQuestions, detail.data.questions)
)
return beforeCallCount !== detail.data.call.size || queueChanged(detail.data, before)
}
export function clearFinishedSubagents(data: SubagentData) {