-
Notifications
You must be signed in to change notification settings - Fork 5
/
kamjsonrpc_local_test.go
114 lines (102 loc) · 2.73 KB
/
kamjsonrpc_local_test.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
package kamjsonrpc
import (
"encoding/json"
"flag"
"reflect"
"testing"
)
var testLocal = flag.Bool("local", false, "Perform the tests only on local test environment, not by default.") // This flag will be passed here via "go test -local" args
var kamAddr = flag.String("kam_addr", "http://127.0.0.1:5060", "Address where to reach kamailio http server")
var kamRpc *KamailioJsonRpc
func TestKamJsonRpcConn(t *testing.T) {
if !*testLocal {
return
}
var err error
if kamRpc, err = NewKamailioJsonRpc(*kamAddr, true); err != nil {
t.Fatal("Cannot connect to kamailio:", err)
}
}
func TestKamJsonRpcCall(t *testing.T) {
if !*testLocal {
return
}
var reply json.RawMessage
if err := kamRpc.Call("core.psx", []string{}, &reply); err != nil {
t.Error(err)
} else if reflect.DeepEqual(reply, json.RawMessage{}) {
t.Error("Empty reply")
}
}
func TestKamJsonRpcCoreEcho(t *testing.T) {
if !*testLocal {
return
}
req := []string{"test_kamjsonrpc"}
var reply []string
if err := kamRpc.CoreEcho(req, &reply); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(req, reply) {
t.Errorf("Expecting: %+v, received: %+v", req, reply)
}
}
func TestKamJsonRpcUacRegEnable(t *testing.T) {
if !*testLocal {
return
}
eReply := "OK"
var reply string
if err := kamRpc.UacRegEnable([]string{"l_uuid", "unknown"}, &reply); err != nil {
t.Error(err)
} else if eReply != reply {
t.Errorf("Expecting: %s, received: %s", eReply, reply)
}
}
func TestKamJsonRpcUacRegDisable(t *testing.T) {
if !*testLocal {
return
}
eReply := "OK"
var reply string
if err := kamRpc.UacRegDisable([]string{"l_uuid", "unknown"}, &reply); err != nil {
t.Error(err)
} else if eReply != reply {
t.Errorf("Expecting: %s, received: %s", eReply, reply)
}
}
func TestKamJsonRpcUacRegReload(t *testing.T) {
if !*testLocal {
return
}
eReply := "OK"
var reply string
if err := kamRpc.UacRegReload([]string{}, &reply); err != nil {
t.Error(err)
} else if eReply != reply {
t.Errorf("Expecting: %s, received: %s", eReply, reply)
}
}
func TestKamJsonRpcUacRegRefresh(t *testing.T) {
if !*testLocal {
return
}
eReply := "OK"
var reply string
if err := kamRpc.UacRegRefresh([]string{"l_uuid", "unknown"}, &reply); err != nil {
t.Error(err)
} else if eReply != reply {
t.Errorf("Expecting: %s, received: %s", eReply, reply)
}
}
func TestKamJsonRpcUacRegInfo(t *testing.T) {
if !*testLocal {
return
}
var eReply RegistrationInfo
var reply RegistrationInfo
if err := kamRpc.UacRegInfo([]string{"l_uuid", "unknown"}, &reply); err != nil {
t.Error(err)
} else if !reflect.DeepEqual(reply, eReply) {
t.Errorf("Expecting: %+v, received: %+v", eReply, reply)
}
}