,jdZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z ddl mZmZmZmZddlmZmZddlmZmZmZmZejeZdZd Zd Zd Z d Z!d Z"de#dee#fdZ$de#de#fdZ%de&de#fdZ'de#de(fdZ)de#de(fdZ*GddeZ+de(fdZ,de(fdZ-de(fdZ.dee/fdZ0ddddd e#d!e#d"ee#d#eee#d$e(dee#eff d%Z1d(d&Z2d(d'Z3dS))uP SimpleX Chat platform adapter (Hermes plugin). Connects to a simplex-chat daemon running in WebSocket mode. Inbound messages arrive via a persistent WebSocket connection. Outbound messages use the same WebSocket with JSON commands. This adapter ships as a Hermes platform plugin under ``plugins/platforms/simplex/``. The Hermes plugin loader scans the directory at startup, calls ``register(ctx)``, and the platform becomes available to ``gateway/run.py`` and ``tools/send_message_tool`` through the registry — no edits to core files are required. SimpleX chat daemon setup: simplex-chat -p 5225 # start daemon on port 5225 # or via Docker: # docker run -p 5225:5225 simplexchat/simplex-chat-cli -p 5225 Required environment variables: SIMPLEX_WS_URL WebSocket URL of the daemon (default: ws://127.0.0.1:5225) Optional environment variables: SIMPLEX_ALLOWED_USERS Comma-separated allowlist. Each entry may be either a numeric contactId (stable across renames; visible via `/contacts` in the CLI) or a contact display name (what the SimpleX UI shows). Both forms are accepted. SIMPLEX_ALLOW_ALL_USERS Set 'true' to allow all contacts SIMPLEX_AUTO_ACCEPT Set 'false' to disable contact-request auto-accept (default: 'true') SIMPLEX_GROUP_ALLOWED Comma-separated group IDs to monitor, or '*' for any group. Omit to disable groups entirely. SIMPLEX_HOME_CHANNEL Default contact/group ID for cron delivery SIMPLEX_HOME_CHANNEL_NAME Human label for the home channel HERMES_SIMPLEX_TEXT_BATCH_DELAY Quiet-period seconds (default: 0.8) used to concatenate rapid-fire inbound text messages into a single MessageEvent — same pattern as Telegram's text batching. The ``websockets`` Python package is imported lazily — the plugin is discoverable and ``hermes setup`` can describe it even when websockets is not installed. ``check_requirements()`` returns False until the package is present, so the gateway will not attempt to instantiate the adapter. N)datetimetimezone)Path)AnyDictListOptional)PlatformPlatformConfig)BasePlatformAdapter MessageEvent MessageType SendResulti@g@gN@>@gr@zhermes-valuereturnc@d|dDS)z4Split a comma-separated string into a stripped list.c^g|]*}||+S)strip).0vs F/home/ubuntu/.hermes/hermes-agent/plugins/platforms/simplex/adapter.py z%_parse_comma_list..[s- = = =!17799 =AGGII = = =,)split)rs r_parse_comma_listrYs" = =u{{3// = = ==r contact_idc|sdSt|}t|dkr|S|dddz|ddzS)z&Redact a contact/group ID for logging.zNz**)strlen)rss r _redact_idr'^sM x JA 1vv{{ RaR54r,r+r*.jpegr/lowerr6s r _is_image_extr<}s 99;;D DDrc.|dvS)N>.aac.m4ar4r0.wav.opusr9r;s r _is_audio_extrBs 99;;K KKrc eZdZdZeZdeffd ZdefdZd0dZ d0dZ d0d Z d e ddfd Z d e ddfd Zd edefdZd eddfdZdeddfdZdefdZde ddfdZ d1dededee fdZdeddfdZ d2dededeedeeeefdef dZededeeeffd Z d3ded!ed"eedefd#Z! d2ded$ed"eedeedef d%Z" d2ded&ed"eedeedef d'Z# d2deded"eed(eedef d)Z$ d4ded+ed"eedeed,e%def d-Z&d3deddfd.Z'dedeeeffd/Z(xZ)S)5SimplexAdapterzSimpleX Chat adapter using the simplex-chat daemon WebSocket API. Instantiated by the ``adapter_factory`` passed to ``ctx.register_platform()`` in :func:`register`. configc td}t||t|dipi}|ddd|_tjd}|.| dv|_ n(t|d d |_ tjd d p|d d }tt||_d|_d|_d|_d|_d|_t|_d|_i|_i|_d|_t5tjdd|_i|_i|_t<d|j|j |jrdnddS)Nsimplex)rEplatformextraws_urlws://127.0.0.1:5225/SIMPLEX_AUTO_ACCEPT>0nofalse auto_acceptTSIMPLEX_GROUP_ALLOWEDrN group_allowedFgrHERMES_SIMPLEX_TEXT_BATCH_DELAYz0.8z@"' I7 ? ?" " ?A"BD& J K  . >IIJ      rrc0K ddl}n+#t$rtdYdSwxYw|jstddS ddl}||jd4d{V dddd{Vn#1d{VswxYwYn9#t $r,}td|j|Yd}~dSd}~wwxYwd |_tj|_ tj | |_ tj ||_t!|d r|td |jd S) zDConnect to the simplex-chat daemon and start the WebSocket listener.rNzHSimpleX: 'websockets' package not installed. Run: pip install websocketsFz#SimpleX: SIMPLEX_WS_URL is required ) open_timeoutz&SimpleX: cannot reach daemon at %s: %sT_mark_connectedzSimpleX: connected to %s) websockets ImportErrorrqerrorrJconnect Exceptionrftimergasyncio create_task _ws_listenerrd_health_monitorrehasattrr{rr)rsr| _wsclientes rrzSimplexAdapter.connects7          LL.   55  {  LL> ? ? ?5  * * * * ((2(FF                                       LLA4;PQ R R R55555  !%+D,=,=,?,?@@ #/0D0D0F0FGG 4* + + #  " " " . <<<tsH $11&B$>BB$ BB$B B$$ C.!CCNcKd|_|jr=|j |jd{Vn#tj$rYnwxYw|jr=|j |jd{Vn#tj$rYnwxYw|jr8 |jd{Vn#t$rYnwxYwd|_t|j D]*}| s|+|j |j |j D]*}| s|+|j t!|dr|t$ddS)z%Stop WebSocket listener and clean up.FN_mark_disconnectedzSimpleX: disconnected)rfrdcancelrCancelledErrorrerccloserlistrpvaluesdoneclearrorkrrrqrr)rstaskfuts r disconnectzSimplexAdapter.disconnects8 =  M " " " m########)          $ $ & & & ''''''''')     8  hnn&&&&&&&&&&    DH7>>@@AA  D99;;   &,,... "((****1133  C88::   %%''' 4- . . &  # # % % % +,,,,,s3 9A  A / A==BBB:: CCcKddl}ddlm}t}|jrR t d|j||jddd4d{V }||_ t}tj |_ t d|23d{V}|jsntj |_ tj|}||d{VY#tj$rt d |Yt"$rt d YwxYw6 dddd{Vn#1d{VswxYwYn#t&j$r Yd|_ dS|$r-}|jrt d ||Yd}~n=d}~wt"$r-}|jrt d ||Yd}~nd}~wwxYwd|_ n #d|_ wxYw|jrN|d zt-jz}t'j||zd{Vt1|dzt2}|jPdSdS)z9Maintain a persistent WebSocket connection to the daemon.rN)ConnectionClosedzSimpleX WS: connecting to %sry) ping_interval ping_timeout close_timeoutzSimpleX WS: connectedz SimpleX WS: invalid JSON: %.100sz SimpleX WS: error handling eventz9SimpleX WS: connection closed: %s (reconnecting in %.0fs)z8SimpleX WS: unexpected error: %s (reconnecting in %.0fs)g?r")r|websockets.exceptionsrWS_RETRY_DELAY_INITIALrfrqdebugrJrrcrrgrrjsonloads _handle_eventJSONDecodeErrorr exceptionrrwarningrandomsleepminWS_RETRY_DELAY_MAX) rsrrbackoffwsrawmsgrjitters rrzSimplexAdapter._ws_listener#s&&&&::::::(m. ?(  ;T[III$,,K"$!#"$ -QQQQQQQQ !DH4G-1Y[[D*KK 7888%' Q Q Q Q Q Q Qc#}"!E15.Q"&*S//C"&"4"4S"9"999999999#3RRR"LL)KSQQQQQ(QQQ",,-OPPPPPQ&(RQQQQQQQQQQQQQQQQQQQQQQQQQQQ.)    $   =NNS7   =NNR7  4} ? 38mGf$4555555555gk+=>>]m. ?. ?. ?. ?. ?sAE9"AE'%E+"E'/C>=E'>*E(E'*#E E'EE'E9' E11E94E15E98H9G8HG8#F>9H> G8 #G3.H3G88H H cK|jrrtjtd{V|jsdSt j|jz }|t krtd||jpdSdS)aObserve WebSocket idleness without reconnecting healthy quiet links. simplex-chat can legitimately stay application-silent for long periods when no messages arrive. The websockets client already sends protocol pings (see _ws_listener ping_interval/ping_timeout), so treating lack of chat events as a stale connection causes needless reconnect churn. Nz&SimpleX: WS application-idle for %.0fs) rfrrHEALTH_CHECK_INTERVALrrgHEALTH_CHECK_STALE_THRESHOLDrqr)rselapseds rrzSimplexAdapter._health_monitor^sm P- 566 6 6 6 6 6 6 6= ikkD$::G555 EwOOO m P P P P Preventc" Kt|dtr|dn|}|d}|rN||jvrE|j|}|s||dS|rKt|tr6|tr|j |dS|dp|dd}|dkr|j r|dipi}|d}|Stdtt||d |d{VdS|d kr|d ipi}t|tr|d nd} | 9td | |d| d{VdS|dkr}|dgpg} t| t&s| g} | D]H} || d{V#t*$rtdYEwxYwdS|dkrI ||d{Vn*#t*$rtdYnwxYwdS|dkr`|dipi} | dipi} | dipi}t|tr|d nd} | | |jvr|j| }|dipi}t|tr|dnd}|r|dipi}d|i|did<||d< ||d{Vn*#t*$rtdYnwxYwdS|rtd|dSdS)z3Dispatch a daemon event to the appropriate handler.respcorrIdNtyperNcontactRequestcontactRequestIdz*SimpleX: auto-accepting contact request %sz/accept rcvFileDescrReadyrcvFileTransferfileIdu>SimpleX: rcvFileDescrReady for fileId=%s — sending /freceive /freceive newChatItems chatItemsz#SimpleX: error processing chat item newChatItemrcvFileCompletechatItemfile fileSourcefilePathz/SimpleX: error processing deferred file messagez!SimpleX: unhandled event type: %s) isinstancer\dictrkpopr set_resultr$ startswith _CORR_PREFIXrhdiscardrRrqrrr' _send_commandr_send_fire_and_forgetr_handle_chat_itemrrrj setdefault)rsrrcorr_idr resp_type contact_reqcontact_req_idrcv_filefile_id chat_itemsitem chat_itemchat_item_data file_infopending file_source file_pathpending_item_datas rrzSimplexAdapter._handle_eventrsw %/uyy/@/@$$G$GRuyy   U))H%%  w$"999)--g66C88:: %t$$$ F  z'3// G4F4F|4T4T   " * *7 3 3 3 FHHV$$= &"(=(=  ( ( (T-= (((#3R88>BK(__-?@@N) @s>2233(()DN)D)DEEEEEEEEE F + + +xx 1266<"H0:8T0J0JThll8,,,PTG" T001Gg1G1GHHHHHHHHH F  & &+r228bJj$// *(\ " L LL006666666666 LLL$$%JKKKKKL F  % % H,,T2222222222 H H H  !FGGGGG H F ) ) )R006BI&]]:r::@bN&**6266<"I1;It1L1LVimmH---RVG"w$2N'N'N6::7CC'mmL"==C "+t44KOOJ///  (/ J(C(C(Ir%"IN%00<<\J+t@f$r"t3jt:j7}!YnwxYwtC|| pd||||!|8}"t d9t| |d d:| pdd d;|t&jkr| r|"|"d S|#|"d {Vd S)z3SimplexAdapter._handle_chat_item..ps.AAr2==**AAAAAArc3@K|]}|dVdS)rNrrs rr z3SimplexAdapter._handle_chat_item..rs.CCR]]8,,CCCCCCritemTs createdAtZz+00:00)tz)sourcer message_type media_urls media_types timestamp raw_messagez"SimpleX: message from %s in %s: %sr2)$r\rrr$rbrqrr'rsuffixr:rBrrrjrr<appendlstrip build_sourcerTEXTanyVOICEPHOTODOCUMENTr fromisoformatreplacenowrutc ValueErrorAttributeErrorr _enqueue_text_eventhandle_message)#rsr chat_inforrrr msg_contentitem_directiondirection_type content_typer msg_type_str sender_id sender_nameris_groupr group_infogroup_idmemberrrrrr file_namerr6rrmsg_typets_strr msg_events# rrz SimplexAdapter._handle_chat_itemsMM*b117R "z266<"MM&"-- !!&"--3 $$Y339rkk,339r (++Ir::@b.8.N.N VN  vr * * *TV  6 6 6 F3=Wd2K2KSw{{62...QS ? * * F+5k4+H+H PKOOFB ' ' 'b  N N N??62..D  ,FFF F    mmIr228bGGKK R8899I!++&8"==%2BBc-$$  GG ' ! !"{B77=2J:>>)R8899H)x))GH#'' r::@bFFJJz26677I **%7<<% AAc-$$  $ t444 (===LL<"8,,F P LL;Y G G G F  LLC D D D F!# !# "&&v.. ) CIt44) C#-- b99?RKk400  +++  " j"55ImmH--GC 59oo,2244 59 59oo,2244 s!3!3 8K Q9B,W5001Gg1G1GHHHHHHHHH C9oo,22446?GDOO*00222R!%%C%%i000&&'A 3'A'ABBBB"3''C%%i000&&'A 3'A'ABBBB%%i000&&'ABBB  *"{B77=2J"'92>>**..CCc-)) ""!)3ggt!.Y #  #  0AA[AAAAA 0&,CC{CCCCC 0&, '/(##@txx R'@'@ 6 :$26>>#x3P3PQQ $LHL999 N+ 6 6 6  555III 6!!!#!     0 y ! ! CRCL ZR"      {' ' 'D '  $ $Y / / / / /%%i00 0 0 0 0 0 0 0 0 0sA \0]]cB|jjjd|jjS)z-Session-scoped key for text message batching.:)rrHrr)rsrs r_text_batch_keyzSimplexAdapter._text_batch_keys#,'-FF 0DFFFrcD||}|j|}| ||j|<np|jr$|jr|jd|jn|j|_|jr>|j|j|j|j|j|}|r(|s| tj | ||j|<dS)z.Buffer a text event and reset the flush timer.N ) r9ror\rrextendrrprrrr_flush_text_batch)rsrkeyexisting prior_tasks rr%z"SimplexAdapter._enqueue_text_events(""5))-11#66  .3D &s + +z 8@ Ux}44 4445:  ?#**5+;<<<$++E,=>>>377<<  joo//      .5.A  " "3 ' '/ / &s+++rr>cKtj} tj|jd{V|j|d}|s< |j||ur|j|ddSdSt d|t|j pd| |d{V|j||ur|j|ddSdS#|j||ur|j|dwwxYw)zrBrs rr=z SimplexAdapter._flush_text_batchs+--  >- 677 7 7 7 7 7 7 7.223==E -11#66,FF.223=====GF KK=EJ$"%%    %%e,, , , , , , , ,-11#66,FF.223=====GFt-11#66,FF.223====Gs>A E! E!?EE!cnK|}|||dd{VdS)aSend a command without waiting for a correlated response. Use this for commands the daemon never sends a corrId reply for, such as ``/freceive``. Awaiting a corr-id reply on those would stall the event loop for the full command timeout. rUN)rLrQ)rsrRrs rrz$SimplexAdapter._send_fire_and_forgetsK$$&&mmww??@@@@@@@@@@@rrrreply_tometadatacKhd}tjd|}|r(tjdd|}|rz|}|dr+t jdd|dig}d |d d d |} nd |d|} ||| dd {V|D]} tj | d |v} | r| || d {V} n||| d {V} | js| cSt!dS)aMSend a text message. If *content* contains ``MEDIA:`` tags (embedded by TTS / audio tools to signal file attachments), they are stripped from the text body and sent as native voice notes or documents. Groups use the structured ``/_send # json [...]`` form because the bracket chat-command syntax (``#[] text``) is parsed by the daemon as a display-name lookup, which silently drops when the group's display name isn't the literal ID. DMs use the simple ``@ text`` form which has always worked in production. The call is fire-and-forget at the WebSocket level: the daemon doesn't always return a corrId reply for chat commands, and waiting for one would serialise all outbound traffic behind a 30-second timeout. >r?r4r0r@rAz MEDIA:(\S+)z MEDIA:\S+rNrrrrr/_send #N json @ rUr2Tsuccess)refindallsubrrLrrrPrQr^pathsplitextr: send_voice send_documentrhr) rsrrr^r_ _voice_exts media_pathsrcomposedcmd_strrlis_voice media_results rrOzSimplexAdapter.send!s2@?? j99  @f\2w77==??G  E((**G!!(++ 2 :"VW$E$EFGCWQRR[BBBB1g1111--77 C CDD D D D D D D D $ $Dw''--a06688KGH G%)__Wd%C%CCCCCCC %)%7%7%F%FFFFFFF ' $#### $$''''rrc .ddl}ddl}t|}|}d} ddlm}||}|jdvr8t| d}| |d| }| dddl } | } | | d d d tj| z}nr#t&$rd |jdvr>t| d}|d ||gddd|dd5} | j} dddn #1swxYwY|d |dddd| gdddt | d5} d tj| z}dddn #1swxYwYt1j| n9#t4|jf$r%}t8d|Yd}~nd}~wwxYwYnwxYw||fS)aEnsure *file_path* is a PNG and return ``(png_path, thumb_data_uri)``. SimpleX clients can't display WebP and a few other formats inline. This converts to PNG when needed and generates a small JPEG thumbnail for the ``image`` field in the ``/_send`` payload so the chat shows an inline preview. Uses Pillow when available, falls back to ImageMagick ``convert``. rNrN)Image)r*r+r8r*PNG)ryJPEGF)qualityzdata:image/jpg;base64,convertT)checkcapture_outputrSr+F)rdeletez-resize128x128z-quality70rbz)SimpleX: image conversion unavailable: %s) subprocesstempfilerPILrwopenrr:r$ with_suffixsavecopy thumbnailioBytesIObase64 b64encodegetvaluedecoder}runNamedTemporaryFilenamereadr^removeFileNotFoundErrorSubprocessErrorrqr)rrrppng_path thumb_urirwimgthumbrbuftmptmp_pathfexcs r_prepare_imagezSimplexAdapter._prepare_image\sY  OO 1 Q ! ! ! ! ! !**Y''Cx~~'@@@q}}V44555)))HHJJE OOJ ' ' ' III**,,C JJsFBJ / / /("3<<>>2299;;< I Q Q Q Q8>>##+DDD"1==#8#899HNN"Ix8"'+ " # 00u0MM(QT"xH(((((((((((((((!!!!" #'   (D))Q063CAFFHH3M3M3T3T3V3VV (####%z'AB Q Q QJCPPPPPPPP Q? QD""sDD!! J-A0IF1% I1F5 5I8F5 93I,>>>>>>>> ? KY 6 6 8 8 Ke3IJJJ J"11)<<):!) '!* ' 2##       h ' ' ;qrr{H;;;;;GG:::::G))'22222222  d+++ +%/EFFFFsA B8B BB image_pathc:K|j|d|fd|i|d{VS)z$Send a local image file via SimpleX.rrN)r)rsrrrr^rts rsend_image_filezSimplexAdapter.send_image_files_%T_ +z++  5< @F         r video_pathcBK||||d{VS)z5Send a video file via SimpleX (as a file attachment).)rN)ro)rsrrrr^rts r send_videozSimplexAdapter.send_videos5''W'MMMMMMMMMrfilenamecKt|stddStj|d|pdddg}|dr|d d }d |d |}nd |d |}||d {V} | tdStddS)z Send a document/file attachment.FzFile not foundrrrNrarrrcNrbrdrTrgzFailed to send documentrrrrrPrr) rsrrrrrtrrr1rRr\s rrozSimplexAdapter.send_documents I%%'' Ee3CDDD D:!*+17=b"I"I      h ' ' ;qrr{H;;;;;GG:::::G))'22222222  d+++ +%/HIIIIrr audio_pathdurationcKt|stddStjd|pd|dd|idg}|d r|d d }d |d |} nd|d |} || d {V} | tdStddS)acSend an audio file as a SimpleX voice note (plays inline). SimpleX distinguishes a generic file attachment (``type: "file"``) from an inline voice note (``type: "voice"``). ``/f`` would deliver a downloadable file; the structured ``/_send`` form with ``msgContent.type == "voice"`` produces the voice-note player. FzVoice file not foundrrrN)rrrr)rrrrcNrbrdrTrgzFailed to send voice messager) rsrrrr^rrtrrr1rRr\s rrnzSimplexAdapter.send_voices J&&(( Ke3IJJJ J:!( ' 2$,## $.z":        h ' ' ;qrr{H;;;;;GG:::::G))'22222222  d+++ +%/MNNNNrc KdS)u.SimpleX has no typing-indicator API — no-op.Nr)rsrr_s r send_typingzSimplexAdapter.send_typing9s rcXK|dr|d|dddS|d|dS)zReturn basic chat info.rrrcN)rrrrr)rsrs r get_chat_infozSimplexAdapter.get_chat_info<sE   h ' ' N&MM M"D'BBBrrN)r)NNN)NNr)*__name__ __module__ __qualname____doc__MAX_MESSAGE_LENGTHr rZr`rrrrrrrr r$r9r%r=rLrQrmr rrrrrrO staticmethodtuplerrrrrorFrnrr __classcell__)rws@rrDrDs ,; ~; ; ; ; ; ; B t    D(-(-(-(-\5?5?5?5?vPPPP(dIdI$dIdIdIdILC1C1$C1C1C1C1RG\GcGGGG  $    ,>3>4>>>>,s** 5(  5(5(5(5(vC##C#%S/C#C#C#\C#R"& 2G2G2G2G# 2G  2G2G2G2Gp"&"&       #  3-        ""&"& N N N N# N 3- N  N N N N"&"& JJJJ# J 3- J JJJJH"&"& )O)O)O)O# )O 3- )O  )O )O)O)O)OV=======C3C4S>CCCCCCCCrrDc`tjdsdS ddl}n#t$rYdSwxYwdS)aPlugin gate: require SIMPLEX_WS_URL AND the websockets package. Returning False keeps the platform out of ``get_connected_platforms()`` so the gateway never instantiates the adapter when the dependency is missing or no daemon URL is configured. SIMPLEX_WS_URLFrNT)r^r_r|r})r|s rcheck_requirementsrGsW 9% & &u uu 4s  ++ct|dipi}tjdp|dd}t |S)z=Validate that the platform config has enough info to connect.rIrrJrNr[r^r_r\r`rErIrJs rvalidate_configrWG FGR ( ( .BE Y' ( ( CEIIh,C,CF <<rct|dipi}tjdp|dd}t |S)z9Check whether SimpleX is configured (env or config.yaml).rIrrJrNrrs r is_connectedr^rrctjdd}|sdSd|i}tjdd}|r|dv|d<tjdd}|r||d <tjd d}|r/|tjd dp|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 WebSocket client. Returns ``None`` when SimpleX isn't minimally configured. The special ``home_channel`` key is handled by the core hook — it becomes a proper ``HomeChannel`` dataclass on the ``PlatformConfig`` rather than being merged into ``extra``. rrNNrJrM>rOrPrQrRrSrTSIMPLEX_HOME_CHANNELSIMPLEX_HOME_CHANNEL_NAME)rr home_channel)r^r_rr:)rJseedrRrThomes r_env_enablementresY' , , 2 2 4 4F tF#D)1266<<>>DDFFKF)1EE]I5r::@@BBM. -_ 9+R 0 0 6 6 8 8D  I92>>DDFFN$  ^ KrF) thread_id media_filesforce_documentrmessagerrrcK ddl}n#t$rddicYSwxYwt|dipi}tjdp|dd}|sdd iS |d r-|d d} tjd d |dig} d| d| } nd|d|} tdttj dz| d} | |dd4d{V } | tj| d{Vtjdd{Vdddd{Vn#1d{VswxYwYdd|dS#t $r}dd|icYd}~Sd}~wwxYw)uOpen an ephemeral WebSocket to the daemon, send, and close. Used by ``tools/send_message_tool._send_via_adapter`` when the gateway runner is not in this process (e.g. ``hermes cron`` running as a separate process from ``hermes gateway``). Without this hook, ``deliver=simplex`` cron jobs fail with "No live adapter for platform". ``thread_id`` and ``force_document`` are accepted for signature parity with other plugins but are not meaningful here. ``media_files`` is accepted but only the text body is delivered — SimpleX file transfers require the daemon's filesystem-backed flow, which an ephemeral connection cannot drive safely. rNr~z5websockets not installed. Run: pip install websocketsrIrrJrKz3SimpleX standalone send: SIMPLEX_WS_URL is requiredrrcrrrarbrdrerfzsnd-rErUry)rzrg?TrG)rhrHrzSimpleX send failed: )r|r}r[r^r_r\rrrPrrFrrrOrrr)pconfigrrrrrrrIrJr1rrrsrMrrs r_standalone_sendrs,R&&&&& RRRPQQQQR GWb ) ) /RE Y' ( (EII'--F PNOO6   h ' ' .qrr{Hz A ABCH<;;;;GG.'--G--G&DD3ty{{T/A+B+BDD   $$ 1%   % % % % % % % % ''$*W--.. . . . . . . .-$$ $ $ $ $ $ $ $  % % % % % % % % % % % % % % % % % % % % % % % % % % % Y7KKK 66644455555556sP !BE+:AEE+ EE+!E"E++ F5F;FFc ttdtdtdtdtdt ddlmmn #t$rtdYd SwxYwd d d t d t dt dd ffd}|dd|dd|dd|dd|ddtdd S)uMinimal stdin wizard for ``hermes setup gateway`` → SimpleX. Prompts for the WebSocket URL and the optional allowlist / groups / auto-accept / home channel. Writes to ``~/.hermes/.env`` via ``hermes_cli.config``. zSimpleX Chat setupz------------------z Requirements:z? 1. simplex-chat daemon running (e.g. `simplex-chat -p 5225`).zF 2. Python package `websockets` installed (`pip install websockets`).r) get_env_valuesave_env_valuezNhermes_cli.config not available; set SIMPLEX_* vars manually in ~/.hermes/.envNF)secretvarpromptrrc:tr |nd}|rdnd} |rddlm}|||d}n&t||d}n&#t t f$rtYdSwxYw|r||dSdS)Nz [keep current]rNr)masked_secret_promptz: )callablehermes_cli.secret_promptrinputrEOFErrorKeyboardInterruptprint) rrrr?rrrrrs r_promptz"interactive_setup.._prompts)1-)@)@J==%%%d&.6""B  =IIIIII,,-B-B-B-BCC333344::<<+,    GGG FF   ' N3 & & & & & ' 's?A%%BBrz2Daemon WebSocket URL (default ws://127.0.0.1:5225)SIMPLEX_ALLOWED_USERSzAAllowed contactIds or display names (comma-separated; blank=skip)rSzIAllowed group IDs (comma-separated, or '*' for any; blank=disable groups)rMzAAuto-accept incoming contact requests? (true/false, default true)rz(Home channel contact/group ID (or empty)zODone. Make sure the simplex-chat daemon is running before starting the gateway.)rhermes_cli.configrrr}r$r`)rrrs @@rinteractive_setuprs GGG   / KLLL RSSS GGGCCCCCCCCC        :? ' ' 'S '# '$ '4 ' ' ' ' ' ' ' G RSSS G #%hiii GS GK G "$NOOO  s+A44BBc|dddtttdgdtt dt ddtd d d d d S)uEPlugin entry point — called by the Hermes plugin system at startup.rGz SimpleX Chatc t|Sr)rD)cfgs rzregister..sN3$7$7rrzJpip install websockets # SimpleX adapter requires the websockets packagerrSIMPLEX_ALLOW_ALL_USERSu🔒TaYou are chatting via SimpleX Chat, a private decentralised messenger. Contacts are identified by opaque internal IDs, not phone numbers or usernames. SimpleX supports standard markdown formatting. There is no typing indicator and no hard message length limit, but keep responses conversational. You can attach native images, voice notes, and arbitrary files; the adapter handles MEDIA: tags by sending them as inline voice notes (audio extensions) or documents.)rlabeladapter_factorycheck_fnrr required_env install_hintsetup_fnenv_enablement_fncron_deliver_env_varstandalone_sender_fnallowed_users_env allow_all_envmax_message_lengthemojipii_safeallow_update_command platform_hintN)register_platformrrrrrrr)ctxs rregisterrsq 77#'!&' !#)3-1/-! E3"""""rr)4rrrrloggingr^rrirrrpathlibrtypingrrrr gateway.configr r rr r rr getLoggerrrqrrrrrrr$rr'bytesr5r`r<rBrDrrrrrrrrrrrrsL,,\  '''''''',,,,,,,,,,,, 43333333  8 $ $ $ >S>T#Y>>>> !3!3!!!!5S*EsEtEEEELsLtLLLLwCwCwCwCwC(wCwCwC| D     tD$N $'+ ;6;6;6 ;6;6 } ;6 $s)$ ;6;6 #s(^;6;6;6;6|5555p$$$$$$r