OwlCyberSecurity - MANAGER
Edit File: caching.cpython-312.pyc
� G��g � �� � d dl Z d dlmZ d dlmZmZ d dlmZ d dl m Z d dl m Z d dlZd dlmZmZ d dlmZmZ erd d lmZ d d lmZ d d lmZ g d �Zd � Zd� Zdd�Zd� Z d� Z d� Z y)� N)� TYPE_CHECKING)� _get_safe_key�_key_as_string)� parse_url)�VERSION)� CacheHandler)�OP�SPANDATA)�capture_internal_exceptions�ensure_integration_enabled)�Any)�Callable)�Optional)�set�set_many�get�get_manyc �. � t t | ||� � S �N)r r )� method_name�args�kwargss �U/opt/hc_python/lib/python3.12/site-packages/sentry_sdk/integrations/django/caching.py�_get_span_descriptionr s � � �-� �T�6�B� C�C� c � � ������� ddl m� t � �� �t ��� �fd�� �t j �� ��� ���fd�� }t � �|� y )Nr ��DjangoIntegrationc � �� |j d� }| }|rt j nt j } t |||� } t j | | �j �� 5 } ||i |��} t � 5 |� | j t j |� |� | j t j |� t |||� } | � | j t j | � d }|rX| r5t t! | � � }| j t j" d� ne| j t j" d� nDt |� }|dk\ rt t! |d � � }n |dk( rt t! |d � � }|� | j t j$ |� d d d � | cd d d � S # 1 sw Y �xY w# 1 sw Y y xY w)Nr )�op�name�originTF� � r )� startswithr � CACHE_PUT� CACHE_GETr � sentry_sdk� start_spanr" r �set_datar �NETWORK_PEER_ADDRESS�NETWORK_PEER_PORTr � CACHE_KEY�len�str� CACHE_HIT�CACHE_ITEM_SIZE)�cacher �original_methodr r �address�port�is_set_operation�is_get_operationr � description�span�value�key� item_size� arg_countr s �r �_instrument_callz-_patch_cache_method.<locals>._instrument_call* s� �� � '�1�1�%�8�� /�/�� -�R�\�\�2�<�<��+�K��v�F� � � "� "�� �$�+�+� � �#�T�4�V�4�E�,�.��&��M�M�(�"?�"?��I��#��M�M�(�"<�"<�d�C�#�K��v�>���?��M�M�(�"4�"4�c�:� � �#� �$'��E� �O� � � � �h�&8�&8�$�?� � � �h�&8�&8�%�@� #�D� �I� �A�~�$'��D��G� �$5� �"�a� �$'��D��G� �$5� � �(��M�M�(�":�":�I�F�9 /�< �K � � /�.�� � �s% �'G�:D6G�0 G�G �G�Gc � �� ����| |��� S r � )r r r> r4 r2 r r3 r5 s ������r � sentry_methodz*_patch_cache_method.<locals>.sentry_method\ s! �� � � �;���v�w�� � r )� sentry_sdk.integrations.djangor �getattrr � functools�wraps�setattr)r2 r r4 r5 rA r r> r3 s ```` @@@r �_patch_cache_methodrG $ s^ �� �@� �e�[�1�O� � 1�?�C�/� D�/�b �_�_�_�%� � � &� � �E�;� �.r c �^ � t | d� s!t D ] }t | |||� � d| _ y y )N�_sentry_patchedT)�hasattr�METHODS_TO_INSTRUMENTrG rI )r2 r4 r5 r s r � _patch_cacherL f s2 � � �5�+� ,�0�K� ��{�G�T� B� 1� $�� � -r c �$ � | j d� }t |t � syd|v rUt |� }dj |j xs d|j xs d|j xs d� }|j }n|}d }||� t |� fS d fS )N�LOCATION�NNz://z {}://{}{}� ) r � isinstancer/ �urlparse�format�scheme�hostname�pathr5 �int)�settings�location� parsed_urlr4 r5 s r �_get_address_portr[ n s� � ��|�|�J�'�H� �h�� $�� ��� �h�'� � �$�$� � � � #�� � � � %�2� �O�O� !�r� �� �������� ��!1�C��I� ;�;�t� ;�;r c �� � ddl m} t j � }|j | � }ddlm} |d uxr. |j d uxr |j du xs |j du S )Nr r �rX T) rB r r( � get_client�get_integration� django.confrX � spotlight�DEBUG� cache_spans)r �client� integrationrX s r �should_enable_cache_spansrf � sh � �@� � "� "� $�F��(�(�):�;�K�$� �d� "� � � � �� %� @�(�.�.�D�*@� +� � "� "�d� *�r c �J ��� t t d� s�t dk rDt j �t j �� �fd�� } | t _ dt _ y t j �t j �� �fd�� }|t _ dt _ y y )NrI )� r# c � �� �| |� }t � r2ddlm} t |j |xs d � \ }}t |||� |S )Nr r] �default)rf r` rX r[ �CACHESrL )�self�aliasr2 rX r4 r5 �original_get_items �r �sentry_get_itemz&patch_caching.<locals>.sentry_get_item� sL �� � *�$��6��,�.�4�$5� ����(:��;�%�M�G�T� !����6� � r Tc � �� �| |� }t � r,t | j |xs d � \ }}t |||� |S )Nrj )rf r[ rX rL )rl rm r2 r4 r5 �original_create_connections �r �sentry_create_connectionz/patch_caching.<locals>.sentry_create_connection� sD �� � 3�4��?��,�.�$5�d�m�m�E�DV�Y�6W�$X�M�G�T� ����6� � r )rJ r �DJANGO_VERSION� __getitem__rD rE rI �create_connection)ro rr rq rn s @@r � patch_cachingrv � s� �� � �<�!2� 3� �F� "� ,� 8� 8� � �_�_� .� /� � 0� � (7�L� $�+/�L� (� *6�)G�)G� &� �_�_� 7� 8� � 9� � .F�L� *�+/�L� (�O 4r rO ) rD �typingr �#sentry_sdk.integrations.redis.utilsr r � urllib3.utilr rR �djangor rs �django.core.cacher r( �sentry_sdk.constsr r �sentry_sdk.utilsr r r r r rK r rG rL r[ rf rv r@ r r �<module>r~ sX �� � � M� .� ,� *� � *�� �� � �� �D� ?/�D%�<�4 � )0r