File: //usr/lib/python3/dist-packages/django/utils/__pycache__/autoreload.cpython-310.pyc
o
3�a�^ � @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl m Z d dl
mZ d dlmZ d dlmZ d dlZd dlmZ d dlmZ d dlmZ d d lmZ d d
l m Z e� Z e� Z d Z e�!d �Z"g Z#da$zd dl%Z%W n e&y� dZ%Y nw zd dl'Z'W n e&y� dZ'Y nw d
d� Z(dd� Z)dd� Z*dd� Z+dd� Z,dd� Z-e j.dd�dd � �Z/e j.dd�d d � �Z0d d � Z1d!d"� Z2d#d$� Z3d%d&� Z4G d'd(� d(�Z5G d)d*� d*e5�Z6G d+d,� d,e7�Z8G d-d.� d.e5�Z9d/d0� Z:d1d2� Z;d3d4� Z<dS )5� N)� defaultdict)�Path)�
ModuleType)� zipimporter)�apps)�request_finished)�Signal)�cached_property)�get_version_tuple�RUN_MAINzdjango.utils.autoreloadc C s | j �d�S )z7Return True if the given module is nested under Django.zdjango.)�__name__�
startswith)�module� r �9/usr/lib/python3/dist-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 st z
� | i |�� W d S t y9 t�� at\}}}t|dd �d u r,t�|�d d }n|j}|tvr8t� |� � w )N�filename���r )
� Exception�sys�exc_info�
_exception�getattr� traceback�
extract_tbr � _error_files�append)�args�kwargs�et�ev�tbr ��fnr r �wrapper< s
�z check_errors.<locals>.wrapper)� functools�wraps)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�� s dS t �tj�} | d t j@ sE| d t jO < ttd�r-t�tjtj �}nd}t �
tjt j | � |durGt�tj|� dS dS 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�signalr1 �SIG_IGN� tcsetattr�TCSANOW)� attr_list� 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! )�keysrG r r r � iter_all_python_module_filesm s
rN r. )�maxsizec C s g }| D ]:}t |t�s q|jdkr t|d�r |�|j� qt|dd�du r&q|j}|jr>t |j t
�r6|j j n|j }|�|� qt
� }t�||�D ]6}|sMqHt|�}z|�� sXW qHW n tyr } z
t�d| |� W Y d} ~ qHd} ~ ww |�� �� }
|�|
� qHt|�S )z1Iterate through all modules needed to be watched.�__main__r �__spec__Nz%"%s" raised when resolving path: "%s")r@ r r r7 r" r r rQ � has_location�loaderr �archive�origin�set� itertools�chainr �exists�
ValueError�logger�debug�resolve�absolute�addrL ) rG � extra_files�sys_file_pathsr �specrU �resultsr r �e�
resolved_pathr r r rK w s@
�� �� rK 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 � g | ]}|j �qS r )�parts)rC �xr r r �
<listcomp>� � z common_roots.<locals>.<listcomp>T)�key�reversec 3 s@ � | � � D ]\}}� |||f �E d H q| s t|� V d S d S r? )�itemsr )�noder �prefix�child��_walkr r rr � s ��zcommon_roots.<locals>._walkr )rF �len�
setdefault�clearrH )�paths�
path_parts�tree�chunksrn �chunkr rq r � common_roots� s
r{ c c sH � t jD ] } t| �} | �� sq| �� �� }|�� r |jV q|V qdS )zZ
Yield absolute directories from sys.path, ignoring entries that don't
exist.
N)r r r rY r] r^ �is_filer )r re r r r �sys_path_directories� s �
�r} c C s� ddl } ttjd �}tjgdd� tjD � }t| dd�dur6| jjr6|d| jjg7 }|tjdd� 7 }|S |� � sp|�
d�}|� � rOt |�gtjdd� �S |� d |j
�}|� � rjg |�t |��tjdd� �S td
| ��|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 )rC �or r r ri � s z'get_child_arguments.<locals>.<listcomp>rQ z-mr. z.exez %s-script.pyzScript %s does not exist.)rP r r �argv�
executable� warnoptionsr rQ r rY � with_suffix�str� with_name�name� RuntimeError)rP � py_scriptr# �exe_entrypoint�script_entrypointr r r �get_child_arguments� s" �
r� c C s t �d| � t�d� d S )Nz%s changed, reloading.r0 )r[ �infor �exit)r r r r �trigger_reload� s r� c C s< i t j�tdi�} t� } tj|| dd�}|jdkr |jS q
)N�trueTF)�env� close_fdsr0 )�os�environ�DJANGO_AUTORELOAD_ENVr� �
subprocess�run�
returncode)� 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? )rV r` r �directory_globs� threading�Event�_stop_condition��selfr r r �__init__ s
zBaseReloader.__init__c C s\ t |�}z|�� }W n ty tjd|dd� Y d S w 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^ �FileNotFoundErrorr[ r\ r� r_ )r� r �globr r r � watch_dir s ��zBaseReloader.watch_dirTc c sT � t � E dH | jE dH |r&| j�� D ]\}}|D ]
}|�|�E dH qqdS dS )zq
Yield all files that need to be watched, including module files and
files within globs.
N)rN r` r� rm r� )r� �
include_globs� directory�patterns�patternr r r �
watched_files s � ��zBaseReloader.watched_filesc C s0 |� � r|jjdd�r
dS |� � st�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.F)�is_alive� ready_event�waitr[ r\ )r� �app_reg�django_main_threadr r r �wait_for_apps_ready( s �
z BaseReloader.wait_for_apps_readyc C sd t �d� | �t|� ddlm} z|� j W n ty Y nw t �d� tj | d� | �
� d S )Nz Waiting for apps ready_event.r )� get_resolverz>Apps ready_event triggered. Sending autoreload_started signal.)�sender) r[ r\ r� r � django.urlsr� �urlconf_moduler �autoreload_started�send�run_loop)r� r� r� r r r r� : s
�
zBaseReloader.runc C s@ | � � }| jszt|� W n ty Y nw | jr| �� d S r? )�tick� should_stop�next�
StopIteration�stop)r� �tickerr r r r� K s �� zBaseReloader.run_loopc C � t d��)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().��NotImplementedErrorr� r r r r� T s zBaseReloader.tickc C r� )Nz/subclasses must implement check_availability().r� ��clsr r r �check_availability^ s z BaseReloader.check_availabilityc C s> t j| |d�}t�d||� tdd� |D ��s t|� d S d S )N)r� � file_pathz+%s notified as changed. Signal results: %s.c s s � | ]}|d V qdS )r. Nr )rC �resr r r rE e s � z3BaseReloader.notify_file_changed.<locals>.<genexpr>)� file_changedr� r[ r\ �anyr� )r� r rc r r r �notify_file_changedb s
�z BaseReloader.notify_file_changedc C s
| j �� S r? )r� �is_setr� r r r r� i s
zBaseReloader.should_stopc C s | j �� d S r? )r� rV r� r r r r� m 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 sz � i } | � � D ]*\}}|�|�}|||< |d u r!t�d||� q||kr2t�d|||� | �|� qt�| j� d V q)NTz File %s first seen with mtime %sz-File %s previous mtime: %s, current mtime: %s)�snapshot_files�getr[ r\ r� �time�sleep�
SLEEP_TIME)r� �mtimes�filepath�mtime�old_timer r r r� t s �
� �zStatReloader.tickc c sZ � t � }| �� D ]"}||v rqz|�� j}W n ty Y qw |�|� ||fV qd S r? )rV r� �stat�st_mtime�OSErrorr_ )r� �
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� q 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� Ze�� dd� �Z d d
� Z
d d � Z d
d� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd� Z� fdd �Zd"d d �Zed d!� �Z� ZS )#�WatchmanReloaderc s6 t t�| _t�� | _ttj� dd��| _
t � � � d S )N�DJANGO_WATCHMAN_TIMEOUT� )
r rV �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� � st�d|� d S |j}| j�dt|�� ��}d|v r+t�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)
rY r r[ r� r� �queryr� r^ r\ 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�}|r$||d < t�d
|||� | j�d |||� d S ) N�allof�anyof�type�f�lr� T)�
expression�fields�since�
dedup_results�
relative_rootz8Issuing watchman subscription %s, for root %s. Query: %s� subscribe)r� r� r[ r\ r� r� )r� r� r� r� r� �rel_path�only_files_expressionr� r r r �
_subscribe� s ��zWatchmanReloader._subscribec sv � � � s(� j� � st�d� � d S d� j }� fdd�|D �}� j� d|dg}nd}d|g}| �� d|� f |� d S ) N�?Unable to watch directory %s as neither it or its parent exist.zfiles-parent-%sc � g | ] }d � j |f �qS �z%s/%s�r� )rC r �r� r r ri � � z3WatchmanReloader._subscribe_dir.<locals>.<listcomp>r� � wholename�files�%s:%s)rY r r[ r� r� r )r� r� � filenamesro r� r r r �_subscribe_dir� s
z WatchmanReloader._subscribe_dirc s� d}� � � s$� j� � st�d� � dS d� j }� fdd�|D �}� j� dg}|D ]
}|�d|d g� q)| �� 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 r r r )rC r� r r r ri � r z0WatchmanReloader._watch_glob.<locals>.<listcomp>r� �matchr r )rY r r[ r� r� r" r )r� r� r� ro r� r� r r r � _watch_glob� s
z WatchmanReloader._watch_globc C s8 | j �� }dd� |D �}tt� �}tg |�|�|�R �S )Nc S rf r �r )rC r� r r r ri � rj z2WatchmanReloader.watched_roots.<locals>.<listcomp>)r� rM �listr} rL )r� r� �extra_directories�watched_file_dirs� sys_pathsr r r �
watched_roots� s
z WatchmanReloader.watched_rootsc s� t | jdd��}t| �|��}t�dt|�� t�d|� t|�D ]}| �|� q!| j �
� D ]
\� }| � � |� q.t|dd� d�}t j
|dd� d�D ]\� }| �� � fd d
�|D �� qJd S ) NF)r� zWatching %s fileszFound common roots: %sc S � | j S r? r �r� r r r �<lambda> � z2WatchmanReloader._update_watches.<locals>.<lambda>)rk c S r r? r r r r r r
r c s g | ] }t |�� ���qS r )r� � relative_to)rC r� r r r ri r z4WatchmanReloader._update_watches.<locals>.<listcomp>)r r� r{ r r[ r\ rs rF r� r� rm r rW �groupbyr
)r� r� � found_rootsr� r� � sorted_files�groupr r r �_update_watches� s �z WatchmanReloader._update_watchesc
C sB z| � � W d S ty } z
| �|�r� W Y d }~d S d }~ww r? )r r �check_server_status)r� �exr r r �update_watches s
���z WatchmanReloader.update_watchesc C sr | j �|�}|s
d S t�d|� |D ]$}t|d �dd�d �}t�d|� |�dg �D ] }| �|| � q,qd S )Nz%Watchman subscription %s has results.� subscription�:r. zFound root directory %sr
)r� �getSubscriptionr[ r\ r �splitr� r� )r� �subr# r� �root_directoryr� r r r �_check_subscription s ��z$WatchmanReloader._check_subscriptionc K s t �d� | j�� d S )Nz0Request processed. Setting update_watches event.)r[ r\ r� rV )r� r$ r r r �request_processed% �
z"WatchmanReloader.request_processedc
c s� � t �| j� | �� | j�� r| �� | j�� z| j�� W n' t j
y+ Y n. t j yH } zt �
d|� | �|� W Y d }~nd }~ww t| jj�� �D ]}| �|� qQd V t�d� q )NTz+Watchman error: %s, checking server status.r� )r �connectr* r" r� r� ru r� �receiver� �
SocketTimeout�
WatchmanErrorr[ r\ r r �subsrM r) r� r� )r� r! r' r r r r� ) s* �
��
�zWatchmanReloader.tickc s | j �� t� �� d S r? )r� �closer� r� r� r� r r r� > r+ zWatchmanReloader.stopNc C s0 z | j �d� W dS ty tt|��|�w )z'Return True if the server is available.�versionT)r� r� r r� r� )r� �inner_exr r r r B s ��z$WatchmanReloader.check_server_statusc C sh t std��t jdd�}z|�� }W n ty td��w t|d �}t�d|� |dk r2td��d S ) Nzpywatchman not installed.r� r� z'Cannot connect to the watchman service.r2 zWatchman version %s)� � z"Watchman 4.9 or later is required.)r� r� r� �capabilityCheckr r
r[ r\ )r� r� r� r2 r r r r� J s � �z#WatchmanReloader.check_availabilityr? )r r� r� r� r r� r� r+ � lru_cacher� r r
r r r r" r) r* r� r� r r� r� �
__classcell__r r r� r r� � s(
r� c C s* zt �� W t � S ty t� Y S w )z7Return the most suitable reloader for this environment.)r� r� r� r� r r r r � get_reloader\ s
�
�r9 c
O s� t � t|�}tj|||dd�}d|_|�� | jsJz| �|� W n# tyD } zt � } t
� d|� t
� d| j
j� W Y d }~nd }~ww | jrd S d S )Nzdjango-main-thread)�targetr# r$ r� Tz Error connecting to Watchman: %s�!Watching for file changes with %s)r> r- r� �Thread�daemon�startr� r� r� r� r[ �errorr� r� r )�reloader� main_funcr# r$ r� r! r r r � start_djangoe s ���rB c O s� t � t jdd� � z-tj�t�dkr,t� }t�d|j j
� t || g|�R i |�� W d S t � }t
�|� W d S ty@ Y d S w )Nc W s
t �d�S )Nr )r r� )r# r r r r y s
z#run_with_reloader.<locals>.<lambda>r� r; )r8 �SIGTERMr� r� r� r� r9 r[ r� r� r rB r� r r� �KeyboardInterrupt)rA r# r$ r@ � exit_coder r r �run_with_reloaderx s �rF )=r+ rW �loggingr� r8 r� r r� r� r rA � collectionsr �pathlibr �typesr � zipimportr r � django.appsr �django.core.signalsr �django.dispatchr �django.utils.functionalr �django.utils.versionr
r� r� r� � getLoggerr[ r! r r2 � ImportErrorr� r r r- r/ r> rN r7 rK r{ r} r� r� r� r� r� r� r� r� r9 rB rF r r r r �<module> sv
� �
-
% i& B