Function TestResponseProcessor_SingleObject

core/cache_response_test.go:286–334

(t *testing.T)

}

func TestResponseProcessor_SingleObject(t *testing.T) {
	// Create qcode with one selection for "users" table
	qc := &qcode.QCode{
		Selects: []qcode.Select{
			{
				Field: qcode.Field{
					ID:        0,
					ParentID:  -1,
					FieldName: "users",
				},
				Table: "users",
				Ti:    sdata.DBTable{Name: "users"},
			},
		},
	}
	rp := NewResponseProcessor(qc)

	input := []byte(`{"data": {"users": {"id": 1, "name": "John", "__gj_id": 1}}}`)
	cleaned, refs, err := rp.ProcessForCache(input)
	if err != nil {
		t.Errorf("unexpected error: %v", err)
	}

	// Should have extracted one ref
	if len(refs) != 1 {
		t.Errorf("expected 1 ref, got %d", len(refs))
	} else {
		if refs[0].Table != "users" {
			t.Errorf("expected table 'users', got %q", refs[0].Table)
		}
		if refs[0].ID != "1" {
			t.Errorf("expected ID '1', got %q", refs[0].ID)
		}
	}

	// Should have removed __gj_id from output
	var result map[string]interface{}
	if err := json.Unmarshal(cleaned, &result); err != nil {
		t.Errorf("failed to parse cleaned response: %v", err)
	}
	dataMap := result["data"].(map[string]interface{})
	usersMap := dataMap["users"].(map[string]interface{})
	if _, hasGjId := usersMap["__gj_id"]; hasGjId {
		t.Errorf("__gj_id should have been removed from response")
	}
	if usersMap["id"] != float64(1) {
		t.Errorf("id field should be preserved")
	}
}

func BenchmarkStripCacheTrackingFields(b *testing.B) {
	data := []byte(`{"data":{"users":{"__gj_id":1,"id":1,"name":"Ada","posts":[{"__gj_id":10,"id":10,"title":"First"},{"id":11,"title":"Second","__gj_id":11}]}}}`)