Ë
    S>{i\  ã                   ó€  — d dl mZ d dlZd dlmZ d dlmZ d dlmZ d dlm	Z	 d dl
mZ d dlmZ d d	lmZmZ d d
lmZmZ d dlmZmZmZ er-d dlmZmZmZmZmZ d dlmZmZm Z  d dlm!Z!  ededef   ¬«      Z"	 d dl#m$Z$m%Z%m&Z&m'Z' d dl(m)Z)m*Z*m+Z+ e)e*e+fZ- G d„ de«      Z.d„ Z/d„ Z0d„ Z1d„ Z2d„ Z3y# e,$ r	  ed«      ‚w xY w)é    )Úabsolute_importN)Údatetime)Úreraise)ÚTYPE_CHECKING)ÚHub)ÚOP)Ú_should_send_default_pii)ÚDidNotEnableÚIntegration)ÚTransactionÚTRANSACTION_SOURCE_TASK)Úcapture_internal_exceptionsÚevent_from_exceptionÚSENSITIVE_DATA_SUBSTITUTE)ÚAnyÚCallableÚOptionalÚUnionÚTypeVar)ÚEventProcessorÚEventÚHint)ÚExcInfoÚF.)Úbound)ÚHueyÚResultÚResultGroupÚTask)ÚCancelExecutionÚ	RetryTaskÚTaskLockedExceptionzHuey is not installedc                   ó    — e Zd ZdZed„ «       Zy)ÚHueyIntegrationÚhueyc                  ó,   — t        «        t        «        y ©N)Úpatch_enqueueÚpatch_execute© ó    úZ/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/sentry_sdk/integrations/huey.pyÚ
setup_oncezHueyIntegration.setup_once(   s   € ô 	ŒÜ�r+   N)Ú__name__Ú
__module__Ú__qualname__Ú
identifierÚstaticmethodr-   r*   r+   r,   r$   r$   %   s   „ Ø€Jàñó ñr+   r$   c                  óF   ‡— t         j                  Šˆfd„} | t         _        y )Nc                 óô   •— t         j                  }|j                  t        «      €	 ‰| |«      S |j	                  t
        j                  |j                  ¬«      5   ‰| |«      cd d d «       S # 1 sw Y   y xY w)N)ÚopÚdescription)r   ÚcurrentÚget_integrationr$   Ú
