E2Manager/managers/e2_connected_status_change_manager.go

   1 //\r
   2 // Copyright (c) 2023 Samsung Electronics Co., Ltd. All Rights Reserved.\r
   3 //\r
   4 // Licensed under the Apache License, Version 2.0 (the "License");\r
   5 // you may not use this file except in compliance with the License.\r
   6 // You may obtain a copy of the License at\r
   7 //\r
   8 //      http://www.apache.org/licenses/LICENSE-2.0\r
   9 //\r
  10 // Unless required by applicable law or agreed to in writing, software\r
  11 // distributed under the License is distributed on an "AS IS" BASIS,\r
  12 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  13 // See the License for the specific language governing permissions and\r
  14 // limitations under the License.\r
  15 \r
  16 //  This source code is part of the near-RT RIC (RAN Intelligent Controller)\r
  17 //  platform project (RICP).\r
  18 \r
  19 package managers\r
  20 \r
  21 import (\r
  22         // "e2mgr/configuration"\r
  23         "e2mgr/logger"\r
  24         "e2mgr/services"\r
  25 \r
  26         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"\r
  27 )\r
  28 \r
  29 type IChangeStatusToConnectedRanManager interface {\r
  30         ChangeStatusToConnectedRan(inventoryName string) error\r
  31 }\r
  32 \r
  33 type ChangeStatusToConnectedRanManager struct {\r
  34         logger                        *logger.Logger\r
  35         rnibDataService               services.RNibDataService\r
  36         ranConnectStatusChangeManager IRanConnectStatusChangeManager\r
  37 }\r
  38 \r
  39 func NewChangeStatusToConnectedRanManager(logger *logger.Logger, rnibDataService services.RNibDataService, ranConnectStatusChangeManager IRanConnectStatusChangeManager) *ChangeStatusToConnectedRanManager {\r
  40         return &ChangeStatusToConnectedRanManager{\r
  41                 logger:                        logger,\r
  42                 rnibDataService:               rnibDataService,\r
  43                 ranConnectStatusChangeManager: ranConnectStatusChangeManager,\r
  44         }\r
  45 }\r
  46 \r
  47 func (m *ChangeStatusToConnectedRanManager) ChangeStatusToConnectedRan(inventoryName string) (bool, error) {\r
  48         nodebInfo, err := m.rnibDataService.GetNodeb(inventoryName)\r
  49 \r
  50         if err != nil {\r
  51                 m.logger.Errorf("#ChangeStatusToConnectedRanManager.ChangeStatusToConnectedRan - RAN name: %s - Failed fetching RAN from rNib. Error: %v", inventoryName, err)\r
  52                 return false, err\r
  53         }\r
  54         connectionStatus := nodebInfo.GetConnectionStatus()\r
  55         m.logger.Infof("#ChangeStatusToConnectedRanManager.ChangeStatusToConnectedRan - RAN name: %s - RAN's connection status: %s", nodebInfo.RanName, connectionStatus)\r
  56 \r
  57         ranConnectStatusChange, err := m.ranConnectStatusChangeManager.ChangeStatus(nodebInfo, entities.ConnectionStatus_CONNECTED)\r
  58 \r
  59         if err != nil {\r
  60                 return ranConnectStatusChange, err\r
  61         }\r
  62         m.logger.Infof("#ChangeStatusToConnectedRanManager.ChangeStatusToConnectedRan Status changed \n")\r
  63         return ranConnectStatusChange, nil\r
  64 }\r