E2Manager/handlers/rmrmsghandlers/e2_term_init_notification_handler.go

   1 //
   2 // Copyright 2019 AT&T Intellectual Property
   3 // Copyright 2019 Nokia
   4 //
   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
   8 //
   9 //      http://www.apache.org/licenses/LICENSE-2.0
  10 //
  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.
  16
  17 //  This source code is part of the near-RT RIC (RAN Intelligent Controller)
  18 //  platform project (RICP).
  19
  20
  21 package rmrmsghandlers
  22
  23 import (
  24         "e2mgr/clients"
  25         "e2mgr/logger"
  26         "e2mgr/managers"
  27         "e2mgr/models"
  28         "e2mgr/services"
  29         "encoding/json"
  30         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
  31         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
  32 )
  33
  34 type E2TermInitNotificationHandler struct {
  35         logger                 *logger.Logger
  36         rnibDataService        services.RNibDataService
  37         ranReconnectionManager *managers.RanReconnectionManager
  38         e2tInstancesManager    managers.IE2TInstancesManager
  39         routingManagerClient   clients.IRoutingManagerClient
  40 }
  41
  42 func NewE2TermInitNotificationHandler(logger *logger.Logger, ranReconnectionManager *managers.RanReconnectionManager, rnibDataService services.RNibDataService, e2tInstancesManager managers.IE2TInstancesManager, routingManagerClient clients.IRoutingManagerClient) E2TermInitNotificationHandler {
  43         return E2TermInitNotificationHandler{
  44                 logger:                 logger,
  45                 rnibDataService:        rnibDataService,
  46                 ranReconnectionManager: ranReconnectionManager,
  47                 e2tInstancesManager:    e2tInstancesManager,
  48                 routingManagerClient:   routingManagerClient,
  49         }
  50 }
  51
  52 func (h E2TermInitNotificationHandler) Handle(request *models.NotificationRequest) {
  53         unmarshalledPayload := models.E2TermInitPayload{}
  54         err := json.Unmarshal(request.Payload, &unmarshalledPayload)
  55
  56         if err != nil {
  57                 h.logger.Errorf("#E2TermInitNotificationHandler.Handle - Error unmarshaling E2 Term Init payload: %s", err)
  58                 return
  59         }
  60
  61         e2tAddress := unmarshalledPayload.Address
  62
  63         if len(e2tAddress) == 0 {
  64                 h.logger.Errorf("#E2TermInitNotificationHandler.Handle - Empty E2T address received")
  65                 return
  66         }
  67
  68         h.logger.Infof("#E2TermInitNotificationHandler.Handle - E2T address: %s - handling E2_TERM_INIT", e2tAddress)
  69
  70         e2tInstance, err := h.e2tInstancesManager.GetE2TInstance(e2tAddress)
  71
  72         if err != nil {
  73                 _, ok := err.(*common.ResourceNotFoundError)
  74
  75                 if !ok {
  76                         h.logger.Errorf("#E2TermInitNotificationHandler.Handle - Failed retrieving E2TInstance. error: %s", err)
  77                         return
  78                 }
  79
  80                 h.HandleNewE2TInstance(e2tAddress)
  81                 return
  82         }
  83
  84         if len(e2tInstance.AssociatedRanList) == 0 {
  85                 h.logger.Infof("#E2TermInitNotificationHandler.Handle - E2T Address: %s - E2T instance has no associated RANs", e2tInstance.Address)
  86                 return
  87         }
  88
  89         if e2tInstance.State == entities.ToBeDeleted{
  90                 h.logger.Infof("#E2TermInitNotificationHandler.Handle - E2T Address: %s - E2T instance status is: %s, ignore", e2tInstance.Address, e2tInstance.State)
  91                 return
  92         }
  93
  94         if e2tInstance.State == entities.RoutingManagerFailure {
  95                 err := h.e2tInstancesManager.ActivateE2TInstance(e2tInstance)
  96                 if err != nil {
  97                         return
  98                 }
  99         }
 100
 101         h.HandleExistingE2TInstance(e2tInstance)
 102
 103         h.logger.Infof("#E2TermInitNotificationHandler.Handle - Completed handling of E2_TERM_INIT")
 104 }
 105
 106 func (h E2TermInitNotificationHandler) HandleExistingE2TInstance(e2tInstance *entities.E2TInstance) {
 107
 108         for _, ranName := range e2tInstance.AssociatedRanList {
 109
 110                 if err := h.ranReconnectionManager.ReconnectRan(ranName); err != nil {
 111                         h.logger.Errorf("#E2TermInitNotificationHandler.HandleExistingE2TInstance - Ran name: %s - connection attempt failure, error: %s", ranName, err)
 112                         _, ok := err.(*common.ResourceNotFoundError)
 113                         if !ok {
 114                                 break
 115                         }
 116                 }
 117         }
 118 }
 119
 120 func (h E2TermInitNotificationHandler) HandleNewE2TInstance(e2tAddress string) {
 121
 122         err := h.routingManagerClient.AddE2TInstance(e2tAddress)
 123
 124         if err != nil{
 125                 h.logger.Errorf("#E2TermInitNotificationHandler.HandleNewE2TInstance - e2t address: %s - routing manager failure", e2tAddress)
 126                 return
 127         }
 128
 129         _ = h.e2tInstancesManager.AddE2TInstance(e2tAddress)
 130 }