߲j7 UdZddlmZddlZddlmZmZmZddlm Z m Z ddl m Z Gdde ZiZd ed <ej"Zdd Zdd Zdd ZddddZddddZddddZddddZddZddZy)aLive operations, one open per (profile, session), found by ``op_id``. The RPC layer reads and drives operations through here; the tool thread that minted one closes it on settle. The profile is part of the key: two multiplexed profiles can carry the same timestamp-based session key, and each side (the tool thread under the turn's profile override, the RPC under the session's profile scope) resolves it through ``hermes_home_key``.) annotationsN)DictOptionalTuple)get_process_hermes_homehermes_home_key)ConnectionOperationc eZdZdfd ZxZS)OperationAlreadyOpencht|d|jd|jd||_y)Nzsession z already has operation z open)super__init__ session_keyop_idexisting)selfr __class__s :/home/ubuntu/.hermes/hermes-agent/tools/connectors/live.pyrzOperationAlreadyOpen.__init__s7 8H$8$8#;;RS[SaSaRbbghi  )rr )__name__ __module__ __qualname__r __classcell__)rs@rr r s !!rr z*Dict[Tuple[str, str], ConnectionOperation]_openc0t|xs tS)zA session record names its profile home only for a non-default profile; the tool thread sees the same home through its turn override, and the default profile through the process home.)rr profile_homes r _profile_keyrs <D+B+D EErct||fSN)r)rrs r_keyr!!s  %{ 22rct|_|j|jf}t5tj |}||j s t||t|<dddy#1swYyxYwr )r profile_keyr_lockrgetsettledr ) operationkeyrs ropenr)%sj+-I  )"7"7 8C 99S>  (8(8&x0 0c s 8A//A8rct5tjt||}ddd|js|SdS#1swYxYwr )r$rr%r!r&)rrr's rcurrentr+/sG ?IId; => ?!-i6G6G9QTQ??s AA ct5tjt||}ddd|j|k(r|SdS#1swYxYwr )r$rr%r!r)rrrr's rr%r%5sK ?IId; => ?!-)//U2J9TPTT??s AA ct|t5tfdtj DdcdddS#1swYyxYw)Nc3nK|],\\}}}|k(r|jk(r|js|.ywr )rr&).0r(_r'rr#s r zget_by_op_id..>s?c#68CY{*y%/GPYPaPacs25rr$nextritems)rrr#s` @r get_by_op_idr5;sI|,K jc%++-cdhjjjjs (AAct|t5tfdtj DdcdddS#1swYyxYw)Nc3K|]?\\}}}|k(r2|js&|jxjdk(r|Ayw)N connector)r&targetkind)r/r(r0r'namer#r9s rr1zfind_target..EsUh#68CY{*93D3D$-$4$4T$::&GFKK[fLfhsAAr2)r;rr#r9s` @@r find_targetr<BsI|,K oh%++-himoooos )AAc|j|jf}t5tj ||urt|=dddy#1swYyxYwr )r#rr$rr%)r'r(s rcloser>JsG  )"7"7 8C  99S>Y &c s AAcbt5tjdddy#1swYyxYwr )r$rclearrrreset_for_testsrBQs#  s%.)r Optional[str]returnstr)rrErrCrDzTuple[str, str])r'r rDNone)rrErrCrDOptional[ConnectionOperation])rrErrErrCrDrG)rrErrCrDrG)r;rErrCrDrG)rDrF)__doc__ __future__r threadingtypingrrrhermes_constantsrrtools.connectors.operationr RuntimeErrorr r__annotations__Lockr$rr!r)r+r%r5r<r>rBrArrrQsE#((E:!<! 5716 F 3@DR HLU ?Cj=Aor