subagent_requirements.go RawHistoryFolder

1package agent
2
3import (
4	"fmt"
5	"strings"
6
7	"github.com/bnema/zut/packages/core"
8)
9
10const requiredWorkerContextHeader = "[required-subagents update]"
11
12// WireRequiredWorkerGate prevents a parent terminal response while required
13// resident work remains unresolved. The manager is the sole authority; there
14// is no worker reload or process-side acknowledgement path.
15func (rt *subagentRuntime) WireRequiredWorkerGate(parent *core.Agent) {
16	if rt == nil || parent == nil || rt.residentManagerForTools() == nil {
17		return
18	}
19	previousBeforeAssistant := parent.BeforeAssistantMessage
20	parent.BeforeAssistantMessage = func(text string) (bool, string, string) {
21		unmet := rt.residentManagerForTools().UnmetRequired()
22		if len(unmet) != 0 {
23			var b strings.Builder
24			b.WriteString(requiredWorkerContextHeader)
25			b.WriteString("\nTerminal completion is blocked by required resident delegated work:")
26			for _, child := range unmet {
27				fmt.Fprintf(&b, "\n- %s: %s", child.ID, child.State)
28			}
29			return false, b.String(), ""
30		}
31		if previousBeforeAssistant != nil {
32			return previousBeforeAssistant(text)
33		}
34		return true, "", ""
35	}
36}