From e04df1dc6f438610c706526a11aa5107c17d0731 Mon Sep 17 00:00:00 2001 From: "naman.gupta" Date: Mon, 22 May 2023 17:17:32 +0530 Subject: [PATCH] Getting node for which e2 reset has to be applied Getting node for which e2 reset has to be applied. Signed-off-by: naman.gupta Change-Id: Ibe571b66748029769823daa04ec827eed6d90809 --- .../httpmsghandlers/e2_reset_request_handler.go | 75 ++++++++++++++++++++++ 1 file changed, 75 insertions(+) create mode 100644 E2Manager/handlers/httpmsghandlers/e2_reset_request_handler.go diff --git a/E2Manager/handlers/httpmsghandlers/e2_reset_request_handler.go b/E2Manager/handlers/httpmsghandlers/e2_reset_request_handler.go new file mode 100644 index 0000000..e2b6429 --- /dev/null +++ b/E2Manager/handlers/httpmsghandlers/e2_reset_request_handler.go @@ -0,0 +1,75 @@ +// +// Copyright (c) 2023 Samsung Electronics Co., Ltd. All Rights Reserved. +// +// Licensed under the Apache License, Version 2.0 (the "License"); +// you may not use this file except in compliance with the License. +// You may obtain a copy of the License at +// +// http://www.apache.org/licenses/LICENSE-2.0 +// +// Unless required by applicable law or agreed to in writing, software +// distributed under the License is distributed on an "AS IS" BASIS, +// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +// See the License for the specific language governing permissions and +// limitations under the License. + +// This source code is part of the near-RT RIC (RAN Intelligent Controller) +// platform project (RICP). + +package httpmsghandlers + +import ( + "e2mgr/e2managererrors" + "e2mgr/logger" + "e2mgr/managers" + "e2mgr/models" + "e2mgr/services" + "e2mgr/services/rmrsender" + + "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common" + "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities" +) + +type E2ResetRequestHandler struct { + rNibDataService services.RNibDataService + rmrSender *rmrsender.RmrSender + logger *logger.Logger + ranResetManager *managers.RanResetManager +} + +func NewE2ResetRequestHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, rNibDataService services.RNibDataService, ranResetManager *managers.RanResetManager) *E2ResetRequestHandler { + return &E2ResetRequestHandler{ + rNibDataService: rNibDataService, + rmrSender: rmrSender, + logger: logger, + ranResetManager: ranResetManager, + } +} + +func (e *E2ResetRequestHandler) Handle(request models.Request) error { + resetRequest := request.(models.ResetRequest) + e.logger.Infof("#E2ResetRequestHandler.Handle - Ran name: %s", resetRequest.RanName) + nodebInfo, err := e.getNodebInfo(resetRequest.RanName) + if err != nil { + e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to get status of RAN: %s from RNIB. Error: %s", resetRequest.RanName, err.Error()) + _, ok := err.(*common.ResourceNotFoundError) + if ok { + return e2managererrors.NewResourceNotFoundError() + } + return e2managererrors.NewRnibDbError() + } + + e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - nodeB entity retrieved. RanName %s, ConnectionStatus %s", nodebInfo.RanName, nodebInfo.ConnectionStatus) + + return nil +} + +func (e *E2ResetRequestHandler) getNodebInfo(ranName string) (*entities.NodebInfo, error) { + + nodebInfo, err := e.rNibDataService.GetNodeb(ranName) + if err != nil { + e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to retrieve nodeB entity. RanName: %s. Error: %s", ranName, err.Error()) + return nil, err + } + return nodebInfo, nil +} -- 2.16.6