
    gh                         S r SSKJrJr  SSKJr  SSKJr  SSKJ	r	  \	(       a  SSK
Jr  SSKJr  SSKJr  SS	KJr  S
 rS rS rS rg)z,
Code used for the Queries module in Sentry
    )OPSPANDATA)_get_safe_command)capture_internal_exceptions)TYPE_CHECKING)Redis)RedisIntegration)Span)Anyc                 D    [        XU5      n[        R                  US.nU$ )N)opdescription)_get_db_span_descriptionr   DB_REDIS)integrationredis_commandargsr   
propertiess        p/home/kali/devsecops-assessor/venv/lib/python3.13/site-packages/sentry_sdk/integrations/redis/modules/queries.py_compile_db_span_propertiesr      s)    *;tLK kk"J
     c                    Un[        5          [        X5      nS S S 5        U R                  =(       a    [        U5      U R                  :  nU(       a  US U R                  [        S5      -
   S-   nU$ ! , (       d  f       N`= f)Nz...)r   r   max_data_sizelen)r   command_namer   r   data_should_be_truncateds        r   r   r      sv    K	$	&'; 
' 	!!Rc+&69R9R&R   !"JK$=$=E
$JKeS 
'	&s   A33
Bc                    U R                  [        R                  S5        UR                  S5      nUb)  U R                  [        R                  [        U5      5        UR                  S5      nUb   U R                  [        R                  U5        UR                  S5      nUb!  U R                  [        R                  U5        g g )Nredisdbhostport)set_datar   	DB_SYSTEMgetDB_NAMEstrSERVER_ADDRESSSERVER_PORT)spanconnection_paramsr   r    r!   s        r   _set_db_data_on_spanr+   .   s    MM($$g.			t	$B	~h&&B0  (Dh--t4  (Dh**D1 r   c                 d     [        XR                  R                  5        g ! [         a     g f = f)N)r+   connection_poolconnection_kwargsAttributeError)r)   redis_instances     r   _set_db_datar1   ?   s-    T#A#A#S#ST s   " 
//N)__doc__sentry_sdk.constsr   r   #sentry_sdk.integrations.redis.utilsr   sentry_sdk.utilsr   typingr   r   r   sentry_sdk.integrations.redisr	   sentry_sdk.tracingr
   r   r   r   r+   r1    r   r   <module>r:      s;    + A 8  >'	 2"r   