[sr-dev] git:master:832d1e62: presence: new rpc command presence.updateWatchers

Module: kamailio Branch: master Commit: 832d1e622c5f1c9165540f41ad1e3efa077e49d3 URL: https://github.com/kamailio/kamailio/commit/832d1e622c5f1c9165540f41ad1e3ef… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2019-06-23T11:35:36+02:00 presence: new rpc command presence.updateWatchers - trigger update of watchers via rpc --- Modified: src/modules/presence/presence.c --- Diff: https://github.com/kamailio/kamailio/commit/832d1e622c5f1c9165540f41ad1e3ef… Patch: https://github.com/kamailio/kamailio/commit/832d1e622c5f1c9165540f41ad1e3ef… --- diff --git a/src/modules/presence/presence.c b/src/modules/presence/presence.c index dc1e8216f5..26e91970a2 100644 --- a/src/modules/presence/presence.c +++ b/src/modules/presence/presence.c @@ -1728,6 +1728,49 @@ void rpc_presence_refresh_watchers(rpc_t *rpc, void *ctx) static const char *rpc_presence_refresh_watchers_doc[2] = { "Trigger refresh of watchers", 0}; +/*! \brief + * rpc cmd: presence.updateWatchers + * \<presentity_uri> + * \<event> + * * */ +void rpc_presence_update_watchers(rpc_t *rpc, void *ctx) +{ + str pres_uri = {0, 0}; + str event = {0, 0}; + int pn; + + LM_DBG("init update of watchers\n"); + + pn = rpc->scan(ctx, "SS", &pres_uri, &event); + if(pn < 2) { + rpc->fault(ctx, 500, "Not enough parameters"); + return; + } + + if(pres_uri.s == NULL || pres_uri.len == 0) { + LM_ERR("empty uri\n"); + rpc->fault(ctx, 500, "Empty presentity URI"); + return; + } + + if(event.s == NULL || event.len == 0) { + LM_ERR("empty event parameter\n"); + rpc->fault(ctx, 500, "Empty event parameter"); + return; + } + LM_DBG("uri '%.*s' - event '%.*s'\n", pres_uri.len, pres_uri.s, + event.len, event.s); + + if(ki_pres_update_watchers(NULL, &pres_uri, &event)<0) { + rpc->fault(ctx, 500, "Processing error"); + return; + } +} + +static const char *rpc_presence_update_watchers_doc[2] = { + "Trigger update of watchers", 0}; + + void rpc_presence_cleanup(rpc_t *rpc, void *c) { LM_DBG("rpc_presence_cleanup:start\n"); @@ -1749,6 +1792,8 @@ rpc_export_t presence_rpc[] = { {"presence.cleanup", rpc_presence_cleanup, rpc_presence_cleanup_doc, 0}, {"presence.refreshWatchers", rpc_presence_refresh_watchers, rpc_presence_refresh_watchers_doc, 0}, + {"presence.updateWatchers", rpc_presence_update_watchers, + rpc_presence_update_watchers_doc, 0}, {0, 0, 0, 0}}; static int presence_init_rpc(void)