Mercurial > prosody-modules
changeset 5148:bf42f1401f1c
mod_unified_push: Refactor in anticipation of other registration backends
author | Matthew Wild <mwild1@gmail.com> |
---|---|
date | Fri, 13 Jan 2023 16:50:43 +0000 (23 months ago) |
parents | 658658ea9323 |
children | fa56ed2bacab |
files | mod_unified_push/mod_unified_push.lua |
diffstat | 1 files changed, 24 insertions(+), 7 deletions(-) [+] |
line wrap: on
line diff
--- a/mod_unified_push/mod_unified_push.lua Fri Jan 13 16:41:48 2023 +0000 +++ b/mod_unified_push/mod_unified_push.lua Fri Jan 13 16:50:43 2023 +0000 @@ -4,6 +4,7 @@ local base64 = require "util.encodings".base64; local datetime = require "util.datetime"; local id = require "util.id"; +local jid = require "util.jid"; local jwt = require "util.jwt"; local st = require "util.stanza"; local urlencode = require "util.http".urlencode; @@ -54,6 +55,19 @@ return ok, result; end +local function register_route(params) + local expiry = os.time() + push_registration_ttl; + return { + url = module:http_url("push").."/"..urlencode(jwt_sign(unified_push_secret, { + instance = params.instance; + application = params.application; + sub = params.jid; + exp = expiry; + })); + expiry = expiry; + }; +end + -- Handle incoming registration from XMPP client function handle_register(event) local origin, stanza = event.origin, event.stanza; @@ -68,17 +82,20 @@ if not application then return st.error_reply(stanza, "modify", "bad-request", "application: "..application_err); end - local expiry = os.time() + push_registration_ttl; - local url = module:http_url("push").."/"..urlencode(jwt_sign({ + local route = register_route({ instance = instance; application = application; - sub = stanza.attr.from; - exp = expiry; - })); + jid = stanza.attr.from; + }); + + if not route then + return st.error_reply(stanza, "wait", "internal-server-error"); + end + module:log("debug", "New push registration successful"); return origin.send(st.reply(stanza):tag("registered", { - expiration = datetime.datetime(expiry); - endpoint = url; + expiration = datetime.datetime(route.expiry); + endpoint = route.url; xmlns = xmlns_up; })); end