Support for subscription callback

[ric-plt/xapp-frame.git] / pkg / xapp / xapp_test.go

diff --git a/pkg/xapp/xapp_test.go b/pkg/xapp/xapp_test.go
index e52c3ee..9696e6e 100755 (executable)
--- a/pkg/xapp/xapp_test.go
+++ b/pkg/xapp/xapp_test.go
@@ -190,44 +190,44 @@ func TestMessagesReceivedSuccessfullyUsingWh(t *testing.T) {
 }
 
 func TestMessagesReceivedSuccessfullyUsingWhCall(t *testing.T) {
-        time.Sleep(time.Duration(5) * time.Second)
-        whid := Rmr.Openwh("localhost:4560")
-                params := &RMRParams{}
-                params.Payload = []byte("newrt|start\nnewrt|end\n")
-                params.Whid = int(whid)
-               params.Callid = 4
-               params.Timeout = 1000
-               Rmr.SendCallMsg(params)
+       time.Sleep(time.Duration(5) * time.Second)
+       whid := Rmr.Openwh("localhost:4560")
+       params := &RMRParams{}
+       params.Payload = []byte("newrt|start\nnewrt|end\n")
+       params.Whid = int(whid)
+       params.Callid = 4
+       params.Timeout = 1000
+       Rmr.SendCallMsg(params)
 
        // Allow time to process the messages
        time.Sleep(time.Duration(2) * time.Second)
 
-        waitForSdl := viper.GetBool("db.waitForSdl")
-        stats := getMetrics(t)
-        if !strings.Contains(stats, "ricxapp_RMR_Transmitted 200") {
-                t.Errorf("Error: ricxapp_RMR_Transmitted value incorrect: %v", stats)
-        }
+       waitForSdl := viper.GetBool("db.waitForSdl")
+       stats := getMetrics(t)
+       if !strings.Contains(stats, "ricxapp_RMR_Transmitted 200") {
+               t.Errorf("Error: ricxapp_RMR_Transmitted value incorrect: %v", stats)
+       }
 
-        if !strings.Contains(stats, "ricxapp_RMR_Received 201") {
-                t.Errorf("Error: ricxapp_RMR_Received value incorrect: %v", stats)
-        }
+       if !strings.Contains(stats, "ricxapp_RMR_Received 201") {
+               t.Errorf("Error: ricxapp_RMR_Received value incorrect: %v", stats)
+       }
 
-        if !strings.Contains(stats, "ricxapp_RMR_TransmitError 1") {
-                t.Errorf("Error: ricxapp_RMR_TransmitError value incorrect")
-        }
+       if !strings.Contains(stats, "ricxapp_RMR_TransmitError 1") {
+               t.Errorf("Error: ricxapp_RMR_TransmitError value incorrect")
+       }
 
-        if !strings.Contains(stats, "ricxapp_RMR_ReceiveError 0") {
-                t.Errorf("Error: ricxapp_RMR_ReceiveError value incorrect")
-        }
+       if !strings.Contains(stats, "ricxapp_RMR_ReceiveError 0") {
+               t.Errorf("Error: ricxapp_RMR_ReceiveError value incorrect")
+       }
 
-        if waitForSdl && !strings.Contains(stats, "ricxapp_SDL_Stored 201") {
-                t.Errorf("Error: ricxapp_SDL_Stored value incorrect")
-        }
+       if waitForSdl && !strings.Contains(stats, "ricxapp_SDL_Stored 201") {
+               t.Errorf("Error: ricxapp_SDL_Stored value incorrect")
+       }
 
-        if waitForSdl && !strings.Contains(stats, "ricxapp_SDL_StoreError 0") {
-                t.Errorf("Error: ricxapp_SDL_StoreError value incorrect")
-        }
-        Rmr.Closewh(int(whid))
+       if waitForSdl && !strings.Contains(stats, "ricxapp_SDL_StoreError 0") {
+               t.Errorf("Error: ricxapp_SDL_StoreError value incorrect")
+       }
+       Rmr.Closewh(int(whid))
 }
 
 func TestSubscribeChannels(t *testing.T) {