`gjdZddlmZddlZddlZddlZddlmZddlm Z m Z m Z ddl m Z ddlmZd dZGd d Zy) aVRemote node server. Runs on the machine that will host the Meet bot (typically the user's Mac laptop with a signed-in Chrome). Exposes a WebSocket endpoint that accepts signed RPC requests and dispatches them to the existing ``plugins.google_meet.process_manager`` module. Launched by ``hermes meet node run``. Token handling -------------- On first boot we mint 32 hex chars of entropy and persist them at ``$HERMES_HOME/workspace/meetings/node_token.json``. Subsequent boots reuse the same token so previously-approved gateways don't need to be re-paired. The operator copies this token out-of-band to the gateway via ``hermes meet node approve ``. Dependencies ------------ ``websockets`` is an optional dep. We import it lazily inside :meth:`serve` so installing the plugin doesn't require it unless you actually host a node. ) annotationsN)Path)AnyDictOptional)get_hermes_home)protocolc:ttdz dz dz S)N workspacemeetingsznode_token.json)rrR/root/.hermes/venv/lib/python3.12/site-packages/plugins/google_meet/node/server.py_default_token_pathr%s ! "[ 0: =@Q QQrcTeZdZdZ d d dZd dZd dZd dZd dZy) NodeServerz5WebSocket server that executes meet bot RPCs locally.Nct||_||_||_| t|n t |_d|_y)N)hostport display_namerr token_path_token)selfrrrrs r__init__zNodeServer.__init__,s8  (.8.D$z*J]J_%) rc|jr |jS|jjr\ tj|jj d}|j d}t|tr |r ||_|Stjd}|jjjdd|jjd}|j!tj"|t%j$dd d |j'd |j+|j||_|S#ttjf$rYwxYw#tt(f$rYTwxYw) z@Return the persisted shared secret, generating one on first use.utf-8encodingtokenTparentsexist_okz .json.tmp)r generated_at)indenti)rris_filejsonloads read_textget isinstancestrOSErrorJSONDecodeErrorsecrets token_hexparentmkdir with_suffix write_textdumpstimechmodNotImplementedErrorreplace)rdatatoktmps r ensure_tokenzNodeServer.ensure_token;sE ;;;;  ?? " " $ zz$//";";W";"MNhhw'c3'C"%DKJ# $$TD$Aoo))+6  JJdiikB1 M    IIe  DOO$  %T112  ,-   s$AE$E8E54E58F  F c"|jS)zDAlias for :meth:`ensure_token`; does not mutate on subsequent calls.)r>)rs r get_tokenzNodeServer.get_tokenZs  ""rc K|j}tj||\}}|s2tjt |j dxsd|S|d}|d}|d}ddlm} |dk(r%d||jtjd d S|d k(rYd D cic] } | |vr| || } } d | vrtj|dS|jd'i| } tj|| S|dk(r:|j dd} |j| } tj|| S|dk(r$tj||jS|dk(r9|j d} |j| } tj|| S|dk(r|j dd}|j}d}|r|j drt!|ddz } |j"j%dd|j'dd 5}|j)t+j,|tjd!d"zd#d#d#d}tj|d||d$S tj|d&|Scc} w#1swYDxYw#t.$rd}YRwxYw#t0$r8}tj|t3|j4d%|cYd#}~Sd#}~wwxYww)(uValidate + dispatch a single decoded request envelope. Always returns a response envelope (success or error); never raises. Errors from inside the process_manager are wrapped into the response payload's ``ok``/``error`` keys (which pm already does) rather than being re-encoded as error envelopes — the envelope-level error channel is reserved for auth / protocol failures. idtypepayloadr)process_managerpingpong)rts)rDrBrE start_bot)url guest_namedurationheaded auth_state session_idout_dirrKzmissing 'url' in payloadstopreason requested)rSstatus transcriptlast)rWsaytextFrQzsay_queue.jsonlTr!arr)rYrI N)okenqueuedrYz: zunhandled type: r )r>_protovalidate_request make_errorr-r+plugins.google_meetrFrr7start make_responserRrUrV _read_activerr2r3openwriter(r6r. ExceptionrD__name__)rmsgexpectedr\rSreq_idtrEpmkkwargsresult reason_argrWrYactiver]queuefhexcs r_handle_requestzNodeServer._handle_request`s$$&,,S(; F$$S)<"%=vF FT Ki. >0 MF{ &f484E4E*.))+$788KEG|wqzM &!,,V5OPP!+F+++FF;;F{$[[;?  3++FF;;H}++FBIIK@@L {{6*D1++FF;;Ez{{62.* fjj3  !236GGE) **4$*G"ZZgZ>["HHTZZTYY[0Q%RUY%YZ[#'++XtD!.  +;A5)ABBW>[[#)#()  M$$VS 0B0B/C2cU-KL L MsA3L6)J?L J?)J:J?L'J?=L>>J?<L=(J?%L&=J?#L$A J?20J."=J" J.)J?LJ?"J+'J.. J<9J?;J<<J?? L-K;5L6L;LLcjK ddl}jfd}|j |j j 4d{ddl}|jd{dddd{y#t$r}td|d}~wwxYw7N747&#1d{7swYyxYww)z{Run the WebSocket server until cancelled. Blocks forever. Callers typically wrap this in ``asyncio.run``. rNz[NodeServer.serve requires the 'websockets' package. Install it with: pip install websocketsc K|23d{} tjt|tr|n|jd}j|d{}|j tj |d{7#t$rN}|j tj tjdd|d{7Yd}~d}~wwxYw77c6yw)NrrCzdecode: ) r^decoder,r- ValueErrorsendencoder`rv)wsrawrirureplyrs r_handlerz"NodeServer.serve.._handlers 4 4c --z#s/CT[I\]C#22377ggfmmE2333 4"''&--0A0A"QTPUFV0W"XYYY83 sxC.C,B C,C.6BC.C(+C.C*C. C, C%>C CC C. C%%C.*C.,C.) websockets ImportError RuntimeErrorr>serverrasyncioFuture)rrrurrs` rrzNodeServer.serves     4##HdiiC # # .." " " # # #% :  $ # # # # # #s|B3A;AB3 B B3 B%B&B* B35B6B3; B BBB3BB3B0$B' %B0,B3)z 127.0.0.1ieINzhermes-meet-node) rr-rintrzOptional[Path]rr-returnNone)rr-)riDict[str, Any]rr)rr) rh __module__ __qualname____doc__rr>r@rvrr rrrr)s_? %). * * *# *  *  *># HCX#rr)rr)r __future__rr(r0r7pathlibrtypingrrrhermes_constantsrplugins.google_meet.noder r^rrr rrrs90#  &&,7R_#_#r