2 // Copyright (c) 2020 Samsung Electronics Co., Ltd. All Rights Reserved.
4 // Licensed under the Apache License, Version 2.0 (the "License");
5 // you may not use this file except in compliance with the License.
6 // You may obtain a copy of the License at
8 // http://www.apache.org/licenses/LICENSE-2.0
10 // Unless required by applicable law or agreed to in writing, software
11 // distributed under the License is distributed on an "AS IS" BASIS,
12 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 // See the License for the specific language governing permissions and
14 // limitations under the License.
16 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
17 // platform project (RICP).
19 package httpmsghandlers
22 "e2mgr/e2managererrors"
28 "e2mgr/services/rmrsender"
31 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
32 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
37 healthCheckEmptyTagsToReplaceToSelfClosingTags = []string{"reject", "ignore", "protocolIEs", "procedureCode"}
40 type HealthCheckRequestHandler struct {
42 rNibDataService services.RNibDataService
43 ranListManager managers.RanListManager
44 rmrsender *rmrsender.RmrSender
47 func NewHealthCheckRequestHandler(logger *logger.Logger, rNibDataService services.RNibDataService, ranListManager managers.RanListManager, rmrsender *rmrsender.RmrSender) *HealthCheckRequestHandler {
48 return &HealthCheckRequestHandler{
50 rNibDataService: rNibDataService,
51 ranListManager: ranListManager,
56 func (h *HealthCheckRequestHandler) Handle(request models.Request) (models.IResponse, error) {
57 ranNameList := h.getRanNameList(request)
58 isAtleastOneRanConnected := false
60 nodetypeToNbIdentityMapOld := make(map[entities.Node_Type][]*entities.NbIdentity)
61 nodetypeToNbIdentityMapNew := make(map[entities.Node_Type][]*entities.NbIdentity)
63 for _, ranName := range ranNameList {
64 nodebInfo, err := h.rNibDataService.GetNodeb(ranName)
66 _, ok := err.(*common.ResourceNotFoundError)
68 h.logger.Errorf("#HealthCheckRequest.Handle - failed to get nodeBInfo entity for ran name: %v from RNIB. Error: %s", ranName, err)
69 return nil, e2managererrors.NewRnibDbError()
74 if nodebInfo.ConnectionStatus == entities.ConnectionStatus_CONNECTED {
75 isAtleastOneRanConnected = true
77 err := h.sendRICServiceQuery(nodebInfo)
82 oldnbIdentity, newnbIdentity := h.ranListManager.UpdateHealthcheckTimeStampSent(ranName)
83 nodetypeToNbIdentityMapOld[nodebInfo.NodeType] = append(nodetypeToNbIdentityMapOld[nodebInfo.NodeType], oldnbIdentity)
84 nodetypeToNbIdentityMapNew[nodebInfo.NodeType] = append(nodetypeToNbIdentityMapNew[nodebInfo.NodeType], newnbIdentity)
88 for k, _ := range nodetypeToNbIdentityMapOld {
89 err := h.ranListManager.UpdateNbIdentities(k, nodetypeToNbIdentityMapOld[k], nodetypeToNbIdentityMapNew[k])
95 if isAtleastOneRanConnected == false {
96 return nil, e2managererrors.NewNoConnectedRanError()
99 h.logger.Infof("#HealthcheckRequest.Handle - HealthcheckTimeStampSent Update completed to RedisDB")
104 func (h *HealthCheckRequestHandler) sendRICServiceQuery(nodebInfo *entities.NodebInfo) error {
106 serviceQuery := models.NewRicServiceQueryMessage(nodebInfo.GetGnb().RanFunctions)
107 payLoad, err := xml.Marshal(serviceQuery.E2APPDU)
109 h.logger.Errorf("#HealthCHeckRequest.Handle- RAN name: %s - Error marshalling RIC_SERVICE_QUERY. Payload: %s", nodebInfo.RanName, payLoad)
110 //return nil, e2managererrors.NewInternalError()
113 payLoad = utils.ReplaceEmptyTagsWithSelfClosing(payLoad,healthCheckEmptyTagsToReplaceToSelfClosingTags)
116 var msgSrc unsafe.Pointer
117 msg := models.NewRmrMessage(rmrCgo.RIC_SERVICE_QUERY, nodebInfo.RanName, payLoad, xAction, msgSrc)
119 err = h.rmrsender.Send(msg)
122 h.logger.Errorf("#HealthCHeckRequest.Handle - failed to send RIC_SERVICE_QUERY message to RMR for %s. Error: %s", nodebInfo.RanName, err)
123 //return nil, e2managererrors.NewRmrError()
125 h.logger.Infof("#HealthCHeckRequest.Handle - RAN name : %s - Successfully built and sent RIC_SERVICE_QUERY. Message: %x", nodebInfo.RanName, msg)
131 func (h *HealthCheckRequestHandler) getRanNameList(request models.Request) []string {
132 healthCheckRequest := request.(models.HealthCheckRequest)
133 if request != nil && len(healthCheckRequest.RanList) != 0 {
134 return healthCheckRequest.RanList
137 h.logger.Infof("#HealthcheckRequest.getRanNameList - Empty request sent, fetching all connected NbIdentitylist")
139 nodeIds := h.ranListManager.GetNbIdentityList()
140 var ranNameList []string
142 for _, nbIdentity := range nodeIds {
143 if nbIdentity.ConnectionStatus == entities.ConnectionStatus_CONNECTED {
144 ranNameList = append(ranNameList, nbIdentity.InventoryName)