push code back with legal issues fix
[ric-plt/e2mgr.git] / 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 }