feat(frontend): check endpoint correspondence for trtype

Signed-off-by: Artsiom Koltun <[email protected]>

pkg/frontend/nvme_controller_validate.go

@@ -5,6 +5,9 @@
 package frontend
 
 import (
+	"errors"
+	"fmt"
+
 	"go.einride.tech/aip/fieldbehavior"
 	"go.einride.tech/aip/resourceid"
 	"go.einride.tech/aip/resourcename"
@@ -23,6 +26,22 @@ func (s *Server) validateCreateNvmeControllerRequest(in *pb.CreateNvmeController
 			return err
 		}
 	}
+
+	switch in.NvmeController.Spec.Trtype {
+	case pb.NvmeTransportType_NVME_TRANSPORT_PCIE:
+		if _, ok := in.NvmeController.Spec.Endpoint.(*pb.NvmeControllerSpec_PcieId); !ok {
+			return errors.New("invalid endpoint type passed for transport")
+		}
+	case pb.NvmeTransportType_NVME_TRANSPORT_TCP:
+		fallthrough
+	case pb.NvmeTransportType_NVME_TRANSPORT_RDMA:
+		if _, ok := in.NvmeController.Spec.Endpoint.(*pb.NvmeControllerSpec_FabricsId); !ok {
+			return errors.New("invalid endpoint type passed for transport")
+		}
+	default:
+		return fmt.Errorf("not supported transport type: %v", in.NvmeController.Spec.Trtype)
+	}
+
 	// Validate that a resource name conforms to the restrictions outlined in AIP-122.
 	return resourcename.Validate(in.Parent)
 }