Method resolveDatabaseRootRemotes

core/database_join.go:891–921

(
	ctx context.Context,
	dbName string,
	qc *qcode.QCode,
	data []byte,
)

}

func (s *gstate) resolveDatabaseRootRemotes(
	ctx context.Context,
	dbName string,
	qc *qcode.QCode,
	data []byte,
) (json.RawMessage, error) {
	if qc == nil || qc.Remotes == 0 || len(data) == 0 {
		return json.RawMessage(data), nil
	}

	sub := gstate{
		gj:        s.gj,
		r:         cloneGraphqlReq(s.r),
		cs:        &cstate{st: stmt{qc: qc}},
		data:      injectRemoteMarkers(data, qc),
		role:      s.role,
		database:  dbName,
		skipCache: s.skipCache,
	}
	err := sub.execRemoteJoin(ctx)
	if hits := sub.fragmentHits.Load(); hits != 0 {
		s.fragmentHits.Add(hits)
	}
	if misses := sub.fragmentMisses.Load(); misses != 0 {
		s.fragmentMisses.Add(misses)
	}
	if err != nil {
		return nil, err
	}
	return json.RawMessage(sub.data), nil
}