jWdZddlZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z  ddlZdZn#e$rdZdZYnwxYwddlmZmZddlmZmZmZmZejeZGd d eZd Zd Zd Z dZ!gdZ"dZ#de$de e$e$ffdZ%de$de$de&fdZ'de(fdZ)de(fdZ*de(fdZ+GddeZ,de-dzfdZ.ddddde$de$de e$d e e e$d!e(de e$e ff d"Z/d$d#Z0dS)%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 SendResultceZdZdZdS)_FatalStreamErrorz>2299;;!3'!3!344 .u.. //rmessagecontextct|tkr/td|t|t|dtdS)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_bodyr3ns_  7||((( E S\\#5    &&& ' . .w 7 77rctsdStjdd}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: u IlB ' ' - - / /E ;;rct|dipi}|dptjdd}t |S)z;Validate that the configured ntfy platform has a topic set.extrar;r5r6)getattrgetr8r9r:configr>r;s rvalidate_configrCsF FGR ( ( .BE IIg   =")L""="=E ;;rct|dipi}tjdp|dd}t |S)z6Check whether ntfy is configured (env or config.yaml).r>r5r;r6)r?r8r9r@r:rAs r is_connectedrEsF FGR ( ( .BE Il # # =uyy"'='=E ;;rc 4eZdZdZeZdeffd ZdefdZddZ de d e e e fddfd Z dd Z d e e efddfd Zde defdZ dde de dee dee e efdef dZdde ddfdZde 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|||jpi}|dpt jdtd|_ |dpt jdd|_ |d pt jd dp|j |_ |d pt jd d|_ d|_ d|_i|_dS) 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   <y*N;; &++ !99W--L<1L1L IIo & & y-r22 {  !99W--L<1L1L 48;?13rr c,Kts"td|jdS|js"td|jdS t jd|_tj | |_ | t d|j|j|jdS#t$r,}td|j|Yd}~dSd}~wwxYw) z 6 R R R F )$$*1133  LL&s7|| EEEE (  = = = IGY/ 6 6 6  555III 6%$)      3TYtCRCyQQQ!!-00000000000sAE6F  F rctj}t|jtkr4|tz fd|jD|_||jvrdS||j|<dS)zHReturn True if this message ID was already seen within the dedup window.c(i|]\}}|k ||Srr).0kvcutoffs r z-NtfyAdapter._is_duplicate..ms+"^"^"^DAqSTW]S]S]1aS]S]S]rTF)rrr/r[DEDUP_MAX_SIZEDEDUP_WINDOW_SECONDSitems)r\rrrs @rrzNtfyAdapter._is_duplicatehsikk t" # #n 4 4//F"^"^"^"^D4G4M4M4O4O"^"^"^D  T( ( (4&)F#urrcontentreply_tometadatac K|pi}|dp|jp|}|jstddS|jd|}|jjpidd}i|ddi}|rd |d <t||j kr4t d |j t||j |d |j } |j || d |dd {V} | jdkr | } | dpt#jjd d} n0#t($r#t#jjd d} YnwxYwtd| S| j} t d|j | j| d dtdd| jd| d dS#t,j$rtddcYSt($rI}td|j |tdt3|cYd }~Sd }~wwxYw)z2Publish a message to the configured publish topic.rNFzHTTP client not initialized)successrjrMmarkdown Content-Typetext/plain; charset=utf-8true X-Markdownz7[%s] Message truncated from %d to %d chars (ntfy limit)Nr.r)rr|r`rr T)rrz[%s] Send failed HTTP %d: %szHTTP : zTimeout publishing to ntfyz[%s] Send error: %s)r@rWrZrrUrBr>ror/r0r1r2rapostr'rrrrrrirrbTimeoutExceptionrjstr)r\rrrrrNr{markdown_enabledr|bodyrespdata returned_id body_textrks rsendzNtfyAdapter.sendvs>r _55W9LWPW   Re3PQQQ Q// // K-388UKKWT''))W>;VWW  +$*GL ! w<<$1 1 1 NNI 3w<<)@   ///0 ;*//T[[117D0D#%%899;;D"&((4.."IDJLL4DSbS4IKK 888"&*,,"23B3"7KKK8!$;GGGG I NN949dFVXabfcfbfXg h h he3`4;K3`3`yY]Z]Y]3`3`aaa a% Q Q Qe3OPPP P P P ; ; ; LL. 1 = = =e3q66::: : : : : : : ;sQ(AH+A E54H5*F"H!F""H6AH J2 J;>I?9J?Jc KdS)z(ntfy does not support typing indicators.Nr)r\rrs r send_typingzNtfyAdapter.send_typings  rcK|ddS)z&Return basic info about an ntfy topic.r)ratyper)r\rs r get_chat_infozNtfyAdapter.get_chat_infos...rc*t|jS)z4Build Authorization header if a token is configured.)r*rXrs rrozNtfyAdapter._auth_headerss!$+...rr N)NNN)rrrrr0r rRr:rlrfrrrtrrrrrrrrrro __classcell__)r]s@rrGrGs ,3~3333332t&B.2.2tCH~.2$.2.2.2.2`4444,11tCH~11$11111111j C D    $#'-1 -;-;-;-;3- -; 4S>* -;  -;-;-;-;^       /3/4S>//// /tCH~////////rrGctjdd}|sdS|tjdtdd}tjdd}|r||d<tjd d}|r||d <tjd d}|r|d v|d <tjddp|}|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)rra home_channel)r8r9r$rSrTlower)r;seedrNrrhomes r_env_enablementrsR IlB ' ' - - / /E t)-~>>EEcJJDI2B77==??M. -_ IlB ' ' - - / /E W y"--3355;;==H<#';;Z 9(" - - 3 3 5 5 >D  I6==  ^ Kr) thread_id media_filesforce_documentrrrrcKtsddiSt|dipi}|dptjdt d}|pw|dpbtjdd p;|d p&tjd d }|sdd iS|d ptjdd } tjdd } t|dp| dv} ddit| } | rd| d<t|d} |d|} tj d4d{V}||| | d{V}dddd{Vn#1d{VswxYwY|jdkrdd|jd|jddiS |}|d pt%jjdd!}n0#t*$r#t%jjdd!}YnwxYwd"d#||d$S#t*$r}dd%|icYd}~Sd}~wwxYw)&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. rjz)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:r*r3rbrcrrrrrrrri)pconfigrr+rrrr>rKrNr markdown_envrr|rr{clientrrrrks r_standalone_sendrs* FDEE GWb ) ) /RE ( 8 9& 7 7 fSkk  / 99_ % % / 9)2 . . 4 4 6 6 / 99W   / 9\2 & & , , . .  LJKK IIg   =")L""="=E9_b117799??AALEIIj1122ZlFZ6Z:X>PQV>W>WXG' &  '+< = = =D  % %m % %C >$T222 I I I I I I IfS$HHHHHHHHD I I I I I I I I I I I I I I I I I I I I I I I I I I I  s " "O$*:OOdioOOP P +99;;DXXd^^>><<<=======>sgJ%:G+J%+ G55J%8G59)J%$A I.-J%.*JJ%J J%% K/J;5K;Kc|dddtttdgdtdt ddt dd d d d S) uEPlugin entry point — called by the Hermes plugin system at startup.rIc t|Sr)rG)cfgs rzregister..%sK$4$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.)ralabeladapter_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 sn 44#'!"^H*1..,-! 7=$$$$$rr)1rrdrloggingr8rrrrrtypingrrrrrbr7 ImportErrorgateway.configr r gateway.platforms.baser r r r getLoggerrr1rirrSr0rrrvrrr*bytesr3r:r<rCrErGdictrrrrrrrs,,\  '''''''',,,,,,,,,,,,LLLOOO EEE43333333  8 $ $GGGGG GGG#&&&0c0d38n00000 8C 8S 8U 8 8 8 8 D    tDZ/Z/Z/Z/Z/%Z/Z/Z/D #####V $'+ >>>>>> >>>> } >> $s)$ >>>> #s(^>>>>>>>>B&&&&&&s7 AA