RSM/handlers/rmrmsghandlers/resource_status_response_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         "rsm/converters"
  25         "rsm/e2pdus"
  26         "rsm/logger"
  27         "rsm/models"
  28         "rsm/services"
  29 )
  30
  31 type ResourceStatusResponseHandler struct {
  32         logger          *logger.Logger
  33         rnibDataService services.RNibDataService
  34         converter       converters.IResourceStatusResponseConverter
  35 }
  36
  37 func NewResourceStatusResponseHandler(logger *logger.Logger, converter converters.IResourceStatusResponseConverter, rnibDataService services.RNibDataService) ResourceStatusResponseHandler {
  38         return ResourceStatusResponseHandler{
  39                 logger:          logger,
  40                 converter:       converter,
  41                 rnibDataService: rnibDataService,
  42         }
  43 }
  44
  45 func (h ResourceStatusResponseHandler) Handle(request *models.RmrRequest) {
  46         h.logger.Infof("#ResourceStatusResponseHandler.Handle - RAN name: %s - Received resource status response notification", request.RanName)
  47
  48         if h.logger.DebugEnabled() {
  49                 pduAsString, err := h.converter.UnpackX2apPduAsString(request.Payload, e2pdus.MaxAsn1CodecMessageBufferSize)
  50                 if err != nil {
  51                         h.logger.Errorf("#ResourceStatusResponseHandler.Handle - RAN name: %s - unpack failed. Error: %v", request.RanName, err)
  52                         return
  53                 }
  54                 h.logger.Debugf("#ResourceStatusResponseHandler.Handle - RAN name: %s - pdu: %s", request.RanName, pduAsString)
  55         }
  56
  57         response, err := h.converter.Convert(request.Payload)
  58
  59         if err != nil {
  60                 h.logger.Errorf("#ResourceStatusResponseHandler.Handle - RAN name: %s - unpack failed. Error: %v", request.RanName, err)
  61                 return
  62         }
  63
  64         if response.ENB2_Measurement_ID == 0 {
  65                 h.logger.Errorf("#ResourceStatusResponseHandler.Handle - RAN name: %s - ignoring response without ENB2_Measurement_ID", request.RanName)
  66                 return
  67         }
  68
  69         h.logger.Infof("#ResourceStatusResponseHandler.Handle - RAN name: %s - (success) ENB1_Measurement_ID: %d, ENB2_Measurement_ID: %d",
  70                 request.RanName,
  71                 response.ENB1_Measurement_ID,
  72                 response.ENB2_Measurement_ID)
  73
  74         rsmRanInfo, err := h.rnibDataService.GetRsmRanInfo(request.RanName)
  75
  76         if err != nil {
  77                 return
  78         }
  79
  80         rsmRanInfo.Enb2MeasurementId = response.ENB2_Measurement_ID
  81         rsmRanInfo.ActionStatus = true
  82
  83         err = h.rnibDataService.SaveRsmRanInfo(rsmRanInfo)
  84
  85         if err != nil {
  86                 return
  87         }
  88
  89         h.logger.Infof("#ResourceStatusResponseHandler.Handle - RAN name: %s - Successfully updated RsmRanInfo", request.RanName)
  90 }