[RICPLT-1852] Supports E2T Initialize + ExecuteSetup + prepare setup request on init
[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/e2pdus"
22         "e2mgr/logger"
23         "e2mgr/rNibWriter"
24         "e2mgr/rnibBuilders"
25         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
26         "sync"
27         "time"
28
29         "e2mgr/models"
30         "e2mgr/rmrCgo"
31         "e2mgr/sessions"
32 )
33
34 type EndcSetupRequestHandler struct {
35         rnibWriterProvider func() rNibWriter.RNibWriter
36 }
37
38 func NewEndcSetupRequestHandler(rnibWriterProvider func() rNibWriter.RNibWriter) *EndcSetupRequestHandler {
39         return &EndcSetupRequestHandler{
40                 rnibWriterProvider: rnibWriterProvider,
41         }
42 }
43
44 func (handler EndcSetupRequestHandler) PreHandle(logger *logger.Logger, details *models.RequestDetails) error {
45         nodebInfo, nodebIdentity := rnibBuilders.CreateInitialNodeInfo(details,entities.E2ApplicationProtocol_ENDC_X2_SETUP_REQUEST)
46
47         rNibErr := handler.rnibWriterProvider().SaveNodeb(nodebIdentity, nodebInfo)
48         if rNibErr != nil {
49                 logger.Errorf("#endc_setup_request_handler.PreHandle - failed to initial nodeb entity for ran name: %v in RNIB. Error: %s", details.RanName, rNibErr.Error())
50         } else {
51                 logger.Infof("#endc_setup_request_handler.PreHandle - initial nodeb entity for ran name: %v was saved to RNIB ", details.RanName)
52         }
53
54         return rNibErr
55 }
56
57 func (EndcSetupRequestHandler) CreateMessage(logger *logger.Logger, requestDetails *models.RequestDetails, messageChannel chan *models.E2RequestMessage, e2sessions sessions.E2Sessions, startTime time.Time, wg sync.WaitGroup) {
58
59         wg.Add(1)
60
61         transactionId := requestDetails.RanName
62         e2sessions[transactionId] = sessions.E2SessionDetails{SessionStart: startTime, Request: requestDetails}
63         setupRequestMessage := models.NewE2RequestMessage(transactionId, requestDetails.RanIp, requestDetails.RanPort, requestDetails.RanName, e2pdus.PackedEndcX2setupRequest)
64
65         logger.Debugf("#endc_setup_request_handler.CreateMessage - PDU: %s", e2pdus.PackedEndcX2setupRequestAsString)
66         logger.Debugf("#endc_setup_request_handler.CreateMessage - setupRequestMessage was created successfuly. setup request details(transactionId = [%s]): %+v", transactionId, setupRequestMessage)
67         messageChannel <- setupRequestMessage
68
69         wg.Done()
70 }
71
72 func (EndcSetupRequestHandler) GetMessageType() int {
73         return rmrCgo.RIC_ENDC_X2_SETUP_REQ
74 }