From 53a2b87f594caf63f5d67b3a0548562d0b6cf164 Mon Sep 17 00:00:00 2001 From: Trial97 Date: Fri, 14 Dec 2018 15:34:19 +0200 Subject: [PATCH] Added SessionSv1.SyncSessions API --- apier/v1/sessions.go | 11 +++++++++++ sessions/sessions.go | 7 +++++++ utils/consts.go | 1 + 3 files changed, 19 insertions(+) diff --git a/apier/v1/sessions.go b/apier/v1/sessions.go index 556641501..f4b906492 100644 --- a/apier/v1/sessions.go +++ b/apier/v1/sessions.go @@ -41,6 +41,7 @@ func (ssv1 *SessionSv1) Handlers() map[string]interface{} { utils.SessionSv1InitiateSession: ssv1.BiRpcInitiateSession, utils.SessionSv1InitiateSessionWithDigest: ssv1.BiRpcInitiateSessionWithDigest, utils.SessionSv1UpdateSession: ssv1.BiRpcUpdateSession, + utils.SessionSv1SyncSessions: ssv1.BiRpcSyncSessions, utils.SessionSv1TerminateSession: ssv1.BiRpcTerminateSession, utils.SessionSv1ProcessCDR: ssv1.BiRpcProcessCDR, utils.SessionSv1ProcessEvent: ssv1.BiRpcProcessEvent, @@ -76,6 +77,11 @@ func (ssv1 *SessionSv1) UpdateSession(args *sessions.V1UpdateSessionArgs, return ssv1.SMG.BiRPCv1UpdateSession(nil, args, rply) } +func (ssv1 *SessionSv1) SyncSessions(args *string, + rply *string) error { + return ssv1.SMG.BiRPCv1SyncSessions(nil, "", rply) +} + func (ssv1 *SessionSv1) TerminateSession(args *sessions.V1TerminateSessionArgs, rply *string) error { return ssv1.SMG.BiRPCv1TerminateSession(nil, args, rply) @@ -123,6 +129,11 @@ func (ssv1 *SessionSv1) BiRpcUpdateSession(clnt *rpc2.Client, args *sessions.V1U return ssv1.SMG.BiRPCv1UpdateSession(clnt, args, rply) } +func (ssv1 *SessionSv1) BiRpcSyncSessions(clnt *rpc2.Client, args *string, + rply *string) error { + return ssv1.SMG.BiRPCv1SyncSessions(clnt, "", rply) +} + func (ssv1 *SessionSv1) BiRpcTerminateSession(clnt *rpc2.Client, args *sessions.V1TerminateSessionArgs, rply *string) error { return ssv1.SMG.BiRPCv1TerminateSession(clnt, args, rply) diff --git a/sessions/sessions.go b/sessions/sessions.go index ba86f1a1d..cc03cb5fc 100644 --- a/sessions/sessions.go +++ b/sessions/sessions.go @@ -2427,6 +2427,13 @@ func (smg *SMGeneric) syncSessions() { } } +func (smg *SMGeneric) BiRPCv1SyncSessions(clnt rpcclient.RpcClientConnection, + ignParam string, reply *string) error { + smg.syncSessions() + *reply = utils.OK + return nil +} + func (smg *SMGeneric) BiRPCv1RegisterInternalBiJSONConn(clnt rpcclient.RpcClientConnection, ignParam string, reply *string) error { smg.intBiJSONConns = append(smg.intBiJSONConns, clnt) diff --git a/utils/consts.go b/utils/consts.go index a2bcf2518..22fb97d57 100755 --- a/utils/consts.go +++ b/utils/consts.go @@ -749,6 +749,7 @@ const ( SessionSv1InitiateSession = "SessionSv1.InitiateSession" SessionSv1InitiateSessionWithDigest = "SessionSv1.InitiateSessionWithDigest" SessionSv1UpdateSession = "SessionSv1.UpdateSession" + SessionSv1SyncSessions = "SessionSv1.SyncSessions" SessionSv1TerminateSession = "SessionSv1.TerminateSession" SessionSv1ProcessCDR = "SessionSv1.ProcessCDR" SessionSv1ProcessEvent = "SessionSv1.ProcessEvent"