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

Renamed ee archive api

Browse Source
This commit is contained in:
porosnicuadrian
2021-12-06 17:59:58 +02:00
committed by Dan Christian Bogos
parent dc1f726a45
commit 22c7b3f4ac
4 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
apis/ees.go
View File

@@ -37,6 +37,6 @@ func (cS *EeSv1) ProcessEvent(ctx *context.Context, cgrEv *utils.CGREventWithEeI
return cS.ees.V1ProcessEvent(ctx, cgrEv, rply)
}
func (cS *EeSv1) ArchiveEventsAsReply(ctx *context.Context, args *ees.ArchiveEventsArgs, reply *[]byte) error {
return cS.ees.V1ArchiveEventsAsReply(ctx, args, reply)
func (cS *EeSv1) ArchiveEventsInReply(ctx *context.Context, args *ees.ArchiveEventsArgs, reply *[]byte) error {
return cS.ees.V1ArchiveEventsInReply(ctx, args, reply)
}

4
ees/ees.go
View File

@@ -329,8 +329,8 @@ type ArchiveEventsArgs struct {
Events []*utils.CGREvent
}
// V1ArchiveEventsAsReply should archive the events sent with existing exporters. The zipped content should be returned back as a reply.
func (eeS *EeS) V1ArchiveEventsAsReply(ctx *context.Context, args *ArchiveEventsArgs, reply *[]byte) (err error) {
// V1ArchiveEventsInReply should archive the events sent with existing exporters. The zipped content should be returned back as a reply.
func (eeS *EeS) V1ArchiveEventsInReply(ctx *context.Context, args *ArchiveEventsArgs, reply *[]byte) (err error) {
if args.Tenant == utils.EmptyString {
args.Tenant = eeS.cfg.GeneralCfg().DefaultTenant
}

2
ees/filecsv_it_test.go
View File

@@ -418,7 +418,7 @@ func testCsvExportBufferedEvent(t *testing.T) {
`4,cd8112998c2abb0e4a7cd3a94c74817cd5fe67d3,Default_charging_id,*prepaid,dispatchers.org,photo,1005,1005,1000,2679-04-25T22:02:25Z,2679-04-25T22:02:40Z,10,1.4422` + "\n" +
`4,10s,46.9706` + "\n"
var reply []byte
if err := csvRpc.Call(utils.EeSv1ArchiveEventsAsReply,
if err := csvRpc.Call(utils.EeSv1ArchiveEventsInReply,
eventVoice, &reply); err != nil {
t.Error(err)
} else if string(reply) != expected {

2
utils/consts.go
View File

@@ -1503,7 +1503,7 @@ const (
EeSv1 = "EeSv1"
EeSv1Ping = "EeSv1.Ping"
EeSv1ProcessEvent = "EeSv1.ProcessEvent"
EeSv1ArchiveEventsAsReply = "EeSv1.ArchiveEventsAsReply"
EeSv1ArchiveEventsInReply = "EeSv1.ArchiveEventsInReply"
)
// ActionProfile APIs