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 cgr_max_usage variable to fs channels

Browse Source
This commit is contained in:
arberkatellari
2025-07-03 14:06:39 +02:00
committed by Dan Christian Bogos
parent eda74a79a9
commit ad5ec6c062
2 changed files with 19 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
agents/fsagent.go
View File

@@ -104,40 +104,44 @@ func (fsa *FSsessions) createHandlers() map[string][]func(string, int) {
// Sets the call timeout valid of starting of the call
func (fsa *FSsessions) setMaxCallDuration(uuid string, connIdx int,
maxDur time.Duration, destNr string) error {
maxDur time.Duration, destNr string) (err error) {
// set variable cgr_max_usage to the fs channel
if _, err = fsa.conns[connIdx].SendApiCmd(
fmt.Sprintf("uuid_setvar %s %s %d \n\n",
uuid, VarCGRMaxUsage, int(maxDur.Seconds()))); err != nil {
utils.Logger.Err(
fmt.Sprintf("<%s> Could not set %s variable to freeswitch channel, error: <%s>, connIdx: %v",
utils.FreeSWITCHAgent, VarCGRMaxUsage, err.Error(), connIdx))
return
}
if len(fsa.cfg.EmptyBalanceContext) != 0 {
_, err := fsa.conns[connIdx].SendApiCmd(
if _, err = fsa.conns[connIdx].SendApiCmd(
fmt.Sprintf("uuid_setvar %s execute_on_answer sched_transfer +%d %s XML %s\n\n",
uuid, int(maxDur.Seconds()), destNr, fsa.cfg.EmptyBalanceContext))
if err != nil {
uuid, int(maxDur.Seconds()), destNr, fsa.cfg.EmptyBalanceContext)); err != nil {
utils.Logger.Err(
fmt.Sprintf("<%s> Could not transfer the call to empty balance context, error: <%s>, connIdx: %v",
utils.FreeSWITCHAgent, err.Error(), connIdx))
return err
}
return nil
return
}
if len(fsa.cfg.EmptyBalanceAnnFile) != 0 {
if _, err := fsa.conns[connIdx].SendApiCmd(
if _, err = fsa.conns[connIdx].SendApiCmd(
fmt.Sprintf("sched_broadcast +%d %s playback!manager_request::%s aleg\n\n",
int(maxDur.Seconds()), uuid, fsa.cfg.EmptyBalanceAnnFile)); err != nil {
utils.Logger.Err(
fmt.Sprintf("<%s> Could not send uuid_broadcast to freeswitch, error: <%s>, connIdx: %v",
utils.FreeSWITCHAgent, err.Error(), connIdx))
return err
}
return nil
return
}
_, err := fsa.conns[connIdx].SendApiCmd(
if _, err = fsa.conns[connIdx].SendApiCmd(
fmt.Sprintf("uuid_setvar %s execute_on_answer sched_hangup +%d alloted_timeout\n\n",
uuid, int(maxDur.Seconds())))
if err != nil {
uuid, int(maxDur.Seconds()))); err != nil {
utils.Logger.Err(
fmt.Sprintf("<%s> Could not send sched_hangup command to freeswitch, error: <%s>, connIdx: %v",
utils.FreeSWITCHAgent, err.Error(), connIdx))
return err
}
return nil
return
}
// Sends the transfer command to unpark the call to freeswitch

1
agents/fsevent.go
View File

@@ -74,6 +74,7 @@ const (
VarAnswerEpoch = "variable_answer_epoch"
VarCGRACD = varPrefix + utils.CgrAcd
VarCGROriginHost = varPrefix + utils.CGROriginHost
VarCGRMaxUsage = "cgr_max_usage"
)
func NewFSEvent(strEv string) (fsev FSEvent) {