X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fmanagers%2Fran_connect_status_change_manager.go;h=138f08975e292ad9c1c3fe8022d1eccbe940ff32;hb=885ce20e6a593863923b249bf74ffc09ad610176;hp=26d12b2e7178fc2e8c2db1eed10ff5c36027f5a2;hpb=a07b8597afc9d063a7f37a376a5bcf29ba29b557;p=ric-plt%2Fe2mgr.git

diff --git a/E2Manager/managers/ran_connect_status_change_manager.go b/E2Manager/managers/ran_connect_status_change_manager.go
index 26d12b2..138f089 100644
--- a/E2Manager/managers/ran_connect_status_change_manager.go
+++ b/E2Manager/managers/ran_connect_status_change_manager.go
@@ -31,6 +31,10 @@ const (
 	NONE_RAW_EVENT         = "NONE"
 )
 
+type IRanConnectStatusChangeManager interface {
+	ChangeStatus(nodebInfo *entities.NodebInfo, nextStatus entities.ConnectionStatus) (bool, error)
+}
+
 type RanConnectStatusChangeManager struct {
 	logger          *logger.Logger
 	rnibDataService services.RNibDataService
@@ -47,9 +51,11 @@ func NewRanConnectStatusChangeManager(logger *logger.Logger, rnibDataService ser
 	}
 }
 
-func (m *RanConnectStatusChangeManager) ChangeStatus(nodebInfo *entities.NodebInfo, nextStatus entities.ConnectionStatus) error {
+func (m *RanConnectStatusChangeManager) ChangeStatus(nodebInfo *entities.NodebInfo, nextStatus entities.ConnectionStatus) (bool, error) {
 	m.logger.Infof("#RanConnectStatusChangeManager.ChangeStatus - RAN name: %s, currentStatus: %s, nextStatus: %s", nodebInfo.RanName, nodebInfo.GetConnectionStatus(), nextStatus)
 
+	var ranStatusChangePublished bool
+
 	// set the proper event
 	event := m.setEvent(nodebInfo, nextStatus)
 	isConnectivityEvent := event != NONE_RAW_EVENT
@@ -59,13 +65,14 @@ func (m *RanConnectStatusChangeManager) ChangeStatus(nodebInfo *entities.NodebIn
 	if !isConnectivityEvent {
 		err := m.updateNodebInfo(nodebInfo)
 		if err != nil {
-			return err
+			return ranStatusChangePublished, err
 		}
 	} else {
 		err := m.updateNodebInfoOnConnectionStatusInversion(nodebInfo, event)
 		if err != nil {
-			return err
+			return ranStatusChangePublished, err
 		}
+		ranStatusChangePublished = true
 	}
 
 	// in any case, update RanListManager
@@ -85,7 +92,7 @@ func (m *RanConnectStatusChangeManager) ChangeStatus(nodebInfo *entities.NodebIn
 		}
 	}
 
-	return nil
+	return ranStatusChangePublished, nil
 }
 
 func (m *RanConnectStatusChangeManager) updateNodebInfoOnConnectionStatusInversion(nodebInfo *entities.NodebInfo, event string) error {