X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fsbi%2Fnngpush_test.go;h=79821eb8672c742c0a64c32031e34878378ec79c;hb=refs%2Fchanges%2F51%2F4551%2F1;hp=d7a65726ae4f9044c8e30b7da72bc89154e27573;hpb=761934a3d9f7a1426d1e14e34fb9a4c16599a237;p=ric-plt%2Frtmgr.git

diff --git a/pkg/sbi/nngpush_test.go b/pkg/sbi/nngpush_test.go
index d7a6572..79821eb 100644
--- a/pkg/sbi/nngpush_test.go
+++ b/pkg/sbi/nngpush_test.go
@@ -21,208 +21,145 @@
 ==================================================================================
 */
 /*
-	Mnemonic:	nngpush_test.go
+	Mnemonic:	rmrpush_test.go
 	Abstract:
 	Date:		3 May 2019
 */
 package sbi
 
 import (
-	"errors"
+	//"errors"
 	"routing-manager/pkg/rtmgr"
 	"routing-manager/pkg/stub"
+	"time"
+	"os"
+	"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
 	"testing"
 )
 
-/*
-Returns an error free Socket instance
-*/
-func createNewStubPushSocket() (NngSocket, error) {
-	socket := stub.MangosSocket{}
-	return socket, nil
-}
-
-/*
-Returns a SocketError
-*/
-func createNewStubPushSocketError() (NngSocket, error) {
-	return nil, errors.New("stub generated Create Socket error")
-}
-
-/*
-Returns a Socket which always generates error on Close()
-*/
-func createNewStubPushSocketCloseError() (NngSocket, error) {
-	socket := stub.MangosSocket{}
-	socket.GenerateSocketCloseError = true
-	return socket, nil
-}
+type Consumer struct{}
 
-/*
-Returns a Socket which always generates error on Send()
-*/
-func createNewStubPushSocketSendError() (NngSocket, error) {
-	socket := stub.MangosSocket{}
-	socket.GenerateSocketSendError = true
-	return socket, nil
+func (m Consumer) Consume(params *xapp.RMRParams) (err error) {
+        xapp.Sdl.Store("myKey", params.Payload)
+        return nil
 }
 
-/*
-Returns a Socket which always generates error on Dial()
-*/
-func createNewStubPushSocketDialError() (NngSocket, error) {
-	socket := stub.MangosSocket{}
-	socket.GenerateSocketDialError = true
-	return socket, 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)
 }
 
 /*
 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
-		ep.Socket, _ = instance.NewSocket()
+		//ep.Socket, _ = instance.NewSocket()
 		rtmgr.Eps[ep.Uuid] = &ep
 	}
 }
 
 /*
-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{}
-	nngpush.NewSocket = createNewStubPushSocket
+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{}
-	nngpush.NewSocket = createNewStubPushSocket
+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{}
-	nngpush.NewSocket = createNewStubPushSocket
-	rtmgr.Eps = make(rtmgr.Endpoints)
+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")
-	}
-}
-
-/*
-nngpush.AddEndpoint() is tested for happy path case
-*/
-func TestNngPushAddEndpoint(t *testing.T) {
-	var err error
-	var nngpush = NngPush{}
-	nngpush.NewSocket = createNewStubPushSocket
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
-
-	err = nngpush.AddEndpoint(rtmgr.Eps["10.0.0.1:0"])
-	if err != nil {
-		t.Errorf("nngpush.AddEndpoint() return was incorrect, got: %v, want: %v.", err, "nil")
-	}
-	if rtmgr.Eps["10.0.0.1:0"].Socket == nil {
-		t.Errorf("nngpush.AddEndpoint() was incorrect, got: %v, want: %v.", nil, "Socket")
+		t.Errorf("rmrpush.UpdateEndpoints() result was incorrect, got: %v, want: %v.", nil, "rtmgr.Endpoints")
 	}
 }
 
 /*
-nngpush.AddEndpoint() is tested for Socket creating error case
+rmrpush.AddEndpoint() is tested for happy path case
 */
