Browse Source

Completing rpc methods of uac module

master
DanB 10 years ago
parent
commit
8a1706bf75
2 changed files with 71 additions and 1 deletions
  1. +32
    -1
      kamjsonrpc.go
  2. +39
    -0
      kamjsonrpc_local_test.go

+ 32
- 1
kamjsonrpc.go View File

@ -18,6 +18,10 @@ import (
"sync"
)
const (
OK = "OK"
)
type KamJsonRpcRequest struct {
Jsonrpc string `json:"jsonrpc"`
Method string `json:"method"`
@ -98,12 +102,39 @@ func (self *KamailioJsonRpc) Call(serviceMethod string, args interface{}, reply
// Add inidividual methods over the generic one
func (self *KamailioJsonRpc) UacRegEnable(params []string, reply *string) error {
var regRaw json.RawMessage
if err := self.Call("uac.reg_enable", params, &regRaw); err != nil {
return err
}
*reply = OK
return nil
}
func (self *KamailioJsonRpc) UacRegDisable(params []string, reply *string) error {
var regRaw json.RawMessage
if err := self.Call("uac.reg_disable", params, &regRaw); err != nil {
return err
}
*reply = OK
return nil
}
func (self *KamailioJsonRpc) UacRegReload(params []string, reply *string) error {
var regRaw json.RawMessage
if err := self.Call("uac.reg_reload", params, &regRaw); err != nil {
return err
}
*reply = "OK"
*reply = OK
return nil
}
func (self *KamailioJsonRpc) UacRegRefresh(params []string, reply *string) error {
var regRaw json.RawMessage
if err := self.Call("uac.reg_refresh", params, &regRaw); err != nil {
return err
}
*reply = OK
return nil
}


+ 39
- 0
kamjsonrpc_local_test.go View File

@ -34,6 +34,32 @@ func TestKamJsonRpcCall(t *testing.T) {
}
}
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
@ -47,6 +73,19 @@ func TestKamJsonRpcUacRegReload(t *testing.T) {
}
}
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


Loading…
Cancel
Save