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

Update fwv reader

Browse Source
This commit is contained in:
ionutboangiu
2022-07-22 15:55:07 +03:00
committed by Dan Christian Bogos
parent b715ff4009
commit 90f41f6f22
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
ers/filefwv.go
View File

@@ -281,7 +281,7 @@ func (rdr *FWVFileER) processTrailer(file *os.File, rowNr, evsPosted int, absPat
record := string(buf)
rdr.trailerDP = config.NewFWVProvider(record)
agReq := agents.NewAgentRequest(
nil, nil, nil, nil, rdr.Config().Tenant,
utils.NavigableMap2{}, nil, nil, nil, rdr.Config().Tenant,
rdr.cgrCfg.GeneralCfg().DefaultTenant,
utils.FirstNonEmpty(rdr.Config().Timezone,
rdr.cgrCfg.GeneralCfg().DefaultTimezone),
@@ -317,9 +317,10 @@ func (rdr *FWVFileER) processHeader(file *os.File, rowNr, evsPosted int, absPath
}
func (rdr *FWVFileER) createHeaderMap(record string, rowNr, evsPosted int, absPath string, hdrFields []*config.FCTemplate) (err error) {
rdr.offset += rdr.headerOffset // increase the offset
rdr.headerDP = config.NewFWVProvider(record)
agReq := agents.NewAgentRequest(
nil, nil, nil, nil,
utils.NavigableMap2{}, nil, nil, nil,
rdr.Config().Tenant,
rdr.cgrCfg.GeneralCfg().DefaultTenant,
utils.FirstNonEmpty(rdr.Config().Timezone,
@@ -333,10 +334,8 @@ func (rdr *FWVFileER) createHeaderMap(record string, rowNr, evsPosted int, absPa
utils.Logger.Warning(
fmt.Sprintf("<%s> reading file: <%s> row <%d>, ignoring due to error: <%s>",
utils.ERs, absPath, rowNr, err.Error()))
rdr.offset += rdr.lineLen // increase the offset when exit
return err
}
rdr.offset += rdr.headerOffset // increase the offset
rdr.rdrEvents <- &erEvent{
cgrEvent: config.NMAsCGREvent(agReq.CGRRequest, agReq.Tenant, utils.NestingSep),
rdrCfg: rdr.Config(),