Ë
    UV.j2  ã                  óL   — d Z ddlmZ ddlmZ ddlmZ dgZd„ Z G d„ d«      Z	y	)
z Amazon SQS queue implementation.é    )Úannotations)Ú	transformé   )ÚAsyncMessageÚ
AsyncQueuec                ó,   — t        | «      dk(  r| d   S dS )z4Get the first item in a list, or None if list empty.r   r   N)Úlen)Úrss    úbC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\kombu/asynchronous/aws/sqs/queue.pyÚ
list_firstr      s   € ä˜“G˜q’Lˆ2ˆa‰5Ð* dÐ*ó    c                  óè   — e Zd ZdZddefd„Zd„ ZexZxZxZ	xZ
xZxZxZxZxZxZZdd„Zdd„Zdd„Zd„ Zdd	„Zd
„ Z	 dd„Zdd„Z	 	 dd„Zdd„Zdd„Zd„ Z	 	 dd„Zdd„Zdd„Z dd„Z!dd„Z"	 	 dd„Z#y)r   zAsync SQS Queue.Nc                ó<   — || _         || _        || _        d | _        y ©N)Ú
connectionÚurlÚmessage_classÚvisibility_timeout)Úselfr   r   r   s       r   Ú__init__zAsyncQueue.__init__   s    € Ø$ˆŒØˆŒØ*ˆÔØ"&ˆÕr   c                ó   — t        «       ‚r   )ÚNotImplementedError)r   ÚargsÚkwargss      r   Ú_NAzAsyncQueue._NA   s   € Ü!Ó#Ð#r   c                ó<   — | j                   j                  | ||«      S r   )r   Úget_queue_attributes)r   Ú
attributesÚcallbacks      r   Úget_attributeszAsyncQueue.get_attributes    s    € Ø�‰×3Ñ3Ø�*˜hó
ð 	
r   c                ó>   — | j                   j                  | |||«      S r   )r   Úset_queue_attribute)r   Ú	attributeÚvaluer   s       r   Úset_attributezAsyncQueue.set_attribute%   s"   € Ø�‰×2Ñ2Ø�)˜U Hó
ð 	
r   c           	     óZ   — | j                  |t        | j                  ||t        «      «      S r   ©r    r   Ú_coerce_field_valueÚint)r   r   Ú_attrs      r   Úget_timeoutzAsyncQueue.get_timeout*   s.   € Ø×"Ñ"Ø”9Ø×(Ñ(¨(°E¼3óó
ð 	
r   c                ó   —  |||   «      S r   © )r   ÚkeyÚtypeÚresponses       r   r(   zAsyncQueue._coerce_field_value1   s   € Ù�H˜S‘MÓ"Ð"r   c                óP   — | j                  d|t        | j                  |«      «      S ©NÚVisibilityTimeout)r%   r   Ú_on_timeout_set)r   r   r   s      r   Úset_timeoutzAsyncQueue.set_timeout4   s.   € Ø×!Ñ!ØÐ!3ÜØ×$Ñ$ hóó
ð 	
r   c                ó,   — |r|| _         | j                   S r   )r   )r   r   s     r   r4   zAsyncQueue._on_timeout_set<   s   € ÙØ&8ˆDÔ#Ø×&Ñ&Ð&r   c                ó@   — | j                   j                  | ||||«      S r   )r   Úadd_permission)r   ÚlabelÚaws_account_idÚaction_namer   s        r   r8   zAsyncQueue.add_permissionA   s$   € à�‰×-Ñ-Ø�%˜¨°hó
ð 	
r   c                ó<   — | j                   j                  | ||«      S r   )r   Úremove_permission)r   r9   r   s      r   r=   zAsyncQueue.remove_permissionG   s   € Ø�‰×0Ñ0°°u¸hÓGÐGr   c           	     óH   — | j                  d||t        t        |«      ¬«      S )Nr   )Úwait_time_secondsr   )Úget_messagesr   r   )r   r   r?   r   s       r   ÚreadzAsyncQueue.readJ   s-   € à× Ñ ØÐ!Ø/Üœz¨8Ó4ð !ó 
ð 	
r   c           
     ó†   — | j                   j                  | |j                  «       |t        | j                  ||«      ¬«      S ©N)r   )r   Úsend_messageÚget_body_encodedr   Ú_on_message_sent)r   ÚmessageÚdelay_secondsr   s       r   ÚwritezAsyncQueue.writeR   s@   € Ø�‰×+Ñ+Ø�'×*Ñ*Ó,¨mÜ˜t×4Ñ4°hÀÓHð ,ó 
