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