-func TestNngPushAddEndpointWithSocketError(t *testing.T) {
-	var err error
-	var nngpush = NngPush{}
-	nngpush.NewSocket = createNewStubPushSocketError
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
-
-	err = nngpush.AddEndpoint(rtmgr.Eps["10.0.0.1:0"])
-	if err == nil {
-		t.Errorf("nngpush.AddEndpoint() was incorrect, got: %v, want: %v.", nil, "error")
-	}
-	if rtmgr.Eps["10.0.0.1:0"].Socket != nil {
-		t.Errorf("nngpush.AddEndpoint() was incorrect, got: %v, want: %v.", rtmgr.Eps["10.0.0.1:0"].Socket, 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.AddEndpoint() is tested for Dialing error case
-*/
-func TestNngPushAddEndpointWithSocketDialError(t *testing.T) {
-	var err error
-	var nngpush = NngPush{}
-	nngpush.NewSocket = createNewStubPushSocketDialError
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
-
-	err = nngpush.AddEndpoint(rtmgr.Eps["10.0.0.1:0"])
-	if err == nil {
-		t.Errorf("nngpush.AddEndpoint() was incorrect, got: %v, want: %v.", nil, "error")
-	}
-}
 
 /*
-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{}
-	nngpush.NewSocket = createNewStubPushSocket
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
+	var rmrpush = RmrPush{}
+	resetTestPushDataset(rmrpush, stub.ValidEndpoints)
 
-	err = nngpush.DistributeAll(stub.ValidPolicies)
+	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.DistributeAll() is tested for Sending error case
+rmrpush.DistributeToEp() is tested for Sending case
 */
-func TestNngPushDistributeAllSocketSendError(t *testing.T) {
+func TestDistributeToEp(t *testing.T) {
 	var err error
-	var nngpush = NngPush{}
-	nngpush.NewSocket = createNewStubPushSocketSendError
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
+	var rmrpush = RmrPush{}
+	resetTestPushDataset(rmrpush, stub.ValidEndpoints)
 
-	err = nngpush.DistributeAll(stub.ValidPolicies)
+	err = rmrpush.DistributeToEp(stub.ValidPolicies,"localhost:4561",100)
 	if err != nil {
-		t.Errorf("nngpush.DistributeAll(policies) was incorrect, got: %v, want: %v.", err, "nil")
+		t.Errorf("rmrpush.DistributetoEp(policies) was incorrect, got: %v, want: %v.", err, "nil")
 	}
 }
 
-func TestNngPushDeleteEndpoint(t *testing.T) {
+func TestDeleteEndpoint(t *testing.T) {
 	var err error
-	var nngpush = NngPush{}
-	nngpush.NewSocket = createNewStubPushSocket
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
+	var rmrpush = RmrPush{}
+	resetTestPushDataset(rmrpush, stub.ValidEndpoints)
 
-	err = nngpush.DeleteEndpoint(rtmgr.Eps["10.0.0.1:0"])
+	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 TestNngPushDeleteEndpointWithSocketCloseError(t *testing.T) {
-	var err error
-	var nngpush = NngPush{}
-	nngpush.NewSocket = createNewStubPushSocketCloseError
-	resetTestPushDataset(nngpush, stub.ValidEndpoints)
-
-	err = nngpush.DeleteEndpoint(rtmgr.Eps["10.1.1.1:0"])
-	if err == nil {
-		t.Errorf("nngpush.DeleteEndpoint() was incorrect, got: %v, want: %v.", nil, "error")
-	}
+func TestCreateEndpoint(t *testing.T) {
+	var rmrpush = RmrPush{}
+	resetTestPushDataset(rmrpush, stub.ValidEndpoints1)
+	rmrpush.CreateEndpoint("192.168.0.1:0","Src=192.168.0.1:4561")
+	rmrpush.CreateEndpoint("localhost:4560","Src=192.168.11.1:4444")
+}
+/*
+Initialize and send 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)
 }