ð 	
r   c                ó>   — | j                   j                  | ||¬«      S rC   )r   Úsend_message_batch©r   Úmessagesr   s      r   Úwrite_batchzAsyncQueue.write_batchX   s%   € Ø�‰×1Ñ1Ø�( Xð 2ó 
ð 	
r   c                óJ   — |j                   |_         |j                  |_        |S r   )ÚidÚmd5)r   Úorig_messageÚnew_messages      r   rF   zAsyncQueue._on_message_sent]   s   € Ø%Ÿ.™.ˆŒØ&Ÿ?™?ˆÔØÐr   c                óD   — | j                   j                  | |||||¬«      S )N)Únumber_messagesr   r   r?   r   )r   Úreceive_message)r   Únum_messagesr   r   r?   r   s         r   r@   zAsyncQueue.get_messagesb   s/   € à�‰×.Ñ.Ø ,Ø1Ø!Ø/Øð /ó 
ð 	
r   c                ó<   — | j                   j                  | ||«      S r   )r   Údelete_message)r   rG   r   s      r   rY   zAsyncQueue.delete_messagel   s   € Ø�‰×-Ñ-¨d°G¸XÓFÐFr   c                ó>   — | j                   j                  | ||¬«      S rC   )r   Údelete_message_batchrL   s      r   r[   zAsyncQueue.delete_message_batcho   s%   € Ø�‰×3Ñ3Ø�( Xð 4ó 
ð 	
r   c                ó>   — | j                   j                  | ||¬«      S rC   )r   Úchange_message_visibility_batchrL   s      r   r]   z*AsyncQueue.change_message_visibility_batcht   s%   € Ø�‰×>Ñ>Ø�( Xð ?ó 
ð 	
r   c                ó<   — | j                   j                  | |¬«      S rC   )r   Údelete_queue)r   r   s     r   ÚdeletezAsyncQueue.deletey   s   € Ø�‰×+Ñ+¨D¸8Ð+ÓDÐDr   c           	     ó\   — | j                  |t        | j                  ||t        «      ¬«      S rC   r'   )r   Ú	page_sizeÚvtimeoutr   r*   s        r   ÚcountzAsyncQueue.count|   s3   € à×"Ñ"ØœIØ×(Ñ(¨(°E¼3óð #ó 
ð 	
r   )ÚAllNr   r2   )NNN)NN)r   NNNN)é
   rf   NÚApproximateNumberOfMessages)$Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   Ú
count_slowÚdumpÚsave_to_fileÚsave_to_filenameÚsaveÚ
save_to_s3Úload_from_s3Úload_from_fileÚload_from_filenameÚloadÚclearr    r%   r+   r(   r5   r4   r8   r=   rA   rI   rN   rF   r@   rY   r[   r]   r`   rd   r-   r   r   r   r      så   „ Ùà"&¨DÀó 'ò$ð ð€Jð �ð ˜ð Ð'7ð ¸$ð ØðØ!ðØ$2ðØ5Gðàˆuó
ó

ó

ò#ó
ò'ð !%ó
óHð ?CØó
ó
ó
ò
ð
 ?CØGKó
óGó
ó

ó
Eð 9=Ø1ô
r   N)
rk   Ú
__future__r   Úviner   rG   r   Ú_all__r   r   r-   r   r   Ú<module>rz      s)   ðÙ &å "å å !à
ˆ€ò+÷
q
ò q
r   