X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fric_service_update_handler.go;fp=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fric_service_update_handler.go;h=b8d1c063ae15366f64c2620740c2a1210a0fa01a;hb=0249b5fc410b6c6814906b185dfdf25b27621148;hp=15f89a8684a2b73a3c7d2f0fe0a35bb23badc60d;hpb=046e93dca8cf63d0bc9645b435c9428e538c1b71;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go b/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go
index 15f89a8..b8d1c06 100644
--- a/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go
+++ b/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go
@@ -55,14 +55,16 @@ type RicServiceUpdateHandler struct {
 	rmrSender       *rmrsender.RmrSender
 	rNibDataService services.RNibDataService
 	ranListManager  managers.RanListManager
+	RicServiceUpdateManager managers.IRicServiceUpdateManager
 }
 
-func NewRicServiceUpdateHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, rNibDataService services.RNibDataService, ranListManager managers.RanListManager) *RicServiceUpdateHandler {
+func NewRicServiceUpdateHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, rNibDataService services.RNibDataService, ranListManager managers.RanListManager,RicServiceUpdateManager managers.IRicServiceUpdateManager) *RicServiceUpdateHandler {
 	return &RicServiceUpdateHandler{
 		logger:          logger,
 		rmrSender:       rmrSender,
 		rNibDataService: rNibDataService,
 		ranListManager:  ranListManager,
+		RicServiceUpdateManager: RicServiceUpdateManager,
 	}
 }
 
@@ -87,6 +89,8 @@ func (h *RicServiceUpdateHandler) Handle(request *models.NotificationRequest) {
 		return
 	}
 	h.logger.Infof("#RicServiceUpdateHandler.Handle - RIC_SERVICE_UPDATE has been parsed successfully %+v", ricServiceUpdate)
+	h.RicServiceUpdateManager.StoreExistingRanFunctions(ranName)
+	h.logger.Infof("#RicServiceUpdate.Handle - Getting the ranFunctions before we do the RIC ServiceUpdate handling")
 
 	ackFunctionIds := h.updateFunctions(ricServiceUpdate.E2APPDU.InitiatingMessage.Value.RICServiceUpdate.ProtocolIEs.RICServiceUpdateIEs, nodebInfo)
 	if len(ricServiceUpdate.E2APPDU.InitiatingMessage.Value.RICServiceUpdate.ProtocolIEs.RICServiceUpdateIEs) > 1 {
@@ -112,6 +116,8 @@ func (h *RicServiceUpdateHandler) Handle(request *models.NotificationRequest) {
 	}
 
 	h.logger.Infof("#RicServiceUpdate.Handle - Completed successfully")
+	models.UpdateProcedureType(ranName, models.RicServiceUpdateCompleted)
+	h.logger.Debugf("#RicServiceUpdateHandler.Handle  - updating the enum value to RicServiceUpdateCompleted completed")
 }
 
 func (h *RicServiceUpdateHandler) sendUpdateAck(updateAck models.RicServiceUpdateAckE2APPDU, nodebInfo *entities.NodebInfo, request *models.NotificationRequest) error {