X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fe2_reset_request_handler.go;h=eb20f13ddf0255e19b5d89ba2eef8bb13c5e3a5a;hb=8b146be80f4b6daa8ce90d8ab62cab9f53f7e4f6;hp=4e1e3f4cf7289a05a950f41cc0c3b680ea8d9a28;hpb=bead73bf1014375ce51c272f546a2c94f9071530;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/handlers/rmrmsghandlers/e2_reset_request_handler.go b/E2Manager/handlers/rmrmsghandlers/e2_reset_request_handler.go
index 4e1e3f4..eb20f13 100644
--- a/E2Manager/handlers/rmrmsghandlers/e2_reset_request_handler.go
+++ b/E2Manager/handlers/rmrmsghandlers/e2_reset_request_handler.go
@@ -40,20 +40,22 @@ var (
 )
 
 type E2ResetRequestNotificationHandler struct {
-	logger          *logger.Logger
-	rnibDataService services.RNibDataService
-	config          *configuration.Configuration
-	rmrSender       *rmrsender.RmrSender
-	ranResetManager *managers.RanResetManager
+	logger                            *logger.Logger
+	rnibDataService                   services.RNibDataService
+	config                            *configuration.Configuration
+	rmrSender                         *rmrsender.RmrSender
+	ranResetManager                   *managers.RanResetManager
+	changeStatusToConnectedRanManager *managers.ChangeStatusToConnectedRanManager
 }
 
-func NewE2ResetRequestNotificationHandler(logger *logger.Logger, rnibDataService services.RNibDataService, config *configuration.Configuration, rmrSender *rmrsender.RmrSender, ranResetManager *managers.RanResetManager) *E2ResetRequestNotificationHandler {
+func NewE2ResetRequestNotificationHandler(logger *logger.Logger, rnibDataService services.RNibDataService, config *configuration.Configuration, rmrSender *rmrsender.RmrSender, ranResetManager *managers.RanResetManager, changeStatusToConnectedRanManager *managers.ChangeStatusToConnectedRanManager) *E2ResetRequestNotificationHandler {
 	return &E2ResetRequestNotificationHandler{
-		logger:          logger,
-		rnibDataService: rnibDataService,
-		config:          config,
-		rmrSender:       rmrSender,
-		ranResetManager: ranResetManager,
+		logger:                            logger,
+		rnibDataService:                   rnibDataService,
+		config:                            config,
+		rmrSender:                         rmrSender,
+		ranResetManager:                   ranResetManager,
+		changeStatusToConnectedRanManager: changeStatusToConnectedRanManager,
 	}
 }
 
@@ -108,12 +110,19 @@ func (e *E2ResetRequestNotificationHandler) Handle(request *models.NotificationR
 	e.logger.Infof("#E2ResetRequestNotificationHandler.Handle - RIC_RESET_REQUEST has been parsed successfully %+v", resetRequest)
 	e.handleSuccessfulResponse(ranName, request, resetRequest)
 
-	nodebInfo.ConnectionStatus = entities.ConnectionStatus_CONNECTED
-
-	err = e.rnibDataService.UpdateNodebInfoAndPublish(nodebInfo)
-
+	isConnectedStatus, err := e.changeStatusToConnectedRanManager.ChangeStatusToConnectedRan(ranName)
 	if err != nil {
-		e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to update connection status of nodeB entity. RanName: %s. Error: %s", request.RanName, err.Error())
+		e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to update and notify connection status of nodeB entity. RanName: %s. Error: %s", request.RanName, err.Error())
+	} else {
+		if isConnectedStatus {
+			nodebInfoupdated, err1 := e.getNodebInfo(request.RanName)
+			if err1 != nil {
+				e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to get updated nodeB entity. RanName: %s. Error: %s", request.RanName, err1.Error())
+			}
+			e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - Connection status Set Successfully ran: %s , Connection status updated : %s", ranName, nodebInfoupdated.ConnectionStatus)
+		} else {
+			e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - Connection status Setting Failed")
+		}
 	}
 
 	e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - nodeB entity connected state. RanName %s, ConnectionStatus %s", nodebInfo.RanName, nodebInfo.ConnectionStatus)
@@ -144,13 +153,13 @@ func (e *E2ResetRequestNotificationHandler) waitfortimertimeout(request *models.
 
 func (e *E2ResetRequestNotificationHandler) parseE2ResetMessage(payload []byte) (*models.E2ResetRequestMessage, error) {
 	e2resetMessage := models.E2ResetRequestMessage{}
-	err := xml.Unmarshal(utils.NormalizeXml(payload), &(e2resetMessage.E2APPDU))
+	err := xml.Unmarshal(utils.NormalizeXml(payload), &(e2resetMessage.E2ApPDU))
 
 	if err != nil {
 		e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - error in parsing request message: %+v", err)
 		return nil, err
 	}
-	e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - Unmarshalling is successful %v", e2resetMessage.E2APPDU.InitiatingMessage.ProcedureCode)
+	e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - Unmarshalling is successful %v", e2resetMessage.E2ApPDU.InitiatingMessage.ProcedureCode)
 	return &e2resetMessage, nil
 }