Publish Route only once to the endpoint that requests it. Periodic/Event based distri...

[ric-plt/rtmgr.git] / pkg / sbi / nngpush_test.go

diff --git a/pkg/sbi/nngpush_test.go b/pkg/sbi/nngpush_test.go
index 954dcaa..aae9121 100644 (file)
--- a/pkg/sbi/nngpush_test.go
+++ b/pkg/sbi/nngpush_test.go
@@ -21,12 +21,13 @@
 ==================================================================================
 */
 /*
-       Mnemonic:       nngpush_test.go
+       Mnemonic:       rmrpush_test.go
        Abstract:
        Date:           3 May 2019
 */
 package sbi
 
+
 import (
        //"errors"
        "routing-manager/pkg/rtmgr"
@@ -55,7 +56,7 @@ func TestMain(m *testing.M) {
 /*
 Resets the EndpointList according to argumnets
 */
-func resetTestPushDataset(instance NngPush, testdata []rtmgr.Endpoint) {
+func resetTestPushDataset(instance RmrPush, testdata []rtmgr.Endpoint) {
        rtmgr.Eps = make(map[string]*rtmgr.Endpoint)
        for _, endpoint := range testdata {
                ep := endpoint
@@ -65,101 +66,133 @@ 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) {
+func TestRmrPushAddEndpoint(t *testing.T) {
 //     var err error
-       var nngpush = NngPush{}
-       resetTestPushDataset(nngpush, stub.ValidEndpoints)
-       _ = nngpush.AddEndpoint(rtmgr.Eps["localhost"])
+       var rmrpush = RmrPush{}
+       resetTestPushDataset(rmrpush, stub.ValidEndpoints)
+       _ = rmrpush.AddEndpoint(rtmgr.Eps["localhost"])
 /*     if err != nil {
-               t.Errorf("nngpush.AddEndpoint() return was incorrect, got: %v, want: %v.", 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)
+       var rmrpush = RmrPush{}
+       resetTestPushDataset(rmrpush, stub.ValidEndpoints)
 
-       err = nngpush.DistributeAll(stub.ValidPolicies)
+       rmrcallid = 200
+       err = rmrpush.DistributeAll(stub.ValidPolicies)
        if err != nil {
-               t.Errorf("nngpush.DistributeAll(policies) was incorrect, got: %v, want: %v.", 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)
+func TestRmrPushInitializeandsendPolicies(t *testing.T) {
+        var rmrpush = RmrPush{}
+       resetTestPushDataset(rmrpush, stub.ValidEndpoints)
         policies := []string{"hello","welcome"}
-       nngpush.send(rtmgr.Eps["localhost"],&policies)
+       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{&params}
+       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)
 }