`gj~dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlmZmZddlmZddlmZmZmZmZmZerddlZdZn ddlZdZdd lmZmZdd lm Z m!Z!m"Z"m#Z#m$Z$dd l%m&Z&d d l'm(Z(ejRe*Z+dZ,dZ-dZ.dZ/dZ0ee1jddz Z3dZ4dZ5dZ6ddgZ7d3dZ8d4dZ9d4dZ:d5dZ;d6dZd4d Z?Gd!d"e Z@d8d#ZAd$d%d&d'd$d$d$d(ZBd)d)d*d+d)d,d,d-ZCdd. d9d/ZDdddd0 d:d1ZEd5d2ZFy#e$rdZdZYwxYw);u2 Photon Spectrum (iMessage) platform adapter for Hermes Agent. Both directions of traffic flow through a small supervised Node sidecar (see ``sidecar/index.mjs``) that runs the ``spectrum-ts`` SDK — the SDK is TypeScript-only and there is no public HTTP message API, so a sidecar is unavoidable. Inbound: The SDK's ``app.messages`` is a long-lived **gRPC** stream. The sidecar serializes each message to a normalized JSON event and streams it to this adapter over a loopback ``GET /inbound`` (NDJSON). A background task here consumes that stream, dedupes on ``messageId``, and dispatches a ``MessageEvent`` to the gateway via ``BasePlatformAdapter.handle_message``. No webhook, no public URL, no signing secret. Outbound: ``send`` / ``send_typing`` are loopback POSTs to the sidecar's control endpoints, authenticated with a shared bearer token. Outbound media (images, voice notes, video, documents) goes through spectrum-ts' ``attachment()`` / ``voice()`` content builders via the sidecar's ``/send-attachment`` endpoint. ) annotationsN)datetimetimezone)Path) TYPE_CHECKINGAnyDictListOptionalTF)PlatformPlatformConfig)BasePlatformAdapter MessageEvent MessageTypeProcessingOutcome SendResult)strip_markdown)load_project_credentialsiU"z 127.0.0.1i@iisidecariX)zinternal sidecar errorzupstream connect errorzupstream unavailablezconnection droppedzreset reason: overflowupstream_overflowupstream_unavailable@z#(? ? > ) 1 1 3 r/ctdz }tdz dz } |jj|jjkDS#t$rYywxYw)a(True when node_modules exists but is older than the committed lockfile. `hermes update` rewrites ``package-lock.json`` when the spectrum-ts pin is bumped, but does not reinstall ``node_modules``. npm records the state of the last install in ``node_modules/.package-lock.json``; when the top-level lockfile is newer than that marker, the install is out of date. This is the same signal ``npm ci`` uses. Returns False (do nothing) if either file is missing or unreadable, so a first-run or odd filesystem never blocks start. zpackage-lock.jsonr&z.package-lock.jsonF)r,statst_mtimeOSError)lockfilemarkers r!_sidecar_deps_staler7sY11H N *-A AF}}''&++-*@*@@@ s4A AAc tjd}|stjdyddlm} t j|dgttdddt| }|jdk7rItjd t j|d gttdddt| }|jdk7rAtjd |jxs|jxsdj!ytj#dy#t j$rtjd tYywxYw)uReinstall the sidecar's node_modules from the lockfile (blocking). Mirrors ``hermes photon install-sidecar``: ``npm ci`` for an exact, reproducible install, falling back to ``npm install`` if the lockfile is missing or drifted. Runs the postinstall patch as part of the install. Best-effort — a failure here just leaves the (stale) deps in place and the normal ``_start_sidecar`` readiness check reports the real error. npmz=[photon] cannot reinstall stale sidecar deps: npm not on PATHNrwindows_hide_flagsciTF)cwdcapture_outputtextchecktimeout creationflagsz?[photon] sidecar `npm ci` failed; falling back to `npm install`installz9[photon] sidecar dependency reinstall timed out after %ssz0[photon] sidecar dependency reinstall failed: %sz7[photon] sidecar dependencies reinstalled from lockfile)r(r)loggerwarninghermes_cli._subprocess_compatr; subprocessrunstrr,_NPM_REINSTALL_TIMEOUT returncodeTimeoutExpirederrorstderrstdoutstripinfo)r9r;results r!_reinstall_sidecar_depsrTs, ,,u C VWA  $KL!*,.     ! NNQ  ^^i  %#.02F&A > ]] 1fmm 1r 8 8 :  MN!  $ $   G "   sB D''-EEc|jxsi}|jdxstjd}|jdxstjd}|r|st \}}t |xr|Sy)N project_idPHOTON_PROJECT_IDproject_secretPHOTON_PROJECT_SECRETT)extragetr*r+rbool)cfgrZrVrX stored_id stored_secs r!validate_configr`so IIOE<(JBII6I,JJYY/0VBII>U4VN ^ 8 : :I,*-- r/ct|Sr)r`r]s r! is_connectedrcs 3 r/ct\}}|r|sy||d}tjddj}|r|tjddd|d<|S) zSeed PlatformConfig.extra from env so env-only setups appear in status. The special ``home_channel`` key is handled by the core plugin hook and becomes a proper ``HomeChannel`` on ``PlatformConfig``. N)rVrXPHOTON_HOME_CHANNELrDPHOTON_HOME_CHANNEL_NAMEHome)chat_idname home_channel)rr*r+rQ)rVrXseedhomes r!_env_enablementrmse ":!;J > *nMD 99*B / 5 5 7D II8&A ^ Kr/cjtjddjjdvS)a:Send agent replies as markdown (spectrum-ts ``markdown()`` builder). iMessage renders it natively; other Spectrum platforms degrade to readable plain text. On-device rendering can't be unit-tested, so ``PHOTON_MARKDOWN=false`` is the kill-switch back to stripped plain text without a release. PHOTON_MARKDOWNtrue>0nofalser*r+rQlowerr.r/r!_markdown_enabledrvs5 99& / 5 5 7 = = ?H r/cXeZdZdZeZd6fd Zed7dZd8dZ d9dZ ddd:dZ d;d Z d;d Z d;d ZddZed?dZed@dZed@dZd;dZd;dZdAdZd;dZ dB dCdZ dD dEfd Z dD dFdZ dD dGdZ dD dHdZ dI dJdZ dD dKdZdLdMdZ dMdZ!d Z"d!Z#dNd"Z$e%jLd#Z'e(dOd$Z) dPd%Z*dQd&Z+ dRd'Z,dSd(Z- dL dTd)Z. dL dUd*Z/dVd+Z0 dWd,Z1dXd-Z2dYd.Z3edZd/Z4 d[ d\d0Z5d]d1Z6dddd2d3 d^d4Z7d_d5Z8xZ9S)` PhotonAdapterzBidirectional bridge to Photon Spectrum via the Node spectrum-ts sidecar. Inbound: consume the sidecar's ``/inbound`` gRPC stream. Outbound: loopback POSTs to the sidecar's control channel. ct||td|jxsi}t \}}t j dxs|jdxs|xsd|_t j dxs|jdxs|xsd|_ t|jdxst j dt|_ t|_t j d xstj d |_t%t j d d j'd v|_t j dxst+j,dxsd|_t1|_d|_d|_d|_d|_d|_d|_d|_ i|_!i|_"i|_#i|_$|jd}|t j d}t%|jKj'dv|_&|jOd|vr|d|_(yt j d|_(y)NphotonrWrVrDrYrX sidecar_portPHOTON_SIDECAR_PORTPHOTON_SIDECAR_TOKENPHOTON_SIDECAR_AUTOSTARTrp)rqrsrrr$r%F.@require_mentionPHOTON_REQUIRE_MENTION>1onyesrpmention_patternsPHOTON_MENTION_PATTERNS))super__init__r rZrr*r+r[ _project_id_project_secretr"_DEFAULT_SIDECAR_PORT _sidecar_port_DEFAULT_SIDECAR_BIND _sidecar_bindsecrets token_hex_sidecar_tokenrJru_autostart_sidecarr(r) _node_binrvsupports_code_blocks _sidecar_proc_sidecar_supervisor_task _inbound_task_sidecar_health_task_inbound_running _http_client_sidecar_health_interval_seen_messages_sent_message_ids_last_inbound_by_chat_typing_last_sentrQr_compile_mention_patterns_mention_patterns)selfconfigrZr^r__require_mention __class__s r!rzPhotonAdapter.__init__sX (!34 " !9 : : II) * yy&    II- . yy)*   * IIn % I3H)I ! 3 II, - F1B1B21F #& II0& 9# %'-#.#45Wf9MWQW%6$7!:>@D%59<@! %;?(,%134668"35 !99%67  #!yy)AB "#34::<BBDI  "&!?!?!U* $ %" 45" r/c|tt}nt|tr|j } |rt j |ng}t|tr|nC|jDcgc](}|jdD]}|j *c}}}nt|tr|}n|g}g}|D]R}t|j }|s |jtj|tjT|S#t$rd}YwxYwcc}}w#tj$r!}tj!d||Yd}~d}~wwxYw)aDCompile group-mention wake words from config/env. ``raw`` is a list (config or env JSON), a string (env var: JSON list, or comma/newline-separated), or None (use Hermes defaults). Mirrors the BlueBubbles implementation so both iMessage channels accept the same configuration shapes. N,z'[photon] Invalid mention pattern %r: %s)list_DEFAULT_MENTION_PATTERNS isinstancerJrQjsonloads Exception splitlinessplitappendrecompile IGNORECASErNrErF) rawpatternsr?loadedlinepartcompiledpatternexcs r!rz'PhotonAdapter._compile_mention_patternshsJ ;56H S !99;D -1D)r",FD!9v OO-@ JJsO@ @@H T "HuH') UGw<%%'D U 4 ?@  U+  @"88 UH$PSTT Us/D2-D&3D, D#"D#,E ?EE c^r |jsytfd|jDS)NFc3@K|]}|jywr)search).0rr?s r! zBPhotonAdapter._message_matches_mention_patterns..sNG7>>$'N)rany)rr?s `r!!_message_matches_mention_patternsz/PhotonAdapter._message_matches_mention_patternss(411Nt7M7MNNNr/c|s|S|jD][}|j|j}|s%|j|jdjd}|xs|cS|S)zStrip a leading wake word before dispatch. Custom mention patterns are regexes, so we only strip a leading match to avoid deleting ordinary words later in the prompt. Nz ,:-)rmatchlstripend)rr?rrcleaneds r!_clean_mention_textz!PhotonAdapter._clean_mention_textsl K-- 'GMM$++-0E++- 5<@rASIDECAR_FAILEDz failed to start Photon sidecar: TuD[photon] sidecar autostart disabled — inbound + outbound will failuD[photon] connected — sidecar on %s:%d, streaming inbound over gRPC)r'_set_fatal_errorrrhttpx AsyncClientrr_start_sidecarracloserErFrasyncioget_event_loop create_task _inbound_loopr_monitor_sidecar_healthr_mark_connectedrRrr)rrclientes r!connectzPhotonAdapter.connects  ! !4 " t';';  ! !%+ "  ""40"  " " ))+++ NNV  !%$335AA     %,$:$:$<$H$H  ( ( *% !  R    2 2 ;, %%$6qc:"& mmo%%$(! sOA2F!5EE E CF!E F*FF  FF!FF!cKd|_|jD|j}d|_|j|tjur |d{|j6|jj |jd{d|_|jd{|j* |jjd{d|_ |jy7#tj $rYt $rYwxYw7#tj $rYt $rYwxYw77h#t $rYqwxYww)NF) rrcancelr current_taskCancelledErrorrr _stop_sidecarrr_mark_disconnected)rtasks r! disconnectzPhotonAdapter.disconnectsN %  $ $ 0,,D(,D % KKM7//11JJ    )    % % ' (((( "&D   """    ( ''..000!%D  !+--  )))    #1  sA EC=C;C=&ED"D D"E/E0EE EE #E;C==DEDEDE D""E5E7E?EEEE EEEEcJK|j}|yd|jd|jd}d|ji}d}|jr |j d||d4d{}|j d k7rtd |j d}|j23d{}|jsn-|j}|s*|j|d{Ddddd{|jryy77`7(6'7#1d{7swY+xYw#tj$rt$r_}|jsYd}~ytjd ||tj |d{7t#|d zd }Yd}~d}~wwxYww)zConsume the sidecar's ``/inbound`` NDJSON stream, with reconnect. The sidecar owns the gRPC reconnect/heartbeat to Photon; this loop only has to re-open the loopback HTTP stream if it drops (e.g. the sidecar restarts). Nhttp://:z/inboundX-Hermes-Sidecar-Tokeng?GETheadersrAz/inbound returned z;[photon] inbound stream dropped (%s); reconnecting in %.1fsr)rrrrrstream status_code RuntimeError aiter_linesrQ_on_inbound_linerrrrErFsleepmin)rrurlrbackoffresprrs r!rzPhotonAdapter._inbound_loops"" > **+1T-?-?,@I+T-@-@A## 1!==3) : :''3.*-?@P@P?Q+RSS!G&*&6&6&8::d#44!#zz|#$"33D999 : :## : : : '9 : : : :))  1,,QwmmG,,,gk40 1sA F# D%%D&D%):D#D 'D(D +6D!D "D' D%2D3D%7 F#F#D%D  D DD%D"D D"D%%F  F F#/FFFF#F  F#cpK|jr2tj|jd{|jsy |j did{}t|tr|jdnd}t|tr|jddurt|jdxsd}|jd }t|jd xsd }d |d |d|}tjd||jd|d |jd{yy77#tj $rt $r!}tjd|Yd}~}d}~wwxYw7K#t $r }tj!d|Yd}~yd}~wwxYww)aPromote degraded upstream Photon stream health into reconnect. The sidecar HTTP process can stay alive while spectrum-ts repeatedly fails to maintain the upstream inbound gRPC stream. Polling `/healthz` keeps that from becoming a silent inbound outage. N/healthzz([photon] sidecar health check failed: %srokFstateunknown degradedForMs lastIssuezunknown stream issuez'Photon upstream stream degraded (state=z, degradedForMs=z): [photon] %sUPSTREAM_STREAM_DEGRADEDTr,[photon] fatal-error notification failed: %s)rrrr _sidecar_callrrrEdebugrdictr[rJrNr_notify_fatal_errorrF)rdatarrrdegraded_for_ms last_issuemessages r!rz%PhotonAdapter._monitor_sidecar_health"s##-- = => > >(( !// B??,6dD+ATXXh'tFfd+vzz$/?u/L 7+8y9E$jj9OVZZ 4N8NOJ '!1/1B#,   LL 0  ! !* "   T..000 E$ >@))   GM .1 TMsSS  Ts0F6EF6EEEC F6)F <F=F F6EF$F:F6FF6F F3F.)F6.F33F6c^K tj|}|j d}|r|j |ry |j|d{y#tj$rtj dYywxYw73#t$rtjdYywxYww)Nz'[photon] skipping non-JSON inbound line messageIdz [photon] inbound dispatch failed) rrJSONDecodeErrorrEr r[ _is_duplicate_dispatch_inboundr exception)rreventmsg_ids r!rzPhotonAdapter._on_inbound_lineMs JJt$E;' d((0  A((/ / /##  LLB C   0 A   ? @ As\B-A%B-B BB B-(BB-BB-B B*'B-)B**B-c(tj}|j}|j|}| ||z tkry||vr||=|||<t |t kDr4t |jdt |t z D]}||=y)NTF)timerr[_DEDUP_WINDOW_SECONDSlen_DEDUP_MAX_SIZErkeys)rrnowseentolds r!rzPhotonAdapter._is_duplicate[siik"" HHV  =S1W'<< T>V V t9 &DIIK()F3t9+FG I r/c  K|jdxsi}|jdxsi}|jdxsi}|jdxsd}|stjdy|jdd k(rd nd }|jdxs|jd xs|}|jd xsd} |r%tj|j d dn#tj tj} g} g} d(d} |jd} | dk(r|jd}|jddk(xs|xr||jv}|stjdy|jdxsd}|j|||||xsd}|jtd|tj ||jd||jdxsdd||  d{y|j#||jd| dk(r'|jdxsd}tj }n| dvr| |\}}} } n| d k(rjg}tj }|jdxsgD]}t%|t&s|jdxsi}t%|t&s:|jd}|dk(r)|jdxsd}|r|j)|y|dvrX| |\}}}}|tj k(r|}| j+|| j+||s|j)||s|j)d |d!| r#|tj k(rtj,}d"j/d#|Dj1}|s| rd$nd%}nd | d!}tj }|d k(rD|j2r8|j5|stjd&y|j7|}|j|||||xsd}t||||jd|| | | '}|j|d{y#t$r(tj tj} YwxYw77<w))uqNormalize a sidecar inbound event and dispatch it to the gateway. Event shape (from ``sidecar/index.mjs``):: { "messageId": "...", "platform": "iMessage", "space": {"id": "...", "type": "dm"|"group", "phone": "+E164"}, "sender": {"id": "+E164"}, "content": {"type": "text", "text": "..."} | {"type": "attachment"|"voice", "id", "name", "mimeType", "size", "duration"?, "data"?, "encoding"?} | {"type": "reaction", "emoji": "❤️", "targetMessageId": "..." | null, "targetDirection": "inbound"|"outbound" | null, "targetText": "..." | null}, "timestamp": "2026-05-14T19:06:32.000Z" Attachment and voice content carry the bytes inline as base64 ``data`` (with ``encoding == "base64"``) when the sidecar could read them within its size cap; otherwise only metadata is present and we surface a marker. } spacesendercontentidrDz![photon] inbound missing space.idNtypegroupdmphone timestampZz+00:00)tzc|jddk(}|jdxs|rdnd}|jdxsd}|rtjn t|}t ||||}|r|rdnd ||g|xs|rd gfSd gfS|rdnd }|jd }t |t tfrd|dnd}d|d|d|xsd|d|ggfS)Nr'voiceriz (unnamed)mimeTyperD force_audioz(voice) (attachment) audio/mp4zapplication/octet-stream attachmentdurationz , duration: sz[Photon z received: z (z unknown MIMEz)])r[rVOICE_attachment_message_type_cache_inbound_attachmentrrfloat) payloadis_voicerimimemtypecachedlabelr6 duration_texts r!_normalize_binary_payloadzBPhotonAdapter._dispatch_inbound.._normalize_binary_payloads${{6*g5H;;v&Ph7KD;;z*0bD)1K%%7OPT7UE.tF!)I~HVXkW   r/reactiontargetMessageIdtargetDirectionoutboundz6[photon] ignoring reaction on a message we didn't sendemoji)rh chat_name chat_typeuser_id user_namezreaction:added:r targetTextT) r? message_typesource message_idreply_to_message_id reply_to_textreply_to_is_own_message raw_messager+r?>r/r5itemsz"[Photon content type not handled: ] c3&K|] }|s| ywrr.)rrs r!rz2PhotonAdapter._dispatch_inbound..sAdDTAsr3z[Photon empty group received]zR[photon] ignoring group message (require_mention=true, no mention pattern matched))r?rNrOrPrTr+ media_urls media_types)r<Dict[str, Any]returnz-tuple[str, MessageType, List[str], List[str]])r[rErFr fromisoformatreplacerrutcrrr  build_sourcehandle_messagerrTEXT_record_last_inboundrr rextendDOCUMENTjoinrQrrr)rrr#r$r%space_idrJ sender_idts_strr+rYrZrCctype target_idis_oursrHrOr?r? text_partsitem item_content item_type item_textr6 item_mtype item_urls item_types message_events r!rzPhotonAdapter._dispatch_inboundls4 '"(b8$*))I&,"99T?(b NN> ?  %yy0G;G JJt$F '(:Fh ;'-2 6&&v~~c8'DE\\X\\2 !# !#  #  : @ F# J   $56Ikk"34 BAi4+A+AA  LKK(.BE&& "#!#+t 'F%%*5'2!,!1!1!$yy5(1")++l";"Ct,0 %'      !!(EIIk,BC F?;;v&,"D$$E - -3LW3U 0D%[ g $&J$$E G,2 Y!$-#xx 28b !,5(,,V4 & , 0 0 8 >BI ")))4 77@Y$A=FJ : 0 00 *%%i0&&z2$"))&1%%(J9+UV&WX1 Y2e{'7'77#,,99AjAAGGID)3~9X7wa@D$$E  D$8$899$? I++D1D""'4 # %yy-!#  !!-000C 6  5I 6L v 1sRCSA RC;S S  E)S6DSS S-SSSS Sc2 tjddd|dgdddd}|jj Dcgc],}|j js"t|.c}S#ttjf$rgcYSwxYwcc}w) zBPIDs listening on a local TCP port (empty if none/undeterminable).lsofz-tiztcp:z -sTCP:LISTENTrFr>r?rAr@) rHrIr4rMrPrrQisdigitr)portouttoks r!_find_listener_pidsz!PhotonAdapter._find_listener_pids?s ..$tf ~>#$5C %(JJ$4$4$6PS#))+:M:M:OCPP223 I Ps!A3#B# B3BBc tjddt|ddgdddd}d |j vS#ttjf$rYywxYw) z;True if ``pid``'s command line is a Photon sidecar process.psz-pz-ozcommand=TrFrxzphoton/sidecar/index.mjs)rHrIrJr4rMrP)pidr{s r!_pid_is_sidecarzPhotonAdapter._pid_is_sidecarKs` ..tSXtZ8#$5C*SZZ77223  s(8AAcP tj|dy#t$rYywxYw)NrTF)r*killr4)rs r! _pid_alivezPhotonAdapter._pid_aliveXs)  GGCO  s  %%cjKtjdk(ry tjd4d{}|j dj dj ddji d{dddd{jj }|Dcgc]}j|s|}}|Dcgc] }||vs| }}|s td j d |xsd d |D]H}tjd|j  tj|t j"Jt'j&dz}t'j&|kr]t)fd|DrIt+j,dd{t'j&|krt)fd|DrI|D]9}j/|s tj|t j0;t+j,dd{|rtd j d|dy777#1d{7swYxYw#tj$rYywxYwcc}wcc}w#t$$rYwxYw7#t$$rYwxYw7w)u:Kill an orphaned sidecar squatting our port before spawning ours. A hard gateway exit (crash, SIGKILL, supervisor restart) used to leave the detached sidecar running with a token the new gateway doesn't know, so it can't be told to ``/shutdown`` — and every replacement spawn died on EADDRINUSE, failing each reconnect attempt. The stdin-EOF watch prevents new orphans; this reclaims the port from orphans that predate it (or survived it). Listeners are verified by command line before being signalled. win32N@rrrrrrzport z% is in use by another process (pids: ruR, not a Photon sidecar) — free it or set PHOTON_SIDECAR_PORT to a different portz5[photon] reaping orphaned sidecar (pid %d) on port %d@c3@K|]}j|ywr)r)rprs r!rz4PhotonAdapter._reap_stale_sidecar..s,OAT__Q-?,Org?皙?z. is also held by non-sidecar processes (pids: u<) — free it or set PHOTON_SIDECAR_PORT to a different port)sysplatformrrpostrrr RequestErrorr}rrrErFr*rsignalSIGTERMr4rrrrrSIGKILL)rrpidsrstaleforeigndeadlines` r!_reap_stale_sidecarz!PhotonAdapter._reap_stale_sidecar`s <<7 "  ((5  kkd00143E3E2FhO5t7J7JK"  ''(:(:; $B(<(I5I6I: I-II- J3)JJJ3 J J A J3#$JAJ3#J $/J3J3,$J"J3*J1+#J3I-II-I*I I*%I--JJ3J J3 JJ3JJ3" J.+J3-J..J3c Ktdz jstdtdtr6tj dt jtd{|jd{tjj}|j|d<|j|d<t|j |d<|j"|d<|j$|d <d |d <d d lm} t+j,|j.ttdz ttgdddd|}|j0d k7r5t|j2xs|j4xsdj7|j2j7r.tj9d|j2j7t+j<|j.ttdz gt*j>t*j>t*j@|tBjDdk7||_#t jH}|jK|jM|jF|_'tQjPdz}d}tSjTd4d{}tQjP|kr|jFjW#td|jFj0d |jYd|j"d|j d d!|j$i"d{} | jZd#k(r dddd{y t j^d$d{tQjP|krdddd{td%|7u7`#t:$r!}tj d|Yd}~/d}~wwxYw7D77#tRj\$r } | }Yd} ~ d} ~ wwxYw77p#1d{7swYxYww)&Nr&z+Photon sidecar deps not installed. Run: cd z, && npm install (or `hermes photon setup`)zX[photon] sidecar deps are stale (lockfile newer than install); reinstalling before startrWrYr|PHOTON_SIDECAR_BINDr}rPHOTON_SIDECAR_WATCH_STDINrr:z$patch-spectrum-mixed-attachments.mjsT F)r>r?rAr@rBrDrz<[photon] failed to apply Spectrum mixed attachment patch: %sz index.mjsr)stdinrPrOenvstart_new_sessionrBrrrz Photon sidecar exited with code z before becoming readyrrrrrrrz0Photon sidecar did not become ready within 15s: )0r,r-rr7rErFr to_threadrTrr*environcopyrrrJrrrrGr;rHrIrrLrOrPrQr rPopenPIPESTDOUTrrrrr_supervise_sidecarrrrrpollrrrr) rrr;patchrlooprlast_errrrrs r!rzPhotonAdapter._start_sidecars~-557"^#OQ   NN, ##$;< < <&&(((jjoo#'#3#3  '+';'; #$%(););%< !"%)%7%7 !"&*&9&9 "#-0 () E NNNN 'MMN % $12 E1$"ELL$FELL$FB#M#M#OPP||!!# ]ELL,>,>,@A(-- ^^S !;< =//??$$"||w6-.  %%'(,(8(8  # #D$6$6 7) % 99;%(,$$S1 ) )V))+(%%**,8&:--8899OQ!!'!$"4"4!5Qt7I7I6J(S!94;N;N O"-"D''3. ) ) )/mmC((())+( ) )">xj I  e =(H  NNN   8 ) )))! H!(! ) ) ) )sA&Q(O)QO BQCO#C3Q P QAP=&=P#P$P8 QPQ P="P9#P=? Q P; Q Q# P ,PQP  QPQP6*P1,P=1P66P=;Q=QQ Q QcK|jy|j}tj} |jd|jd{}|sn5t j d|jddj\ |jrX|j}t jd||jdd |d d  |jd{yy7#t$r }t jd|Yd}~d}~wwxYw74#t$r }t jd |Yd}~yd}~wwxYww) z1Pump the sidecar's stdout/stderr into our logger.NTz[photon-sidecar] %szutf-8r^z&[photon-sidecar] supervisor exited: %suG[photon] sidecar exited unexpectedly (code %s) — triggering reconnectSIDECAR_CRASHEDz)Photon sidecar exited unexpectedly (code )rr)rPrrrun_in_executorreadlinerErRdecoderstriprrFrrrNrr )rprocrPrrr exit_coders r!rz PhotonAdapter._supervise_sidecars? ;;  %%' H!11$HH 14;;w 3R3Y3Y3[\    I LLY   ! !!;I;aH "   T..000 ! I H NNCQ G G H1 TMsSS Ts}.E C6C4>J22 Z3   ? S+GYRRR R S sGA%979A%A#A%9A AA A%A  A%cFK|j|||d{S7wNrr)rrh image_pathrrrkwargss r!send_image_filezPhotonAdapter.send_image_filep122 Z3    !!cHK|j|||dd{S7w)Nr/)rkindr)rrh audio_pathrrrrs r! send_voicezPhotonAdapter.send_voice}s322 Zw3    " "cFK|j|||d{S7wrr)rrh video_pathrrrrs r! send_videozPhotonAdapter.send_videorrcHK|j||||d{S7w)N)rirr)rrh file_pathr file_namerrrs r! send_documentzPhotonAdapter.send_documents322 YY3    rcHK|j|||||d{S7wr)r)rrh animation_urlrrrs r!send_animationzPhotonAdapter.send_animations.__ ]GXx    rc8Ktj}||jj|dz tkry||j|< |j d|ddd{y7#t $r }t jd|Yd}~yd}~wwxYww)Ng/typingstartspaceIdrz[photon] send_typing failed: %s)rrr[_TYPING_COOLDOWN_SECONDSrrrEr )rrhrrrs r! send_typingzPhotonAdapter.send_typingsiik ''++GS9 9 > ?sBA BA.&A,'A.+B,A.. B7B BBBcK|jj|d |jd|ddd{y7#t$r }tj d|Yd}~yd}~wwxYww)Nrstoprz[photon] stop_typing failed: %s)rpoprrrEr )rrhrs r! stop_typingzPhotonAdapter.stop_typingsf ""7D1 ?$$w@   ? LL:A > > ?s;A,A>AA,A A) A$A,$A))A,irc|sy|j}||vr||=tj||<t||jkDr;t |j dt||jz D]}||=yyr)rrr _SENT_IDS_MAXrr)rrPsentr!s r!_record_sent_messagez"PhotonAdapter._record_sent_messages %%  Z 99;Z t9t)) )DIIK()I3t9t7I7I+IJ I  *r/z^any;-;(\+\d{6,})$cb|jj|}|r|jdS|S)Nr)_DM_CHAT_GUID_RErr()clsrhrs r!_normalize_chat_keyz!PhotonAdapter._normalize_chat_keys-$$**73!&u{{1~3G3r/c|r|sy|j|}|j}||vr||=|||<t||jkDr;t |j dt||jz D]}||=yyr)rrr_LAST_INBOUND_CHATS_MAXrr)rrhrPkeylastr!s r!rcz"PhotonAdapter._record_last_inboundsj &&w/)) $;S S t9t33 3DIIK(:#d)d::: I  4r/cjtjddjjdvS)NPHOTON_REACTIONSrs>rrrrprt)rs r!_reactions_enabledz PhotonAdapter._reactions_enableds3yy+W5;;=CCEJ   r/cK |jd|||dd{y7#t$r }tjd|Yd}~yd}~wwxYww)zCTapback ``emoji`` onto a message. Soft-fails (False), never raises.z/react)rrrHNTz [photon] add_reaction failed: %sFrrrEr )rrhrPrHrs r! _add_reactionzPhotonAdapter._add_reactions] $$#*uM       LL;Q ? s6A%#%A% AA A AAcK |jd||dd{y7#t$r }tjd|Yd}~yd}~wwxYww)a+Retract our tapback from a message. Soft-fails (False), never raises. The sidecar tracks one reaction handle per target message; after a sidecar restart the handle is gone and removal is best-effort (the stale tapback self-heals when the next reaction replaces it). z/unreact)rrNTz#[photon] remove_reaction failed: %sFr)rrhrPrs r!_remove_reactionzPhotonAdapter._remove_reaction sZ $$jI     LL> B s6A$"$A$ A AAA  AcK|xs*|jj|j|}|sdddS|j|||d{}|sdddSd|dS7w)uATapback ``emoji`` onto a message in ``chat_id``. Without ``message_id``, targets the chat's most recent inbound message (typically the one the agent is responding to). iMessage maps ❤️👍👎😂‼️❓ to native tapbacks; anything else uses Apple's custom-emoji reaction. Fukno message to react to — pass message_id (no inbound message seen in this chat since the gateway started)successrNNz'reaction failed (see gateway debug log)TrrP)rr[rr)rrhrHrPtargetrs r! add_reactionzPhotonAdapter.add_reaction s t99==  $ $W -  O  %%gvu= = B  v66 >sA A!AA!cK|xs*|jj|j|}|sdddS|j||d{}|sdddSd|dS7w)z1Retract our tapback from a message (best-effort).Fu)no message to unreact — pass message_idrNz&unreact failed (see gateway debug log)Tr)rr[rr)rrhrPrrs r!remove_reactionzPhotonAdapter.remove_reaction>s t99==  $ $W -  D ((&9 9 A  v66 :sA A  AA cK|jsyt|jdd}t|dd}|r|r|j||dd{yyy7w)u=Tapback 👀 on the triggering message while the agent works.NrhrPu👀)rgetattrrOr)rrrhrPs r!on_processing_startz!PhotonAdapter.on_processing_startRs\&&( %,, 48UL$7 z$$Wj,G G G"7 GsAAAAc|K|jsyt|jdd}t|dd}|r|sy|j||d{|tj k(r|j ||dd{y|tjk(r|j ||dd{yy7c777 w)uSwap the 👀 progress tapback for a 👍/👎 result. Remove-then-add rather than a bare replace: deterministic whether the platform replaces a sender's previous tapback or stacks them, and it keeps the sidecar's reaction-handle slot coherent. NrhrPu👍u👎)rr rOrrSUCCESSrFAILURE)rroutcomerhrPs r!on_processing_completez$PhotonAdapter.on_processing_complete[s&&( %,, 48UL$7 j ##GZ888 '// /$$Wj,G G G )11 1$$Wj,G G G2 9 G Gs6AB<B6-B<B8.B</B:0B<8B<:B<cK|d|dSw)zReturn whatever we know about a Spectrum space id. Photon's ``space.id`` is opaque; the inbound event also carries the DM/group type, but here we only have the id, so infer conservatively. r))rir'r&r.)rrhs r! get_chat_infozPhotonAdapter.get_chat_infoqs  W==s c0tr|St|Sr)rvr)rr%s r!rzPhotonAdapter.format_messageys  Ng&&r/ctj|ry|sy|jtfdtDS)NTFc3&K|]}|v ywrr.)rpatlowereds r!rz4PhotonAdapter._is_retryable_error..sHc3'>Hs)r_is_retryable_errorrur_PHOTON_RETRYABLE_PATTERNS)rNrs @r!rz!PhotonAdapter._is_retryable_errors7  2 25 9++-H-GHHHr/cK|j|}|j||||d{}|jr|S|jxsd} |jxs|j | } | s|j | r|S| rtd|dzD]} |d| dz zz} tjd| || | tj| d{|j||||d{}|jr|cS|jxsd} |jr|j | rntjd|| |Stjd| |j||d|j||d{} | js tjd | j| S77779w) uRetry sends without the generic Markdown banner. Photon replies are markdown (rendered by iMessage) or stripped plain text under ``PHOTON_MARKDOWN=false`` — either way the gateway's generic banner never applies. )rhr%rrNrDrrz;[photon] Send failed (attempt %d/%d, retrying in %.1fs): %sz8[photon] Failed to deliver response after %d retries: %sz6[photon] Send failed: %s - retrying plain-text messagez)[photon] Plain-text retry also failed: %s) rrrrNrr_is_timeout_errorrangerErFrrMAX_MESSAGE_LENGTH)rrhr%rr max_retries base_delayr?rS error_str is_networkattemptdelayfallback_results r!_send_with_retryzPhotonAdapter._send_with_retrys""7+yy !   >>MLL&B %%L)A)A))L d44Y?M  K!O4 "aGaK&89Q[%mmE***#yy# %% )  >>!M"LL.B ((D,D,DY,O# & N  D  !% 24223 !*!   && LLDoF[F[ \i *+, sS*GF>B&GGG0G10G"G4AG G 3GGGGcKt||jkDr9tjdt||j|d|j}||d}t rd|d< |j d|d{}|j|jdtd |jd S7@#t $r }tdt|cYd}~Sd}~wwxYww) Nz0[photon] truncating outbound from %d to %d charsrr?markdownformat/sendFrrTr) rrrErFrvrrrrJrr[)rrgr?bodyr rs r!rzPhotonAdapter._sidecar_sends t9t.. . NNBD 422 1$112D+3TB  'DN ;++GT::D !!$((;"78$488K3HII ; ;e3q6: : ;sHA&C-)C>B??CEED !!$((;"78$488K3HII F ;e3q6: : ;sHA/C62C CC > **+1T-?-?,@G+T-@-@A$$T2 F FfStWEED F F   s "!$z$2B2B1C2diiPTQToEVW yy{ bxx~!$'8'9J8KL   FE F F F Fs[AD- D!D-$D<D=D D- D BD-DD-D*D! D*&D-)rr )rrr\z'list[re.Pattern]')r?rJr\r\)r?rJr\rJ)rr\r\r\r\None)rrJr\r;)rrJr\r\)rr[r\r;)rzrr\z List[int])rrr\r\)rzsubprocess.Popenr\r;)NN) rhrJr%rJr Optional[str]rOptional[Dict[str, Any]]r\r)NNN) rhrJrrJrr<rr<rr=r\r) rhrJrrJrr<rr<rr=r\r) rhrJrrJrr<rr<rr=r\r) rhrJrrJrr<rr<rr=r\r)NNNN)rhrJrrJrr<rr<rr<rr=r\r) rhrJrrJrr<rr<rr=r\rr)rhrJr\r;)rPr<r\r;)rhrJr\rJ)rhr<rPr<r\r;r\r\)rhrJrPrJrHrJr\r\)rhrJrPrJr\r\)rhrJrHrJrPr<r\r[)rhrJrPr<r\r[)rrr\r;)rrrrr\r;)rhrJr\r[)r%rJr\rJ)rNr<r\r\)NNrr)rhrJr%rJrr<rrrrrr;r\r)rgrJr?rJr\r)rgrJr/rJrir<r,r<rr<rrJr\r)r/rJr+r[r\r[):__name__ __module__ __qualname____doc___MAX_MESSAGE_LENGTHrr staticmethodrrrrrrrrrrr}rrrrrrrrrrrrrrrrrrrrr classmethodrrcrrrrrr rrrrr%rrr __classcell__)rs@r!rxrxs -J \##JO "5:3j"B&1P)V A"O1f Q Q 8 87rf PT<)5b#'-1 OOO O + O  O*"&"&-1        +    ."&"&-1          +     ""&"&-1          +     ""&"&-1          +     ""&#'"&-1        !    +     $"&"&-1          +      ??M!  "rzz"7844$2?    (+ 47   4%) 777" 7  7>9=77(57 7(HH!H,=H H,>'II#'DDD D  D  DD DLJ0##'!% /J/J/J  /J ! /J/J/J /Jbr/rxcR|xsdj}|jdrtjS|jdrtjS|jdrtj S|jdrtj Stj S)NrDimage/zvideo/audio/z application/)ru startswithrPHOTOVIDEOAUDIOre)r>s r!r9r90s JB   D x     x     x     ~&###   r/.jpgz.pngz.gifz.webp)z image/jpegz image/pngz image/gifz image/webpz image/heicz image/heifz image/tiff.mp3z.oggz.wav.m4a)z audio/mp3z audio/mpegz audio/oggz audio/wavz audio/x-cafr4z audio/aacr1c|jd}|sy tj|}ddlm}m }m } |xsdj}|rt|jnd} |jdr$| xstj|d} | || S|s|jd r'| xst j||rd nd } ||| S|||S#ttf$r }t j d|Yd}~yd}~wwxYw#t$r |||cYSwxYw#t"$r!}t j d ||Yd}~yd}~wwxYw) aDecode a base64-inlined inbound attachment and cache it locally. The sidecar inlines the attachment bytes as ``content["data"]`` (base64). We decode them and route to the shared media cache by MIME type, returning the cached absolute path so the caller can populate ``media_urls`` (which the gateway then hands to the model). Returns ``None`` when there are no bytes (over the sidecar's inline cap or a failed read) or when caching fails, so the caller can fall back to a text marker. r Nz6[photon] failed to decode inbound attachment bytes: %sr)cache_audio_from_bytescache_document_from_bytescache_image_from_bytesrDrHrNrIrPrOz2[photon] failed to cache inbound attachment %s: %s)r[base64 b64decoderrrErFrrRrSrTrursuffixrJ_IMAGE_EXT_BY_MIME_AUDIO_EXT_BY_MIMEr) r%rir>r2data_b64rrrRrSrTrWexts r!r:r:SsU {{6"H x(  JB   D"&T$Z  BF ??8 $@.224@C <-c377 $//(3.22 fC*#s3 3(d339  "OQTU$ <1d;; < KTSVWsYC#+D%D 9D%D%D *DD  D"D%!D""D%% E.E  E) thread_id media_filesforce_documentc KtsddiSt|jxsijdxst j dt }t j d}|sddiSdtd|}d |i} d} tjd 4d{} |r||dtd } trd | d<| j|d| | d{} | jdk7r2dd| jd| jddicdddd{S| jxsi}|jds(d|jdxsdicdddd{S|jd} ddl}|xsgD]'\}}t#j$t'|}|st(j+d=|j-|\}}|||rdndd}|r||d<| j|d|| d{} | jdk7r4dd| jd| jddiccdddd{S| jxsi}|jds*d|jdxsdiccdddd{S|jdxs| } *dddd{d| dS7*777j777B7#1d{7swY+xYw#t.$r}dd |icYd}~Sd}~wwxYww)!NrNrr{r|r}zPhoton standalone send requires a running sidecar with PHOTON_SIDECAR_TOKEN set in the environment. Cron processes cannot spawn the sidecar themselves.rrrrrr'r(r)r*r8rzsidecar returned r9rzsidecar reported failurerrz-[photon] standalone send skipping unsafe pathr/r5r.r0r0TrzPhoton standalone send failed: )r'r"rZr[r*r+rrrrrCrvrrr?rr2rr1rJrErFr3r)pconfigrhrr\r]r^rztokenbaserlast_message_idr send_bodyrr r2 media_pathr=r4r5r6att_bodyrs r!_standalone_sendrgs .//   "!!.1URYY?T5U D II, -E  7  *+1TF 3D'/G%)O2@$$T2- K- Kf&#$8%89- %&*4Ih'#[[fENG)##s*#'89I9I8J"TYYW[X[_L]%^_- K- K- Kyy{(bxx~#TXXg%6%T:TU!- K- K- K"#'((;"7 (3(9r K$ H/LLSQ[_]  NN#RS&11)< &%'/G\, +2HZ(#[[f,-Hg)##s*#'89I9I8J"TYYW[X[_L]%^__S- K- K- KTyy{(bxx~#TXXg%6%T:TUUY- K- K- KZ#'((;"7"J?+ K1- K- K^ ??_- K- K- KJK- K- K- K- K- K- K` @:1#>??@s3Azregister..s M#$6r/rWrYzRun: hermes photon setup (logs in via device flow, creates a Spectrum project, links your phone number, installs the spectrum-ts sidecar).rePHOTON_ALLOWED_USERSPHOTON_ALLOW_ALL_USERSu📱TuaYou are communicating via Photon Spectrum (iMessage). Treat replies like regular text messages — short and friendly. Markdown is rendered (bold, italics, lists, code), but keep formatting light and conversational. Recipient identifiers are E.164 phone numbers; never expose them in responses unless the user asked. Attachments arrive as metadata only.)rirAadapter_factorycheck_fnr`rc required_env install_hintsetup_fnenv_enablement_fncron_deliver_env_varstandalone_sender_fnallowed_users_env allow_all_envmax_message_lengthrHpii_safeallow_update_command platform_hintz1Set up and manage the Photon iMessage integration)rihelprr handler_fnN) rDriregister_platformr0r`rc gateway_setuprmrgrCregister_cli_command register_clidispatch)ctx_clis r!registerrs #6#'!)+BC $ ##)2-0..! ?;$N  @""== r/)rrr rr\rr>r:)r]r r\r\)r\zOptional[dict])r>rJr\r) r%r[rirJr>rJr2r\r\r<)r`r rhrJrrJr\r<r]zOptional[list]r^r\r\r[)GrB __future__rrrUrloggingr*rrr(rrHrrrrpathlibrtypingrrr r r rr' ImportErrorgateway.configr r rrrrrrgateway.platforms.helpersrauthr getLoggerr?rErrrCrr__file__parentr,rKrrrr"r0r7rTr`rcrmrvrxr9rXrYr:rgrr.r/r!rs.#    ';;O 45*   8 $ # !H~$$y0  +" $8Ov &  Y'Y~(    4 4 4 4  4  4B $"& M@ M@ M@M@  M@  M@M@M@f2]5 sD00 D<;D<