Code Review / ric-plt / rtmgr.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | review | tree
raw | inline | side by side
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 422a036..aae9121 100644 (file)
--- a/pkg/sbi/nngpush_test.go
+++ b/pkg/sbi/nngpush_test.go
@@ -14,211 +14,185 @@
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
+
+   This source code is part of the near-RT RIC (RAN Intelligent Controller)
+   platform project (RICP).
+
 ==================================================================================
 */
 /*
 ==================================================================================
 */
 /*
-       Mnemonic:       nngpush_test.go
+       Mnemonic:       rmrpush_test.go
        Abstract:
        Date:           3 May 2019
 */
 package sbi
 
        Abstract:
        Date:           3 May 2019
 */
 package sbi
 
+
 import (
 import (
-       "errors"
+       //"errors"
        "routing-manager/pkg/rtmgr"
        "routing-manager/pkg/stub"
        "routing-manager/pkg/rtmgr"
        "routing-manager/pkg/stub"
+       "time"
+       "os"
+       "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
        "testing"
 )
 
        "testing"
 )
 
-/*
-Returns an error free Socket instance
-*/
-func createNewStubPushSocket() (NngSocket, error) {
-       socket := stub.MangosSocket{}
-       return socket, nil
-}
+type Consumer struct{}
 
 
-/*
-Returns a SocketError
-*/
-func createNewStubPushSocketError() (NngSocket, error) {
-       return nil, errors.New("stub generated Create Socket error")
+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 Close()
-*/
-func createNewStubPushSocketCloseError() (NngSocket, error) {
-       socket := stub.MangosSocket{}
-       socket.GenerateSocketCloseError = true
-       return socket, nil
-}
-
-/*
-Returns a Socket which always generates error on Send()
-*/
-func createNewStubPushSocketSendError() (NngSocket, error) {
-       socket := stub.MangosSocket{}
-       socket.GenerateSocketSendError = true
-       return socket, 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
 */
 }
 
 /*
 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
        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
        }
 }
 
 /*
                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 {
        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{}
-       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")
-       }
+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 Socket creating error case
+rmrpush.DistributeAll() is tested for happy path case
 */
 */
-func TestNngPushAddEndpointWithSocketError(t *testing.T) {
+func TestRmrPushDistributeAll(t *testing.T) {
        var err error
        var err error
-       var nngpush = NngPush{}
-       nngpush.NewSocket = createNewStubPushSocketError
-       resetTestPushDataset(nngpush, stub.ValidEndpoints)
+       var rmrpush = RmrPush{}
+       resetTestPushDataset(rmrpush, 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)
+       rmrcallid = 200
+       err = rmrpush.DistributeAll(stub.ValidPolicies)
+       if err != nil {
+               t.Errorf("rmrpush.DistributeAll(policies) was incorrect, got: %v, want: %v.", err, "nil")
        }
 }
 
 /*
        }
 }
 
 /*
-nngpush.AddEndpoint() is tested for Dialing error case
+rmrpush.DistributeToEp() is tested for Sending case
 */
 */
-func TestNngPushAddEndpointWithSocketDialError(t *testing.T) {
+func TestDistributeToEp(t *testing.T) {
        var err error
        var err error
-       var nngpush = NngPush{}
-       nngpush.NewSocket = createNewStubPushSocketDialError
-       resetTestPushDataset(nngpush, stub.ValidEndpoints)
+       var rmrpush = RmrPush{}
+       resetTestPushDataset(rmrpush, 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")
+       rmrdynamiccallid = 255
+       err = rmrpush.DistributeToEp(stub.ValidPolicies,"localhost:4561",100)
+       if err != nil {
+               t.Errorf("rmrpush.DistributetoEp(policies) was incorrect, got: %v, want: %v.", err, "nil")
        }
 }
 
        }
 }
 
-/*
-nngpush.DistributeAll() is tested for happy path case
-*/
-func TestNngPushDistributeAll(t *testing.T) {
+func TestDeleteEndpoint(t *testing.T) {
        var err error
        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.DeleteEndpoint(rtmgr.Eps["localhost"])
        if err != nil {
        if err != nil {
-               t.Errorf("nngpush.DistributeAll(policies) 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 rmrpush = RmrPush{}
+       resetTestPushDataset(rmrpush, stub.ValidEndpoints1)
+       rmrpush.CreateEndpoint("Src=127.0.0.1:4561 hello")
+}
 /*
 /*
-nngpush.DistributeAll() is tested for Sending error case
+Initialize and send policies
 */
 */
-func TestNngPushDistributeAllSocketSendError(t *testing.T) {
-       var err error
-       var nngpush = NngPush{}
-       nngpush.NewSocket = createNewStubPushSocketSendError
-       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")
-       }
+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 TestNngPushDeleteEndpoint(t *testing.T) {
-       var err error
-       var nngpush = NngPush{}
-       nngpush.NewSocket = createNewStubPushSocket
-       resetTestPushDataset(nngpush, stub.ValidEndpoints)
+func TestString( t *testing.T) {
+       var params xapp.RMRParams
+       params.Payload = []byte("abcdefgh")
+       params.Meid = &xapp.RMRMeid{}
+       msg := RMRParams{&params}
+       msg.String()
 
 
-       err = nngpush.DeleteEndpoint(rtmgr.Eps["10.0.0.1:0"])
-       if err != nil {
-               t.Errorf("nngpush.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)
+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)
+}
 
 
-       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 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)
 }
 }
Routing Manager (ric-plt/rtmgr) is a basic RIC platform service, responsible for generating and distributing routing policies to xApps.