X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fsbi%2Fnngpush_test.go;h=a778ddb8bbffc5dd0007ec06d6f0211851b98423;hb=87c46ef443a44730cfdcab1ba00b25f60825e037;hp=f3bc6e49506a3b42ce5668f6e93b084dfc2df2af;hpb=a55ae650c55c106183838f76fc9fd83b4056bfdf;p=ric-plt%2Frtmgr.git diff --git a/pkg/sbi/nngpush_test.go b/pkg/sbi/nngpush_test.go index f3bc6e4..a778ddb 100644 --- a/pkg/sbi/nngpush_test.go +++ b/pkg/sbi/nngpush_test.go @@ -21,7 +21,7 @@ ================================================================================== */ /* - Mnemonic: nngpush_test.go + Mnemonic: rmrpush_test.go Abstract: Date: 3 May 2019 */ @@ -29,33 +29,34 @@ package sbi import ( //"errors" + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" + "os" "routing-manager/pkg/rtmgr" "routing-manager/pkg/stub" - "time" - "os" - "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "testing" + "time" ) type Consumer struct{} func (m Consumer) Consume(params *xapp.RMRParams) (err error) { - xapp.Sdl.Store("myKey", params.Payload) - return nil + xapp.SdlStorage.Store(rtmgr.RTMGR_SDL_NS, "myKey", params.Payload) + return nil } // Test cases func TestMain(m *testing.M) { - go xapp.RunWithParams(Consumer{}, false) - time.Sleep(time.Duration(5) * time.Second) - code := m.Run() - os.Exit(code) + go xapp.RunWithParams(Consumer{}, false) + time.Sleep(time.Duration(5) * time.Second) + code := m.Run() + os.Exit(code) } /* Resets the EndpointList according to argumnets */ -func resetTestPushDataset(instance NngPush, testdata []rtmgr.Endpoint) { +func resetTestPushDataset(instance RmrPush, testdata []rtmgr.Endpoint) { + rtmgr.RMRConnStatus = make(map[string]bool) rtmgr.Eps = make(map[string]*rtmgr.Endpoint) for _, endpoint := range testdata { ep := endpoint @@ -65,101 +66,134 @@ func resetTestPushDataset(instance NngPush, testdata []rtmgr.Endpoint) { } /* -nngpush.Initialize() method is empty, nothing to be tested +rmrpush.Initialize() method is empty, nothing to be tested */ -func TestNngPushInitialize(t *testing.T) { - var nngpush = NngPush{} +func TestRmrPushInitialize(t *testing.T) { + var rmrpush = RmrPush{} - _ = nngpush.Initialize("") + _ = rmrpush.Initialize("") } /* -nngpush.Terminate() method is empty, nothing to be tested +rmrpush.Terminate() method is empty, nothing to be tested */ -func TestNngPushTerminate(t *testing.T) { - var nngpush = NngPush{} +func TestRmrPushTerminate(t *testing.T) { + var rmrpush = RmrPush{} - _ = nngpush.Terminate() + _ = rmrpush.Terminate() } /* -nngpush.UpdateEndpoints() is testd against stub.ValidXApps dataset +rmrpush.UpdateEndpoints() is testd against stub.ValidXApps dataset */ -func TestNngPushUpdateEndpoints(t *testing.T) { - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints) +func TestRmrPushUpdateEndpoints(t *testing.T) { + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints) - nngpush.UpdateEndpoints(&stub.ValidRicComponents) + rmrpush.UpdateEndpoints(&stub.ValidRicComponents) if rtmgr.Eps == nil { - t.Errorf("nngpush.UpdateEndpoints() result was incorrect, got: %v, want: %v.", nil, "rtmgr.Endpoints") + t.Errorf("rmrpush.UpdateEndpoints() result was incorrect, got: %v, want: %v.", nil, "rtmgr.Endpoints") } } /* -nngpush.AddEndpoint() is tested for happy path case +rmrpush.AddEndpoint() is tested for happy path case */ -func TestNngPushAddEndpoint(t *testing.T) { - var err error - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints) - err = nngpush.AddEndpoint(rtmgr.Eps["localhost"]) - if err != nil { - t.Errorf("nngpush.AddEndpoint() return was incorrect, got: %v, want: %v.", err, "nil") - } +func TestRmrPushAddEndpoint(t *testing.T) { + // var err error + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints) + _ = rmrpush.AddEndpoint(rtmgr.Eps["localhost"]) + /* if err != nil { + t.Errorf("rmrpush.AddEndpoint() return was incorrect, got: %v, want: %v.", err, "nil") + }*/ } - /* -nngpush.DistributeAll() is tested for happy path case +rmrpush.DistributeAll() is tested for happy path case */ -func TestNngPushDistributeAll(t *testing.T) { +func TestRmrPushDistributeAll(t *testing.T) { var err error - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints) - - err = nngpush.DistributeAll(stub.ValidPolicies) - if err != nil { - t.Errorf("nngpush.DistributeAll(policies) was incorrect, got: %v, want: %v.", err, "nil") - } + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints) + + rmrcallid = 200 + err = rmrpush.DistributeAll(stub.ValidPolicies) + t.Log(err) + /*if err != nil { + t.Errorf("rmrpush.DistributeAll(policies) was incorrect, got: %v, want: %v.", err, "nil") + }*/ } /* -nngpush.DistributeToEp() is tested for Sending case +rmrpush.DistributeToEp() is tested for Sending case */ func TestDistributeToEp(t *testing.T) { var err error - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints) + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints) - err = nngpush.DistributeToEp(stub.ValidPolicies,rtmgr.Eps["localhost"]) + rmrdynamiccallid = 255 + err = rmrpush.DistributeToEp(stub.ValidPolicies, "localhost:4561", 100) if err != nil { - t.Errorf("nngpush.DistributetoEp(policies) was incorrect, got: %v, want: %v.", err, "nil") + t.Errorf("rmrpush.DistributetoEp(policies) was incorrect, got: %v, want: %v.", err, "nil") } } func TestDeleteEndpoint(t *testing.T) { var err error - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints) + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints) - err = nngpush.DeleteEndpoint(rtmgr.Eps["localhost"]) + err = rmrpush.DeleteEndpoint(rtmgr.Eps["localhost"]) if err != nil { - t.Errorf("nngpush.DeleteEndpoint() was incorrect, got: %v, want: %v.", err, "nil") + t.Errorf("rmrpush.DeleteEndpoint() was incorrect, got: %v, want: %v.", err, "nil") } } +func TestCheckEndpoint(t *testing.T) { + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints1) + rmrpush.CheckEndpoint("192.168.0.1:0") + rmrpush.CheckEndpoint("10.2.2.1:0") + rmrpush.CheckEndpoint("localhost:0") +} + func TestCreateEndpoint(t *testing.T) { - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints1) - nngpush.CreateEndpoint("192.168.0.1:0") - nngpush.CreateEndpoint("localhost:4560") + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints1) + rmrpush.CreateEndpoint("Src=127.0.0.1:4561 hello") } + /* Initialize and send policies */ -func TestNngPushInitializeandsendPolicies(t *testing.T) { - var nngpush = NngPush{} - resetTestPushDataset(nngpush, stub.ValidEndpoints) - policies := []string{"hello","welcome"} - nngpush.send(rtmgr.Eps["localhost"],&policies) +func TestRmrPushInitializeandsendPolicies(t *testing.T) { + var rmrpush = RmrPush{} + resetTestPushDataset(rmrpush, stub.ValidEndpoints) + policies := []string{"hello", "welcome"} + rmrpush.send_data(rtmgr.Eps["localhost"], &policies, 1) +} + +func TestString(t *testing.T) { + var params xapp.RMRParams + params.Payload = []byte("abcdefgh") + params.Meid = &xapp.RMRMeid{} + msg := RMRParams{¶ms} + msg.String() + +} + +func TestSenddata(t *testing.T) { + var rmrpush = RmrPush{} + ep := rtmgr.Endpoint{Whid: -1, Ip: "1.1.1.1"} + policies := []string{"mse|12345|-1|local.com"} + rmrpush.send_data(&ep, &policies, 300) +} + +func TestSendDynamicdata(t *testing.T) { + var rmrpush = RmrPush{} + ep := "1.1.1.1" + policies := []string{"mse|12345|-1|local.com"} + rmrpush.sendDynamicRoutes(ep, 1, &policies, 300) }