uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Add new test for call (freeswitch)

Browse Source
This commit is contained in:
TeoV
2018-03-20 10:57:22 -04:00
committed by Dan Christian Bogos
parent ae9ceb5169
commit 164ab7270a
4 changed files with 291 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
data/tutorials/fs_evsock/cgrates/etc/cgrates/cgrates.json
View File

@@ -27,16 +27,16 @@
"rals": {
"enabled": true,
"thresholds_conns": [
{"address": "*internal"}
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"stats_conns": [
{"address": "*internal"}
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"pubsubs_conns": [
{"address": "*internal"}
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"attributes_conns": [
{"address": "*internal"}
{"address": "127.0.0.1:2012", "transport": "*json"}
],
},
@@ -63,12 +63,21 @@
"attributes_conns": [
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"stats_conns": [
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"thresholds_conns": [
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"debit_interval": "10s",
},
"freeswitch_agent": {
"enabled": true,
"sessions_conns": [
{"address": "*internal"}
],
},
@@ -79,14 +88,17 @@
"attributes": {
"enabled": true,
"string_indexed_fields": ["Account"],
},
"resources": {
"enabled": true,
"thresholds_conns": [
{"address": "*internal"}
{"address": "127.0.0.1:2012", "transport": "*json"}
],
"string_indexed_fields": ["Account"],
"prefix_indexed_fields": ["Destination"],
},
@@ -95,11 +107,13 @@
"thresholds_conns": [
{"address": "*internal"}
],
"string_indexed_fields": ["Account","EventType"],
},
"thresholds": {
"enabled": true,
"string_indexed_fields": ["Account","EventType","StatID","ResourceID"],
},
@@ -114,6 +128,8 @@
"stats_conns": [
{"address": "*internal"}
],
"string_indexed_fields": ["Account"],
"prefix_indexed_fields": ["Destination"],
},

4
data/tutorials/fs_evsock/cgrates/etc/init.d/cgrates
View File

@@ -18,8 +18,8 @@ PATH=/sbin:/usr/sbin:/bin:/usr/bin
DESC="CGRateS real-time charging system"
NAME=cgrates
DAEMON=/usr/bin/cgr-engine
USER=cgrates
GROUP=cgrates
USER=teo
GROUP=teo
DAEMON_OPTS=""
TUTFOLDER=/usr/share/cgrates/tutorials/fs_evsock/cgrates
TMP_DIR=/tmp/cgr_fsevsock/cgrates

262
general_tests/tut_fs_calls_test.go Executable file
View File

@@ -0,0 +1,262 @@
// +build newcall
/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>
*/
package general_tests
import (
"flag"
"net/rpc"
"net/rpc/jsonrpc"
"os"
"path"
"reflect"
"testing"
"time"
"github.com/cgrates/cgrates/config"
"github.com/cgrates/cgrates/engine"
"github.com/cgrates/cgrates/sessions"
"github.com/cgrates/cgrates/utils"
)
var tutFsCallsCfg *config.CGRConfig
var tutFsCallsRpc *rpc.Client
var tutFsCallsPjSuaListener *os.File
var waitRater = flag.Int("wait_rater", 100, "Number of miliseconds to wait for rater to start and cache")
var dataDir = flag.String("data_dir", "/usr/share/cgrates", "CGR data dir path here")
func TestFSCallInitCfg(t *testing.T) {
// Init config first
var err error
tutFsCallsCfg, err = config.NewCGRConfigFromFolder(path.Join(*dataDir, "tutorials", "fs_evsock", "cgrates", "etc", "cgrates"))
if err != nil {
t.Error(err)
}
tutFsCallsCfg.DataFolderPath = *dataDir // Share DataFolderPath through config towards StoreDb for Flush()
config.SetCgrConfig(tutFsCallsCfg)
}
// Remove data in both rating and accounting db
func TestFSCallResetDataDb(t *testing.T) {
if err := engine.InitDataDb(tutFsCallsCfg); err != nil {
t.Fatal(err)
}
}
// Wipe out the cdr database
func TestFSCallResetStorDb(t *testing.T) {
if err := engine.InitStorDb(tutFsCallsCfg); err != nil {
t.Fatal(err)
}
}
// start FS server
func TestFSCallStartFS(t *testing.T) {
engine.KillProcName("freeswitch", 5000)
if err := engine.CallScript(path.Join(*dataDir, "tutorials", "fs_evsock", "freeswitch", "etc", "init.d", "freeswitch"), "start", 3000); err != nil {
t.Fatal(err)
}
}
// Start CGR Engine
func TestTutFsCallsStartEngine(t *testing.T) {
engine.KillProcName("cgr-engine", *waitRater)
if err := engine.CallScript(path.Join(*dataDir, "tutorials", "fs_evsock", "cgrates", "etc", "init.d", "cgrates"), "start", 100); err != nil {
t.Fatal(err)
}
}
// Restart FS so we make sure reconnects are working
func TestFSCallRestartFS(t *testing.T) {
if err := engine.CallScript(path.Join(*dataDir, "tutorials", "fs_evsock", "freeswitch", "etc", "init.d", "freeswitch"), "restart", 5000); err != nil {
t.Fatal(err)
}
}
// Connect rpc client to rater
func TestFSCallRpcConn(t *testing.T) {
var err error
tutFsCallsRpc, err = jsonrpc.Dial("tcp", tutFsCallsCfg.RPCJSONListen) // We connect over JSON so we can also troubleshoot if needed
if err != nil {
t.Fatal(err)
}
}
// Load the tariff plan, creating accounts and their balances
func TestFSCallLoadTariffPlanFromFolder(t *testing.T) {
reply := ""
attrs := &utils.AttrLoadTpFromFolder{FolderPath: path.Join(*dataDir, "tariffplans", "tutorial")}
if err := tutFsCallsRpc.Call("ApierV1.LoadTariffPlanFromFolder", attrs, &reply); err != nil {
t.Error(err)
} else if reply != "OK" {
t.Error(reply)
}
time.Sleep(time.Duration(*waitRater) * time.Millisecond) // Give time for scheduler to execute topups
}
// Make sure account was debited properly
func TestFSCallAccountsBefore(t *testing.T) {
var reply *engine.Account
attrs := &utils.AttrGetAccount{Tenant: "cgrates.org", Account: "1001"}
if err := tutFsCallsRpc.Call("ApierV2.GetAccount", attrs, &reply); err != nil {
t.Error("Got error on ApierV2.GetAccount: ", err.Error())
} else if reply.BalanceMap[utils.MONETARY].GetTotalValue() != 10.0 { // Make sure we debitted
t.Errorf("Calling ApierV1.GetBalance received: %f", reply.BalanceMap[utils.MONETARY].GetTotalValue())
}
}
// Start Pjsua as listener and register it to receive calls
func TestFSCallStartPjsuaListener(t *testing.T) {
var err error
acnts := []*engine.PjsuaAccount{
&engine.PjsuaAccount{Id: "sip:1001@192.168.56.202",
Username: "1001", Password: "CGRateS.org", Realm: "*", Registrar: "sip:192.168.56.202:5060"},
&engine.PjsuaAccount{Id: "sip:1002@192.168.56.202",
Username: "1002", Password: "CGRateS.org", Realm: "*", Registrar: "sip:192.168.56.202:5060"}}
if tutFsCallsPjSuaListener, err = engine.StartPjsuaListener(
acnts, 5070, time.Duration(*waitRater)*time.Millisecond); err != nil {
t.Fatal(err)
}
}
// Call from 1001 (prepaid) to 1002
func TestFSCallCall1001To1002(t *testing.T) {
if err := engine.PjsuaCallUri(
&engine.PjsuaAccount{Id: "sip:1001@192.168.56.202", Username: "1001", Password: "CGRateS.org", Realm: "*"},
"sip:1002@192.168.56.202", "sip:192.168.56.202:5060", time.Duration(67)*time.Second, 5071); err != nil {
t.Fatal(err)
}
}
// GetActiveSessions
func TestFSCallGetActiveSessions(t *testing.T) {
time.Sleep(time.Duration(150 * time.Millisecond)) // Allow Session to start
var reply *[]*sessions.ActiveSession
expected := &[]*sessions.ActiveSession{
&sessions.ActiveSession{
TOR: "*voice",
ReqType: "*prepaid",
Tenant: "cgrates.org",
Category: "call",
Account: "1001",
Subject: "1001",
Destination: "1002",
},
}
if err := tutFsCallsRpc.Call("SessionSv1.GetActiveSessions",
&map[string]string{}, &reply); err != nil {
t.Error("Got error on SessionSv1.GetActiveSessions: ", err.Error())
} else {
// compare some fields (eg. CGRId is generated)
if !reflect.DeepEqual((*expected)[0].TOR, (*reply)[0].TOR) {
t.Errorf("Expected: %s, received: %s", (*expected)[0].TOR, (*reply)[0].TOR)
} else if !reflect.DeepEqual((*expected)[0].ReqType, (*reply)[0].ReqType) {
t.Errorf("Expected: %s, received: %s", (*expected)[0].ReqType, (*reply)[0].ReqType)
} else if !reflect.DeepEqual((*expected)[0].Account, (*reply)[0].Account) {
t.Errorf("Expected: %s, received: %s", (*expected)[0].Account, (*reply)[0].Account)
} else if !reflect.DeepEqual((*expected)[0].Destination, (*reply)[0].Destination) {
t.Errorf("Expected: %s, received: %s", (*expected)[0].Destination, (*reply)[0].Destination)
}
}
}
// get account while call is on
// check resource for alocation
// add threshold non recurent
// while call is on threshold is there
// for 1001 -> 1002 non recurent
// for 1002 -> 1001 recurent acnd check if was executed
// Make sure account was debited properly
func TestFSCallAccount1001(t *testing.T) {
time.Sleep(time.Duration(75) * time.Second) // Allow calls to finish before start querying the results
var reply *engine.Account
attrs := &utils.AttrGetAccount{Tenant: "cgrates.org", Account: "1001"}
if err := tutFsCallsRpc.Call("ApierV2.GetAccount", attrs, &reply); err != nil {
t.Error(err.Error())
} else if reply.BalanceMap[utils.MONETARY].GetTotalValue() == 10.0 { // Make sure we debitted
t.Errorf("Expected: 10, received: %+v", reply.BalanceMap[utils.MONETARY].GetTotalValue())
} else if reply.Disabled == true {
t.Error("Account disabled")
}
}
// after call end threshold should't be there
//get cdr and check source of cdr to be *sessions
// Make sure account was debited properly
func TestTutFsCalls1001Cdrs(t *testing.T) {
var reply []*engine.ExternalCDR
//var CGRID string // Share with getCostDetails
//var cCost engine.CallCost
req := utils.RPCCDRsFilter{RunIDs: []string{utils.META_DEFAULT}, Accounts: []string{"1001"}, DestinationPrefixes: []string{"1002"}}
if err := tutFsCallsRpc.Call("ApierV2.GetCdrs", req, &reply); err != nil {
t.Error("Unexpected error: ", err.Error())
} else if len(reply) != 1 {
t.Error("Unexpected number of CDRs returned: ", len(reply))
} else {
//CGRID = reply[0].CGRID
if reply[0].Source != "freeswitch_json" {
t.Errorf("Unexpected Source for CDR: %+v", reply[0])
}
if reply[0].RequestType != utils.META_PREPAID {
t.Errorf("Unexpected RequestType for CDR: %+v", reply[0])
}
if reply[0].Usage != "1m7s" { // Usage as seconds
t.Errorf("Unexpected Usage for CDR: %+v", utils.ToJSON(reply[0].Usage))
}
if reply[0].Cost == -1.0 { // Cost was not calculated
t.Errorf("Unexpected Cost for CDR: %+v", reply[0])
}
}
var cc *engine.SMCost
attrs := utils.AttrGetCallCost{
CgrId: reply[0].CGRID,
RunId: reply[0].RunID,
}
if err := tutFsCallsRpc.Call("ApierV1.GetCallCostLog", attrs, &cc); err != nil {
t.Error(err.Error())
}
if cc.CostSource != utils.MetaSessionS {
t.Errorf("Expected: *sessions, received: %+v", cc.CostSource)
}
}
// check resource for release
// check stats for ACD & ACC
func TestFSCallStopPjsuaListener(t *testing.T) {
tutFsCallsPjSuaListener.Write([]byte("q\n")) // Close pjsua
time.Sleep(time.Duration(1) * time.Second) // Allow pjsua to finish it's tasks, eg un-REGISTER
}
func TestFSCallStopCgrEngine(t *testing.T) {
if err := engine.KillEngine(100); err != nil {
t.Error(err)
}
}
func TestFSCallStopFS(t *testing.T) {
engine.KillProcName("freeswitch", 1000)
}

12
sessions/sessions.go
View File

@@ -1357,7 +1357,7 @@ func (smg *SMGeneric) BiRPCv1AuthorizeEvent(clnt rpcclient.RpcClientConnection,
}
var rplyEv engine.AttrSProcessEventReply
if err := smg.attrS.Call(utils.AttributeSv1ProcessEvent,
args.CGREvent, &rplyEv); err == nil {
&args.CGREvent, &rplyEv); err == nil {
args.CGREvent = *rplyEv.CGREvent
authReply.Attributes = &rplyEv
} else if err.Error() != utils.ErrNotFound.Error() {
@@ -1444,7 +1444,7 @@ func (smg *SMGeneric) BiRPCv1AuthorizeEvent(clnt rpcclient.RpcClientConnection,
return utils.NewErrNotConnected(utils.StatService)
}
var statReply string
if err := smg.statS.Call(utils.StatSv1ProcessEvent, args.CGREvent, &statReply); err != nil &&
if err := smg.statS.Call(utils.StatSv1ProcessEvent, &args.CGREvent, &statReply); err != nil &&
err.Error() != utils.ErrNotFound.Error() {
utils.Logger.Warning(
fmt.Sprintf("<SessionS> error: %s processing event %+v with StatS.", err.Error(), args.CGREvent))
@@ -1542,7 +1542,7 @@ func (smg *SMGeneric) BiRPCv1InitiateSession(clnt rpcclient.RpcClientConnection,
}
var rplyEv engine.AttrSProcessEventReply
if err := smg.attrS.Call(utils.AttributeSv1ProcessEvent,
args.CGREvent, &rplyEv); err == nil {
&args.CGREvent, &rplyEv); err == nil {
args.CGREvent = *rplyEv.CGREvent
rply.Attributes = &rplyEv
} else if err.Error() != utils.ErrNotFound.Error() {
@@ -1607,7 +1607,7 @@ func (smg *SMGeneric) BiRPCv1InitiateSession(clnt rpcclient.RpcClientConnection,
return utils.NewErrNotConnected(utils.StatService)
}
var statReply string
if err := smg.statS.Call(utils.StatSv1ProcessEvent, args.CGREvent, &statReply); err != nil &&
if err := smg.statS.Call(utils.StatSv1ProcessEvent, &args.CGREvent, &statReply); err != nil &&
err.Error() != utils.ErrNotFound.Error() {
utils.Logger.Warning(
fmt.Sprintf("<SessionS> error: %s processing event %+v with StatS.", err.Error(), args.CGREvent))
@@ -1660,7 +1660,7 @@ func (smg *SMGeneric) BiRPCv1UpdateSession(clnt rpcclient.RpcClientConnection,
}
var rplyEv engine.AttrSProcessEventReply
if err := smg.attrS.Call(utils.AttributeSv1ProcessEvent,
args.CGREvent, &rplyEv); err == nil {
&args.CGREvent, &rplyEv); err == nil {
args.CGREvent = *rplyEv.CGREvent
rply.Attributes = &rplyEv
} else if err.Error() != utils.ErrNotFound.Error() {
@@ -1748,7 +1748,7 @@ func (smg *SMGeneric) BiRPCv1TerminateSession(clnt rpcclient.RpcClientConnection
return utils.NewErrNotConnected(utils.StatService)
}
var statReply string
if err := smg.statS.Call(utils.StatSv1ProcessEvent, args.CGREvent, &statReply); err != nil &&
if err := smg.statS.Call(utils.StatSv1ProcessEvent, &args.CGREvent, &statReply); err != nil &&
err.Error() != utils.ErrNotFound.Error() {
utils.Logger.Warning(
fmt.Sprintf("<SessionS> error: %s processing event %+v with StatS.", err.Error(), args.CGREvent))