interactive_host_test.go RawHistoryFolder

1package modes
2
3import (
4	"testing"
5
6	"github.com/bnema/zut/packages/agent/internal/orchestration"
7	"github.com/bnema/zut/packages/agent/subagents"
8	"github.com/bnema/zut/packages/core"
9)
10
11func TestSubmitOrQueuePreservesSealedWorkerWaveWithPendingWorker(t *testing.T) {
12	i := &Interactive{agent: &core.Agent{}}
13	i.applyCoordinator(orchestration.Event{Kind: orchestration.EventManagerStarted})
14	i.applyCoordinator(orchestration.Event{Kind: orchestration.EventWorkerRegistered, WorkerID: "worker#1"})
15	i.applyCoordinator(orchestration.Event{Kind: orchestration.EventManagerFinished})
16
17	i.submitOrQueue("review the result", nil, true)
18
19	actions := i.applyCoordinator(orchestration.Event{
20		Kind:     orchestration.EventWorkerFinished,
21		WorkerID: "worker#1",
22		Completion: subagents.Completion{
23			AgentID: "worker",
24			Status:  "completed",
25		},
26	})
27	if len(actions) != 1 {
28		t.Fatalf("completion actions = %d, want 1", len(actions))
29	}
30	if got := actions[0].Text; got != "review the result" {
31		t.Fatalf("completion action text = %q, want queued user input", got)
32	}
33}