Function TestResponseProcessor_NestedObjects

core/cache_response_test.go:447–523

(t *testing.T)

}

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

	input := []byte(`{"data": {"users": {
		"id": 1,
		"name": "John",
		"__gj_id": 1,
		"posts": [
			{"id": 10, "title": "First Post", "__gj_id": 10},
			{"id": 11, "title": "Second Post", "__gj_id": 11}
		]
	}}}`)

	cleaned, refs, err := rp.ProcessForCache(input)
	if err != nil {
		t.Errorf("unexpected error: %v", err)
	}

	// Should have extracted 3 refs (1 user + 2 posts)
	if len(refs) != 3 {
		t.Errorf("expected 3 refs, got %d", len(refs))
	}

	// Count by table
	tableCount := make(map[string]int)
	for _, ref := range refs {
		tableCount[ref.Table]++
	}
	if tableCount["users"] != 1 {
		t.Errorf("expected 1 users ref, got %d", tableCount["users"])
	}
	if tableCount["posts"] != 2 {
		t.Errorf("expected 2 posts refs, got %d", tableCount["posts"])
	}