pkg/control/ut_test.go

   1 /*
   2 ==================================================================================
   3   Copyright (c) 2019 AT&T Intellectual Property.
   4   Copyright (c) 2019 Nokia
   5
   6    Licensed under the Apache License, Version 2.0 (the "License");
   7    you may not use this file except in compliance with the License.
   8    You may obtain a copy of the License at
   9
  10        http://www.apache.org/licenses/LICENSE-2.0
  11
  12    Unless required by applicable law or agreed to in writing, software
  13    distributed under the License is distributed on an "AS IS" BASIS,
  14    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15    See the License for the specific language governing permissions and
  16    limitations under the License.
  17 ==================================================================================
  18 */
  19
  20 package control
  21
  22 import (
  23         "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststub"
  24         "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststubdummy"
  25         "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/teststube2ap"
  26         "os"
  27         "testing"
  28 )
  29
  30 //-----------------------------------------------------------------------------
  31 //
  32 //-----------------------------------------------------------------------------
  33 func CaseBegin(desc string) *teststub.TestWrapper {
  34         tent := teststub.NewTestWrapper(desc)
  35         tent.Logger.Info(desc)
  36         return tent
  37 }
  38
  39 //-----------------------------------------------------------------------------
  40 //
  41 //-----------------------------------------------------------------------------
  42
  43 var xappConn1 *teststube2ap.E2Stub
  44 var xappConn2 *teststube2ap.E2Stub
  45 var e2termConn1 *teststube2ap.E2Stub
  46 var e2termConn2 *teststube2ap.E2Stub
  47 var rtmgrHttp *testingHttpRtmgrStub
  48 var mainCtrl *testingSubmgrControl
  49
  50 var dummystub *teststubdummy.RmrDummyStub
  51
  52 func ut_test_init() {
  53         tent := CaseBegin("ut_test_init")
  54
  55         //---------------------------------
  56         //
  57         //---------------------------------
  58         rtmgrHttp = createNewHttpRtmgrStub("RTMGRSTUB", "8989")
  59         go rtmgrHttp.run()
  60
  61         //---------------------------------
  62         //
  63         //---------------------------------
  64
  65         //
  66         //Cfg creation won't work like this as xapp-frame reads it during init.
  67         //
  68         /*
  69             cfgstr:=`{
  70               "local": {
  71                   "host": ":8080"
  72               },
  73               "logger": {
  74                   "level": 4
  75               },
  76               "rmr": {
  77                  "protPort": "tcp:14560",
  78                  "maxSize": 4096,
  79                  "numWorkers": 1,
  80                  "txMessages": ["RIC_SUB_REQ", "RIC_SUB_DEL_REQ"],
  81                  "rxMessages": ["RIC_SUB_RESP", "RIC_SUB_FAILURE", "RIC_SUB_DEL_RESP", "RIC_SUB_DEL_FAILURE", "RIC_INDICATION"]
  82               },
  83               "db": {
  84                   "host": "localhost",
  85                   "port": 6379,
  86                   "namespaces": ["sdl", "rnib"]
  87               },
  88                  "rtmgr" : {
  89                    "HostAddr" : "localhost",
  90                    "port" : "8989",
  91                    "baseUrl" : "/"
  92                  }
  93            `
  94
  95            cfgfilename,_ := testCreateTmpFile(cfgstr)
  96            defer os.Remove(cfgfilename)
  97            os.Setenv("CFG_FILE", cfgfilename)
  98         */
  99         tent.Logger.Info("Using cfg file %s", os.Getenv("CFG_FILE"))
 100
 101         //---------------------------------
 102         // Static routetable for rmr
 103         //
 104         // NOTE: Routing table is configured so, that responses
 105         //       are duplicated to xapp1 and xapp2 instances.
 106         //       If XID is not matching xapp stub will just
 107         //       drop message. (Messages 12011, 12012, 12021, 12022)
 108         //
 109         // NOTE2: 55555 message type is for stub rmr connectivity probing
 110         //
 111         // NOTE3: Ports per entity:
 112         //
 113         // DataPort Entity
 114         // RoutePort (svc) will be DataPort+1
 115         // -------------------
 116         // 14560   submgr
 117         // 15560   e2term1 stub
 118         // 15660   e2term2 stub
 119         // 13560   xapp1 stub
 120         // 13660   xapp2 stub
 121         // 16560   dummy stub
 122         //
 123         //---------------------------------
 124         rt := &teststub.RmrRouteTable{}
 125         rt.AddRoute(12010, "", -1, "localhost:14560")
 126         rt.AddRoute(12010, "localhost:14560", -1, "%meid")
 127         rt.AddRoute(12011, "localhost:15560", -1, "localhost:14560")
 128         rt.AddRoute(12012, "localhost:15560", -1, "localhost:14560")
 129         rt.AddRoute(12011, "localhost:15660", -1, "localhost:14560")
 130         rt.AddRoute(12012, "localhost:15660", -1, "localhost:14560")
 131         rt.AddRoute(12011, "localhost:14560", -1, "localhost:13660;localhost:13560")
 132         rt.AddRoute(12012, "localhost:14560", -1, "localhost:13660;localhost:13560")
 133         rt.AddRoute(12020, "", -1, "localhost:14560")
 134         rt.AddRoute(12020, "localhost:14560", -1, "%meid")
 135         rt.AddRoute(12021, "localhost:15560", -1, "localhost:14560")
 136         rt.AddRoute(12022, "localhost:15560", -1, "localhost:14560")
 137         rt.AddRoute(12021, "localhost:15660", -1, "localhost:14560")
 138         rt.AddRoute(12022, "localhost:15660", -1, "localhost:14560")
 139         rt.AddRoute(12021, "localhost:14560", -1, "localhost:13660;localhost:13560")
 140         rt.AddRoute(12022, "localhost:14560", -1, "localhost:13660;localhost:13560")
 141         rt.AddRoute(55555, "", -1, "localhost:13660;localhost:13560;localhost:15560;localhost:15660;localhost:16560")
 142
 143         rt.AddMeid("localhost:15560", []string{"RAN_NAME_1", "RAN_NAME_2"})
 144         rt.AddMeid("localhost:15660", []string{"RAN_NAME_11", "RAN_NAME_12"})
 145
 146         rtfilename, _ := teststub.CreateTmpFile(rt.GetTable())
 147         defer os.Remove(rtfilename)
 148         tent.Logger.Info("table[%s]", rt.GetTable())
 149         //---------------------------------
 150         //
 151         //---------------------------------
 152         tent.Logger.Info("### submgr ctrl run ###")
 153         mainCtrl = createSubmgrControl(rtfilename, 14560, 0)
 154
 155         //---------------------------------
 156         //
 157         //---------------------------------
 158         tent.Logger.Info("### xapp1 stub run ###")
 159         xappConn1 = teststube2ap.CreateNewE2Stub("xappstub1", rtfilename, 13560, 0, "RMRXAPP1STUB", 55555)
 160
 161         //---------------------------------
 162         //
 163         //---------------------------------
 164         tent.Logger.Info("### xapp2 stub run ###")
 165         xappConn2 = teststube2ap.CreateNewE2Stub("xappstub2", rtfilename, 13660, 0, "RMRXAPP2STUB", 55555)
 166
 167         //---------------------------------
 168         //
 169         //---------------------------------
 170         tent.Logger.Info("### e2term1 stub run ###")
 171         e2termConn1 = teststube2ap.CreateNewE2termStub("e2termstub1", rtfilename, 15560, 0, "RMRE2TERMSTUB1", 55555)
 172
 173         //---------------------------------
 174         //
 175         //---------------------------------
 176         tent.Logger.Info("### e2term2 stub run ###")
 177         e2termConn2 = teststube2ap.CreateNewE2termStub("e2termstub2", rtfilename, 15660, 0, "RMRE2TERMSTUB2", 55555)
 178
 179         //---------------------------------
 180         // Just to test dummy stub
 181         //---------------------------------
 182         tent.Logger.Info("### dummy stub run ###")
 183         dummystub = teststubdummy.CreateNewRmrDummyStub("dummystub", rtfilename, 16560, 0, "DUMMYSTUB", 55555)
 184
 185         //---------------------------------
 186         // Testing message sending
 187         //---------------------------------
 188         if teststub.RmrStubControlWaitAlive(10, 55555, mainCtrl.c) == false {
 189                 os.Exit(1)
 190         }
 191 }
 192
 193 //-----------------------------------------------------------------------------
 194 //
 195 //-----------------------------------------------------------------------------
 196 func TestMain(m *testing.M) {
 197         CaseBegin("TestMain start")
 198         ut_test_init()
 199         code := m.Run()
 200         os.Exit(code)
 201 }