uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-17 06:09:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

CallDescriptor.UpdateFromCGREvent

Browse Source
This commit is contained in:
DanB
2017-12-12 12:38:58 +01:00
parent 21707a5119
commit 7032bea919
1 changed files with 51 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
engine/calldesc.go
View File

@@ -184,6 +184,57 @@ func (cd *CallDescriptor) AsCGREvent() *utils.CGREvent {
return cgrEv
}
// UpdateFromCGREvent will update CallDescriptor with fields from CGREvent
// cgrEv contains both fields and their values
// fields represent fields needing update
func (cd *CallDescriptor) UpdateFromCGREvent(cgrEv *utils.CGREvent, fields []string) (err error) {
for _, fldName := range fields {
switch fldName {
case utils.TOR:
if cd.TOR, err = cgrEv.FieldAsString(fldName); err != nil {
return
}
case utils.TENANT:
if cd.Tenant, err = cgrEv.FieldAsString(fldName); err != nil {
return
}
case utils.CATEGORY:
if cd.Category, err = cgrEv.FieldAsString(fldName); err != nil {
return
}
case utils.ACCOUNT:
if cd.Account, err = cgrEv.FieldAsString(fldName); err != nil {
return
}
case utils.SUBJECT:
if cd.Subject, err = cgrEv.FieldAsString(fldName); err != nil {
return
}
case utils.DESTINATION:
if cd.Destination, err = cgrEv.FieldAsString(fldName); err != nil {
return
}
case utils.ANSWER_TIME:
if cd.TimeStart, err = cgrEv.FieldAsTime(fldName, config.CgrConfig().DefaultTimezone); err != nil {
return
}
case utils.USAGE:
usage, err := cgrEv.FieldAsDuration(fldName)
if err != nil {
return err
}
cd.TimeEnd = cd.TimeStart.Add(usage)
default:
fldVal, err := cgrEv.FieldAsString(fldName)
if err != nil {
return err
}
cd.ExtraFields[fldName] = fldVal
}
}
return
}
func (cd *CallDescriptor) ValidateCallData() error {
if cd.TimeStart.After(cd.TimeEnd) || cd.TimeStart.Equal(cd.TimeEnd) {
return errors.New("TimeStart must be strctly before TimeEnd")