Function TestResponseProcessor_Array

core/cache_response_test.go:393–445

(t *testing.T)

}

func TestResponseProcessor_Array(t *testing.T) {
	qc := &qcode.QCode{
		Selects: []qcode.Select{
			{
				Field: qcode.Field{
					ID:        0,
					ParentID:  -1,
					FieldName: "products",
				},
				Table: "products",
				Ti:    sdata.DBTable{Name: "products"},
			},
		},
	}
	rp := NewResponseProcessor(qc)

	input := []byte(`{"data": {"products": [
		{"id": 1, "name": "Widget", "__gj_id": 1},
		{"id": 2, "name": "Gadget", "__gj_id": 2},
		{"id": 3, "name": "Gizmo", "__gj_id": 3}
	]}}`)

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

	// Should have extracted three refs
	if len(refs) != 3 {
		t.Errorf("expected 3 refs, got %d", len(refs))
	}

	// Verify all refs are for products table
	for i, ref := range refs {
		if ref.Table != "products" {
			t.Errorf("ref[%d] expected table 'products', got %q", i, ref.Table)
		}
	}

	// Verify __gj_id removed from all items
	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{})
	products := dataMap["products"].([]interface{})
	for i, p := range products {
		prod := p.(map[string]interface{})
		if _, hasGjId := prod["__gj_id"]; hasGjId {
			t.Errorf("products[%d] should not have __gj_id", i)
		}
	}
}

func TestResponseProcessor_NestedObjects(t *testing.T) {
	// Create qcode with nested selection: users -> posts