Method ProcessForCache

core/cache_response.go:235–275

ProcessForCache extracts row references and strips __gj_id from response. Returns the cleaned response and list of (table, row_id) pairs.

(data []byte)

// ProcessForCache extracts row references and strips __gj_id from response.
// Returns the cleaned response and list of (table, row_id) pairs.
func (rp *ResponseProcessor) ProcessForCache(data []byte) (cleaned []byte, refs []RowRef, err error) {
	if len(data) == 0 {
		return data, nil, nil
	}
	if rp.qc == nil {
		return data, nil, nil
	}

	// Parse JSON response
	var result map[string]interface{}
	if err = json.Unmarshal(data, &result); err != nil {
		return data, nil, err
	}

	dataMap, ok := responseDataMap(result)
	if !ok {
		return data, nil, nil
	}

	refs = make([]RowRef, 0, 100)

	// Process each root selection
	for i := range rp.qc.Selects {
		sel := &rp.qc.Selects[i]
		if sel.ParentID != -1 {
			continue // Skip non-root selections
		}

		fieldName := sel.FieldName
		if fieldName == "" {
			fieldName = sel.Table
		}

		if fieldData, ok := dataMap[fieldName]; ok {
			rp.processNode(sel.Table, fieldData, &refs, sel)
		}
	}

	cleaned, err = stripCacheTrackingFields(data)
	return
}

func stripCacheTrackingFields(data []byte) ([]byte, error) {
	fields := jsn.Get(data, [][]byte{[]byte("__gj_id")})