X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=E2Manager%2FrNibWriter%2FrNibWriter.go;fp=E2Manager%2FrNibWriter%2FrNibWriter.go;h=7678fb373abd01619137ef52d0fa5e22b6792a30;hb=7ec48b27b054a29e96e901eb43dfed257dea2990;hp=30692588b47e588ef852b57f62b4540a994a6d27;hpb=74f9752fae845468e4f8948265c892fa8fe9fdb7;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/rNibWriter/rNibWriter.go b/E2Manager/rNibWriter/rNibWriter.go
index 3069258..7678fb3 100644
--- a/E2Manager/rNibWriter/rNibWriter.go
+++ b/E2Manager/rNibWriter/rNibWriter.go
@@ -59,6 +59,7 @@ type RNibWriter interface {
 	UpdateEnb(nodebInfo *entities.NodebInfo, servedCells []*entities.ServedCellInfo) error
 	AddNbIdentity(nodeType entities.Node_Type, nbIdentity *entities.NbIdentity) error
 	RemoveNbIdentity(nodeType entities.Node_Type, nbIdentity *entities.NbIdentity) error
+	AddEnb(nodebInfo *entities.NodebInfo) error
 }
 
 /*
@@ -166,13 +167,48 @@ func (w *rNibWriterInstance) SaveNodeb(nodebInfo *entities.NodebInfo) error {
 		}
 	}
 
-	if nodebInfo.GetNodeType() == entities.Node_ENB {
-		channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanAddedEvent)
-		err = w.sdl.SetAndPublish(channelsAndEvents, pairs)
-	} else {
-		err = w.sdl.Set(pairs)
+	err = w.sdl.Set(pairs)
+
+	if err != nil {
+		return common.NewInternalError(err)
 	}
 
+	return nil
+}
+
+func (w *rNibWriterInstance) AddEnb(nodebInfo *entities.NodebInfo) error {
+
+	data, err := proto.Marshal(nodebInfo)
+
+	if err != nil {
+		return common.NewInternalError(err)
+	}
+
+	var pairs []interface{}
+	key, rNibErr := common.ValidateAndBuildNodeBNameKey(nodebInfo.RanName)
+
+	if rNibErr != nil {
+		return rNibErr
+	}
+
+	pairs = append(pairs, key, data)
+
+	if nodebInfo.GlobalNbId != nil {
+
+		key, rNibErr = common.ValidateAndBuildNodeBIdKey(nodebInfo.GetNodeType().String(), nodebInfo.GlobalNbId.GetPlmnId(), nodebInfo.GlobalNbId.GetNbId())
+		if rNibErr != nil {
+			return rNibErr
+		}
+		pairs = append(pairs, key, data)
+	}
+
+	pairs, rNibErr = appendEnbCells(nodebInfo.RanName, nodebInfo.GetEnb().GetServedCells(), pairs)
+	if rNibErr != nil {
+		return rNibErr
+	}
+
+	channelsAndEvents := getChannelsAndEventsPair(w.rnibWriterConfig.RanManipulationMessageChannel, nodebInfo.RanName, RanAddedEvent)
+	err = w.sdl.SetAndPublish(channelsAndEvents, pairs)
 	if err != nil {
 		return common.NewInternalError(err)
 	}