LF RNIB Adaptation
Change-Id: Ibfddb7688559c77803a5df025c5bbdbcf1ce2e8d
Signed-off-by: Mohamed Abukar <abukar.mohamed@nokia.com>
diff --git a/pkg/xapp/xapp_test.go b/pkg/xapp/xapp_test.go
index 06345af..84a910f 100755
--- a/pkg/xapp/xapp_test.go
+++ b/pkg/xapp/xapp_test.go
@@ -32,7 +32,7 @@
type Consumer struct {
}
-func (m Consumer) Consume(mtype, sid, len int, payload []byte) (err error) {
+func (m Consumer) Consume(mtype, sid int, payload []byte, meid *RMRMeid) (err error) {
Sdl.Store("myKey", payload)
return nil
}
@@ -100,7 +100,7 @@
func TestMessagesReceivedSuccessfully(t *testing.T) {
for i := 0; i < 100; i++ {
- Rmr.Send(10004, 1111, 100, []byte{1, 2, 3, 4, 5, 6})
+ Rmr.Send(10004, 1111, []byte{1, 2, 3, 4, 5, 6}, &RMRMeid{PlmnID: "1234", EnbID: "7788"})
}
// Allow time to process the messages
@@ -132,16 +132,6 @@
}
}
-func TestGetgNBList(t *testing.T) {
- Rnib.Store("Kiikale", "Hello")
- Rnib.Store("mykey", "myval")
-
- v, _ := Rnib.GetgNBList()
- if v["Kiikale"] != "Hello" || v["mykey"] != "myval" {
- t.Errorf("Error: GetgNBList failed!")
- }
-}
-
func TestSubscribeChannels(t *testing.T) {
var NotificationCb = func(ch string, events ...string) {
if ch != "channel1" {
@@ -166,7 +156,7 @@
}
name := Rmr.GetRicMessageName(12010)
- if name != "RIC_SUB_REQ" {
+ if name != "RIC_SUB_REQ" {
t.Errorf("Error: GetRicMessageName failed: name=%s", name)
}
}
@@ -178,14 +168,13 @@
}
name := Rmr.GetRicMessageName(123456)
- if name != "" {
+ if name != "" {
t.Errorf("Error: GetRicMessageName returned invalid value: name=%s", name)
}
}
func TestTeardown(t *testing.T) {
Sdl.Clear()
- Rnib.Clear()
}
// Helper functions
@@ -209,4 +198,4 @@
response := executeRequest(req)
return response.Body.String()
-}
\ No newline at end of file
+}