feat: complete ListNvmePaths and GetNvmePath

Signed-off-by: Minhee Han <minhee.han@mangoboost.io>

Author: han-minhee

pkg/backend/nvme_path.go

@@ -210,13 +210,30 @@ func (s *Server) ListNvmePaths(ctx context.Context, in *pb.ListNvmePathsRequest)
 		token = uuid.New().String()
 		s.Pagination[token] = offset + size
 	}
-	Blobarray := make([]*pb.NvmePath, len(result))
-	for i := range result {
-		r := &result[i]
-		Blobarray[i] = &pb.NvmePath{Name: r.Name /* TODO: fill this */}
+	Blobarray := make([]*pb.NvmePath, 0, len(result))
+	for _, r := range result {
+		for _, c := range r.Ctrlrs {
+			path := &pb.NvmePath{
+				Name:   r.Name,
+				Trtype: utils.ParseOpiTransportType(c.Trid.Trtype),
+				Traddr: c.Trid.Traddr,
+				Fabrics: &pb.FabricsPath{
+					Trsvcid:       utils.ParseTrsvcid(c.Trid.Trsvcid),
+					Subnqn:        c.Trid.Subnqn,
+					Adrfam:        utils.SpdkAddressFamilyToOpi(c.Trid.Adrfam),
+					SourceTraddr:  c.Host.Addr,
+					SourceTrsvcid: utils.ParseTrsvcid(c.Host.Svcid),
+					Hostnqn:       c.Host.Nqn,
+				},
+			}
+			Blobarray = append(Blobarray, path)
+		}
 	}
 	sortNvmePaths(Blobarray)
-	return &pb.ListNvmePathsResponse{NvmePaths: Blobarray, NextPageToken: token}, nil
+	return &pb.ListNvmePathsResponse{
+		NvmePaths:     Blobarray,
+		NextPageToken: token,
+	}, nil
 }
 
 // GetNvmePath gets Nvme path
@@ -239,10 +256,23 @@ func (s *Server) GetNvmePath(ctx context.Context, in *pb.GetNvmePathRequest) (*p
 	}
 	log.Printf("Received from SPDK: %v", result)
 
-	for i := range result {
-		r := &result[i]
-		if r.Name != "" {
-			return &pb.NvmePath{ /* TODO: fill this */ }, nil
+	for _, r := range result {
+		for _, c := range r.Ctrlrs {
+			if c.Trid.Subnqn == path.Fabrics.Subnqn {
+				return &pb.NvmePath{
+					Name:   r.Name,
+					Trtype: utils.ParseOpiTransportType(c.Trid.Trtype),
+					Traddr: c.Trid.Traddr,
+					Fabrics: &pb.FabricsPath{
+						Trsvcid:       utils.ParseTrsvcid(c.Trid.Trsvcid),
+						Subnqn:        c.Trid.Subnqn,
+						Adrfam:        utils.SpdkAddressFamilyToOpi(c.Trid.Adrfam),
+						SourceTraddr:  c.Host.Addr,
+						SourceTrsvcid: utils.ParseTrsvcid(c.Host.Svcid),
+						Hostnqn:       c.Host.Nqn,
+					},
+				}, nil
+			}
 		}
 	}
 	msg := fmt.Sprintf("Could not find NQN: %s", path.Fabrics.Subnqn)

pkg/utils/server.go

@@ -13,6 +13,7 @@ import (
 	"net"
 	"os"
 	"path/filepath"
+	"strconv"
 	"strings"
 
 	"google.golang.org/grpc"
@@ -150,3 +151,47 @@ func OpiAdressFamilyToSpdk(adrfam pb.NvmeAddressFamily) string {
 
 	return strings.ReplaceAll(adrfam.String(), "NVME_ADDRESS_FAMILY_", "")
 }
+
+// SpdkAddressFamilyToOpi converts a SPDK address family string to the corresponding OPI NvmeAddressFamily enum.
+func SpdkAddressFamilyToOpi(adrfam string) pb.NvmeAddressFamily {
+	switch strings.ToLower(adrfam) {
+	case "ipv4":
+		return pb.NvmeAddressFamily_NVME_ADDRESS_FAMILY_IPV4
+	case "ipv6":
+		return pb.NvmeAddressFamily_NVME_ADDRESS_FAMILY_IPV6
+	case "ib":
+		return pb.NvmeAddressFamily_NVME_ADDRESS_FAMILY_IB
+	case "fc":
+		return pb.NvmeAddressFamily_NVME_ADDRESS_FAMILY_FC
+	case "intra_host":
+		return pb.NvmeAddressFamily_NVME_ADDRESS_FAMILY_INTRA_HOST
+	default:
+		return pb.NvmeAddressFamily_NVME_ADDRESS_FAMILY_UNSPECIFIED
+	}
+}
+
+// ParseOpiTransportType parses a string to the corresponding OPI TransportType enum.
+func ParseOpiTransportType(t string) pb.NvmeTransportType {
+	switch strings.ToLower(t) {
+	case "fc":
+		return pb.NvmeTransportType_NVME_TRANSPORT_TYPE_FC
+	case "pcie":
+		return pb.NvmeTransportType_NVME_TRANSPORT_TYPE_PCIE
+	case "rdma":
+		return pb.NvmeTransportType_NVME_TRANSPORT_TYPE_RDMA
+	case "tcp":
+		return pb.NvmeTransportType_NVME_TRANSPORT_TYPE_TCP
+	default:
+		return pb.NvmeTransportType_NVME_TRANSPORT_TYPE_UNSPECIFIED
+	}
+}
+
+// ParseTrsvcid parses a string into int64, returning -1 on failure.
+func ParseTrsvcid(s string) int64 {
+	// if it fails, it just returns -1
+	i, err := strconv.ParseInt(s, 10, 64)
+	if err != nil {
+		return -1
+	}
+	return i
+}