§
     @g9  ã                   óz   — d dl Z d dlZd dlmZ d dlmZ ddlmZmZ  ej	        e
¦  «        Z G d„ de¦  «        ZdS )é    N)ÚIterator)ÚQueueClienté   )ÚQueueClientBaseÚQueueItemBasec            	       óX   — e Zd Zddedededdfd„Zdefd	„Zd
efd„Z	de
e         fd„ZdS )ÚAzureStorageQueueClientç      ð?Úconnection_strÚnameÚdequeue_intervalÚreturnNc                 óŠ   — t                                d¦  «         t          j        ||¦  «        | _        i | _        || _        d S )Nz”!! AzureStorageQueueClient is an experimental implementation. This client causes performance issues especially when putting chunks in stream mode !!)ÚloggerÚwarningr   Úfrom_connection_stringÚqueue_clientÚ	itemtypesr   )Úselfr   r   r   s       úL/var/www/piapp/venv/lib/python3.11/site-packages/aiproxy/azurequeueclient.pyÚ__init__z AzureStorageQueueClient.__init__   sK   € Ý�Šð  nñ  	oô  	oð  	oÝ'Ô>¸~ÈtÑTÔTˆÔØˆŒØ 0ˆÔÐÐó    Ú
item_typesc                 ól   — |D ]0}| j                              |j        ¦  «        s|| j         |j        <   Œ1d S ©N)r   ÚgetÚ__name__)r   r   Úts      r   Úadd_item_typesz&AzureStorageQueueClient.add_item_types   sD   € Øð 	/ð 	/ˆAØ”>×%Ò% a¤jÑ1Ô1ð /Ø-.�”˜qœzÑ*øð	/ð 	/r   Úitemc                 ó^   — | j                              |                     ¦   «         ¦  «         d S r   )r   Úsend_messageÚto_json)r   r    s     r   ÚputzAzureStorageQueueClient.put   s'   € ØÔ×&Ò& t§|¢|¡~¤~Ñ6Ô6Ð6Ð6Ð6r   c              #   ób  K  — | j                              ¦   «         D ]’}t          j        |j        ¦  «        }| j                             |d         ¦  «        }|r2|                     |¦  «        V — | j                              |¦  «         Œot           
                    d|d         › �¦  «         Œ“d S )NÚtypezUnknown queue item type: )r   Úreceive_messagesÚjsonÚloadsÚcontentr   r   Ú	from_dictÚdelete_messager   r   )r   ÚmÚdÚclss       r   r   zAzureStorageQueueClient.get   s¹   è è € ØÔ"×3Ò3Ñ5Ô5ð 	Hð 	HˆAÝ”
˜1œ9Ñ%Ô%ˆAØ”.×$Ò$ Q v¤YÑ/Ô/ˆCØð HØ—m’m AÑ&Ô&Ð&Ð&Ð&ØÔ!×0Ò0°Ñ3Ô3Ð3Ð3å—’ÐF¸1¸V¼9ÐFÐFÑGÔGÐGÐGð	Hð 	Hr   )r
   )r   Ú
__module__Ú__qualname__ÚstrÚfloatr   Úlistr   r   r$   r   r   © r   r   r	   r	      s§   € € € € € ð1ð 1 sð 1°#ð 1Èð 1ÐY]ð 1ð 1ð 1ð 1ð/¨ð /ð /ð /ð /ð
7˜ð 7ð 7ð 7ð 7ðH�X˜mÔ,ð Hð Hð Hð Hð Hð Hr   r	   )r(   ÚloggingÚtypingr   Úazure.storage.queuer   Úqueueclientr   r   Ú	getLoggerr   r   r	   r5   r   r   ú<module>r;      s¥   ðØ €€€Ø €€€Ø Ð Ð Ð Ð Ð Ø +Ð +Ð +Ð +Ð +Ð +Ø 7Ð 7Ð 7Ð 7Ð 7Ð 7Ð 7Ð 7ð 
ˆÔ	˜8Ñ	$Ô	$€ðHð Hð Hð Hð H˜oñ Hô Hð Hð Hð Hr   