+
    —h©j|  ã                   ó–   € ^ RI Ht ^ RI Ht ^ RI Ht  ! R R]4      t ! R R]4      t ! R R	4      t ! R
 R]4      t ! R R]	4      t
R# )é    )Ú
exceptions)Úquery)Úsentencec                   ó^   a € ] tR t^t o R tRR ltRR ltR tR tR t	R t
R	 tR
 tRtV tR# )ÚApiCommunicatorBasec                ó.   € Wn         ^ V n        / V n        R# ©r   N)ÚbaseÚtagÚresponse_buffor)Úselfr
   s   &&Ú]/var/www/html/bestweb/venv/lib/python3.14/site-packages/routeros_api/api_communicator/base.pyÚ__init__ÚApiCommunicatorBase.__init__   s   € ØŒ	ØˆŒØ!ˆÖó    Nc           	     ó¢   € V P                  4       pV P                  WW4WeR 7      pV P                  V4       \        VR7      V P                  V&   V# ))r   Úadditional_queries©Úcommand)Ú_get_next_tagÚget_commandÚsend_commandÚAsynchronousResponser   )r   Úpathr   Ú	argumentsÚqueriesr   r   s   &&&&&& r   ÚsendÚApiCommunicatorBase.send   sO   € Ø× Ñ Ó"ˆØ×"Ñ" 4°)È#Ð"ÓuˆØ×Ñ˜'Ô"Ü$8ÀÔ$Iˆ×Ñ˜SÑ!Øˆ
r   c                ój  € T;'       g    / pT;'       g    / p\         P                  ! WVR 7      pVP                  4        F  w  rxVP                  Wx4       K  	  VP                  4        F*  w  rxVP	                  \
        P                  ! Wx4      4       K,  	  V F  p	VP	                  V	4       K  	  V# ))r   )r   ÚCommandSentenceÚitemsÚsetÚfilterr   ÚIsEqualQuery)
r   r   r   r   r   r   r   ÚkeyÚvalueÚadditional_querys
   &&&&&&&   r   r   ÚApiCommunicatorBase.get_command   s�   € Ø—O�O ˆ	Ø—-�-˜RˆÜ×*Ò*¨4¸cÔBˆØ#Ÿ/™/Ö+‰JˆCØ�K‰K˜Ö#ñ ,à!Ÿ-™-ž/‰JˆCØ�N‰Nœ5×-Ò-¨cÓ9Ö:ñ *ã 2ÐØ�N‰NÐ+Ö,ñ !3àˆr   c                óX   € V P                   P                  VP                  4       4       R # ©N)r
   Úsend_sentenceÚget_api_format)r   r   s   &&r   r   Ú ApiCommunicatorBase.send_command   s   € Ø�	‰	×Ñ × 6Ñ 6Ó 8Ö9r   c                óz   € V ;P                   ^,          un         \        V P                   4      P                  4       # ©é   )r   ÚstrÚencode©r   s   &r   r   Ú!ApiCommunicatorBase._get_next_tag"   s&   € Ø�Š�A��Ü�4—8‘8‹}×#Ñ#Ó%Ð%r   c                óØ   € \        W4      pVP                  '       g   VP                  4        K$  VP                  4        VP                  pVP
                  '       d   VP                  hV# r*   )Ú!AsynchronousResponseBufforManagerÚdoneÚstep_to_finish_responseÚcleanÚresponseÚerrorÚerror_as_exception)r   r   Úresponse_buffor_managerr:   s   &&  r   ÚreceiveÚApiCommunicatorBase.receive&   sV   € Ü"CÀDÓ"NÐØ)×.×.Ð.Ø#×;Ñ;Ö=Ø×%Ñ%Ô'Ø*×3Ñ3ˆØ�>�>ˆ>Ø×-Ñ-Ð-àˆOr   c                ó.   € \        W4      p\        V4      # r*   )r6   ÚAsynchronousResponseIterator)r   r   r=   s   && r   Úreceive_iteratorÚ$ApiCommunicatorBase.receive_iterator1   s   € Ü"CÀDÓ"NÐÜ+Ð,CÓDÐDr   c                ó\   € V P                  4       pVP                  V P                  4       R # r*   )Úreceive_single_responseÚsave_to_bufforr   )r   r:   s   & r   Úprocess_single_responseÚ+ApiCommunicatorBase.process_single_response5   s$   € Ø×/Ñ/Ó1ˆØ×Ñ × 4Ñ 4Ö5r   c                ó¢   € . pV'       g   V P                   P                  4       pK$  \        P                  P	                  V4      p\        V4      # r*   )r
   Úreceive_sentencer   ÚResponseSentenceÚparseÚSingleResponse)r   Ú
