Ë
    ñÝjç  ã                  ór   — d Z ddlmZ ddlmZ ddlmZmZmZm	Z	m
Z
 ddlmZ ddlmZ  G d„ d	e«      Zg d
¢Zy)u
  Adapter-Sammlung.

Der frÃ¼here AriaOrchestrator (AusfÃ¼hrung ohne Policy und ohne Digest) ist
entfernt: Der einzige AusfÃ¼hrungspfad ist gateway.Gateway.handle().
MockAdapter ist ein vollwertiger BackendAdapter: Auch er fÃ¼hrt nur mit
gÃ¼ltiger HMAC-Clearance aus.
é    )Úannotations)ÚOptionalé   )Ú
AdapterJobÚAdapterResultÚBackendAdapterÚOutboundÚResultStatus)ÚClaudeChannelAdapter)ÚCodexAdapterc                  óH   ‡ — e Zd ZdZdZddddœ	 	 	 d	ˆ fd„Zd
d„Zdd„Zˆ xZS )ÚMockAdapterÚmockTNF)ÚoutputÚ	fail_codeÚraise_errorc               óx   •— || _         t        ‰| �	  |«       d| _        g | _        || _        || _        || _        y )Nr   )ÚnameÚsuperÚ__init__ÚcallsÚtransmittedÚ_outputÚ
_fail_codeÚ_raise)ÚselfÚverifierr   r   r   r   Ú	__class__s         €ú5/home/aria/aria-v3-dev/python/aria_router/adapters.pyr   zMockAdapter.__init__   s;   ø€ àˆŒ	Ü‰Ñ˜Ô"ØˆŒ
Ø!#ˆÔØˆŒØ#ˆŒØ!ˆ�ó    c                óz   — t        | j                  d|j                  j                  «       i|j                  ¬«      S )NÚcontext)Úpayload)r	   r   ÚenvelopeÚcanonical_dict)r   Újobs     r   Ú_preparezMockAdapter._prepare   s.   € Ü˜Ÿ	™	 I¨s¯|©|×/JÑ/JÓ/LÐ#MÐWZ×WcÑWcÔdÐdr    c           	     óä  — | xj                   dz  c_         | j                  j                  |j                  «       | j                  rt	        d«      ‚| j
                  r;t        |j                  | j                  t        j                  | j
                  ¬«      S t        |j                  | j                  t        j                  | j                  xs d| j                  › d|j                  › �¬«      S )Nr   zSimulated failure)Ú
error_codezMOCK_RESPONSE backend=z job=)r   )r   r   Úappendr   ÚRuntimeErrorr   r   Újob_idr   r
   ÚFAILEDÚSUCCESSr   )r   Úoutboundr&   Ú	clearances       r   Ú	_transmitzMockAdapter._transmit"   s­   € Ø�
Š
�a‰�
Ø×Ñ×Ñ × 4Ñ 4Ô5Ø�;Š;ÜÐ2Ó3Ð3Ø�?Š?Ü  §¡¨T¯Y©Y¼×8KÑ8KÐX\×XgÑXgÔhÐhÜØ�J‰J˜Ÿ	™	¤<×#7Ñ#7Ø—<‘<ÒXÐ%;¸D¿I¹I¸;ÀeÈCÏJÉJÈ<Ð#Xô
ð 	
r    )r   Ústrr   úOptional[str]r   r3   r   Úbool)r&   r   Úreturnr	   )r/   r	   r&   r   r5   r   )	Ú__name__Ú
__module__Ú__qualname__r   Úaccepts_memoryr   r'   r1   Ú__classcell__)r   s   @r   r   r      s5   ø„ Ø€DØ€NàGKØ,0Àeñ"Ø)ð"Ø?Cõ"óe÷

r    r   )r   r   r   N)Ú__doc__Ú
__future__r   Útypingr   Úadapter_contractr   r   r   r	   r
   Úclaude_channelr   Úcodex_adapterr   r   Ú__all__© r    r   ú<module>rC      s2   ðñõ #å ç _Õ _Ý 0Ý 'ô
�.ô 
ò< B�r    