+
    Q(i                       a  R t0 t ^ RIHt ^ RIt^ RIHt ^ RIHt ]]P                  P                  ]P                  P                  3,          ]P                  P                  ,          ],          t] ^ k ]t] ^k  ! R R4      tR# )    )	TypeAliasN)MessageHandlerFnT)RequestResponderc                   D  a  ] tR t^t o RtV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR	 ltV 3R
 lR lt	V 3R lR lt
V 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R  lR! ltR"tV tR## )$MessageHandlerz
This class is used to handle MCP messages sent to the client. It is used to handle all messages,
requests, notifications, and exceptions. Users can override any of the hooks
c                   < V ^8  d   QhRS[ S[P                  P                  S[P                  P                  3,          S[P                  P
                  ,          S[,          RR/#    messagereturnN)r   mcptypesServerRequestClientResultServerNotification	Exception)format__classdict__s   "]/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/fastmcp/client/messages.py__annotate__MessageHandler.__annotate__   sW     , ,!#))"9"9399;Q;Q"QR
))
&
&'
,
 
,    c                @   "   V P                  V4      G R j  xL
 #  L5iN)dispatchselfr   s   &&r   __call__MessageHandler.__call__   s      ]]7++++s   c                $   < V ^8  d   QhRS[ RR/# r	   Message)r   r   s   "r   r   r      s     ,1 ,1g ,1$ ,1r   c                  "   V P                  V4      G R j  xL
  T;\        Rc ;Ee+   w    V P                  V4      G R j  xL
  VP                  P                  ;\
        P                  P                  Rc ;e3   w    V P                  VP                  P                  4      G R j  xL
  R #  ;\
        P                  P                  Rc ;e3   w    V P                  VP                  P                  4      G R j  xL
  R #  \
        P                  P                  Rc ;e2   w   V P                  VP                  P                  4      G R j  xL
  R #  R #  ;\
        P                  P                  Rc ;Ee'   w    V P                  V4      G R j  xL
  VP                  ;\
        P                  P                  Rc ;e)   w    V P!                  VP                  4      G R j  xL
  R #  ;\
        P                  P"                  Rc ;e)   w    V P%                  VP                  4      G R j  xL
  R #  ;\
        P                  P&                  Rc ;e)   w    V P)                  VP                  4      G R j  xL
  R #  ;\
        P                  P*                  Rc ;e)   w    V P-                  VP                  4      G R j  xL
  R #  ;\
        P                  P.                  Rc ;e)   w    V P1                  VP                  4      G R j  xL
  R #  ;\
        P                  P2                  Rc ;e)   w    V P5                  VP                  4      G R j  xL
  R #  \
        P                  P6                  Rc ;e(   w   V P9                  VP                  4      G R j  xL
  R #  R #  \:        Rc ;e   w   V P=                  V4      G R j  xL
  R #  R #  EL EL EL( EL EL ELJ EL EL ELp EL* L L LW L-5i)N )
on_messager   
on_requestrequestrootr   r   PingRequeston_pingListRootsRequeston_list_rootsCreateMessageRequeston_create_messager   on_notificationCancelledNotificationon_cancelledProgressNotificationon_progressLoggingMessageNotificationon_logging_messageToolListChangedNotificationon_tool_list_changedResourceListChangedNotificationon_resource_list_changedPromptListChangedNotificationon_prompt_list_changedResourceUpdatedNotificationon_resource_updatedr   on_exceptionr   s   &&r   r   MessageHandler.dispatch   s    oog&&&#!## oog... oo**0..0"ll7??+?+?@@@ 15335"001E1EFFF 6779"44W__5I5IJJJ : $  0--//**7333 ll:88:"//=== ;9779"..w||<<< :?==?"55gllCCC @@>>@"77EEE ADBBD";;GLLIII EB@@B"99',,GGG C>>@"66w||DDD A% 0* ''000 S 	' / AFJ
 4
 ><CEIGD 1s  O.O)O.OA$O.&O'AO.9O:AO.
