Function runWithCache

pkg/runtime/cache_test.go:18–37

(t *testing.T, c *cache.Cache, prov *messageRecordingProvider, sess *session.Session)

)

func runWithCache(t *testing.T, c *cache.Cache, prov *messageRecordingProvider, sess *session.Session) []Event {
	t.Helper()

	root := agent.New("root", "You are a test agent",
		agent.WithModel(prov),
		agent.WithCache(c),
	)
	tm := team.New(team.WithAgents(root))

	rt, err := NewLocalRuntime(t.Context(), tm, WithSessionCompaction(false), WithModelStore(mockModelStore{}))
	require.NoError(t, err)
	sess.Title = "cache test"

	evCh := rt.RunStream(t.Context(), sess)
	var events []Event
	for ev := range evCh {
		events = append(events, ev)
	}
	return events
}

// TestCache_StoresAndReplaysAnswer verifies that a cache miss invokes the model
// once, and a subsequent identical question is served from the cache without