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).
23 "e2mgr/e2managererrors"
27 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
28 "github.com/pkg/errors"
31 type UpdateEnbManager struct {
33 rnibDataService services.RNibDataService
34 nodebValidator *NodebValidator
37 func NewUpdateEnbManager(logger *logger.Logger, rnibDataService services.RNibDataService, nodebValidator *NodebValidator) *UpdateEnbManager {
38 return &UpdateEnbManager{
40 rnibDataService: rnibDataService,
41 nodebValidator: nodebValidator,
45 func (h *UpdateEnbManager) Validate(request models.Request) error {
47 updateEnbRequest := request.(*models.UpdateEnbRequest)
49 h.logger.Infof("#UpdateEnbManager.Validate - Validate incoming request, ran name: %s", updateEnbRequest.RanName)
52 if err := h.validateRequestBody(updateEnbRequest); err != nil {
53 h.logger.Errorf("#UpdateEnbManager.Validate - validation failure: %s is a mandatory field and cannot be empty", err)
60 func (h *UpdateEnbManager) RemoveNodebCells(nodeb *entities.NodebInfo) error {
62 if nodeb.NodeType != entities.Node_ENB {
63 h.logger.Errorf("#UpdateEnbManager.RemoveNodebCells - RAN name: %s - nodeb missing eNB configuration", nodeb.GetRanName())
64 return e2managererrors.NewRequestValidationError()
67 err := h.rnibDataService.RemoveServedCells(nodeb.GetRanName(), nodeb.GetEnb().GetServedCells())
69 h.logger.Errorf("#UpdateEnbManager.RemoveNodebCells - RAN name: %s - Failed removing eNB served cells", nodeb.GetRanName())
70 return e2managererrors.NewRnibDbError()
72 h.logger.Infof("#UpdateEnbManager.RemoveNodebCells - RAN name: %s - Successfully removed eNB served cells", nodeb.GetRanName())
77 func (h *UpdateEnbManager) SetNodeb(nodeb *entities.NodebInfo, request models.Request) error {
79 updateEnbRequest := request.(*models.UpdateEnbRequest)
81 nodeb.Configuration = &entities.NodebInfo_Enb{Enb: updateEnbRequest.Enb}
86 func (h *UpdateEnbManager) UpdateNodeb(nodeb *entities.NodebInfo) error {
88 err := h.rnibDataService.UpdateEnb(nodeb, nodeb.GetEnb().GetServedCells())
90 h.logger.Errorf("#UpdateEnbManager.UpdateNodeb - RAN name: %s - Failed updating eNB. Error: %s", nodeb.GetRanName(), err)
91 return e2managererrors.NewRnibDbError()
93 h.logger.Infof("#UpdateEnbManager.UpdateNodeb - RAN name: %s - Successfully updated eNB", nodeb.GetRanName())
98 func (h *UpdateEnbManager) validateRequestBody(request *models.UpdateEnbRequest) error {
100 if request.Enb == nil {
101 return errors.New("enb")
104 if err := h.nodebValidator.IsEnbValid(request.Enb); err != nil {