2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
17 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
18 // platform project (RICP).
25 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
29 type ranListManagerInstance struct {
31 rnibDataService services.RNibDataService
33 nbIdentityMap map[string]*entities.NbIdentity
36 type RanListManager interface {
37 InitNbIdentityMap() error
38 AddNbIdentity(nodeType entities.Node_Type, nbIdentity *entities.NbIdentity) error
39 UpdateNbIdentityConnectionStatus(nodeType entities.Node_Type, ranName string, connectionStatus entities.ConnectionStatus) error
40 RemoveNbIdentity(nodeType entities.Node_Type, ranName string) error
41 GetNbIdentityList() []*entities.NbIdentity
42 UpdateRanState(nodebInfo *entities.NodebInfo) error // TODO: replace with UpdateNbIdentityConnectionStatus
45 func NewRanListManager(logger *logger.Logger, rnibDataService services.RNibDataService) RanListManager {
46 return &ranListManagerInstance{
48 rnibDataService: rnibDataService,
49 nbIdentityMap: make(map[string]*entities.NbIdentity),
53 // TODO: replace with UpdateNbIdentityConnectionStatus
54 func (m *ranListManagerInstance) UpdateRanState(nodebInfo *entities.NodebInfo) error {
55 m.logger.Infof("#ranListManagerInstance.UpdateRanState - RAN name: %s - Updating state...", nodebInfo.RanName)
59 func (m *ranListManagerInstance) InitNbIdentityMap() error {
60 nbIds, err := m.rnibDataService.GetListNodebIds()
63 m.logger.Errorf("#ranListManagerInstance.InitNbIdentityMap - Failed fetching RAN list from DB. error: %s", err)
67 for _, v := range nbIds {
68 m.nbIdentityMap[v.InventoryName] = v
71 m.logger.Infof("#ranListManagerInstance.InitNbIdentityMap - Successfully initiated nodeb identity map")
72 m.logger.Debugf("#ranListManagerInstance.InitNbIdentityMap - nodeb Identity map: %s", m.nbIdentityMap)
76 func (m *ranListManagerInstance) AddNbIdentity(nodeType entities.Node_Type, nbIdentity *entities.NbIdentity) error {
80 m.nbIdentityMap[nbIdentity.InventoryName] = nbIdentity
82 err := m.rnibDataService.AddNbIdentity(nodeType, nbIdentity)
85 m.logger.Errorf("#ranListManagerInstance.AddNbIdentity - RAN name: %s - Failed adding nodeb identity to DB. error: %s", nbIdentity.InventoryName, err)
89 m.logger.Infof("#ranListManagerInstance.AddNbIdentity - RAN name: %s - Successfully added nodeb identity", nbIdentity.InventoryName)
90 m.logger.Debugf("#ranListManagerInstance.AddNbIdentity - nodeb Identity map: %s", m.nbIdentityMap)
94 func (m *ranListManagerInstance) UpdateNbIdentityConnectionStatus(nodeType entities.Node_Type, ranName string, connectionStatus entities.ConnectionStatus) error {
99 func (m *ranListManagerInstance) RemoveNbIdentity(nodeType entities.Node_Type, ranName string) error {
103 m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - deleting nodeb identity from memory and db...", ranName)
105 nbIdentity, ok := m.nbIdentityMap[ranName]
107 m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - nodeb identity not found", ranName)
111 delete(m.nbIdentityMap, ranName)
113 err := m.rnibDataService.RemoveNbIdentity(nodeType, nbIdentity)
115 m.logger.Errorf("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - Failed removing nodeb identity from DB. error: %s", ranName, err)
119 m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - Successfully deleted nodeb identity", ranName)
123 func (m *ranListManagerInstance) GetNbIdentityList() []*entities.NbIdentity {
124 nbIds := make([]*entities.NbIdentity, 0, len(m.nbIdentityMap))
125 for _, v := range m.nbIdentityMap {
126 nbIds = append(nbIds, v)
129 m.logger.Infof("#ranListManagerInstance.GetNbIdentityList - %d identity returned", len(nbIds))