diff --git a/api/grpc.go b/api/grpc.go index 1a28558310e32c22d8cf9e6224493697b7ddfd51..c3765cdf59f7ae64dda21efc19b3bc81857c842f 100644 --- a/api/grpc.go +++ b/api/grpc.go @@ -41,6 +41,7 @@ func Init(addr string) error { log.Infof("SBI: %v", sbi) } } + viper.WriteConfig() return nil } diff --git a/northbound/server/core.go b/northbound/server/core.go index 60de83baded00b37a2c2d84166913f5b18cc7c8f..a655ef4d21889974240ecf6607fbcfbc3b59721c 100644 --- a/northbound/server/core.go +++ b/northbound/server/core.go @@ -9,6 +9,8 @@ import ( spb "code.fbi.h-da.de/cocsn/api/go/gosdn/southbound" "code.fbi.h-da.de/cocsn/gosdn/nucleus" "github.com/google/uuid" + "google.golang.org/grpc/codes" + "google.golang.org/grpc/status" ) type core struct { @@ -24,7 +26,7 @@ func (s core) Get(ctx context.Context, request *pb.GetRequest) (*pb.GetResponse, var err error pndList, err = stringToUUID(request.Pid) if err != nil { - return nil, err + return nil, status.Errorf(codes.Aborted, "%v", err) } } @@ -34,10 +36,23 @@ func (s core) Get(ctx context.Context, request *pb.GetRequest) (*pb.GetResponse, if err != nil { return nil, err } + + ond, err := fillOnds(pnd, true) + if err != nil { + return nil, status.Errorf(codes.Aborted, "%v", err) + } + + sbi, err := fillSbis(pnd, true) + if err != nil { + return nil, status.Errorf(codes.Aborted, "%v", err) + } + pnds[i] = &ppb.PrincipalNetworkDomain{ Id: pnd.ID().String(), Name: pnd.GetName(), Description: pnd.GetDescription(), + Ond: ond, + Sbi: sbi, } } return &pb.GetResponse{ @@ -52,10 +67,10 @@ func (s core) Set(ctx context.Context, request *pb.SetRequest) (*pb.SetResponse, pnd, err := nucleus.NewPND(r.Name, r.Description, uuid.New(), sbi) if err != nil { - return nil, err + return nil, status.Errorf(codes.Aborted, "%v", err) } if err := pndc.Add(pnd); err != nil { - return nil, err + return nil, status.Errorf(codes.Aborted, "%v", err) } } return &pb.SetResponse{