serializedÚresponse_sentences   &  r   rE   Ú+ApiCommunicatorBase.receive_single_response9   s?   € Øˆ
ßØŸ™×3Ñ3Ó5ŠJÜ$×5Ñ5×;Ñ;¸JÓGÐÜÐ/Ó0Ð0r   )r
   r   r   )NN© )NNNrQ   )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r   r   r   r   r>   rB   rG   rE   Ú__static_attributes__Ú__classdictcell__©Ú__classdict__s   @r   r   r      s8   ø‡ € ò"ô
ô
ò:ò&ò	òEò6÷1ð 1r   r   c                   ó,   a € ] tR t^At o R tR tRtV tR# )rM   c                ó   € Wn         R # r*   ©r:   )r   rO   s   &&r   r   ÚSingleResponse.__init__B   s   € Ø)Žr   c                ó  € V P                   P                  V9  d,   \        P                  ! R V P                   P                  4      hWP                   P                  ,          pV P                   P                  R8X  d(   V P                   P
                  pVP                  V4       V P                   P                  R8X  d&   RVn        V P                   P
                  pW2n        R	# V P                   P                  R8X  d%   V P                   P
                  R,          Vn	        R	# V P                   P                  R8X  dI   WP                   P                   RP                  VP                  R7      p\        P                  ! V4      hR	# )
zUnknown tag %ss   res   doneTs   traps   messages   fatalz'Fatal error executing command {command}r   N)r:   r   r   ÚFatalRouterOsApiErrorÚtypeÚ
attributesÚappendr7   Údone_messager;   Úformatr   Ú"RouterOsApiFatalCommunicationError)r   ÚbufforÚasynchronous_responsera   Úmessages   &&   r   rF   ÚSingleResponse.save_to_bufforE   s)  € Ø�=‰=×Ñ FÔ*Ü×2Ò2Ø  $§-¡-×"3Ñ"3ó5ð 5à &§}¡}×'8Ñ'8Õ 9ÐØ�=‰=×Ñ Ô&ØŸ™×1Ñ1ˆJØ!×(Ñ(¨Ô4Ø�=‰=×Ñ Ô(Ø)-Ð!Ô&ØŸ™×1Ñ1ˆJØ1;Ö.Ø�]‰]×Ñ 7Ô*Ø*.¯-©-×*BÑ*BÀ:Õ*NÐ!Ö'Ø�]‰]×Ñ 8Ô+ØŸ™×)Ñ)Ð*Ø?×FÑFØ-×5Ñ5ð Gó 7ˆGä×?Ò?ÀÓHÐHñ	 ,r   r\   N)rR   rS   rT   rU   r   rF   rV   rW   rX   s   @r   rM   rM   A   s   ø‡ € ò*÷Ið Ir   rM   c                   óB   a € ] tR t^Zt o R tR tR t]R 4       tRt	V t
R# )rA   c                ó    € Wn         ^ V n        R# r	   )r=   Úindex)r   r=   s   &&r   r   Ú%AsynchronousResponseIterator.__init__[   s   € Ø'>Ô$ØˆŽ
r   c                ó   € V # r*   rQ   r3   s   &r   Ú__iter__Ú%AsynchronousResponseIterator.__iter___   s   € Øˆr   c                ó  € V P                   P                  pV P                  '       d9   V P                   P                  '       g   V P                   P	                  4        KJ  V P                  '       d9   VP
                  '       d'   V P                   P                  4        VP                  hV P                  '       d!   V P                   P                  4        \        hWP                  ,          pV ;P                  ^,          un	        V# r/   )
