OwlCyberSecurity - MANAGER
Edit File: autoreload.cpython-39.pyc
a kH�f]_ � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl m Z d dl m Z mZ d dlmZ d dlmZ d dlmZ d dlZd dlmZ d dlmZ d d lmZ d d l m Z d d l m Z e� Z e� Z!d Z"e�#d �Z$g Z%da&z d dl'Z'W n e(�y dZ'Y n0 z d dl)Z)W n e(�y@ dZ)Y n0 dd� Z*dd� Z+dd� Z,dd� Z-dd� Z.dd� Z/e dd�d d � �Z0e dd�d d � �Z1d d!� Z2d"d#� Z3d$d%� Z4d&d'� Z5G d(d)� d)�Z6G d*d+� d+e6�Z7G d,d-� d-e8�Z9G d.d/� d/e6�Z:d0d1� Z;d2d3� Z<d4d5� Z=dS )6� N)� defaultdict)� lru_cache�wraps)�Path)� ModuleType)� zipimporter)�apps)�request_finished)�Signal)�cached_property)�get_version_tupleZRUN_MAINzdjango.utils.autoreloadc C s | j �d�S )z7Return True if the given module is nested under Django.zdjango.)�__name__� startswith)�module� r �Y/home/gouroczh/virtualenv/test/3.9/lib/python3.9/site-packages/django/utils/autoreload.py�is_django_module1 s r c C s t tj�jt | �jv S )z:Return True if the given file path is nested under Django.)r �django�__file__�parent�parents)�pathr r r �is_django_path6 s r c s t � �� fdd��}|S )Nc sz z� | i |�� W nb t yt t�� at\}}}t|dd �d u rVt�|�d d }n|j}|tvrnt� |� � Y n0 d S )N�filename���r ) � Exception�sys�exc_info� _exception�getattr� traceback� extract_tbr � _error_files�append)�args�kwargs�etZev�tbr ��fnr r �wrapper< s z check_errors.<locals>.wrapper)r )r) r* r r( r � check_errors; s r+ c C s t d urt d �d S )N� )r r r r r �raise_last_exceptionT s r- c C s� t rtj�� sdS t �tj�} | d t j@ s�| d t jO < ttd�rZt�tjtj �}nd}t � tjt j | � |dur�t�tj|� dS )z} Ensure that echo mode is enabled. Some tools such as PDB disable it which causes usability issues after reload. N� �SIGTTOU) �termiosr �stdin�isatty� tcgetattr�ECHO�hasattr�signalr/ �SIG_IGN� tcsetattr�TCSANOW)Z attr_listZ old_handlerr r r �ensure_echo_onZ s r: c C s4 t tj�} tdd� ttjj| �D ��}t|tt��S )Nc s s | ]}t |tj�s|V qd S �N)� isinstance�weakref� ProxyTypes)�.0�mr r r � <genexpr>s s �z/iter_all_python_module_files.<locals>.<genexpr>) �sortedr �modules�tuple�map� __getitem__�iter_modules_and_files� frozensetr" )�keysrC r r r � iter_all_python_module_filesm s �rJ r, )�maxsizec C s g }| D ]t}t |t�sq|jdv r:t|d�r|�|j� qt|dd�du rLq|j}|jrt |j t �rl|j j n|j }|�|� qt � }t�||�D ]x}|s�q�t|�}z|�� s�W q�W n> ty� } z&t�d| |� W Y d} ~ q�W Y d} ~ n d} ~ 0 0 |�� �� } |�| � q�t|�S )z1Iterate through all modules needed to be watched.)�__main__� __mp_main__r �__spec__Nz%"%s" raised when resolving path: "%s")r< r r r5 r# r r rN � has_location�loaderr �archive�origin�set� itertools�chainr �exists� ValueError�logger�debug�resolve�absolute�addrH ) rC � extra_filesZsys_file_pathsr �specrR �resultsr r �e� resolved_pathr r r rG { s> � � " rG c sb t dd� | D �tdd�}i }|D ]&}|}|D ]}|�|i �}q,|�� q � fdd�� t� |d��S )a Return a tuple of common roots that are shared between the given paths. File system watchers operate on directories and aren't cheap to create. Try to find the minimum set of directories to watch that encompass all of the files that need to be watched. c S s g | ] }|j �qS r )�parts)r? �xr r r � <listcomp>� � z common_roots.<locals>.<listcomp>T)�key�reversec 3 s: | � � D ] \}}� |||f �E d H q| s6t|� V d S r; )�itemsr )�noder �prefix�child��_walkr r rm � s zcommon_roots.<locals>._walkr )rB �len� setdefault�clearrD )�paths� path_parts�tree�chunksri �chunkr rl r � common_roots� s rv c c sF t jD ]:} t| �} | �� s q| �� �� }|�� r:|jV q|V qdS )zZ Yield absolute directories from sys.path, ignoring entries that don't exist. N)r r r rV rZ r[ �is_filer )r ra r r r �sys_path_directories� s rx c C s4 ddl } ttjd �}tjgdd� tjD � }tjjdkrT|�dd� tj � � D �� t | dd�dur�| j }|jd ks�|j� d �r�|jr�|j}n|j}|d |g7 }|tjd d� 7 }n||�� �s&|�d �}|�� r�|gtjd d� �S |�d|j �}|�� �rg |�|�tjd d� �S td| ��n |tj7 }|S )z� Return the executable. This contains a workaround for Windows if the executable is reported to not have the .exe extension which can cause bugs on reloading. r Nc S s g | ] }d | �qS )z-W%sr )r? �or r r rd � re z'get_child_arguments.<locals>.<listcomp>�cpythonc s s4 | ],\}}|d u r d|� �nd|� d|� �V qdS )Tz-X�=Nr )r? rf �valuer r r rA � s �z&get_child_arguments.<locals>.<genexpr>rN rL z .__main__z-mr, z.exez %s-script.pyzScript %s does not exist.)rL r r �argv� executable� warnoptions�implementation�name�extend� _xoptionsrh r rN �endswithr rV � with_suffix� with_name� RuntimeError)rL Z py_scriptr$ r^ r� Zexe_entrypointZscript_entrypointr r r �get_child_arguments� s0 � r� c C s t �d| � t�d� d S )Nz%s changed, reloading.r. )rX �infor �exit)r r r r �trigger_reload s r� c C s> i t j�tdi�} t� }tj|| dd�}|jdkr|jS qd S )N�trueF)�env� close_fdsr. )�os�environ�DJANGO_AUTORELOAD_ENVr� � subprocess�run� returncode)Z new_environr$ �pr r r �restart_with_reloader s r� c @ sn e Zd Zdd� Zdd� Zddd�Zdd � Zd d � Zd d � Zdd� Z e dd� �Z dd� Z e dd� �Zdd� ZdS )� BaseReloaderc C s t � | _tt �| _t�� | _d S r; )rS r] r �directory_globs� threading�Event�_stop_condition��selfr r r �__init__ s zBaseReloader.__init__c C s\ t |�}z |�� }W n$ ty8 tjd|dd� Y d S 0 t�d||� | j| �|� d S )Nz6Unable to watch directory %s as it cannot be resolved.T)r z Watching dir %s with glob %s.)r r[ �FileNotFoundErrorrX rY r� r\ )r� r �globr r r � watch_dir s �zBaseReloader.watch_dirTc c sN t � E dH | jE dH |rJ| j�� D ]"\}}|D ]}|�|�E dH q2q&dS )zq Yield all files that need to be watched, including module files and files within globs. N)rJ r] r� rh r� )r� � include_globs� directory�patterns�patternr r r � watched_files+ s zBaseReloader.watched_filesc C s* |� � r |jjdd�r dS q t�d� dS )a� Wait until Django reports that the apps have been loaded. If the given thread has terminated before the apps are ready, then a SyntaxError or other non-recoverable error has been raised. In that case, stop waiting for the apps_ready event and continue processing. Return True if the thread is alive and the ready event has been triggered, or False if the thread is terminated while waiting for the event. 皙�����?��timeoutTz8Main Django thread has terminated before apps are ready.FN)�is_aliveZ ready_event�waitrX rY )r� Zapp_reg�django_main_threadr r r �wait_for_apps_ready7 s z BaseReloader.wait_for_apps_readyc C sd t �d� | �t|� ddlm} z |� j W n ty@ Y n0 t �d� tj | d� | � � d S )Nz Waiting for apps ready_event.r )� get_resolverz>Apps ready_event triggered. Sending autoreload_started signal.)�sender) rX rY r� r Z django.urlsr� Zurlconf_moduler �autoreload_started�send�run_loop)r� r� r� r r r r� I s zBaseReloader.runc C s@ | � � }| js4z t|� W q ty0 Y q4Y q0 q| �� d S r; )�tick� should_stop�next� StopIteration�stop)r� Ztickerr r r r� Z s zBaseReloader.run_loopc C s t d��dS )aX This generator is called in a loop from run_loop. It's important that the method takes care of pausing or otherwise waiting for a period of time. This split between run_loop() and tick() is to improve the testability of the reloader implementations by decoupling the work they do from the loop. z!subclasses must implement tick().N��NotImplementedErrorr� r r r r� c s zBaseReloader.tickc C s t d��d S )Nz/subclasses must implement check_availability().r� ��clsr r r �check_availabilitym s z BaseReloader.check_availabilityc C s: t j| |d�}t�d||� tdd� |D ��s6t|� d S )N)r� � file_pathz+%s notified as changed. Signal results: %s.c s s | ]}|d V qdS )r, Nr )r? �resr r r rA t re z3BaseReloader.notify_file_changed.<locals>.<genexpr>)� file_changedr� rX rY �anyr� )r� r r_ r r r �notify_file_changedq s z BaseReloader.notify_file_changedc C s | j �� S r; )r� �is_setr� r r r r� x s zBaseReloader.should_stopc C s | j �� d S r; )r� rS r� r r r r� | s zBaseReloader.stopN)T)r � __module__� __qualname__r� r� r� r� r� r� r� � classmethodr� r� �propertyr� r� r r r r r� s r� c @ s, e Zd ZdZdd� Zdd� Zedd� �ZdS ) � StatReloaderr, c c s| i }| � � D ]V\}}|�|�}|||< |d u r@t�d||� q q ||kr t�d|||� | �|� q t�| j� d V qd S )Nz File %s first seen with mtime %sz-File %s previous mtime: %s, current mtime: %s)�snapshot_files�getrX rY r� �time�sleep� SLEEP_TIME)r� Zmtimes�filepath�mtimeZold_timer r r r� � s" � zStatReloader.tickc c s\ t � }| �� D ]H}||v r qz|�� j}W n ty@ Y qY n0 |�|� ||fV qd S r; )rS r� �stat�st_mtime�OSErrorr\ )r� Z seen_files�filer� r r r r� � s zStatReloader.snapshot_filesc C s dS )NTr r� r r r r� � s z StatReloader.check_availabilityN)r r� r� r� r� r� r� r� r r r r r� � s r� c @ s e Zd ZdS )�WatchmanUnavailableN)r r� r� r r r r r� � s r� c s� e Zd Z� fdd�Zedd� �Zdd� Zedd� �Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Z� fdd �Zd"d d �Zed d!� �Z� ZS )#�WatchmanReloaderc s6 t t�| _t�� | _ttj� dd��| _ t � � � d S )NZDJANGO_WATCHMAN_TIMEOUT� ) r rS �rootsr� r� �processed_request�intr� r� r� �client_timeout�superr� r� �� __class__r r r� � s zWatchmanReloader.__init__c C s t j| jd�S )Nr� )� pywatchman�clientr� r� r r r r� � s zWatchmanReloader.clientc C st |� � s(|j� � s"t�d|� d S |j}| j�dt|�� ��}d|v rVt�d|d � t�d|� |d |� d�fS )Nz>Unable to watch root dir %s as neither it or its parent exist.z watch-project�warningzWatchman warning: %sz!Watchman watch-project result: %s�watch� relative_path) rV r rX r� r� �query�strr[ rY r� )r� �root�resultr r r � _watch_root� s � z WatchmanReloader._watch_rootc C s | j �d|�d S )N�clock)r� r� )r� r� r r r � _get_clock� s zWatchmanReloader._get_clockc C sn | � |�\}}ddddgddgg|g}|dg| �|�dd�}|rH||d < t�d |||� | j�d |||� d S ) NZallof�anyof�type�f�lr� T)� expression�fieldsZsinceZ dedup_resultsZ relative_rootz8Issuing watchman subscription %s, for root %s. Query: %s� subscribe)r� r� rX rY r� r� )r� r� r� r� r� �rel_pathZonly_files_expressionr� r r r � _subscribe� s& ���zWatchmanReloader._subscribec sv � � � sP� j� � s"t�d� � d S d� j }� fdd�|D �}� j� d|dg}n d}d|g}| �� d|� f |� d S ) N�?Unable to watch directory %s as neither it or its parent exist.zfiles-parent-%sc s g | ]}d � j |f �qS �z%s/%s�r� )r? r �r� r r rd � re z3WatchmanReloader._subscribe_dir.<locals>.<listcomp>r� � wholename�files�%s:%s)rV r rX r� r� r� )r� r� � filenamesrj r� r r� r �_subscribe_dir� s � z WatchmanReloader._subscribe_dirc s� d}� � � sH� j� � s&t�d� � dS d� j }� fdd�|D �}� j� dg}|D ]}|�d|d g� qR| �� d |� f |� dS ) a� Watch a directory with a specific glob. If the directory doesn't yet exist, attempt to watch the parent directory and amend the patterns to include this. It's important this method isn't called more than one per directory when updating all subscriptions. Subsequent calls will overwrite the named subscription, so it must include all possible glob expressions. r� r� Nzglob-parent-%sc s g | ]}d � j |f �qS r� r� )r? r� r� r r rd re z0WatchmanReloader._watch_glob.<locals>.<listcomp>r� �matchr� r� )rV r rX r� r� r# r� )r� r� r� rj r� r� r r� r � _watch_glob s � z WatchmanReloader._watch_globc C s8 | j �� }dd� |D �}tt� �}tg |�|�|�R �S )Nc S s g | ] }|j �qS r �r )r? r� r r r rd re z2WatchmanReloader.watched_roots.<locals>.<listcomp>)r� rI �listrx rH )r� r� Zextra_directoriesZwatched_file_dirsZ sys_pathsr r r � watched_roots s z WatchmanReloader.watched_rootsc s� t | jdd��}t| �|��}t�dt|�� t�d|� t|�D ]}| �|� qB| j � � D ]\� }| � � |� q\t|dd� d�}t j |dd� d�D ]"\� }| �� � fd d �|D �� q�d S ) NF)r� zWatching %s fileszFound common roots: %sc S s | j S r; r� �r� r r r �<lambda>+ re z2WatchmanReloader._update_watches.<locals>.<lambda>)rf c S s | j S r; r� r r r r r , re c s g | ]}t |�� ���qS r )r� � relative_to)r? r� r� r r rd / re z4WatchmanReloader._update_watches.<locals>.<listcomp>)r� r� rv r� rX rY rn rB r� r� rh r� rT �groupbyr� )r� r� Z found_rootsr� r� Z sorted_files�groupr r� r �_update_watches s �z WatchmanReloader._update_watchesc C sB z | � � W n0 ty< } z| �|�r(� W Y d }~n d }~0 0 d S r; )r r �check_server_status)r� �exr r r �update_watches2 s z WatchmanReloader.update_watchesc C sr | j �|�}|sd S t�d|� |D ]H}t|d �dd�d �}t�d|� |�dg �D ]}| �|| � qXq$d S )Nz%Watchman subscription %s has results.� subscription�:r, zFound root directory %sr� )r� ZgetSubscriptionrX rY r �splitr� r� )r� �subr r� Zroot_directoryr� r r r �_check_subscription: s z$WatchmanReloader._check_subscriptionc K s t �d� | j�� d S )Nz0Request processed. Setting update_watches event.)rX rY r� rS )r� r% r r r �request_processedI s z"WatchmanReloader.request_processedc c s� t �| j� | �� | j�� r0| �� | j�� z| j�� W nN t j yR Y n\ t j y� } z"t � d|� | �|� W Y d }~n*d }~0 0 t| jj�� �D ]}| �|� q�d V t�d� qd S )Nz+Watchman error: %s, checking server status.r� )r �connectr r r� r� rp r� Zreceiver� � SocketTimeoutZ WatchmanErrorrX rY r r� �subsrI r r� r� )r� r r r r r r� M s zWatchmanReloader.tickc s | j �� t� �� d S r; )r� �closer� r� r� r� r r r� b s zWatchmanReloader.stopNc C s6 z| j �d� W n ty0 tt|��|�Y n0 dS )z'Return True if the server is available.�versionT)r� r� r r� r� )r� Zinner_exr r r r f s z$WatchmanReloader.check_server_statusc C sl t s td��t jdd�}z |�� }W n ty> td��Y n0 t|d �}t�d|� |dk rhtd��d S ) Nzpywatchman not installed.r� r� z'Cannot connect to the watchman service.r zWatchman version %s)� � z"Watchman 4.9 or later is required.)r� r� r� ZcapabilityCheckr r rX rY )r� r� r� r r r r r� n s z#WatchmanReloader.check_availability)N)r r� r� r� r r� r� r r� r� r� r� r� r r r r r� r� r r� r� � __classcell__r r r� r r� � s& r� c C s, z t �� W n ty$ t� Y S 0 t � S )z7Return the most suitable reloader for this environment.)r� r� r� r� r r r r � get_reloader� s r c O sD t � t|�}tj|||dd�}d|_|�� | js@| �|� q.d S )Nzdjango-main-thread)�targetr$ r% r� T)r: r+ r� �Thread�daemon�startr� r� )�reloader� main_funcr$ r% r� r r r � start_django� s �r c O s~ t � t jdd� � zTtj�t�dkrTt� }t�d|j j � t || g|�R i |�� nt � }t �|� W n tyx Y n0 d S )Nc W s t �d�S )Nr )r r� )r$ r r r r � re z#run_with_reloader.<locals>.<lambda>r� z!Watching for file changes with %s)r6 �SIGTERMr� r� r� r� r rX r� r� r r r� r r� �KeyboardInterrupt)r r$ r% r � exit_coder r r �run_with_reloader� s � r" )>rT �loggingr� r6 r� r r� r� r r= � collectionsr � functoolsr r �pathlibr �typesr � zipimportr r Z django.appsr Zdjango.core.signalsr Zdjango.dispatchr Zdjango.utils.functionalr Zdjango.utils.versionr r� r� r� � getLoggerrX r" r r0 � ImportErrorr� r r r+ r- r: rJ rG rv rx r� r� r� r� r� r� r� r� r r r" r r r r �<module> sp 1 , i+ R