Function compileAndFindResponseDescriptor

utils/grpc.go:159–207

compileAndFindResponseDescriptor compiles all compileNames (+ imports via roots) and returns serviceFull.method Output desc. We avoid building a separate registry; instead we search the linked files directly.

(compileNames []string, roots []string, serviceFull, method string)

// compileAndFindResponseDescriptor compiles all compileNames (+ imports via roots) and returns serviceFull.method Output desc.
// We avoid building a separate registry; instead we search the linked files directly.
func compileAndFindResponseDescriptor(compileNames []string, roots []string, serviceFull, method string) (protoreflect.MessageDescriptor, []protoreflect.FileDescriptor, error) {
	c := &protocompile.Compiler{
		Resolver: &protocompile.SourceResolver{ImportPaths: roots},
		Reporter: reporter.NewReporter(
			func(e reporter.ErrorWithPos) error { return e }, // errors
			func(w reporter.ErrorWithPos) { /* optionally log warnings */ },
		),
	}

	ctx, cancel := context.WithTimeout(context.Background(), 45*time.Second)
	defer cancel()

	files, err := c.Compile(ctx, compileNames...)
	if err != nil {
		return nil, nil, fmt.Errorf("compile %v (relative to -I: %v): %w", compileNames, roots, err)
	}
	if len(files) == 0 {
		return nil, nil, fmt.Errorf("no files compiled for %v", compileNames)
	}

	// Directly search the linked files for the service, then the method.
	full := protoreflect.FullName(serviceFull)
	for _, f := range files {
		d := f.FindDescriptorByName(full)
		if d == nil {
			continue
		}

		sd, ok := d.(protoreflect.ServiceDescriptor)
		if !ok {
			continue
		}

		for i := range sd.Methods().Len() {
			m := sd.Methods().Get(i)
			if string(m.Name()) == method {
				// Convert linker.Files to []protoreflect.FileDescriptor
				fileDescs := make([]protoreflect.FileDescriptor, len(files))
				for i, f := range files {
					fileDescs[i] = f
				}
				return m.Output(), fileDescs, nil
			}
		}
		return nil, nil, fmt.Errorf("method %q not found on service %q", method, serviceFull)
	}

	return nil, nil, fmt.Errorf("service %q not found in compiled set", serviceFull)
}

func mustAbs(p string) (string, error) {
	if p == "" {