prosody: mod_sane_ntfy: hook to detect jingle calls

hosts/by-name/servo/services/prosody/default.nix

@@ -239,7 +239,7 @@ in
       # legacy coturn integration
       # see: <https://modules.prosody.im/mod_turncredentials.html>
       # "turncredentials"
-      "sane_hello"
+      "sane_ntfy"
     ] ++ lib.optionals enableDebug [
       "stanza_debug"  #< logs EVERY stanza as debug: <https://prosody.im/doc/modules/mod_stanza_debug>
     ];

hosts/by-name/servo/services/prosody/modules/mod_sane_hello.lua

@@ -1,4 +0,0 @@
--- simple proof-of-concept Prosody module
--- module development guide: <https://prosody.im/doc/developers/modules>
--- module API docs: <https://prosody.im/doc/developers/moduleapi>
-module:log("info", "Hello world!");

hosts/by-name/servo/services/prosody/modules/mod_sane_ntfy.lua

@@ -0,0 +1,37 @@
+-- simple proof-of-concept Prosody module
+-- module development guide: <https://prosody.im/doc/developers/modules>
+-- module API docs: <https://prosody.im/doc/developers/moduleapi>
+--
+-- much of this code is lifted from Prosody's own `mod_cloud_notify`
+
+local jid = require"util.jid";
+
+module:log("info", "initialized");
+
+local function is_urgent(stanza)
+  if stanza.name == "message" then
+    if stanza:get_child("propose", "urn:xmpp:jingle-message:0") then
+      return true, "jingle call";
+    end
+  end
+end
+
+
+local function archive_message_added(event)
+  -- event is: { origin = origin, stanza = stanza, for_user = store_user, id = id }
+  local stanza = event.stanza;
+  local to = stanza.attr.to;
+  to = to and jid.split(to) or event.origin.username;
+
+  -- only notify if the stanza destination is the mam user we store it for
+  if event.for_user == to then
+    local is_urgent_stanza, urgent_reason = is_urgent(event.stanza);
+
+    if is_urgent_stanza then
+      module:log("info", "Urgent push for %s (%s) (TODO: bridge to ntfy)", to, urgent_reason);
+    end
+  end
+end
+
+
+module:hook("archive-message-added", archive_message_added);