Function deriveProtoDirFromPath

utils/grpc.go:254–297

deriveProtoDirFromPath extracts the package from a gRPC path and searches protoInclude roots for a matching directory. This enables automatic proto directory resolution for multi-service scenarios where a single protoDir config is insufficient. It uses a multi-strategy approach following protobuf c

(grpcPath string, protoIncludes []string)

//
// Returns the first matching directory path, or an error if none found.
func deriveProtoDirFromPath(grpcPath string, protoIncludes []string) (string, error) {
	if grpcPath == "" || len(protoIncludes) == 0 {
		return "", fmt.Errorf("grpcPath and protoIncludes are required")
	}

	// Parse gRPC path to get service full name (e.g., "keploy.v1.keploy")
	serviceFull, _, err := ParseGRPCPath(grpcPath)
	if err != nil {
		return "", fmt.Errorf("failed to parse gRPC path: %w", err)
	}

	parts := strings.Split(serviceFull, ".")

	// Build search strategies in order of likelihood:
	// 1. Full package path (minus service name): "keploy.v1.keploy" → "keploy/v1"
	// 2. First segment only: "keploy"
	var strategies []string

	// Strategy 1: Full package path (remove service name - last part)
	if len(parts) > 1 {
		packageParts := parts[:len(parts)-1] // ["keploy", "v1"]
		strategies = append(strategies, filepath.Join(packageParts...))
	}

	// Strategy 2: First segment only
	strategies = append(strategies, parts[0])

	// Search protoInclude roots for matching directory
	for _, root := range protoIncludes {
		absRoot, err := mustAbs(root)
		if err != nil || absRoot == "" {
			continue
		}

		for _, strategy := range strategies {
			candidateDir := filepath.Join(absRoot, strategy)
			if info, err := os.Stat(candidateDir); err == nil && info.IsDir() {
				return candidateDir, nil
			}
		}
	}

	return "", fmt.Errorf("no proto directory found for service %q in protoInclude roots (tried: %v)", serviceFull, strategies)
}

// ProtoTextToWire turns Protoscope text into wire bytes using the library (no exec).
func ProtoTextToWire(text string) ([]byte, error) {