Function TestResponseProcessor_LargeArray

core/cache_response_test.go:692–745

(t *testing.T)

}

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

	// Generate array with 1000 items
	var items []map[string]interface{}
	for i := 1; i <= 1000; i++ {
		items = append(items, map[string]interface{}{
			"id":      i,
			"__gj_id": i,
			"name":    "Item",
		})
	}
	data := map[string]interface{}{"data": map[string]interface{}{"items": items}}
	input, _ := json.Marshal(data)

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

	// Should extract all refs
	if len(refs) != 1000 {
		t.Errorf("expected 1000 refs, got %d", len(refs))
	}

	// Verify __gj_id removed
	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{})
	itemsResult := dataMap["items"].([]interface{})
	if len(itemsResult) != 1000 {
		t.Errorf("expected 1000 items in cleaned output, got %d", len(itemsResult))
	}
	// Check first item doesn't have __gj_id
	firstItem := itemsResult[0].(map[string]interface{})
	if _, hasGjId := firstItem["__gj_id"]; hasGjId {
		t.Errorf("first item should not have __gj_id")
	}
}

func TestExtractMutationRefs_Update(t *testing.T) {
	qc := &qcode.QCode{