Function TestMemoryNestedOperationsCallDaemonClient

internal/cli/memory_test.go:412–522

(t *testing.T)

}

func TestMemoryNestedOperationsCallDaemonClient(t *testing.T) {
	t.Parallel()

	calls := make(map[string]bool)
	deps := newTestDeps(t, &stubClient{
		memoryHealthFn: func(_ context.Context, workspace string) (MemoryHealthRecord, error) {
			calls["health"] = workspace == "/workspace/project"
			return MemoryHealthRecord{Status: "ok", Enabled: true, Configured: true}, nil
		},
		memoryHistoryFn: func(_ context.Context, query MemoryHistoryQuery) ([]MemoryHistoryRecord, error) {
			calls["history"] = query.Operation == "memory.write" && query.Limit == 7
			return []MemoryHistoryRecord{
				{ID: "evt-1", Operation: memcontract.OperationWrite, Timestamp: fixedTestNow},
			}, nil
		},
		promoteMemoryFn: func(_ context.Context, request MemoryPromoteRequest) (MemoryPromoteRecord, error) {
			calls["promote"] = request.Filename == "prefs.md" &&
				request.From.Scope == memcontract.ScopeWorkspace &&
				request.To.Scope == memcontract.ScopeAgent &&
				request.To.AgentTier == memcontract.AgentTierGlobal
			return MemoryPromoteRecord{
				Decision: testMemoryDecision("dec-promote", memcontract.OpUpdate),
				Applied:  true,
			}, nil
		},
		memoryScopeShowFn: func(_ context.Context, query MemorySelectorQuery) (MemoryScopeShowRecord, error) {
			calls["scope-show"] = query.Scope == memcontract.ScopeAgent && query.AgentName == "reviewer"
			return MemoryScopeShowRecord{
				Selector: contract.MemoryScopeSelectorPayload{Scope: memcontract.ScopeAgent},
			}, nil
		},
		triggerMemoryDreamFn: func(_ context.Context, request MemoryDreamTriggerRequest) (MemoryDreamTriggerRecord, error) {
			calls["dream-trigger"] = request.Scope == memcontract.ScopeWorkspace &&
				request.WorkspaceID == "/workspace/project"
			return MemoryDreamTriggerRecord{Triggered: true, Dream: contract.MemoryDreamPayload{
				Status:    contract.MemoryDreamStateRunning,
				Scope:     memcontract.ScopeWorkspace,
				StartedAt: fixedTestNow,
			}}, nil
		},
		listMemoryProvidersFn: func(context.Context) (MemoryProviderListRecord, error) {
			calls["provider-list"] = true
			return MemoryProviderListRecord{
				Providers: []contract.MemoryProviderPayload{{Name: "local", Active: true}},
			}, nil
		},
		enableMemoryProviderFn: func(_ context.Context, name string, _ MemoryProviderLifecycleRequest) (MemoryProviderLifecycleRecord, error) {
			calls["provider-enable"] = name == "local"
			return MemoryProviderLifecycleRecord{
				Provider: contract.MemoryProviderPayload{Name: name, Active: true},
				Changed:  true,
			}, nil
		},
		getMemoryExtractorStatusFn: func(_ context.Context, sessionID string) (MemoryExtractorStatusRecord, error) {
			calls["extractor-status"] = sessionID == "sess-1"
			return MemoryExtractorStatusRecord{
				Extractor: contract.MemoryExtractorStatusPayload{Status: contract.MemoryExtractorStateStopped},
			}, nil