send more metadata to ntfy clients

frontend.py

@@ -43,6 +43,7 @@
     get_user_assets,
     is_within_timeframe,
     login_required,
+    parse_asset,
 )
 from util.redis import REDIS
 from util.sso import DEFAULT_SSO_PROVIDER, SSO_CONFIG
@@ -457,7 +458,7 @@ def content_request_review(asset_id):
         moderation_message += f"Check it at {moderation_url}"
 
     n = Notifier()
-    n.message(moderation_message)
+    n.message(moderation_message, asset=parse_asset(asset))
 
     return jsonify(ok=True)
 

notifier.py

@@ -2,9 +2,11 @@
 from logging import getLogger
 
 import paho.mqtt.client as mqtt
+from flask import url_for
 from requests import post
 
 from conf import CONFIG
+from util import cached_asset_name
 
 LOG = getLogger("Notifier")
 
@@ -22,7 +24,7 @@ def __init__(self):
                     self.config["MQTT_USERNAME"], self.config["MQTT_PASSWORD"]
                 )
 
-    def message(self, message, level="INFO", component=None):
+    def message(self, message, level="INFO", component=None, asset=None):
         LOG.debug(f"{message=} {level=} {component=}")
         if self.mqtt:
             try:
@@ -32,7 +34,7 @@ def message(self, message, level="INFO", component=None):
 
         for ntfy_url in self.config.get("NTFY", set()):
             try:
-                self._ntfy_message(ntfy_url, message)
+                self._ntfy_message(ntfy_url, message, asset)
             except Exception:
                 LOG.exception(f"ntfy url {ntfy_url} failed sending")
 
@@ -59,12 +61,22 @@ def _mqtt_message(self, message, level, component_suffix):
 
         LOG.info("sent mqtt message")
 
-    def _ntfy_message(self, ntfy_url, message):
+    def _ntfy_message(self, ntfy_url, message, asset):
         LOG.info(f"sending alert to {ntfy_url} with message {message!r}")
 
+        headers = {}
+        if asset is not None:
+            headers["Click"] = url_for(
+                "content_moderate", asset_id=asset.id, _external=True
+            )
+            headers["Attach"] = url_for(
+                "static", filename=cached_asset_name(asset), _external=True
+            )
+
         r = post(
             ntfy_url,
             data=str(message).encode("utf-8"),
+            headers=headers,
         )
         r.raise_for_status()