E2Manager/handlers/endc_setup_request_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
  18 package handlers
  19
  20 import (
  21         "e2mgr/logger"
  22         "e2mgr/rNibWriter"
  23         "e2mgr/rnibBuilders"
  24         "sync"
  25         "time"
  26
  27         "e2mgr/models"
  28         "e2mgr/rmrCgo"
  29         "e2mgr/sessions"
  30 )
  31
  32 type EndcSetupRequestHandler struct {
  33         rnibWriterProvider func() rNibWriter.RNibWriter
  34 }
  35
  36 func NewEndcSetupRequestHandler(rnibWriterProvider func() rNibWriter.RNibWriter) *EndcSetupRequestHandler {
  37         return &EndcSetupRequestHandler{
  38                 rnibWriterProvider: rnibWriterProvider,
  39         }
  40 }
  41
  42 func (handler EndcSetupRequestHandler) PreHandle(logger *logger.Logger, details *models.RequestDetails) error {
  43         nodebInfo, nodebIdentity := rnibBuilders.CreateInitialNodeInfo(details)
  44
  45         rNibErr := handler.rnibWriterProvider().SaveNodeb(nodebIdentity, nodebInfo)
  46         if rNibErr != nil {
  47                 logger.Errorf("#endc_setup_request_handler.PreHandle - failed to initial nodeb entity for ran name: %v in RNIB. Error: %s", details.RanName, rNibErr.Error())
  48         } else {
  49                 logger.Infof("#endc_setup_request_handler.PreHandle - initial nodeb entity for ran name: %v was saved to RNIB ", details.RanName)
  50         }
  51
  52         return rNibErr
  53 }
  54
  55 func (EndcSetupRequestHandler) CreateMessage(logger *logger.Logger, requestDetails *models.RequestDetails, messageChannel chan *models.E2RequestMessage, e2sessions sessions.E2Sessions, startTime time.Time, wg sync.WaitGroup) {
  56
  57         wg.Add(1)
  58
  59          payload, err := packEndcX2apSetupRequest(logger, MaxAsn1CodecAllocationBufferSize /*allocation buffer*/, MaxAsn1PackedBufferSize /*max packed buffer*/, MaxAsn1CodecMessageBufferSize /*max message buffer*/, pLMNId[:], eNBId[:], eNBIdBitqty)
  60         if err != nil {
  61                 logger.Errorf("#endc_setup_request_handler.CreateMessage - pack was failed. Error: %v", err)
  62         } else {
  63                 transactionId := requestDetails.RanName
  64                 e2sessions[transactionId] = sessions.E2SessionDetails{SessionStart: startTime, Request: requestDetails}
  65                 setupRequestMessage := models.NewE2RequestMessage(transactionId, requestDetails.RanIp, requestDetails.RanPort, requestDetails.RanName, payload)
  66
  67                 logger.Debugf("#endc_setup_request_handler.CreateMessage - setupRequestMessage was created successfuly. setup request details(transactionId = [%s]): %+v", transactionId, setupRequestMessage)
  68                 messageChannel <- setupRequestMessage
  69         }
  70
  71         wg.Done()
  72 }
  73
  74 func (EndcSetupRequestHandler) GetMessageType() int {
  75         return rmrCgo.RIC_ENDC_X2_SETUP_REQ
  76 }