RSM/handlers/rmrmsghandlers/resource_status_initiate_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 package rmrmsghandlers
  21
  22 import (
  23         "encoding/json"
  24         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
  25         "rsm/configuration"
  26         "rsm/e2pdus"
  27         "rsm/logger"
  28         "rsm/managers"
  29         "rsm/models"
  30 )
  31
  32 type ResourceStatusInitiateNotificationHandler struct {
  33         logger                        *logger.Logger
  34         config                        *configuration.Configuration
  35         resourceStatusInitiateManager managers.IResourceStatusInitiateManager
  36         requestName                   string
  37 }
  38
  39 func NewResourceStatusInitiateNotificationHandler(logger *logger.Logger, config *configuration.Configuration, resourceStatusInitiateManager managers.IResourceStatusInitiateManager, requestName string) ResourceStatusInitiateNotificationHandler {
  40         return ResourceStatusInitiateNotificationHandler{
  41                 logger:                        logger,
  42                 config:                        config,
  43                 resourceStatusInitiateManager: resourceStatusInitiateManager,
  44                 requestName:                   requestName,
  45         }
  46 }
  47
  48 func (h ResourceStatusInitiateNotificationHandler) Handle(request *models.RmrRequest) {
  49         inventoryName := request.RanName
  50         h.logger.Infof("#ResourceStatusInitiateNotificationHandler - RAN name: %s - Received %s notification", inventoryName, h.requestName)
  51
  52         if !isResourceStatusEnabled(h.config) {
  53                 h.logger.Warnf("#ResourceStatusInitiateNotificationHandler - RAN name: %s - resource status is disabled", inventoryName)
  54                 return
  55         }
  56
  57         payload := models.ResourceStatusPayload{}
  58         err := json.Unmarshal(request.Payload, &payload)
  59
  60         if err != nil {
  61                 h.logger.Errorf("#ResourceStatusInitiateNotificationHandler - RAN name: %s - Error unmarshaling RMR request payload: %v", inventoryName, err)
  62                 return
  63         }
  64
  65         h.logger.Infof("#ResourceStatusInitiateNotificationHandler - Unmarshaled payload successfully: %+v", payload)
  66
  67         if payload.NodeType != entities.Node_ENB {
  68                 h.logger.Debugf("#ResourceStatusInitiateNotificationHandler - RAN name: %s, Node type isn't ENB", inventoryName)
  69                 return
  70         }
  71
  72         resourceStatusInitiateRequestParams := &e2pdus.ResourceStatusRequestData{}
  73         populateResourceStatusInitiateRequestParams(resourceStatusInitiateRequestParams, h.config)
  74
  75         _ = h.resourceStatusInitiateManager.Execute(inventoryName, resourceStatusInitiateRequestParams)
  76 }
  77
  78 func isResourceStatusEnabled(configuration *configuration.Configuration) bool {
  79         return configuration.ResourceStatusParams.EnableResourceStatus
  80 }
  81
  82 func populateResourceStatusInitiateRequestParams(params *e2pdus.ResourceStatusRequestData, config *configuration.Configuration) {
  83         params.PartialSuccessAllowed = config.ResourceStatusParams.PartialSuccessAllowed
  84         params.PrbPeriodic = config.ResourceStatusParams.PrbPeriodic
  85         params.TnlLoadIndPeriodic = config.ResourceStatusParams.TnlLoadIndPeriodic
  86         params.HwLoadIndPeriodic = config.ResourceStatusParams.HwLoadIndPeriodic
  87         params.AbsStatusPeriodic = config.ResourceStatusParams.AbsStatusPeriodic
  88         params.RsrpMeasurementPeriodic = config.ResourceStatusParams.RsrpMeasurementPeriodic
  89         params.CsiPeriodic = config.ResourceStatusParams.CsiPeriodic
  90         params.PeriodicityMS = config.ResourceStatusParams.PeriodicityMs
  91         params.PeriodicityRsrpMeasurementMS = config.ResourceStatusParams.PeriodicityRsrpMeasurementMs
  92         params.PeriodicityCsiMS = config.ResourceStatusParams.PeriodicityCsiMs
  93 }