diff --git a/apier/v1/api_interfaces.go b/apier/v1/api_interfaces.go index b499b5b02..49470a657 100644 --- a/apier/v1/api_interfaces.go +++ b/apier/v1/api_interfaces.go @@ -79,7 +79,7 @@ type SessionSv1Interface interface { InitiateSession(args *sessions.V1InitSessionArgs, rply *sessions.V1InitSessionReply) error InitiateSessionWithDigest(args *sessions.V1InitSessionArgs, rply *sessions.V1InitReplyWithDigest) error UpdateSession(args *sessions.V1UpdateSessionArgs, rply *sessions.V1UpdateSessionReply) error - // SyncSessions(args *string, rply *string) error + SyncSessions(args *utils.TenantWithArgDispatcher, rply *string) error TerminateSession(args *sessions.V1TerminateSessionArgs, rply *string) error ProcessCDR(cgrEv *utils.CGREventWithArgDispatcher, rply *string) error ProcessMessage(args *sessions.V1ProcessMessageArgs, rply *sessions.V1ProcessMessageReply) error diff --git a/apier/v1/dispatcher.go b/apier/v1/dispatcher.go index 65d3fe769..bc545ac4d 100755 --- a/apier/v1/dispatcher.go +++ b/apier/v1/dispatcher.go @@ -505,10 +505,15 @@ func (dS *DispatcherSessionSv1) SetPassiveSession(args *sessions.Session, func (dS *DispatcherSessionSv1) ActivateSessions(args *utils.SessionIDsWithArgsDispatcher, reply *string) error { return dS.dS.SessionSv1ActivateSessions(args, reply) } + func (dS *DispatcherSessionSv1) DeactivateSessions(args *utils.SessionIDsWithArgsDispatcher, reply *string) error { return dS.dS.SessionSv1DeactivateSessions(args, reply) } +func (dS *DispatcherSessionSv1) SyncSessions(args *utils.TenantWithArgDispatcher, rply *string) error { + return dS.dS.SessionSv1SyncSessions(args, rply) +} + func NewDispatcherResponder(dps *dispatchers.DispatcherService) *DispatcherResponder { return &DispatcherResponder{dS: dps} } diff --git a/apier/v1/sessions.go b/apier/v1/sessions.go index 1cef22ef5..de06379b9 100644 --- a/apier/v1/sessions.go +++ b/apier/v1/sessions.go @@ -58,9 +58,9 @@ func (ssv1 *SessionSv1) UpdateSession(args *sessions.V1UpdateSessionArgs, return ssv1.Ss.BiRPCv1UpdateSession(nil, args, rply) } -func (ssv1 *SessionSv1) SyncSessions(args *string, +func (ssv1 *SessionSv1) SyncSessions(args *utils.TenantWithArgDispatcher, rply *string) error { - return ssv1.Ss.BiRPCv1SyncSessions(nil, "", rply) + return ssv1.Ss.BiRPCv1SyncSessions(nil, &utils.TenantWithArgDispatcher{}, rply) } func (ssv1 *SessionSv1) TerminateSession(args *sessions.V1TerminateSessionArgs, diff --git a/apier/v1/sessionsbirpc.go b/apier/v1/sessionsbirpc.go index 874560cae..35009f979 100644 --- a/apier/v1/sessionsbirpc.go +++ b/apier/v1/sessionsbirpc.go @@ -79,9 +79,9 @@ func (ssv1 *SessionSv1) BiRPCv1UpdateSession(clnt *rpc2.Client, args *sessions.V return ssv1.Ss.BiRPCv1UpdateSession(clnt, args, rply) } -func (ssv1 *SessionSv1) BiRPCv1SyncSessions(clnt *rpc2.Client, args *string, +func (ssv1 *SessionSv1) BiRPCv1SyncSessions(clnt *rpc2.Client, args *utils.TenantWithArgDispatcher, rply *string) error { - return ssv1.Ss.BiRPCv1SyncSessions(clnt, "", rply) + return ssv1.Ss.BiRPCv1SyncSessions(clnt, &utils.TenantWithArgDispatcher{}, rply) } func (ssv1 *SessionSv1) BiRPCv1TerminateSession(clnt *rpc2.Client, args *sessions.V1TerminateSessionArgs, diff --git a/dispatchers/sessions.go b/dispatchers/sessions.go index 27c433f70..c22b6e1db 100755 --- a/dispatchers/sessions.go +++ b/dispatchers/sessions.go @@ -151,7 +151,7 @@ func (dS *DispatcherService) SessionSv1UpdateSession(args *sessions.V1UpdateSess } func (dS *DispatcherService) SessionSv1SyncSessions(args *utils.TenantWithArgDispatcher, - reply *sessions.V1UpdateSessionReply) (err error) { + reply *string) (err error) { tnt := dS.cfg.GeneralCfg().DefaultTenant if args.TenantArg != nil && args.TenantArg.Tenant != utils.EmptyString { tnt = args.TenantArg.Tenant diff --git a/sessions/sessions.go b/sessions/sessions.go index 90d246f57..6fccabf14 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -3242,7 +3242,7 @@ func (sS *SessionS) BiRPCv1ProcessEvent(clnt rpcclient.ClientConnector, // BiRPCv1SyncSessions will sync sessions on demand func (sS *SessionS) BiRPCv1SyncSessions(clnt rpcclient.ClientConnector, - ignParam string, reply *string) error { + ignParam *utils.TenantWithArgDispatcher, reply *string) error { sS.syncSessions() *reply = utils.OK return nil