start_spanr   ÚQUEUE_SUBMIT_HUEYÚname)ÚselfÚtaskÚhubÚold_enqueues      €r,   Ú_sentry_enqueuez&patch_enqueue.<locals>._sentry_enqueue3   sc   ø€ ä�k‰kˆà×ÑœÓ/Ð7Ù˜t TÓ*Ð*à�^‰^œr×3Ñ3ÀÇÁˆ^ÓKñ 	+Ù˜t TÓ*÷	+÷ 	+ò 	+ús   Á	A.Á.A7)r   Úenqueue)r@   r?   s    @r,   r(   r(   /   s   ø€ ä—,‘,€Kô+ð #„D…Lr+   c                 ó   ‡ — ˆ fd„}|S )Nc                 ó¬  •— t        «       5  | j                  di «      }‰j                  |d<   ‰j                  ‰j                  kD  |d<   | j                  di «      }‰j
                  t        «       r‰j                  nt        t        «       r‰j                  nt        ‰j                  xs d‰j                  z
  dœ|d<   d d d «       | S # 1 sw Y   | S xY w)NÚtagsÚhuey_task_idÚhuey_task_retryÚextrar   )r=   ÚargsÚkwargsÚretryzhuey-job)
r   Ú
setdefaultÚidÚdefault_retriesÚretriesr;   r	   rH   r   rI   )ÚeventÚhintrD   rG   r=   s       €r,   Úevent_processorz._make_event_processor.<locals>.event_processorB   sÃ   ø€ ô )Ó*ñ 	Ø×#Ñ# F¨BÓ/ˆDØ#'§7¡7ˆD�Ñ Ø&*×&:Ñ&:¸T¿\¹\Ñ&IˆDÐ"Ñ#Ø×$Ñ$ W¨bÓ1ˆEàŸ	™	ä+Ô-ð Ÿ	š	ä.ä+Ô-ð Ÿ+š+ä.Ø×.Ñ.Ò3°!°t·|±|ÑCñ	!ˆE�*Ñ÷	ð  ˆ÷!	ð  ˆús   ŒB3C	Ã	Cr*   )r=   rQ   s   ` r,   Ú_make_event_processorrR   @   s   ø€ ôð* Ðr+   c                 ó~  — t         j                  }| d   t        v r&|j                  j                  j                  d«       y |j                  j                  j                  d«       t        | |j                  r|j                  j                  nd t        j                  ddœ¬«      \  }}|j                  ||¬«       y )Nr   ÚabortedÚinternal_errorF)ÚtypeÚhandled)Úclient_optionsÚ	mechanism)rP   )r   r7   ÚHUEY_CONTROL_FLOW_EXCEPTIONSÚscopeÚtransactionÚ
set_statusr   ÚclientÚoptionsr$   r1   Úcapture_event)Úexc_infor>   rO   rP   s       r,   Ú_capture_exceptionrb   Z   s•   € ä
�+‰+€Cà��{Ô2Ñ2Ø�	‰	×Ñ×(Ñ(¨Ô3Øà‡I�I×Ñ×$Ñ$Ð%5Ô6Ü&ØØ-0¯ZªZ�s—z‘z×)Ò)¸TÜ*×5Ñ5À%ÑHô�K€Eˆ4ð
 ×Ñ�e $ÐÕ'r+   c                 ó   ‡ — ˆ fd„}|S )Nc                  óâ   •— t         j                  }|j                  t        «      € ‰| i |¤ŽS 	  ‰| i |¤Ž}|S # t        $ r+ t        j                  «       }t        |«       t        |Ž  Y S w xY wr'   )	r   r7   r8   r$   Ú	ExceptionÚsysra   rb   r   )rH   rI   r>   Úresultra   Úfuncs        €r,   Ú_sentry_executez+_wrap_task_execute.<locals>._sentry_executem   sy   ø€ ä�k‰kˆØ×ÑœÓ/Ð7Ù˜Ð( Ñ(Ð(ð	Ù˜4Ð* 6Ñ*ˆFð ˆøô ò 	Ü—|‘|“~ˆHÜ˜xÔ(Ü�XÒàˆð	ús   °: º0A.Á-A.r*   )rh   ri   s   ` r,   Ú_wrap_task_executerj   k   s   ø€ ôð Ðr+   c                  óH   ‡— t         j                  Šdˆfd„	} | t         _        y )Nc                 óv  •— t         j                  }|j                  t        «      €
 ‰| ||«      S |j	                  «       5 }t        «       5  d|_        |j                  «        |j                  t        |«      «       d d d «       t        |j                  dt        j                  t        ¬«      }t        |dd«      s!t!        |j"                  «      |_        d|_        |j'                  |«      5   ‰| ||«      cd d d «       cd d d «       S # 1 sw Y   Œ�xY w# 1 sw Y   nxY w	 d d d «       y # 1 sw Y   y xY w)Nr%   Úok)r;   Ústatusr5   ÚsourceÚ_sentry_is_patchedFT)r   r7   r8   r$   Ú
push_scoper   Ú_nameÚclear_breadcrumbsÚadd_event_processorrR   r   r;   r   ÚQUEUE_TASK_HUEYr   Úgetattrrj   Úexecuterp   Ústart_transaction)r<   r=   Ú	timestampr>   r[   r\   Úold_executes         €r,   ri   z&patch_execute.<locals>._sentry_executeƒ   s  ø€ ä�k‰kˆà×ÑœÓ/Ð7Ù˜t T¨9Ó5Ð5à�^‰^Óð 	: Ü,Ó.ñ GØ$�”Ø×'Ñ'Ô)Ø×)Ñ)Ô*?ÀÓ*EÔF÷Gô
 &Ø—Y‘YØÜ×%Ñ%Ü.ô	ˆKô ˜4Ð!5°uÔ=Ü1°$·,±,Ó?�”Ø*.�Ô'à×&Ñ& {Ó3ñ :Ù" 4¨¨yÓ9÷:ð :÷#	:ñ 	:÷Gð Gú÷ :ð :úð :÷#	:÷ 	:ñ 	:ús=   ÁD/Á2DÁ>A2D/Ã0
DÃ:	D/ÄD	ÄD/ÄD"	ÄD/Ä/D8r'   )r   Ú_execute)ri   rz   s    @r,   r)   r)      s   ø€ ä—-‘-€Kõ:ð6 $„D…Mr+   )4Ú
__future__r   rf   r   Úsentry_sdk._compatr   Úsentry_sdk._typesr   Ú
sentry_sdkr   Úsentry_sdk.constsr   Úsentry_sdk.hubr	   Úsentry_sdk.integrationsr
   r   Úsentry_sdk.tracingr   r   Úsentry_sdk.utilsr   r   r   Útypingr   r   r   r   r   r   r   r   r   r   Úhuey.apir   r   r   r   Úhuey.exceptionsr    r!   r"   ÚImportErrorrZ   r$   r(   rR   rb   rj   r)   r*   r+   r,   ú<module>r‰      sº   ðÝ &ã 
Ý å &Ý +Ý Ý  Ý 3ß =ß C÷ñ ñ ß>Õ>ç=Ñ=Ý(á�˜8 C¨ HÑ-Ô.€Að0ß8Ó8ßOÑOð
 !0°Ð<OÐPÐ ô�kô ò#ò"ò4(ò"ó($øðC ò 0Ù
Ð.Ó
/Ð/ð0ús   Á9B/ Â/B=