From cf9cc5dcfc11dbc1894904b66edab9a771ed039d Mon Sep 17 00:00:00 2001 From: ionutboangiu Date: Mon, 23 Sep 2024 18:40:59 +0300 Subject: [PATCH] Generate missing dispatcher methods --- dispatchers/admins.go | 168 ++++++++++++++++++++++++++++++++++++++ dispatchers/cdrs.go | 12 +++ dispatchers/replicator.go | 72 ++++++++++++++++ 3 files changed, 252 insertions(+) diff --git a/dispatchers/admins.go b/dispatchers/admins.go index cb48f0fa2..22b6618c1 100644 --- a/dispatchers/admins.go +++ b/dispatchers/admins.go @@ -245,6 +245,18 @@ func (dS *DispatcherService) AdminSv1GetAttributesIndexesHealth(ctx *context.Con } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetAttributesIndexesHealth, args, reply) } +func (dS *DispatcherService) AdminSv1GetCDRs(ctx *context.Context, args *utils.CDRFilters, reply *[]*utils.CDR) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetCDRs, args, reply) +} func (dS *DispatcherService) AdminSv1GetChargerProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *engine.ChargerProfile) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { @@ -473,6 +485,54 @@ func (dS *DispatcherService) AdminSv1GetFiltersCount(ctx *context.Context, args } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetFiltersCount, args, reply) } +func (dS *DispatcherService) AdminSv1GetRankingProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *engine.RankingProfile) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetRankingProfile, args, reply) +} +func (dS *DispatcherService) AdminSv1GetRankingProfileIDs(ctx *context.Context, args *utils.ArgsItemIDs, reply *[]string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetRankingProfileIDs, args, reply) +} +func (dS *DispatcherService) AdminSv1GetRankingProfiles(ctx *context.Context, args *utils.ArgsItemIDs, reply *[]*engine.RankingProfile) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetRankingProfiles, args, reply) +} +func (dS *DispatcherService) AdminSv1GetRankingProfilesCount(ctx *context.Context, args *utils.ArgsItemIDs, reply *int) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetRankingProfilesCount, args, reply) +} func (dS *DispatcherService) AdminSv1GetRateProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *utils.RateProfile) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { @@ -833,6 +893,54 @@ func (dS *DispatcherService) AdminSv1GetThresholdsIndexesHealth(ctx *context.Con } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetThresholdsIndexesHealth, args, reply) } +func (dS *DispatcherService) AdminSv1GetTrendProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *engine.TrendProfile) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetTrendProfile, args, reply) +} +func (dS *DispatcherService) AdminSv1GetTrendProfileIDs(ctx *context.Context, args *utils.ArgsItemIDs, reply *[]string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetTrendProfileIDs, args, reply) +} +func (dS *DispatcherService) AdminSv1GetTrendProfiles(ctx *context.Context, args *utils.ArgsItemIDs, reply *[]*engine.TrendProfile) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetTrendProfiles, args, reply) +} +func (dS *DispatcherService) AdminSv1GetTrendProfilesCount(ctx *context.Context, args *utils.ArgsItemIDs, reply *int) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1GetTrendProfilesCount, args, reply) +} func (dS *DispatcherService) AdminSv1Ping(ctx *context.Context, args *utils.CGREvent, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && len(args.Tenant) != 0 { @@ -884,6 +992,18 @@ func (dS *DispatcherService) AdminSv1RemoveAttributeProfile(ctx *context.Context } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1RemoveAttributeProfile, args, reply) } +func (dS *DispatcherService) AdminSv1RemoveCDRs(ctx *context.Context, args *utils.CDRFilters, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1RemoveCDRs, args, reply) +} func (dS *DispatcherService) AdminSv1RemoveChargerProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { @@ -944,6 +1064,18 @@ func (dS *DispatcherService) AdminSv1RemoveFilterIndexes(ctx *context.Context, a } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1RemoveFilterIndexes, args, reply) } +func (dS *DispatcherService) AdminSv1RemoveRankingProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1RemoveRankingProfile, args, reply) +} func (dS *DispatcherService) AdminSv1RemoveRateProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { @@ -1016,6 +1148,18 @@ func (dS *DispatcherService) AdminSv1RemoveThresholdProfile(ctx *context.Context } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1RemoveThresholdProfile, args, reply) } +func (dS *DispatcherService) AdminSv1RemoveTrendProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1RemoveTrendProfile, args, reply) +} func (dS *DispatcherService) AdminSv1SetAccount(ctx *context.Context, args *utils.AccountWithAPIOpts, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.Account != nil && len(args.Account.Tenant) != 0) { @@ -1100,6 +1244,18 @@ func (dS *DispatcherService) AdminSv1SetFilter(ctx *context.Context, args *engin } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1SetFilter, args, reply) } +func (dS *DispatcherService) AdminSv1SetRankingProfile(ctx *context.Context, args *engine.RankingProfileWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.RankingProfile != nil && len(args.RankingProfile.Tenant) != 0) { + tnt = args.RankingProfile.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1SetRankingProfile, args, reply) +} func (dS *DispatcherService) AdminSv1SetRateProfile(ctx *context.Context, args *utils.APIRateProfile, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.RateProfile != nil && len(args.RateProfile.Tenant) != 0) { @@ -1160,3 +1316,15 @@ func (dS *DispatcherService) AdminSv1SetThresholdProfile(ctx *context.Context, a } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1SetThresholdProfile, args, reply) } +func (dS *DispatcherService) AdminSv1SetTrendProfile(ctx *context.Context, args *engine.TrendProfileWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TrendProfile != nil && len(args.TrendProfile.Tenant) != 0) { + tnt = args.TrendProfile.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaAdminS, utils.AdminSv1SetTrendProfile, args, reply) +} diff --git a/dispatchers/cdrs.go b/dispatchers/cdrs.go index af621a30d..5336a38dc 100644 --- a/dispatchers/cdrs.go +++ b/dispatchers/cdrs.go @@ -69,3 +69,15 @@ func (dS *DispatcherService) CDRsV1ProcessEventWithGet(ctx *context.Context, arg } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaCDRs, utils.CDRsV1ProcessEventWithGet, args, reply) } +func (dS *DispatcherService) CDRsV1ProcessStoredEvents(ctx *context.Context, args *utils.CDRFilters, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && len(args.Tenant) != 0 { + tnt = args.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaCDRs, utils.CDRsV1ProcessStoredEvents, args, reply) +} diff --git a/dispatchers/replicator.go b/dispatchers/replicator.go index 0e776d479..327f31146 100644 --- a/dispatchers/replicator.go +++ b/dispatchers/replicator.go @@ -229,6 +229,30 @@ func (dS *DispatcherService) ReplicatorSv1GetThresholdProfile(ctx *context.Conte } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1GetThresholdProfile, args, reply) } +func (dS *DispatcherService) ReplicatorSv1GetTrend(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *engine.Trend) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1GetTrend, args, reply) +} +func (dS *DispatcherService) ReplicatorSv1GetTrendProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *engine.TrendProfile) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1GetTrendProfile, args, reply) +} func (dS *DispatcherService) ReplicatorSv1Ping(ctx *context.Context, args *utils.CGREvent, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && len(args.Tenant) != 0 { @@ -436,6 +460,30 @@ func (dS *DispatcherService) ReplicatorSv1RemoveThresholdProfile(ctx *context.Co } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1RemoveThresholdProfile, args, reply) } +func (dS *DispatcherService) ReplicatorSv1RemoveTrend(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1RemoveTrend, args, reply) +} +func (dS *DispatcherService) ReplicatorSv1RemoveTrendProfile(ctx *context.Context, args *utils.TenantIDWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TenantID != nil && len(args.TenantID.Tenant) != 0) { + tnt = args.TenantID.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1RemoveTrendProfile, args, reply) +} func (dS *DispatcherService) ReplicatorSv1SetAccount(ctx *context.Context, args *utils.AccountWithAPIOpts, reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args != nil && (args.Account != nil && len(args.Account.Tenant) != 0) { @@ -637,3 +685,27 @@ func (dS *DispatcherService) ReplicatorSv1SetThresholdProfile(ctx *context.Conte } return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1SetThresholdProfile, args, reply) } +func (dS *DispatcherService) ReplicatorSv1SetTrend(ctx *context.Context, args *engine.TrendWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.Trend != nil && len(args.Trend.Tenant) != 0) { + tnt = args.Trend.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1SetTrend, args, reply) +} +func (dS *DispatcherService) ReplicatorSv1SetTrendProfile(ctx *context.Context, args *engine.TrendProfileWithAPIOpts, reply *string) (err error) { + tnt := dS.cfg.GeneralCfg().DefaultTenant + if args != nil && (args.TrendProfile != nil && len(args.TrendProfile.Tenant) != 0) { + tnt = args.TrendProfile.Tenant + } + ev := make(map[string]any) + opts := make(map[string]any) + if args != nil { + opts = args.APIOpts + } + return dS.Dispatch(ctx, &utils.CGREvent{Tenant: tnt, Event: ev, APIOpts: opts}, utils.MetaReplicator, utils.ReplicatorSv1SetTrendProfile, args, reply) +}