`gjYdZddlZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z  ddlZdZddlmZmZddlmZmZmZmZej2eZGd d eZd Zd Zd Z dZ!gdZ"dZ#dZ$de%de e%e%ffdZ&de%de%de'fdZ(de)fdZ*de)fdZ+de)fdZ,GddeZ-de.dzfdZ/ddddde%de%d e e%d!e e e%d"e)de e%e ff d#Z0d%d$Z1y#e$rdZdZYwxYw)&ulntfy platform adapter (Hermes plugin). Subscribes to a topic on ntfy.sh or any self-hosted ntfy server via HTTP streaming (``/json`` endpoint with ``poll=false``) and publishes replies via HTTP POST. No external SDK — only httpx, which is already a Hermes dependency. This adapter ships as a Hermes platform plugin under ``plugins/platforms/ntfy/``. The Hermes plugin loader scans the directory at startup, calls :func:`register`, and the platform becomes available to ``gateway/run.py`` and ``tools/send_message_tool`` through the registry — no edits to core files required. Configuration in config.yaml:: platforms: ntfy: enabled: true extra: server: "https://ntfy.sh" # or self-hosted URL topic: "hermes-in" # subscribe topic (incoming) publish_topic: "hermes-out" # optional — defaults to topic token: "..." # optional Bearer / Basic auth token markdown: true # optional — enable markdown (default: false) Environment variables (all read at adapter construct time, env wins over config.yaml ``extra``): NTFY_TOPIC Topic to subscribe to (required) NTFY_SERVER_URL Server URL (default: https://ntfy.sh) NTFY_TOKEN Bearer token or 'user:pass' for Basic auth NTFY_PUBLISH_TOPIC Reply topic (defaults to NTFY_TOPIC) NTFY_MARKDOWN "true"/"1"/"yes" enables X-Markdown header NTFY_ALLOWED_USERS Allowlist (treated by gateway as user IDs; on ntfy these are topic names) NTFY_ALLOW_ALL_USERS Allow any topic — dev only NTFY_HOME_CHANNEL Default topic for cron / notification delivery NTFY_HOME_CHANNEL_NAME Human label for the home channel Identity model: ntfy has no native authenticated user identity. The ``title`` field is publisher-controlled and is NOT used for authorization. Each topic is treated as a single trusted channel — ``user_id`` is fixed to the topic name. Use a private topic protected by a read token for any real trust boundary. N)datetimetimezone)AnyDictListOptionalTF)PlatformPlatformConfig)BasePlatformAdapter MessageEvent MessageType SendResultceZdZdZy)_FatalStreamErrorz299;6'!344 wug. //rmessagecontextct|tkDr%tjd|t|t|dtj dS)zApply the ntfy 4096-char limit, logging a warning on truncation. ``context`` is included in the log message so adapter and standalone truncations can be told apart in logs. z7%s: truncating message from %d to %d chars (ntfy limit)Nutf-8)lenMAX_MESSAGE_LENGTHloggerwarningr')r+r,s r_truncate_bodyr3osH  7|(( E S\#5  && ' . .w 77rcntsytjddj}t |S)zCheck whether the ntfy adapter is installable and minimally configured. Reads ``NTFY_TOPIC`` directly to avoid the cost of a full ``load_gateway_config()`` (which also writes to ``os.environ``) on every pre-flight check. F NTFY_TOPIC)HTTPX_AVAILABLEosgetenvr$bool)topics rcheck_requirementsr<}s-  IIlB ' - - /E ;rct|dixsi}|jdxstjdd}t |S)z;Validate that the configured ntfy platform has a topic set.extrar;r5r6)getattrgetr8r9r:configr>r;s rvalidate_configrCs= FGR ( .BE IIg  ="))L""=E ;rct|dixsi}tjdxs|jdd}t |S)z6Check whether ntfy is configured (env or config.yaml).r>r5r;r6)r?r8r9r@r:rAs r is_connectedrEs= FGR ( .BE IIl # =uyy"'=E ;rc eZdZdZeZdeffd ZdddedefdZdd Z d e d e e e fdd fd Z ddZ de e efdd fdZde defdZ dde de dee dee e efdef dZdde dd fdZde de e effdZde e e ffdZxZS) NtfyAdapteruntfy adapter. Subscribes to a topic via HTTP streaming (``/json`` endpoint) and publishes replies via HTTP POST. No external SDK — only httpx. rBc:td}t| |||jxsi}|j dxst j dtjd|_ |j dxst j dd|_ |j d xs$t j d dxs |j|_ |j d xst j d d|_ d|_ d|_i|_y) Nntfy)rBplatformserverNTFY_SERVER_URL/r;r5r6 publish_topicNTFY_PUBLISH_TOPICr NTFY_TOKEN)r super__init__r>r@r8r9DEFAULT_SERVERrstrip_server_topic_publish_topic_token _stream_task _http_client_seen_messages)selfrBrJr> __class__s rrRzNtfyAdapter.__init__sF# : " IIh  <yy*N; &+ !99W-L<1L IIo & yy-r2 {{  !99W-L<1L 48;?13rF) is_reconnectr^r c6Kts!tjd|jy|js!tjd|jy t j d|_tj|j|_ |jtjd|j|j|jy#t$r+}tj!d|j|Yd}~yd}~wwxYww) z 2?* 2N++25?* 2* 2* 2* 2* 2sAG)FG) CG G$F"%G(G6 G)F$G)GF&0GGF?GG)"G$G)&F<9G;F<<GG G) GG)G&G G&"G)cKd|_|j|jr6|jj |jd{d|_|j r)|j jd{d|_|jjtjd|jy7{#tj $rYwxYw7aw)zDisconnect from ntfy.FNz[%s] Disconnected) rq_mark_disconnectedrYcancelrervrZacloser[clearr1rirbr\s r disconnectzNtfyAdapter.disconnects  !       $ $ & ''''!%D    ##**, , , $D  !!# '3())   -sH>C)CC C0C)C'AC) CC$!C)#C$$C)rcTK|jdxstjj}|j |r"t j d|j|y|jdxsg}t|vr!t j d|jy|jdxsdj}|s!t j d|jy|jd xs |j}|}|}|j||d || }|jd } | r.tjt| tj n#tj"tj } t+|t,j.|||| } t j d|j||dd|j1| d{y#t$t&t(f$r'tj"tj } YwxYw7Cw)z'Process an incoming ntfy message event.idz#[%s] Duplicate message %s, skippingNtagsz$[%s] Skipping own message (echo tag)r+r6z![%s] Empty message body, skippingr;dm)chat_id chat_name chat_typeuser_id user_namers)tz)text message_typesource message_id raw_message timestampz[%s] Message on topic %s: %sP)r@uuiduuid4hex _is_duplicater1rrrb _ECHO_TAGr$rV build_sourcer fromtimestampintrutcnow ValueErrorOSError TypeErrorr r TEXThandle_message) r\rmsg_idrrr;rrrunix_tsr message_events rrzNtfyAdapter._on_message4s44DJJL$4$4   f % LL> 6 R yy &B   LL? K  )$*113 LLrprr/r0r1r2rbpostr'rrrrrrjrrcTimeoutExceptionrkstr)r\rrrrrNr|markdown_enabledr}bodyrespdata returned_id body_textrls rsendzNtfyAdapter.send}s`>r _5W9L9LWPW   e3PQ Qa / KK--388UK   " 7  $*GL ! w<$11 1 NNI 3w<)@)@ ///0 ;**//T[[17D0D#%899;D"&((4."IDJJL4D4DSb4IK"$;GG I NN9499dFVFVXabfcfXg heU4;K;K:LByY]Z]N_3`a a!8"&**,"2"23B"7K8 %% Qe3OP P ; LL. 1 =e3q6: : ;sC* 1;  1;f   /3/4S>/ /tCH~/rrGcZtjddj}|sy|tjdtj dd}tjddj}|r||d<tjd dj}|r||d <tjd djj }|r|d v|d <tjddjxs|}|r|tjd|d|d<|S)u]Seed ``PlatformConfig.extra`` from env vars during gateway config load. Called by the platform registry's env-enablement hook BEFORE adapter construction, so ``gateway status`` and ``get_connected_platforms()`` reflect env-only configuration without instantiating the HTTP client. Returns ``None`` when ntfy isn't minimally configured; the caller skips auto-enabling. The special ``home_channel`` key in the returned dict is handled by the core hook — it becomes a proper ``HomeChannel`` dataclass on the ``PlatformConfig`` rather than being merged into ``extra``. r5r6NrLrM)r;rKrOrNrPr NTFY_MARKDOWN1ryesrNTFY_HOME_CHANNELNTFY_HOME_CHANNEL_NAME)rrb home_channel)r8r9r$rSrTlower)r;seedrNrrhomes r_env_enablementrs IIlB ' - - /E ))-~>EEcJDII2B7==?M -_ IIlB ' - - /E W yy"-335;;=H#';;Z 99(" - 3 3 5 >D II6= ^ Kr) thread_id media_filesforce_documentrrrrc`KtsddiSt|dixsi}|jdxstjdt j d}|xsp|jdxs]tjdd jxs7|jd xs$tjd d j}|sdd iS|jd xstjdd } tjdd jj} t|jdxs| dv} dtdt| } | rd| d<t|d} |d|} tjd4d{}|j|| | d{}dddd{j dk\r!dd|j d|j"ddiS |j%}|jd xs!t'j(j*dd!}d"d#||d$S777#1d{7swYxYw#t,$r$t'j(j*dd!}YNwxYw#t,$r}dd%|icYd}~Sd}~wwxYww)&u9Out-of-process publish for cron / send_message_tool fallbacks. Used by ``tools/send_message_tool._send_via_adapter`` and the cron scheduler when the gateway runner is not in this process (e.g. ``hermes cron`` running standalone). Without this hook, ``deliver=ntfy`` cron jobs fail with ``No live adapter for platform``. ``thread_id`` and ``media_files`` are accepted for signature parity only — ntfy has no thread or attachment primitive. Markdown is honored if ``NTFY_MARKDOWN`` is set OR ``pconfig.extra["markdown"]`` is True. rkz)ntfy standalone send: httpx not installedr>rKrLrMrNrOr6r;r5z/ntfy standalone send: NTFY_TOPIC not configuredrrPrrrrrrrzntfy standalone)r,rr`N)rr}rz ntfy HTTP rrrrTrI)rrJrrzntfy standalone send failed: )r7r?r@r8r9rSrTr$rr:rr*r3rcrdrrrrrrrrj)pconfigrr+rrrr>rKrNr markdown_envrr}rr|clientrrrrls r_standalone_sendrs* DEE GWb ) /RE ( 8 99& 7 fSk  / 99_ % / 99)2 . 4 4 6 / 99W  / 99\2 & , , .  JKK IIg  ="))L""=E99_b1779??ALEIIj12ZlFZ6Z:imSefkSlmG &  '+< =D HAm_ %C >$$T2 I IfS$HHD I I   s "z$*:*:);2diio=NOP P +99;DXXd^8<==>sEzregister..0s K$4rr5z1pip install httpx # already a Hermes dependencyrNTFY_ALLOWED_USERSNTFY_ALLOW_ALL_USERSu🔔Tu You are communicating via ntfy push notifications. Use plain text by default — ntfy supports optional markdown (set markdown: true in config or NTFY_MARKDOWN=true). Keep responses concise; ntfy is a push notification service with a 4096-character per-message limit.)rblabeladapter_factorycheck_fnrCrE required_env install_hintenv_enablement_fncron_deliver_env_varstandalone_sender_fnallowed_users_env allow_all_envmax_message_lengthemojipii_safeallow_update_command platform_hintN)register_platformr<rCrErrr0)ctxs rregisterr+sW 4#'!"^H*1..,-! 7=$rr)2rrerloggingr8rsrrrtypingrrrrrcr7 ImportErrorgateway.configr r gateway.platforms.baser r r r getLoggerrr1rjrrSr0rrrwrrrr*bytesr3r:r<rCrErGdictrrrrrrrs,\  ',,O 4   8 $G G#&  0c0d38n00 8C 8S 8U 8 D tDd/%d/X ##V $'+ >> >>>> } >> $s)$ >>>> #s(^>>B&aO EsC C('C(