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

Update fwv reader

Browse Source
This commit is contained in:
ionutboangiu
2022-07-25 18:21:23 +03:00
committed by Dan Christian Bogos
parent 107932e3d2
commit 270d6cc3fb
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

@@ -295,7 +295,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, nil,
utils.MapStorage{}, nil, nil, nil, nil,
rdr.Config().Tenant,
rdr.cgrCfg.GeneralCfg().DefaultTenant,
utils.FirstNonEmpty(rdr.Config().Timezone,
@@ -337,9 +337,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, nil,
utils.MapStorage{}, nil, nil, nil, nil,
rdr.Config().Tenant,
rdr.cgrCfg.GeneralCfg().DefaultTenant,
utils.FirstNonEmpty(rdr.Config().Timezone,
@@ -353,10 +354,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
cgrEv := utils.NMAsCGREvent(agReq.CGRRequest, agReq.Tenant, utils.NestingSep, agReq.Opts)
rdrEv := rdr.rdrEvents
if _, isPartial := cgrEv.APIOpts[utils.PartialOpt]; isPartial {