Method processObject

core/cache_response.go:310–348

(
	tableName string,
	obj map[string]interface{},
	refs *[]RowRef,
	sel *qcode.Select,
)

}

func (rp *ResponseProcessor) processObject(
	tableName string,
	obj map[string]interface{},
	refs *[]RowRef,
	sel *qcode.Select,
) {
	// Extract and remove __gj_id
	if id, ok := obj["__gj_id"]; ok {
		*refs = append(*refs, RowRef{
			Table: tableName,
			ID:    stringifyID(id),
		})
		delete(obj, "__gj_id")
	} else if id, ok := primaryKeyValueFromObject(obj, sel); ok {
		*refs = append(*refs, RowRef{
			Table: tableName,
			ID:    stringifyID(id),
		})
	}

	// Process child selections
	if sel != nil {
		for _, childID := range sel.Children {
			if childID < 0 || int(childID) >= len(rp.qc.Selects) {
				continue
			}
			childSel := &rp.qc.Selects[childID]

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

			if childData, ok := obj[fieldName]; ok {
				rp.processNode(childSel.Table, childData, refs, childSel)
			}
		}
	}
}

func responseDataMap(result map[string]interface{}) (map[string]interface{}, bool) {
	if dataField, ok := result["data"]; ok {