yjwUdZddlmZddlZddlZddlZddlZddlmZm Z m Z m Z m Z ej eZiZded<ejZdZddZddZd dZefd!dZefd"dZd#dZdS)$uGeneric slash-command confirmation primitive (gateway-side). Slash commands that have a non-destructive but expensive side effect worth surfacing to the user (currently only ``/reload-mcp``, which invalidates the provider prompt cache) route through this module. Two delivery paths: 1. Button UI — adapters that override ``send_slash_confirm`` render three inline buttons (Approve Once / Always Approve / Cancel). The button callback calls ``resolve(session_key, confirm_id, choice)``. 2. Text fallback — adapters without button UIs get a plain text prompt. Users reply with ``/approve``, ``/always``, or ``/cancel``; the gateway's ``_handle_message`` intercepts those replies and calls ``resolve()`` directly. State is stored module-level (like ``tools.approval``) so platform adapters can resolve callbacks without needing a backreference to the ``GatewayRunner`` instance. The CLI path (``cli.py``) uses a local synchronous variant — see ``_prompt_slash_confirm`` there. ) annotationsN)Any AwaitableCallableDictOptionalzDict[str, Dict[str, Any]]_pendingi, session_keystr confirm_idcommandhandler)Callable[[str], Awaitable[Optional[str]]]returnNonect5|||tjdt|<ddddS#1swxYwYdS)uRegister a pending slash-command confirmation. Overwrites any prior pending confirm for the same ``session_key`` — the user invoking a new confirmable command supersedes the stale one. )r r r created_atN)_locktimer )r r r rs 9/home/ragecks/.hermes/hermes-agent/tools/slash_confirm.pyregisterr3s   $)++ ! !                   s !6::Optional[Dict[str, Any]]ct5t|}|rt|ndcdddS#1swxYwYdS)z7Return the pending confirm dict for a session, or None.N)rr getdict)r entrys r get_pendingrGs .. [))#-tE{{{..................s-AA Ac|t5t|dddddS#1swxYwYdS)z@Drop the pending confirm for ``session_key`` without running it.N)rr pop)r s rclearr Ns (( [$'''((((((((((((((((((s 155timeoutfloatboolcht5t|}|s ddddStjt |ddpdz |kr)t|d ddddS ddddS#1swxYwYdS)zkDrop the pending confirm if older than ``timeout`` seconds. Returns True if an entry was dropped. NFrrT)rr rrr"r)r r!rs rclear_if_staler%Ts)  [))  9;;uyyq99>Q?? ?' I I LLd + + + sB'AB'B''B+.B+choice Optional[str]cKt5t|}|s ddddS|d|kr ddddSt|dt jt |ddpdz |kr ddddS|d}|dd}dddn #1swxYwY|sdS ||d{V}n:#t $r-}td||d d |cYd}~Sd}~wwxYwt|tr|ndS) aResolve a pending confirm. ``choice`` must be one of ``"once"``, ``"always"``, or ``"cancel"``. Returns the handler's output string (to be sent as a follow-up message), or ``None`` if the confirm was stale, already resolved, or the confirm_id doesn't match. Safe to call from an asyncio callback (button click) or from the gateway's message intercept path. Nr rrrr ?z(Slash-confirm handler for /%s raised: %sT)exc_infou!❌ Error handling confirmation: ) rr rrrr" Exceptionloggererror isinstancer ) r r r&r!rrr resultexcs rresolver1cs6  , , [))  , , , , , , , , 99\ " "j 0 0 , , , , , , , ,  [$''' 9;;uyyq99>Q?? ?' I I , , , , , , , ,))I&&))Is++ , , , , , , , , , , , , , , , t9wv&&&&&& 999 6 S4    9388888888 9  ,, 666$6sAC9C9AC9+C99C=C= D E%"E E Eloopasyncio.AbstractEventLoopc ddlm}|t||||td}|dS|dS#t $r&}td|Yd}~dSd}~wwxYw) a"Synchronous helper: schedule resolve() on a loop and wait for the result. Used by platform callback paths that run on a different thread than the event loop (e.g. Discord's button click handler in some configurations). Prefer the async ``resolve()`` from an async context. r)safe_schedule_threadsafez%resolve_sync_compat scheduling failed)r, log_messageN)r!zresolve_sync_compat failed: %s)agent.async_utilsr5r1r,r/r+r-)r2r r r&r5futr0s rresolve_sync_compatr:s >>>>>>&& KV 4 4d?    ;4zz"z%%%  5s;;;ttttts+AA A5A00A5) r r r r r r rrrr)r r rr)r r rr)r r r!r"rr#) r r r r r&r r!r"rr') r2r3r r r r r&r rr')__doc__ __future__rasynciologging threadingrtypingrrrrr getLogger__name__r,r __annotations__RLockrDEFAULT_TIMEOUT_SECONDSrrr r%r1r:rrHsM.#""""" ;;;;;;;;;;;;;;  8 $ $')((((      (....(((( 7N     &- )7)7)7)7)7XrG