agent-radar
2ed3415fb7
Publish Claude Code Binaries / Stage and publish binaries (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-arm64 (push) Canceled after 0s
Publish Tutti App Runtime / Build darwin-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build linux-amd64 (push) Canceled after 0s
Publish Tutti App Runtime / Build windows-amd64 (push) Canceled after 0s
Sync Tutti Agent Skills / sync (push) Canceled after 0s
Windows Agent Adapters / Test Windows agent adapters (push) Canceled after 0s
Windows Daemon Adapters / Test Windows daemon adapters (push) Canceled after 0s
Publish Tutti App Runtime / Publish runtime catalog (push) Canceled after 0s
35 lines
1.2 KiB
Go
35 lines
1.2 KiB
Go
package agentruntime
|
|
|
|
import (
|
|
"testing"
|
|
|
|
activityshared "github.com/tutti-os/tutti/packages/agent/daemon/activity/events"
|
|
)
|
|
|
|
func TestAgentSubmitRuntimeEventSummaryAggregatesEmissionBatches(t *testing.T) {
|
|
var summary agentSubmitRuntimeEventSummary
|
|
summary.observe([]activityshared.Event{
|
|
{Type: activityshared.EventMessageAppended},
|
|
{Type: activityshared.EventMessageAppended},
|
|
}, Session{Status: SessionStatusWorking})
|
|
summary.observe([]activityshared.Event{
|
|
{Type: activityshared.EventTurnCompleted},
|
|
}, Session{Status: SessionStatusReady})
|
|
|
|
if summary.batchCount != 2 {
|
|
t.Fatalf("batch count = %d, want 2", summary.batchCount)
|
|
}
|
|
if summary.activityEventCount != 3 {
|
|
t.Fatalf("activity event count = %d, want 3", summary.activityEventCount)
|
|
}
|
|
if got := summary.eventTypeCounts[string(activityshared.EventMessageAppended)]; got != 2 {
|
|
t.Fatalf("message update count = %d, want 2", got)
|
|
}
|
|
if got := summary.eventTypeCounts[string(activityshared.EventTurnCompleted)]; got != 1 {
|
|
t.Fatalf("turn completed count = %d, want 1", got)
|
|
}
|
|
if summary.lastSessionStatus != string(SessionStatusReady) {
|
|
t.Fatalf("last session status = %q, want %q", summary.lastSessionStatus, SessionStatusReady)
|
|
}
|
|
}
|