r=   r:   Úend_of_bufferedr7   r8   r;   r9   r<   ÚStopIterationrl   )r   r:   Úcurrents   &  r   Ú__next__Ú%AsynchronousResponseIterator.__next__b   s¶   € Ø×/Ñ/×8Ñ8ˆØ×"×"Ð"¨4×+GÑ+G×+L×+LÐ+LØ×(Ñ(×@Ñ@ÖBØ××Ð H§N§N NØ×(Ñ(×.Ñ.Ô0Ø×-Ñ-Ð-Ø×!×!Ð!Ø×(Ñ(×.Ñ.Ô0ÜÐàŸz™zÕ*ˆGØ�JŠJ˜!�O�JØˆNr   c                óZ   € V P                   \        V P                  P                  4      8¬  # r*   )rl   Úlenr=   r:   r3   s   &r   rr   Ú,AsynchronousResponseIterator.end_of_bufferedq   s"   € à�z‰zœS ×!=Ñ!=×!FÑ!FÓGÑGÐGr   )rl   r=   N)rR   rS   rT   rU   r   ro   ru   Úpropertyrr   rV   rW   rX   s   @r   rA   rA   Z   s*   ø‡ € òòòð ñHó öHr   rA   c                   óB   a € ] tR t^vt o R tR t]R 4       tR tRt	V t
R# )r6   c                óv   € Wn         W n        V P                   P                  V P                  ,          V n        R # r*   )Úreceiverr   r   r:   )r   r}   r   s   &&&r   r   Ú*AsynchronousResponseBufforManager.__init__w   s&   € Ø ŒØŒØŸ™×5Ñ5°d·h±hÕ?ˆŽr   c                ó:   € V P                   P                  4        R # r*   )r}   rG   r3   s   &r   r8   Ú9AsynchronousResponseBufforManager.step_to_finish_response|   s   € Ø�‰×-Ñ-Ö/r   c                ó.   € V P                   P                  # r*   )r:   r7   r3   s   &r   r7   Ú&AsynchronousResponseBufforManager.done   s   € à�}‰}×!Ñ!Ð!r   c                óH   € V P                   P                  V P                   R # r*   )r}   r   r   r3   s   &r   r9   Ú'AsynchronousResponseBufforManager.cleanƒ   s   € Ø�]‰]×*Ñ*¨4¯8©8Ò4r   )r}   r:   r   N)rR   rS   rT   rU   r   r8   rz   r7   r9   rV   rW   rX   s   @r   r6   r6   v   s.   ø‡ € ò@ò
0ð ñ"ó ð"÷6ð 6r   r6   c                   óH   a a€ ] tR t^‡t oV 3R lt]R 4       tR tRtVt	V ;t
# )r   c                ó†   <€ VP                  R 4      V n        \        \        V `  ! V/ VB  / V n        RV n        RV n        R# )r   FN)Úpopr   Úsuperr   r   rc   r7   r;   )r   ÚargsÚkwargsÚ	__class__s   &*,€r   r   ÚAsynchronousResponse.__init__ˆ   s>   ø€ Ø—z‘z )Ó,ˆŒÜÔ" DÒ2°DÐC¸FÒCØˆÔØˆŒ	ØˆŽ
r   c                óÔ   € V P                   '       dV   R P                  V P                   P                  4       V P                  R7      p\        P
                  ! WP                   4      # R# )z+Error "{error}" executing command {command})r;   r   N)r;   rd   Údecoder   r   ÚRouterOsApiCommunicationError)r   rh   s   & r   r<   Ú'AsynchronousResponse.error_as_exception�   sY   € à�:�:ˆ:ØE×LÑLØ—j‘j×'Ñ'Ó)ØŸ™ð Mó &ˆGô ×;Ò;ØŸ™ó%ð %ñ r   c                óÄ   € \        V 4      ! \        W4      V P                  R 7      pV! V P                  4      Vn        V P                  Vn        V P
                  Vn        V# )r   )r`   Úmapr   rc   r7   r;   )r   ÚfunctionÚresults   && r   r’   ÚAsynchronousResponse.mapš   sI   € Ü�d”œC Ó/¸¿¹ÔFˆÙ& t×'8Ñ'8Ó9ˆÔØ—i‘iˆŒØ—z‘zˆŒØˆr   )r   r7   rc   r;   )rR   rS   rT   rU   r   rz   r<   r’   rV   rW   Ú__classcell__)r‹   rY   s   @@r   r   r   ‡   s(   ù‡ € õð ñó ð÷ò r   r   N)Úrouteros_apir   r   r   Úobjectr   rM   rA   r6   Úlistr   rQ   r   r   Ú<module>rš      sM   ðÝ #Ý Ý !ô81˜&ô 81ôvI�Vô I÷2Hñ Hô86¨ô 6ô"˜4ö r   