Method ExecuteManagedQuery

core/managed_handler_mux.go:120–152

(ctx context.Context, req ManagedQueryRequest)

}

func (m *managedQueryMux) ExecuteManagedQuery(ctx context.Context, req ManagedQueryRequest) (json.RawMessage, error) {
	grouped := make(map[ManagedQueryHandler][]ManagedQueryRoot)
	for _, root := range req.Roots {
		handler := m.byTable[strings.ToLower(root.Table)]
		if handler == nil {
			return nil, fmt.Errorf("managed query table %q has no handler", root.Table)
		}
		grouped[handler] = append(grouped[handler], root)
	}

	out := make(map[string]json.RawMessage, len(req.Roots))
	for _, handler := range m.handlers {
		roots := grouped[handler]
		if len(roots) == 0 {
			continue
		}
		data, err := handler.ExecuteManagedQuery(ctx, ManagedQueryRequest{
			Database: req.Database,
			Roots:    roots,
		})
		if err != nil {
			return nil, err
		}
		var partial map[string]json.RawMessage
		if err := json.Unmarshal(data, &partial); err != nil {
			return nil, fmt.Errorf("managed query handler returned invalid JSON object: %w", err)
		}
		for key, value := range partial {
			out[key] = value
		}
	}
	return json.Marshal(out)
}

func (m *managedMutationMux) ExecuteManagedMutation(ctx context.Context, req ManagedMutationRequest) (json.RawMessage, error) {
	grouped := make(map[ManagedMutationHandler][]ManagedMutationRoot)