OAO.OAO.OAO.'O(AO.0O 1AO.9O#:AO.O&AO.O(AO.O*+O.>O,?
O.O.O.O.O.O.O.O. O.#O.&O.(O.*O.,O.c                $   < V ^8  d   QhRS[ RR/# r	   r!   )r   r   s   "r   r   r   L   s       D r   c                   "   R # 5ir   r$   r   s   &&r   r%   MessageHandler.on_messageL           c                   < V ^8  d   QhRS[ S[P                  P                  S[P                  P                  3,          RR/# r	   )r   r   r   r   r   )r   r   s   "r   r   r   O   s;      '		(?(?AWAW(WX	r   c                   "   R # 5ir   r$   r   s   &&r   r&   MessageHandler.on_requestO   
      	rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r)   )r   r   s   "r   r   r   T   s%      SYY%:%: t r   c                   "   R # 5ir   r$   r   s   &&r   r*   MessageHandler.on_pingT   rC   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r+   )r   r   s   "r   r   r   W   s%      399+E+E $ r   c                   "   R # 5ir   r$   r   s   &&r   r,   MessageHandler.on_list_rootsW   rC   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r-   )r   r   s   "r   r   r   Z   s&      syy/M/M RV r   c                   "   R # 5ir   r$   r   s   &&r   r.    MessageHandler.on_create_messageZ   rC   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r   )r   r   s   "r   r   r   ]   s%      SYY-I-I d r   c                   "   R # 5ir   r$   r   s   &&r   r/   MessageHandler.on_notification]   rC   rD   c                $   < V ^8  d   QhRS[ RR/# r	   )r   )r   r   s   "r   r   r   `   s      )  r   c                   "   R # 5ir   r$   r   s   &&r   r>   MessageHandler.on_exception`   rC   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r2   )r   r   s   "r   r   r   c   s%      )G)G D r   c                   "   R # 5ir   r$   r   s   &&r   r3   MessageHandler.on_progressc   rC   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r4   )r   r   s   "r   r   r   f   s'      yy;;	r   c                   "   R # 5ir   r$   r   s   &&r   r5   !MessageHandler.on_logging_messagef   rH   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r6   )r   r   s   "r   r   r   k   '      yy<<	r   c                   "   R # 5ir   r$   r   s   &&r   r7   #MessageHandler.on_tool_list_changedk   rH   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r8   )r   r   s   "r   r   r   p   s'      yy@@	r   c                   "   R # 5ir   r$   r   s   &&r   r9   'MessageHandler.on_resource_list_changedp   rH   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r:   )r   r   s   "r   r   r   u   s'      yy>>	r   c                   "   R # 5ir   r$   r   s   &&r   r;   %MessageHandler.on_prompt_list_changedu   rH   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r<   )r   r   s   "r   r   r   z   r_   r   c                   "   R # 5ir   r$   r   s   &&r   r=   "MessageHandler.on_resource_updatedz   rH   rD   c                L   < V ^8  d   QhRS[ P                  P                  RR/# r	   )r   r   r0   )r   r   s   "r   r   r      s%      #))*I*I d r   c                   "   R # 5ir   r$   r   s   &&r   r1   MessageHandler.on_cancelled   rC   rD   r$   N)__name__
__module____qualname____firstlineno____doc__r   r   r%   r&   r*   r,   r.   r/   r>   r3   r5   r7   r9   r;   r=   r1   __static_attributes____classdictcell__)r   s   @r   r   r      s     
, ,,1 ,1\  
       
 
 
 
 
 r   r   c                h    V ^8  d   Qh/ ^ \         9   d
   \        ;R&   ^\         9   d
   \        ;R&   # )r
   r"   MessageHandlerT)__conditional_annotations__r   )r   s   "r   r   r      s0          / . . r   )rw   typingr   	mcp.typesr   mcp.client.sessionr   mcp.shared.sessionr   r   r   r   r   r   r"   rv   r   r   )rw   s   @r   <module>r|      sr       0 / SYY,,cii.D.DDE	ii""#   / .p pr   