Function TestMemoryHandlersSearchAndReindex

internal/api/httpapi/memory_test.go:338–418

(t *testing.T)

}

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

	store, workspace := newTestMemoryStore(t)
	mustWriteMemory(
		t,
		store,
		memcontract.ScopeGlobal,
		"",
		"prefs.md",
		memcontract.TypeUser,
		"User prefers concise answers",
	)
	mustWriteMemory(
		t,
		store,
		memcontract.ScopeWorkspace,
		workspace,
		"auth.md",
		memcontract.TypeProject,
		"Auth migration uses sessions",
	)

	handlers := newTestMemoryHandlers(t, stubSessionManager{}, stubObserver{}, store, &stubDreamTrigger{})
	engine := newTestRouter(t, handlers)

	search := performRequest(
		t,
		engine,
		http.MethodPost,
		"/api/memory/search",
		[]byte(`{"query_text":"auth migration sessions","workspace_id":"`+escapeJSON(workspace)+`"}`),
	)
	if search.Code != http.StatusOK {
		t.Fatalf("search status = %d, want %d; body=%s", search.Code, http.StatusOK, search.Body.String())
	}

	var searchPayload memorySearchResponse
	decodeJSONResponse(t, search, &searchPayload)
	if len(searchPayload.Results) == 0 || searchPayload.Results[0].Memory.Scope != memcontract.ScopeWorkspace {
		t.Fatalf("search results = %#v, want workspace hit first", searchPayload.Results)
	}

	globalOnly := performRequest(
		t,
		engine,
		http.MethodPost,
		"/api/memory/search",
		[]byte(`{"scope":"global","workspace_id":"`+escapeJSON(workspace)+`","query_text":"sessions"}`),
	)
	if globalOnly.Code != http.StatusOK {
		t.Fatalf(
			"global-only search status = %d, want %d; body=%s",
			globalOnly.Code,
			http.StatusOK,
			globalOnly.Body.String(),
		)
	}