File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/files.tar
Back
base.py 0000644 00000011313 15030003247 0006021 0 ustar 00 import os from io import BytesIO, StringIO, UnsupportedOperation from django.core.files.utils import FileProxyMixin from django.utils.functional import cached_property class File(FileProxyMixin): DEFAULT_CHUNK_SIZE = 64 * 2**10 def __init__(self, file, name=None): self.file = file if name is None: name = getattr(file, "name", None) self.name = name if hasattr(file, "mode"): self.mode = file.mode def __str__(self): return self.name or "" def __repr__(self): return "<%s: %s>" % (self.__class__.__name__, self or "None") def __bool__(self): return bool(self.name) def __len__(self): return self.size @cached_property def size(self): if hasattr(self.file, "size"): return self.file.size if hasattr(self.file, "name"): try: return os.path.getsize(self.file.name) except (OSError, TypeError): pass if hasattr(self.file, "tell") and hasattr(self.file, "seek"): pos = self.file.tell() self.file.seek(0, os.SEEK_END) size = self.file.tell() self.file.seek(pos) return size raise AttributeError("Unable to determine the file's size.") def chunks(self, chunk_size=None): """ Read the file and yield chunks of ``chunk_size`` bytes (defaults to ``File.DEFAULT_CHUNK_SIZE``). """ chunk_size = chunk_size or self.DEFAULT_CHUNK_SIZE try: self.seek(0) except (AttributeError, UnsupportedOperation): pass while True: data = self.read(chunk_size) if not data: break yield data def multiple_chunks(self, chunk_size=None): """ Return ``True`` if you can expect multiple chunks. NB: If a particular file representation is in memory, subclasses should always return ``False`` -- there's no good reason to read from memory in chunks. """ return self.size > (chunk_size or self.DEFAULT_CHUNK_SIZE) def __iter__(self): # Iterate over this file-like object by newlines buffer_ = None for chunk in self.chunks(): for line in chunk.splitlines(True): if buffer_: if endswith_cr(buffer_) and not equals_lf(line): # Line split after a \r newline; yield buffer_. yield buffer_ # Continue with line. else: # Line either split without a newline (line # continues after buffer_) or with \r\n # newline (line == b'\n'). line = buffer_ + line # buffer_ handled, clear it. buffer_ = None # If this is the end of a \n or \r\n line, yield. if endswith_lf(line): yield line else: buffer_ = line if buffer_ is not None: yield buffer_ def __enter__(self): return self def __exit__(self, exc_type, exc_value, tb): self.close() def open(self, mode=None): if not self.closed: self.seek(0) elif self.name and os.path.exists(self.name): self.file = open(self.name, mode or self.mode) else: raise ValueError("The file cannot be reopened.") return self def close(self): self.file.close() class ContentFile(File): """ A File-like object that takes just raw content, rather than an actual file. """ def __init__(self, content, name=None): stream_class = StringIO if isinstance(content, str) else BytesIO super().__init__(stream_class(content), name=name) self.size = len(content) def __str__(self): return "Raw content" def __bool__(self): return True def open(self, mode=None): self.seek(0) return self def close(self): pass def write(self, data): self.__dict__.pop("size", None) # Clear the computed size. return self.file.write(data) def endswith_cr(line): """Return True if line (a text or bytestring) ends with '\r'.""" return line.endswith("\r" if isinstance(line, str) else b"\r") def endswith_lf(line): """Return True if line (a text or bytestring) ends with '\n'.""" return line.endswith("\n" if isinstance(line, str) else b"\n") def equals_lf(line): """Return True if line (a text or bytestring) equals '\n'.""" return line == ("\n" if isinstance(line, str) else b"\n") temp.py 0000644 00000004707 15030003247 0006065 0 ustar 00 """ The temp module provides a NamedTemporaryFile that can be reopened in the same process on any platform. Most platforms use the standard Python tempfile.NamedTemporaryFile class, but Windows users are given a custom class. This is needed because the Python implementation of NamedTemporaryFile uses the O_TEMPORARY flag under Windows, which prevents the file from being reopened if the same flag is not provided [1][2]. Note that this does not address the more general issue of opening a file for writing and reading in multiple processes in a manner that works across platforms. The custom version of NamedTemporaryFile doesn't support the same keyword arguments available in tempfile.NamedTemporaryFile. 1: https://mail.python.org/pipermail/python-list/2005-December/336957.html 2: https://bugs.python.org/issue14243 """ import os import tempfile from django.core.files.utils import FileProxyMixin __all__ = ( "NamedTemporaryFile", "gettempdir", ) if os.name == "nt": class TemporaryFile(FileProxyMixin): """ Temporary file object constructor that supports reopening of the temporary file in Windows. Unlike tempfile.NamedTemporaryFile from the standard library, __init__() doesn't support the 'delete', 'buffering', 'encoding', or 'newline' keyword arguments. """ def __init__(self, mode="w+b", bufsize=-1, suffix="", prefix="", dir=None): fd, name = tempfile.mkstemp(suffix=suffix, prefix=prefix, dir=dir) self.name = name self.file = os.fdopen(fd, mode, bufsize) self.close_called = False # Because close can be called during shutdown # we need to cache os.unlink and access it # as self.unlink only unlink = os.unlink def close(self): if not self.close_called: self.close_called = True try: self.file.close() except OSError: pass try: self.unlink(self.name) except OSError: pass def __del__(self): self.close() def __enter__(self): self.file.__enter__() return self def __exit__(self, exc, value, tb): self.file.__exit__(exc, value, tb) NamedTemporaryFile = TemporaryFile else: NamedTemporaryFile = tempfile.NamedTemporaryFile gettempdir = tempfile.gettempdir __pycache__/__init__.cpython-310.pyc 0000644 00000000366 15030003247 0013213 0 ustar 00 o �h< � @ s d dl mZ dgZdS )� )�Filer N)�django.core.files.baser �__all__� r r �P/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/__init__.py�<module> s __pycache__/images.cpython-310.pyc 0000644 00000004124 15030003247 0012715 0 ustar 00 o �hS � @ s> d Z ddlZddlZddlmZ G dd� de�Zd dd�ZdS ) zO Utility functions for handling images. Requires Pillow as you might imagine. � N)�Filec @ s0 e Zd ZdZedd� �Zedd� �Zdd� ZdS ) � ImageFilez� A mixin for use alongside django.core.files.base.File, which provides additional features for dealing with images. c C � | � � d S )Nr ��_get_image_dimensions��self� r �N/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/images.py�width � zImageFile.widthc C r )N� r r r r r �height r zImageFile.heightc C s, t | d�s| j}| �� t| |d�| _| jS )N�_dimensions_cache)�close)�hasattr�closed�open�get_image_dimensionsr )r r r r r r s z ImageFile._get_image_dimensionsN)�__name__� __module__� __qualname__�__doc__�propertyr r r r r r r r s r Fc C sN ddl m} |�� }t| d�r| }|�� }|�d� nzt| d�}W n ty, Y dS w d}zjd} |�|�}|s;nOz|� |� W n. t j y_ } z|j d � d �rTn� W Y d }~nd }~w tj yh Y n typ Y nw |jr�|jjW |r|�� S |�|� S |d 9 }q3W |r�|�� dS |�|� dS |r�|�� w |�|� w ) z� Return the (width, height) of an image, given an open file or a path. Set 'close' to True to close the file at the end if it is initially in an open state. r )r �read�rb)NNTi r zError -5N� )�PILr �Parserr �tell�seekr �OSErrorr �feed�zlib�error�args� startswith�struct� RuntimeError�image�sizer ) � file_or_pathr �PillowImageFile�p�file�file_pos� chunk_size�data�er r r r " sZ � �� � �� � r )F)r r' r# �django.core.filesr r r r r r r �<module> s __pycache__/uploadedfile.cpython-310.pyc 0000644 00000011162 15030003247 0014105 0 ustar 00 o �h] � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddl m Z ddl m Z dZ G d d � d e �ZG d d � d e�ZG d d� de�ZG dd� de�ZdS )z& Classes representing uploaded files. � N)�BytesIO)�settings)�temp)�File)�validate_file_name)� UploadedFile�TemporaryUploadedFile�InMemoryUploadedFile�SimpleUploadedFilec sP e Zd ZdZ d � fdd� Zdd� Zdd� Zd d � Zeee�Z � Z S ) r a An abstract uploaded file (``TemporaryUploadedFile`` and ``InMemoryUploadedFile`` are the built-in concrete subclasses). An ``UploadedFile`` object behaves somewhat like a file object and represents some file data that the user submitted with a form. Nc s* t � �||� || _|| _|| _|| _d S �N)�super�__init__�size� content_type�charset�content_type_extra)�self�file�namer r r r �� __class__� �T/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/uploadedfile.pyr s zUploadedFile.__init__c C s d| j j| j| jf S )Nz <%s: %s (%s)>)r �__name__r r �r r r r �__repr__- s zUploadedFile.__repr__c C s | j S r )�_namer r r r � _get_name0 s zUploadedFile._get_namec C sf |d ur.t j�|�}t|�dkr*t j�|�\}}|d d� }|d dt|� � | }t|�}|| _d S )N� )�os�path�basename�len�splitextr r )r r �extr r r � _set_name3 s zUploadedFile._set_name)NNNNNN) r � __module__� __qualname__�__doc__r r r r% �propertyr � __classcell__r r r r r s �r c s2 e Zd ZdZd � fdd� Zdd� Zdd� Z� ZS ) r zH A file uploaded to a temporary location (i.e. stream-to-disk). Nc s> t j�|�\}}tjd| tjd�}t� �||||||� d S )Nz.upload)�suffix�dir) r r r# �tempfile�NamedTemporaryFiler �FILE_UPLOAD_TEMP_DIRr r ) r r r r r r �_r$ r r r r r K s �z TemporaryUploadedFile.__init__c C s | j jS )z"Return the full path of this file.)r r r r r r �temporary_file_pathR s z)TemporaryUploadedFile.temporary_file_pathc C s" z| j �� W S ty Y d S w r )r �close�FileNotFoundErrorr r r r r2 V s �zTemporaryUploadedFile.closer )r r& r' r( r r1 r2 r* r r r r r F s r c sB e Zd ZdZ d � fdd� Zd dd�Zd dd�Zd d d �Z� ZS ) r z> A file uploaded into memory (i.e. stream-to-memory). Nc s t � �||||||� || _d S r )r r � field_name)r r r4 r r r r r r r r r e s z InMemoryUploadedFile.__init__c C s | j �d� | S �Nr )r �seek)r �moder r r �openr s zInMemoryUploadedFile.openc c s � | j �d� | �� V d S r5 )r r6 �read�r � chunk_sizer r r �chunksv s � zInMemoryUploadedFile.chunksc C s dS )NFr r: r r r �multiple_chunksz s z$InMemoryUploadedFile.multiple_chunksr ) r r& r' r( r r8 r< r= r* r r r r r ` s � r c s. e Zd ZdZd� fdd� Zedd� �Z� ZS )r zV A simple representation of a file, which just has content, size, and a name. � text/plainc s, |pd}t � �t|�d ||t|�d d � d S )N� )r r r r" )r r �contentr r r r r � s �zSimpleUploadedFile.__init__c C s | |d |d |� dd��S )z� Create a SimpleUploadedFile object from a dictionary with keys: - filename - content-type - content �filenamer@ z content-typer> )�get)�cls� file_dictr r r � from_dict� s �z SimpleUploadedFile.from_dict)r> )r r& r' r( r � classmethodrE r* r r r r r s r )r( r �ior � django.confr �django.core.filesr r- �django.core.files.baser �django.core.files.utilsr �__all__r r r r r r r r �<module> s 1 __pycache__/utils.cpython-310.pyc 0000644 00000006740 15030003247 0012616 0 ustar 00 o �h+ � @ s8 d dl Z d dlZd dlmZ ddd�ZG dd� d�ZdS ) � N)�SuspiciousFileOperationFc C sx t j�| �dv rtd| ��|r,t�t| ��dd��}|�� s$d|j v r*td| ��| S | t j�| �kr:td| ��| S )N> � �.�..z$Could not derive file name from '%s'�\�/r z'Detected path traversal attempt in '%s'z%File name '%s' includes path elements) �os�path�basenamer �pathlib� PurePosixPath�str�replace� is_absolute�parts)�name�allow_relative_pathr � r �M/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/utils.py�validate_file_name s �� r c @ s� e Zd ZdZedd� �Zedd� �Zedd� �Zedd� �Zedd� �Z edd� �Z ed d� �Z ed d� �Z ed d� �Z ed d� �Zed d� �Zedd� �Zedd� �Zedd� �Zedd� �Zdd� Zdd� Zdd� Zdd� ZdS ) �FileProxyMixinz� A mixin class used to forward file methods to an underlaying file object. The internal file object has to be called "file":: class FileProxy(FileProxyMixin): def __init__(self, file): self.file = file c C � | j jS �N)�file�encoding��selfr r r �<lambda>$ � zFileProxyMixin.<lambda>c C r r )r �filenor r r r r % r c C r r )r �flushr r r r r & r c C r r )r �isattyr r r r r ' r c C r r )r �newlinesr r r r r ( r c C r r )r �readr r r r r ) r c C r r )r �readintor r r r r * r c C r r )r �readliner r r r r + r c C r r )r � readlinesr r r r r , r c C r r )r �seekr r r r r - r c C r r )r �tellr r r r r . r c C r r )r �truncater r r r r / r c C r r )r �writer r r r r 0 r c C r r )r � writelinesr r r r r 1 r c C s | j p| j jS r )r �closedr r r r r, 3 s zFileProxyMixin.closedc C �$ | j rdS t| jd�r| j�� S dS )NF�readableT)r, �hasattrr r. r r r r r. 7 � zFileProxyMixin.readablec C s2 | j rdS t| jd�r| j�� S dt| jdd�v S )NF�writable�w�moder )r, r/ r r1 �getattrr r r r r1 > s zFileProxyMixin.writablec C r- )NF�seekableT)r, r/ r r5 r r r r r5 E r0 zFileProxyMixin.seekablec C s t | j�S r )�iterr r r r r �__iter__L s zFileProxyMixin.__iter__N)�__name__� __module__� __qualname__�__doc__�propertyr r r r! r" r# r$ r% r& r' r( r) r* r+ r, r. r1 r5 r7 r r r r r s, r )F)r r �django.core.exceptionsr r r r r r r �<module> s __pycache__/temp.cpython-310.pyc 0000644 00000005265 15030003247 0012424 0 ustar 00 o �h� � @ sT d Z ddlZddlZddlmZ dZejdkr"G dd� de�ZeZnejZej Z dS )a6 The temp module provides a NamedTemporaryFile that can be reopened in the same process on any platform. Most platforms use the standard Python tempfile.NamedTemporaryFile class, but Windows users are given a custom class. This is needed because the Python implementation of NamedTemporaryFile uses the O_TEMPORARY flag under Windows, which prevents the file from being reopened if the same flag is not provided [1][2]. Note that this does not address the more general issue of opening a file for writing and reading in multiple processes in a manner that works across platforms. The custom version of NamedTemporaryFile doesn't support the same keyword arguments available in tempfile.NamedTemporaryFile. 1: https://mail.python.org/pipermail/python-list/2005-December/336957.html 2: https://bugs.python.org/issue14243 � N)�FileProxyMixin)�NamedTemporaryFile� gettempdir�ntc @ s@ e Zd ZdZddd�ZejZdd � Zd d � Zd d � Z dd� Z dS )� TemporaryFilea. Temporary file object constructor that supports reopening of the temporary file in Windows. Unlike tempfile.NamedTemporaryFile from the standard library, __init__() doesn't support the 'delete', 'buffering', 'encoding', or 'newline' keyword arguments. �w+b���� Nc C s4 t j|||d�\}}|| _t�|||�| _d| _d S )N)�suffix�prefix�dirF)�tempfile�mkstemp�name�os�fdopen�file� close_called)�self�mode�bufsizer r r �fdr � r �L/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/temp.py�__init__* s zTemporaryFile.__init__c C sZ | j s+d| _ z| j�� W n ty Y nw z | �| j� W d S ty* Y d S w d S )NT)r r �close�OSError�unlinkr �r r r r r 5 s � ��zTemporaryFile.closec C s | � � d S �N)r r r r r �__del__A s zTemporaryFile.__del__c C s | j �� | S r )r � __enter__r r r r r! D s zTemporaryFile.__enter__c C s | j �|||� d S r )r �__exit__)r �exc�value�tbr r r r" H s zTemporaryFile.__exit__)r r r r N) �__name__� __module__� __qualname__�__doc__r r r r r r! r" r r r r r s r ) r) r r �django.core.files.utilsr �__all__r r r r r r r r �<module> s + __pycache__/move.cpython-310.pyc 0000644 00000004100 15030003247 0012410 0 ustar 00 o �h� � @ sF d Z ddlZddlmZmZ ddlmZ dgZdd� Z d d d�Z dS ) z� Move a file in the safest way possible:: >>> from django.core.files.move import file_move_safe >>> file_move_safe("/tmp/old_file", "/tmp/new_file") � N)�copymode�copystat)�locks�file_move_safec C sZ t tjd�rztj�| |�W S ty Y dS w tj�tj�| ��tj�tj�|��kS )N�samefileF)�hasattr�os�pathr �OSError�normcase�abspath)�src�dst� r �L/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/move.py� _samefile s � �r � Fc C s� t | |�rdS z|st�|tj�rtd| ��t�| |� W dS ty( Y nw t| d��S}t�|tjtj B t tdd�B |sBtj ndB �}z(t � |t j� d}|dkrc|�|�}t�||� |dksTW t �|� t�|� n t �|� t�|� w W d � n1 s�w Y zt| |� W n ty� zt| |� W n ty� Y nw Y nw zt�| � W dS ty� } zt |dd�dkrĂ W Y d}~dS d}~ww ) aU Move a file from one location to another in the safest way possible. First, try ``os.rename``, which is simple but will break across filesystems. If that fails, stream manually from one file to another in pure Python. If the destination file exists and ``allow_overwrite`` is ``False``, raise ``FileExistsError``. Nz8Destination file %s exists and allow_overwrite is False.�rb�O_BINARYr � �winerror� )r r �access�F_OK�FileExistsError�renamer �open�O_WRONLY�O_CREAT�getattr�O_EXCLr �lock�LOCK_EX�read�write�unlock�closer �PermissionErrorr �remove)� old_file_name� new_file_name� chunk_size�allow_overwrite�old_file�fd� current_chunk�er r r r sp �� � � � �� �� � � ��� ���)r F) �__doc__r �shutilr r �django.core.filesr �__all__r r r r r r �<module> s � __pycache__/base.cpython-310.pyc 0000644 00000012333 15030003247 0012363 0 ustar 00 o �h� � @ sp d dl Z d dlmZmZmZ d dlmZ d dlmZ G dd� de�Z G dd� de �Z d d � Z d d � Z d d� Z dS )� N)�BytesIO�StringIO�UnsupportedOperation)�FileProxyMixin)�cached_propertyc @ s� e Zd ZdZd dd�Zdd� Zdd� Zd d � Zd d � Ze d d� �Z d dd�Z d dd�Z dd� Z dd� Zdd� Zd dd�Zdd � ZdS ) �Filei Nc C s: || _ |d u r t|dd �}|| _t|d�r|j| _d S d S )N�name�mode)�file�getattrr �hasattrr )�selfr r � r �L/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/base.py�__init__ s �z File.__init__c C s | j pdS )N� �r �r r r r �__str__ � z File.__str__c C s d| j j| pdf S )Nz<%s: %s>�None)� __class__�__name__r r r r �__repr__ s z File.__repr__c C s t | j�S �N)�boolr r r r r �__bool__ r z File.__bool__c C s | j S r )�sizer r r r �__len__ s z File.__len__c C s� t | jd�r | jjS t | jd�r%z tj�| jj�W S ttfy$ Y nw t | jd�rKt | jd�rK| j� � }| j� dtj � | j� � }| j� |� |S t d��)Nr r �tell�seekr z$Unable to determine the file's size.) r r r �os�path�getsizer �OSError� TypeErrorr r �SEEK_END�AttributeError)r �posr r r r r s � z File.sizec c sN � |p| j }z| �d� W n ttfy Y nw | �|�}|s#dS |V q)z{ Read the file and yield chunks of ``chunk_size`` bytes (defaults to ``File.DEFAULT_CHUNK_SIZE``). r TN)�DEFAULT_CHUNK_SIZEr r' r �read)r � chunk_size�datar r r �chunks0 s � � �z File.chunksc C s | j |p| jkS )z� Return ``True`` if you can expect multiple chunks. NB: If a particular file representation is in memory, subclasses should always return ``False`` -- there's no good reason to read from memory in chunks. )r r) )r r+ r r r �multiple_chunksA s zFile.multiple_chunksc c sv � d }| � � D ](}|�d�D ] }|r$t|�r t|�s |V n|| }d }t|�r,|V q|}qq|d ur9|V d S d S �NT)r- � splitlines� endswith_cr� equals_lf� endswith_lf)r �buffer_�chunk�liner r r �__iter__K s � � �z File.__iter__c C s | S r r r r r r � __enter__f � zFile.__enter__c C s | � � d S r )�close)r �exc_type� exc_value�tbr r r �__exit__i s z File.__exit__c C sH | j s | �d� | S | jr tj�| j�r t| j|p| j�| _| S t d��)Nr z The file cannot be reopened.) �closedr r r! r" �exists�openr r � ValueError�r r r r r rA l s ��z File.openc C s | j �� d S r )r r: r r r r r: u s z File.closer )r � __module__� __qualname__r) r r r r r r r r- r. r7 r8 r> rA r: r r r r r s r c sL e Zd ZdZd� fdd� Zdd� Zdd� Zdd d �Zd d � Zd d� Z � Z S )� ContentFilezU A File-like object that takes just raw content, rather than an actual file. Nc s4 t |t�rtnt}t� j||�|d� t|�| _d S )Nr )� isinstance�strr r �superr �lenr )r �contentr � stream_class�r r r r ~ s zContentFile.__init__c C � dS )Nz Raw contentr r r r r r � r9 zContentFile.__str__c C rN r/ r r r r r r � r9 zContentFile.__bool__c C s | � d� | S )Nr )r rC r r r rA � s zContentFile.openc C s d S r r r r r r r: � r9 zContentFile.closec C s | j �dd � | j�|�S )Nr )�__dict__�popr �write)r r, r r r rQ � s zContentFile.writer ) r rD rE �__doc__r r r rA r: rQ � __classcell__r r rM r rF y s rF c C � | � t| t�r d�S d�S )z9Return True if line (a text or bytestring) ends with ' '.� � ��endswithrG rH �r6 r r r r1 � � r1 c C rT )z9Return True if line (a text or bytestring) ends with ' '.� � rW rY r r r r3 � rZ r3 c C s | t | t�r dkS dkS )z6Return True if line (a text or bytestring) equals ' '.r[ r\ )rG rH rY r r r r2 � s r2 )r! �ior r r �django.core.files.utilsr �django.utils.functionalr r rF r1 r3 r2 r r r r �<module> s q __pycache__/uploadhandler.cpython-310.pyc 0000644 00000017652 15030003247 0014304 0 ustar 00 o �h � @ s� d Z ddlZddlmZ ddlmZ ddlmZmZ ddl m Z g d�Z G dd � d e �Z G d d � d e �ZG d d � d e �ZG dd� de �ZG dd� d�ZG dd� de�ZG dd� de�Zdd� ZdS )zH Base file upload handler classes, and the built-in concrete subclasses � N)�BytesIO)�settings)�InMemoryUploadedFile�TemporaryUploadedFile�� import_string)�UploadFileException� StopUpload�SkipFile�FileUploadHandler�TemporaryFileUploadHandler�MemoryFileUploadHandler� load_handler�StopFutureHandlersc @ � e Zd ZdZdS )r z6 Any error having to do with uploading files. N��__name__� __module__� __qualname__�__doc__� r r �U/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/uploadhandler.pyr � r c @ s" e Zd ZdZddd�Zdd� ZdS ) r z= This exception is raised when an upload must abort. Fc C s || _ dS )z� If ``connection_reset`` is ``True``, Django knows will halt the upload without consuming the rest of the upload. This will cause the browser to show a "connection reset" error. N��connection_reset)�selfr r r r �__init__$ s zStopUpload.__init__c C s | j rdS dS )Nz StopUpload: Halt current upload.z,StopUpload: Consume request data, then halt.r �r r r r �__str__, s zStopUpload.__str__N)F)r r r r r r r r r r r s r c @ r )r zX This exception is raised by an upload handler that wants to skip a given file. Nr r r r r r 3 r r c @ r )r z� Upload handlers that have handled a file and do not want future handlers to run should raise this exception instead of returning None. Nr r r r r r ; s r c @ sX e Zd ZdZdZddd�Z ddd�Z ddd �Zd d � Zd d � Z dd� Z dd� Z dS )r z3 Base class for streaming upload handlers. i Nc C s( d | _ d | _d | _d | _d | _|| _d S �N)� file_name� content_type�content_length�charset�content_type_extra�request)r r% r r r r K s zFileUploadHandler.__init__c C � dS )a� Handle the raw input from the client. Parameters: :input_data: An object that supports reading via .read(). :META: ``request.META``. :content_length: The (integer) value of the Content-Length header from the client. :boundary: The boundary from the Content-Type header. Be sure to prepend two '--'. Nr �r � input_data�METAr" �boundary�encodingr r r �handle_raw_inputS s z"FileUploadHandler.handle_raw_inputc C s( || _ || _|| _|| _|| _|| _dS )z� Signal that a new file has been started. Warning: As with any data from the client, you should not trust content_length (and sometimes won't even get it). N)� field_namer r! r" r# r$ )r r- r r! r" r# r$ r r r �new_fileg s zFileUploadHandler.new_filec C � t d��)z{ Receive data from the streamed upload parser. ``start`` is the position in the file of the chunk. zJsubclasses of FileUploadHandler must provide a receive_data_chunk() method��NotImplementedError�r �raw_data�startr r r �receive_data_chunk} s �z$FileUploadHandler.receive_data_chunkc C r/ )z� Signal that a file has completed. File size corresponds to the actual size accumulated by all the chunks. Subclasses should return a valid ``UploadedFile`` object. zEsubclasses of FileUploadHandler must provide a file_complete() methodr0 �r � file_sizer r r � file_complete� s �z FileUploadHandler.file_completec C r& )z� Signal that the upload is complete. Subclasses should perform cleanup that is necessary for this handler. Nr r r r r �upload_complete� � z!FileUploadHandler.upload_completec C r& )z� Signal that the upload was interrupted. Subclasses should perform cleanup that is necessary for this handler. Nr r r r r �upload_interrupted� r: z$FileUploadHandler.upload_interruptedr )NN) r r r r � chunk_sizer r, r. r5 r8 r9 r; r r r r r D s � � r c s8 e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Z� ZS ) r zA Upload handler that streams data into a temporary file. c s0 t � j|i |�� t| j| jd| j| j�| _dS )zK Create the file object to append to as data is coming in. r N)�superr. r r r! r# r$ �file�r �args�kwargs�� __class__r r r. � s �z#TemporaryFileUploadHandler.new_filec C s | j �|� d S r )r> �writer2 r r r r5 � s z-TemporaryFileUploadHandler.receive_data_chunkc C s | j �d� || j _| j S )Nr )r> �seek�sizer6 r r r r8 � s z(TemporaryFileUploadHandler.file_completec C sH t | d�r"| j�� }z | j�� t�|� W d S ty! Y d S w d S )Nr> )�hasattrr> �temporary_file_path�close�os�remove�FileNotFoundError)r � temp_locationr r r r; � s ��z-TemporaryFileUploadHandler.upload_interrupted) r r r r r. r5 r8 r; � __classcell__r r rB r r � s r c s< e Zd ZdZ d dd�Z� fdd�Zdd� Zd d � Z� ZS ) r zS File upload handler to stream uploads into memory (used for small files). Nc C s |t jk| _dS )zf Use the content_length to signal whether or not this handler should be used. N)r �FILE_UPLOAD_MAX_MEMORY_SIZE� activatedr' r r r r, � s z(MemoryFileUploadHandler.handle_raw_inputc s* t � j|i |�� | jrt� | _t� �d S r )r= r. rP r r> r r? rB r r r. � s �z MemoryFileUploadHandler.new_filec C s | j r | j�|� dS |S )z!Add the data to the BytesIO file.N)rP r> rD r2 r r r r5 � s z*MemoryFileUploadHandler.receive_data_chunkc C s8 | j sdS | j�d� t| j| j| j| j|| j| jd�S )z2Return a file object if this handler is activated.Nr )r> r- �namer! rF r# r$ ) rP r> rE r r- r r! r# r$ r6 r r r r8 � s �z%MemoryFileUploadHandler.file_completer ) r r r r r, r. r5 r8 rN r r rB r r � s � r c O s t | �|i |��S )al Given a path to a handler, return an instance of that handler. E.g.:: >>> from django.http import HttpRequest >>> request = HttpRequest() >>> load_handler( ... 'django.core.files.uploadhandler.TemporaryFileUploadHandler', ... request, ... ) <TemporaryFileUploadHandler object at 0x...> r )�pathr@ rA r r r r � s r )r rJ �ior � django.confr � django.core.files.uploadedfiler r �django.utils.module_loadingr �__all__� Exceptionr r r r r r r r r r r r �<module> s \ . __pycache__/locks.cpython-310.pyc 0000644 00000006451 15030003247 0012570 0 ustar 00 o �h � @ s� d Z ddlZdZdd� Zejdkr�ddlZddlmZmZm Z m Z m Z m Z m Z mZmZ ddlmZmZmZ dZd Zd Zee �ee�krFe Zne ZeZG d d � d e�ZG d d� de �ZG dd� de�Zee�Z e d�Z e j Z ee _ eeeeee ge _ e j!Z!ee!_ eeeee ge!_ dd� Z"dd� Z#dS zddl$Z$e$jZe$jZe$jZW n e%e&fy� d Z ZZdd� Z"dd� Z#Y dS w dd� Z"dd� Z#dS )am Portable file locking utilities. Based partially on an example by Jonathan Feignberg in the Python Cookbook [1] (licensed under the Python Software License) and a ctypes port by Anatoly Techtonik for Roundup [2] (license [3]). [1] https://code.activestate.com/recipes/65203/ [2] https://sourceforge.net/p/roundup/code/ci/default/tree/roundup/backends/portalocker.py # NOQA [3] https://sourceforge.net/p/roundup/code/ci/default/tree/COPYING.txt Example Usage:: >>> from django.core.files import locks >>> with open('./file', 'wb') as f: ... locks.lock(f, locks.LOCK_EX) ... f.write('Django') � N)�LOCK_EX�LOCK_SH�LOCK_NB�lock�unlockc C s t | d�r | �� S | S )zCGet a filedescriptor from something which could be a file or an fd.�fileno)�hasattrr ��f� r �M/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/locks.py�_fd s r �nt) �POINTER� Structure�Union�WinDLL�byref�c_int64�c_ulong�c_void_p�sizeof)�BOOL�DWORD�HANDLE� � c @ s e Zd ZdefdefgZdS )�_OFFSET�Offset� OffsetHighN)�__name__� __module__� __qualname__r �_fields_r r r r r 9 s r c @ s" e Zd ZdgZdefdefgZdS )� _OFFSET_UNION�_offset�PointerN)r r! r" � _anonymous_r �PVOIDr# r r r r r$ < s r$ c @ s. e Zd ZdgZdefdefdefdefgZdS )� OVERLAPPED� _offset_union�Internal� InternalHigh�hEventN)r r! r" r' � ULONG_PTRr$ r r# r r r r r) @ s �r) �kernel32c C s2 t �t| ��}t� }t||dddt|��}t|�S �Nr l � )�msvcrt� get_osfhandler r) � LockFileExr �bool)r �flags�hfile� overlapped�retr r r r T s r c C s0 t �t| ��}t� }t|dddt|��}t|�S r0 )r1 r2 r r) � UnlockFileExr r4 )r r6 r7 r8 r r r r Z s r c C � dS )NFr �r r5 r r r r l � c C r: �NTr r r r r r p r< c C s, z t �t| �|� W dS ty Y dS w )NTF)�fcntl�flockr �BlockingIOErrorr; r r r r v s �c C s t �t| �t j� dS r= )r> r? r �LOCK_UNr r r r r } s )'�__doc__�os�__all__r �namer1 �ctypesr r r r r r r r r �ctypes.wintypesr r r r r r r. r( r r$ r) � LPOVERLAPPEDr/ r3 �restype�argtypesr9 r r r> � ImportError�AttributeErrorr r r r �<module> sP , � move.py 0000644 00000006262 15030003247 0006064 0 ustar 00 """ Move a file in the safest way possible:: >>> from django.core.files.move import file_move_safe >>> file_move_safe("/tmp/old_file", "/tmp/new_file") """ import os from shutil import copymode, copystat from django.core.files import locks __all__ = ["file_move_safe"] def _samefile(src, dst): # Macintosh, Unix. if hasattr(os.path, "samefile"): try: return os.path.samefile(src, dst) except OSError: return False # All other platforms: check for same pathname. return os.path.normcase(os.path.abspath(src)) == os.path.normcase( os.path.abspath(dst) ) def file_move_safe( old_file_name, new_file_name, chunk_size=1024 * 64, allow_overwrite=False ): """ Move a file from one location to another in the safest way possible. First, try ``os.rename``, which is simple but will break across filesystems. If that fails, stream manually from one file to another in pure Python. If the destination file exists and ``allow_overwrite`` is ``False``, raise ``FileExistsError``. """ # There's no reason to move if we don't have to. if _samefile(old_file_name, new_file_name): return try: if not allow_overwrite and os.access(new_file_name, os.F_OK): raise FileExistsError( "Destination file %s exists and allow_overwrite is False." % new_file_name ) os.rename(old_file_name, new_file_name) return except OSError: # OSError happens with os.rename() if moving to another filesystem or # when moving opened files on certain operating systems. pass # first open the old file, so that it won't go away with open(old_file_name, "rb") as old_file: # now open the new file, not forgetting allow_overwrite fd = os.open( new_file_name, ( os.O_WRONLY | os.O_CREAT | getattr(os, "O_BINARY", 0) | (os.O_EXCL if not allow_overwrite else 0) ), ) try: locks.lock(fd, locks.LOCK_EX) current_chunk = None while current_chunk != b"": current_chunk = old_file.read(chunk_size) os.write(fd, current_chunk) finally: locks.unlock(fd) os.close(fd) try: copystat(old_file_name, new_file_name) except PermissionError: # Certain filesystems (e.g. CIFS) fail to copy the file's metadata if # the type of the destination filesystem isn't the same as the source # filesystem. This also happens with some SELinux-enabled systems. # Ignore that, but try to set basic permissions. try: copymode(old_file_name, new_file_name) except PermissionError: pass try: os.remove(old_file_name) except PermissionError as e: # Certain operating systems (Cygwin and Windows) # fail when deleting opened files, ignore it. (For the # systems where this happens, temporary files will be auto-deleted # on close anyway.) if getattr(e, "winerror", 0) != 32: raise uploadedfile.py 0000644 00000010135 15030003247 0007545 0 ustar 00 """ Classes representing uploaded files. """ import os from io import BytesIO from django.conf import settings from django.core.files import temp as tempfile from django.core.files.base import File from django.core.files.utils import validate_file_name __all__ = ( "UploadedFile", "TemporaryUploadedFile", "InMemoryUploadedFile", "SimpleUploadedFile", ) class UploadedFile(File): """ An abstract uploaded file (``TemporaryUploadedFile`` and ``InMemoryUploadedFile`` are the built-in concrete subclasses). An ``UploadedFile`` object behaves somewhat like a file object and represents some file data that the user submitted with a form. """ def __init__( self, file=None, name=None, content_type=None, size=None, charset=None, content_type_extra=None, ): super().__init__(file, name) self.size = size self.content_type = content_type self.charset = charset self.content_type_extra = content_type_extra def __repr__(self): return "<%s: %s (%s)>" % (self.__class__.__name__, self.name, self.content_type) def _get_name(self): return self._name def _set_name(self, name): # Sanitize the file name so that it can't be dangerous. if name is not None: # Just use the basename of the file -- anything else is dangerous. name = os.path.basename(name) # File names longer than 255 characters can cause problems on older OSes. if len(name) > 255: name, ext = os.path.splitext(name) ext = ext[:255] name = name[: 255 - len(ext)] + ext name = validate_file_name(name) self._name = name name = property(_get_name, _set_name) class TemporaryUploadedFile(UploadedFile): """ A file uploaded to a temporary location (i.e. stream-to-disk). """ def __init__(self, name, content_type, size, charset, content_type_extra=None): _, ext = os.path.splitext(name) file = tempfile.NamedTemporaryFile( suffix=".upload" + ext, dir=settings.FILE_UPLOAD_TEMP_DIR ) super().__init__(file, name, content_type, size, charset, content_type_extra) def temporary_file_path(self): """Return the full path of this file.""" return self.file.name def close(self): try: return self.file.close() except FileNotFoundError: # The file was moved or deleted before the tempfile could unlink # it. Still sets self.file.close_called and calls # self.file.file.close() before the exception. pass class InMemoryUploadedFile(UploadedFile): """ A file uploaded into memory (i.e. stream-to-memory). """ def __init__( self, file, field_name, name, content_type, size, charset, content_type_extra=None, ): super().__init__(file, name, content_type, size, charset, content_type_extra) self.field_name = field_name def open(self, mode=None): self.file.seek(0) return self def chunks(self, chunk_size=None): self.file.seek(0) yield self.read() def multiple_chunks(self, chunk_size=None): # Since it's in memory, we'll never have multiple chunks. return False class SimpleUploadedFile(InMemoryUploadedFile): """ A simple representation of a file, which just has content, size, and a name. """ def __init__(self, name, content, content_type="text/plain"): content = content or b"" super().__init__( BytesIO(content), None, name, content_type, len(content), None, None ) @classmethod def from_dict(cls, file_dict): """ Create a SimpleUploadedFile object from a dictionary with keys: - filename - content-type - content """ return cls( file_dict["filename"], file_dict["content"], file_dict.get("content-type", "text/plain"), ) images.py 0000644 00000005123 15030003247 0006356 0 ustar 00 """ Utility functions for handling images. Requires Pillow as you might imagine. """ import struct import zlib from django.core.files import File class ImageFile(File): """ A mixin for use alongside django.core.files.base.File, which provides additional features for dealing with images. """ @property def width(self): return self._get_image_dimensions()[0] @property def height(self): return self._get_image_dimensions()[1] def _get_image_dimensions(self): if not hasattr(self, "_dimensions_cache"): close = self.closed self.open() self._dimensions_cache = get_image_dimensions(self, close=close) return self._dimensions_cache def get_image_dimensions(file_or_path, close=False): """ Return the (width, height) of an image, given an open file or a path. Set 'close' to True to close the file at the end if it is initially in an open state. """ from PIL import ImageFile as PillowImageFile p = PillowImageFile.Parser() if hasattr(file_or_path, "read"): file = file_or_path file_pos = file.tell() file.seek(0) else: try: file = open(file_or_path, "rb") except OSError: return (None, None) close = True try: # Most of the time Pillow only needs a small chunk to parse the image # and get the dimensions, but with some TIFF files Pillow needs to # parse the whole file. chunk_size = 1024 while 1: data = file.read(chunk_size) if not data: break try: p.feed(data) except zlib.error as e: # ignore zlib complaining on truncated stream, just feed more # data to parser (ticket #19457). if e.args[0].startswith("Error -5"): pass else: raise except struct.error: # Ignore PIL failing on a too short buffer when reads return # less bytes than expected. Skip and feed more data to the # parser (ticket #24544). pass except RuntimeError: # e.g. "RuntimeError: could not create decoder object" for # WebP files. A different chunk_size may work. pass if p.image: return p.image.size chunk_size *= 2 return (None, None) finally: if close: file.close() else: file.seek(file_pos) storage/handler.py 0000644 00000003717 15030003247 0010201 0 ustar 00 from django.conf import DEFAULT_STORAGE_ALIAS, STATICFILES_STORAGE_ALIAS, settings from django.core.exceptions import ImproperlyConfigured from django.utils.functional import cached_property from django.utils.module_loading import import_string class InvalidStorageError(ImproperlyConfigured): pass class StorageHandler: def __init__(self, backends=None): # backends is an optional dict of storage backend definitions # (structured like settings.STORAGES). self._backends = backends self._storages = {} @cached_property def backends(self): if self._backends is None: self._backends = settings.STORAGES.copy() # RemovedInDjango51Warning. if settings.is_overridden("DEFAULT_FILE_STORAGE"): self._backends[DEFAULT_STORAGE_ALIAS] = { "BACKEND": settings.DEFAULT_FILE_STORAGE } if settings.is_overridden("STATICFILES_STORAGE"): self._backends[STATICFILES_STORAGE_ALIAS] = { "BACKEND": settings.STATICFILES_STORAGE } return self._backends def __getitem__(self, alias): try: return self._storages[alias] except KeyError: try: params = self.backends[alias] except KeyError: raise InvalidStorageError( f"Could not find config for '{alias}' in settings.STORAGES." ) storage = self.create_storage(params) self._storages[alias] = storage return storage def create_storage(self, params): params = params.copy() backend = params.pop("BACKEND") options = params.pop("OPTIONS", {}) try: storage_cls = import_string(backend) except ImportError as e: raise InvalidStorageError(f"Could not find backend {backend!r}: {e}") from e return storage_cls(**options) storage/base.py 0000644 00000017563 15030003247 0007502 0 ustar 00 import os import pathlib from django.core.exceptions import SuspiciousFileOperation from django.core.files import File from django.core.files.utils import validate_file_name from django.utils.crypto import get_random_string from django.utils.text import get_valid_filename class Storage: """ A base storage class, providing some default behaviors that all other storage systems can inherit or override, as necessary. """ # The following methods represent a public interface to private methods. # These shouldn't be overridden by subclasses unless absolutely necessary. def open(self, name, mode="rb"): """Retrieve the specified file from storage.""" return self._open(name, mode) def save(self, name, content, max_length=None): """ Save new content to the file specified by name. The content should be a proper File object or any Python file-like object, ready to be read from the beginning. """ # Get the proper name for the file, as it will actually be saved. if name is None: name = content.name if not hasattr(content, "chunks"): content = File(content, name) # Ensure that the name is valid, before and after having the storage # system potentially modifying the name. This duplicates the check made # inside `get_available_name` but it's necessary for those cases where # `get_available_name` is overriden and validation is lost. validate_file_name(name, allow_relative_path=True) # Potentially find a different name depending on storage constraints. name = self.get_available_name(name, max_length=max_length) # Validate the (potentially) new name. validate_file_name(name, allow_relative_path=True) # The save operation should return the actual name of the file saved. name = self._save(name, content) # Ensure that the name returned from the storage system is still valid. validate_file_name(name, allow_relative_path=True) return name # These methods are part of the public API, with default implementations. def get_valid_name(self, name): """ Return a filename, based on the provided filename, that's suitable for use in the target storage system. """ return get_valid_filename(name) def get_alternative_name(self, file_root, file_ext): """ Return an alternative filename, by adding an underscore and a random 7 character alphanumeric string (before the file extension, if one exists) to the filename. """ return "%s_%s%s" % (file_root, get_random_string(7), file_ext) def get_available_name(self, name, max_length=None): """ Return a filename that's free on the target storage system and available for new content to be written to. """ name = str(name).replace("\\", "/") dir_name, file_name = os.path.split(name) if ".." in pathlib.PurePath(dir_name).parts: raise SuspiciousFileOperation( "Detected path traversal attempt in '%s'" % dir_name ) validate_file_name(file_name) file_root, file_ext = os.path.splitext(file_name) # If the filename already exists, generate an alternative filename # until it doesn't exist. # Truncate original name if required, so the new filename does not # exceed the max_length. while self.exists(name) or (max_length and len(name) > max_length): # file_ext includes the dot. name = os.path.join( dir_name, self.get_alternative_name(file_root, file_ext) ) if max_length is None: continue # Truncate file_root if max_length exceeded. truncation = len(name) - max_length if truncation > 0: file_root = file_root[:-truncation] # Entire file_root was truncated in attempt to find an # available filename. if not file_root: raise SuspiciousFileOperation( 'Storage can not find an available filename for "%s". ' "Please make sure that the corresponding file field " 'allows sufficient "max_length".' % name ) name = os.path.join( dir_name, self.get_alternative_name(file_root, file_ext) ) return name def generate_filename(self, filename): """ Validate the filename by calling get_valid_name() and return a filename to be passed to the save() method. """ filename = str(filename).replace("\\", "/") # `filename` may include a path as returned by FileField.upload_to. dirname, filename = os.path.split(filename) if ".." in pathlib.PurePath(dirname).parts: raise SuspiciousFileOperation( "Detected path traversal attempt in '%s'" % dirname ) return os.path.normpath(os.path.join(dirname, self.get_valid_name(filename))) def path(self, name): """ Return a local filesystem path where the file can be retrieved using Python's built-in open() function. Storage systems that can't be accessed using open() should *not* implement this method. """ raise NotImplementedError("This backend doesn't support absolute paths.") # The following methods form the public API for storage systems, but with # no default implementations. Subclasses must implement *all* of these. def delete(self, name): """ Delete the specified file from the storage system. """ raise NotImplementedError( "subclasses of Storage must provide a delete() method" ) def exists(self, name): """ Return True if a file referenced by the given name already exists in the storage system, or False if the name is available for a new file. """ raise NotImplementedError( "subclasses of Storage must provide an exists() method" ) def listdir(self, path): """ List the contents of the specified path. Return a 2-tuple of lists: the first item being directories, the second item being files. """ raise NotImplementedError( "subclasses of Storage must provide a listdir() method" ) def size(self, name): """ Return the total size, in bytes, of the file specified by name. """ raise NotImplementedError("subclasses of Storage must provide a size() method") def url(self, name): """ Return an absolute URL where the file's contents can be accessed directly by a web browser. """ raise NotImplementedError("subclasses of Storage must provide a url() method") def get_accessed_time(self, name): """ Return the last accessed time (as a datetime) of the file specified by name. The datetime will be timezone-aware if USE_TZ=True. """ raise NotImplementedError( "subclasses of Storage must provide a get_accessed_time() method" ) def get_created_time(self, name): """ Return the creation time (as a datetime) of the file specified by name. The datetime will be timezone-aware if USE_TZ=True. """ raise NotImplementedError( "subclasses of Storage must provide a get_created_time() method" ) def get_modified_time(self, name): """ Return the last modified time (as a datetime) of the file specified by name. The datetime will be timezone-aware if USE_TZ=True. """ raise NotImplementedError( "subclasses of Storage must provide a get_modified_time() method" ) storage/__pycache__/__init__.cpython-310.pyc 0000644 00000002726 15030003247 0014661 0 ustar 00 o �h� � @ s� d dl Z d dlmZmZ d dlmZ d dlmZ d dlm Z ddl m Z ddl m Z dd lmZmZ dd lmZ d Zd Zdd d�ZG dd� de�Ze� Ze� ZdS )� N)�DEFAULT_STORAGE_ALIAS�settings)�RemovedInDjango51Warning)� LazyObject)� import_string� )�Storage)�FileSystemStorage)�InvalidStorageError�StorageHandler)�InMemoryStorage) r r r �DefaultStorage�default_storage�get_storage_classr r �storageszodjango.core.files.storage.get_storage_class is deprecated in favor of using django.core.files.storage.storages.c C s t jttdd� t| p tj�S )N� )� stacklevel)�warnings�warn� GET_STORAGE_CLASS_DEPRECATED_MSGr r r �DEFAULT_FILE_STORAGE)� import_path� r �X/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/storage/__init__.pyr s �r c @ s e Zd Zdd� ZdS )r c C s t t | _d S �N)r r �_wrapped)�selfr r r �_setup) s zDefaultStorage._setupN)�__name__� __module__� __qualname__r r r r r r ( s r r )r � django.confr r �django.utils.deprecationr �django.utils.functionalr �django.utils.module_loadingr �baser � filesystemr �handlerr r �memoryr �__all__r r r r r r r r r �<module> s � storage/__pycache__/memory.cpython-310.pyc 0000644 00000023510 15030003247 0014424 0 ustar 00 o �h& � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddl m Z ddl m Z ddl mZ ddlmZ dd lmZ dd lmZ dd lmZ d d lmZ d dlmZ dZG dd� d�Z G dd� de e �Z G dd� de �Z edd�G dd� dee��Z dS )ub Based on dj-inmemorystorage (BSD) by Cody Soyland, Seán Hayes, Tore Birkeland, and Nick Presta. � N)�urljoin)�settings)� ContentFile)�setting_changed)� safe_join)�deconstructible)�filepath_to_uri)�cached_property)�now� )�Storage)�StorageSettingsMixin)�InMemoryStoragec @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� TimingMixinc C s t � | _| j| _| j| _d S �N)r � created_time� accessed_time� modified_time��self� r �V/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/storage/memory.py�_initialize_times s z TimingMixin._initialize_timesc C � t � | _d S r )r r r r r r �_update_accessed_time! � z!TimingMixin._update_accessed_timec C r r )r r r r r r �_update_modified_time$ r z!TimingMixin._update_modified_timeN)�__name__� __module__� __qualname__r r r r r r r r s r c sF e Zd ZdZd dd�Z� fdd�Z� fdd�Zd d � Zd d � Z� Z S )�InMemoryFileNodez� Helper class representing an in-memory file node. Handle unicode/bytes conversion during I/O operations and record creation, modification, and access times. � c C s$ d | _ t|�| _| �� | �� d S r )�file�type� _content_type�_initialize_streamr )r �content�namer r r �__init__0 s zInMemoryFileNode.__init__c s | � |� | �� t� �|�S r )�_convert_stream_contentr �super�open)r �mode�� __class__r r r+ 6 s zInMemoryFileNode.openc s t � �|� | �� d S r )r* �writer )r �datar- r r r/ ; s zInMemoryFileNode.writec C s& | j tkr t�� | _dS t�� | _dS )z;Initialize underlying stream according to the content type.N)r$ �bytes�io�BytesIO�StringIOr" r r r r r% ? s &z#InMemoryFileNode._initialize_streamc C s` d|v rt nt}| j|krdS | j�� }t|t�r |�� n|�� }|| _| �� | j� |� dS )z:Convert actual file content according to the opening mode.�bN) r1 �strr$ r" �getvalue� isinstance�encode�decoder% r/ )r r, �new_content_typer& r r r r) C s z(InMemoryFileNode._convert_stream_content)r! r! ) r r r �__doc__r( r+ r/ r% r) � __classcell__r r r- r r ( s r c @ s: e Zd ZdZdd� Zddd�Zd d � Zd d � Zd d� ZdS )�InMemoryDirNodez� Helper class representing an in-memory directory node. Handle path navigation of directory trees, creating missing nodes if needed. c C s i | _ | �� d S r )� _childrenr r r r r r( Z s zInMemoryDirNode.__init__FNTc C s� t t�|�j�}| }|rI|�d�}t|t�r3tj� |�}d� |d|� |�� �}t t jt�t j�|��|�||t|�dkr?|nt�}|du rGn|s |du rZ|rZtt jt�t j�|��|rzt||�sz|tu rjt t jfntt jf\} } | | t�| �|��|S )a� Navigate current directory tree, returning node matching path or creating a new one, if missing. - path: path of the node to search - create_if_missing: create nodes if not exist. Defaults to False. - leaf_cls: expected type of leaf node. Defaults to None. - check_exists: if True and the leaf node does not exist, raise a FileNotFoundError. Defaults to True. r �/N)�list�pathlib�Path�parts�popr8 r �os�path�split�join�index�NotADirectoryError�errno�ENOTDIR�strerror�_resolve_child�lenr> �FileNotFoundError�ENOENT�IsADirectoryError�EISDIR) r rG �create_if_missing�leaf_cls� check_exists� path_segments� current_node� path_segment� current_path� error_cls� error_coder r r �resolve^ s: ���� ��zInMemoryDirNode.resolvec C s0 |r| � � | �� | j�||� �S | j�|�S r )r r r? � setdefault�get)r rZ rU � child_clsr r r rO � s z InMemoryDirNode._resolve_childc C sF g g }}| j �� D ]\}}t|t�r|�|� q |�|� q ||fS r )r? �itemsr8 r> �append)r � directories�filesr' �entryr r r �listdir� s zInMemoryDirNode.listdirc C s* || j v r| �� | �� | j |= d S d S r )r? r r �r r' r r r � remove_child� s �z InMemoryDirNode.remove_child�FNT) r r r r< r( r^ rO rg ri r r r r r> R s / r> z)django.core.files.storage.InMemoryStorage)rG c @ s� e Zd ZdZ d,dd�Zedd� �Zedd� �Zed d � �Zed d � �Z ed d� �Z dd� Z d-dd�Z d.dd�Z dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� ZdS )/r z!A storage saving files in memory.Nc C sB || _ || _|| _|| _t� | _| j| jdtd� t� | j � d S )NT�rU rV ) � _location� _base_url�_file_permissions_mode�_directory_permissions_moder> �_root�_resolve� base_locationr �connect�_clear_cached_properties)r �location�base_url�file_permissions_mode�directory_permissions_moder r r r( � s �zInMemoryStorage.__init__c C � | � | jtj�S r )�_value_or_settingrl r � MEDIA_ROOTr r r r rr � s z InMemoryStorage.base_locationc C s t j�| j�S r )rF rG �abspathrr r r r r ru � s zInMemoryStorage.locationc C s4 | j d ur| j �d�s| j d7 _ | �| j tj�S )Nr@ )rm �endswithrz r � MEDIA_URLr r r r rv � s zInMemoryStorage.base_urlc C ry r )rz rn r �FILE_UPLOAD_PERMISSIONSr r r r rw � � �z%InMemoryStorage.file_permissions_modec C ry r )rz ro r �!FILE_UPLOAD_DIRECTORY_PERMISSIONSr r r r rx � r� z*InMemoryStorage.directory_permissions_modec C s | � |�}tj �|| j�S r )rG rF �relpathru )r r' � full_pathr r r �_relative_path� s z InMemoryStorage._relative_pathFTc C sT z| � |�}| jj||||d�W S ty) } z | �|j�}t|� d���d }~ww )N)rU rV rW z exists and is not a directory.)r� rp r^ rK rG �filename�FileExistsError)r r' rU rV rW � relative_path�exc� absolute_pathr r r rq � s � ��zInMemoryStorage._resolve�rbc C s" d|v }| j ||td�}|�|�S )N�wrk )rq r r+ )r r' r, rU � file_noder r r �_open� s � zInMemoryStorage._openc C s� | j |dtd�}d }|�� D ]}|d u r"t|t�rdnd}|�|�}|�|� qt|d�r4t� |� � � t � |_ | � |��dd�S )NTrk �wb�wt�temporary_file_path�\r@ )rq r �chunksr8 r1 r+ r/ �hasattrrF �remover� r r r� �replace)r r' r& r� �fd�chunkr, r r r �_save� s � zInMemoryStorage._savec C s t | j|�S r )r ru rh r r r rG � r zInMemoryStorage.pathc C s8 t j�|�\}}| j|dd�}|d u rd S |�|� d S �NF)rW )rF rG rH rq ri )r r' rG r� �dir_noder r r �delete� s zInMemoryStorage.deletec C s | j |dd�d uS r� )rq rh r r r �exists s zInMemoryStorage.existsc C s | j |td�}|�� S )N)rV )rq r> rg )r rG �noder r r rg s zInMemoryStorage.listdirc C s t | �|d�j�� �S )Nr� )rP r� r" r7 rh r r r �size s zInMemoryStorage.sizec C s8 | j d u r td��t|�}|d ur|�d�}t| j |�S )Nz&This file is not accessible via a URL.r@ )rv � ValueErrorr �lstripr )r r' �urlr r r r� s zInMemoryStorage.urlc C � | � |�}|jS r )rq r �r r' r� r r r �get_accessed_time � z!InMemoryStorage.get_accessed_timec C r� r )rq r r� r r r �get_created_time r� z InMemoryStorage.get_created_timec C r� r )rq r r� r r r �get_modified_time r� z!InMemoryStorage.get_modified_time)NNNNrj )r� )r r r r< r( r rr ru rv rw rx r� rq r� r� rG r� r� rg r� r� r� r� r� r r r r r � s< � r ) r< rL r2 rF rB � urllib.parser � django.confr �django.core.files.baser �django.core.signalsr �django.utils._osr �django.utils.deconstructr �django.utils.encodingr �django.utils.functionalr �django.utils.timezoner �baser �mixinsr �__all__r r r> r r r r r �<module> s, *R storage/__pycache__/handler.cpython-310.pyc 0000644 00000003766 15030003247 0014544 0 ustar 00 o �h� � @ sZ d dl mZmZmZ d dlmZ d dlmZ d dlm Z G dd� de�Z G dd� d�Z d S ) � )�DEFAULT_STORAGE_ALIAS�STATICFILES_STORAGE_ALIAS�settings)�ImproperlyConfigured)�cached_property)� import_stringc @ s e Zd ZdS )�InvalidStorageErrorN)�__name__� __module__� __qualname__� r r �W/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/storage/handler.pyr s r c @ s2 e Zd Zd dd�Zedd� �Zdd� Zdd � ZdS ) �StorageHandlerNc C s || _ i | _d S �N)� _backends� _storages)�self�backendsr r r �__init__ s zStorageHandler.__init__c C sP | j d u r%tj�� | _ t�d�rdtji| j t< t�d�r%dtji| j t< | j S )N�DEFAULT_FILE_STORAGE�BACKEND�STATICFILES_STORAGE) r r �STORAGES�copy� is_overriddenr r r r )r r r r r s � �zStorageHandler.backendsc C sf z| j | W S ty2 z| j| }W n ty# td|� d���w | �|�}|| j |< | Y S w )NzCould not find config for 'z' in settings.STORAGES.)r �KeyErrorr r �create_storage)r �alias�params�storager r r � __getitem__! s �� �zStorageHandler.__getitem__c C sh |� � }|�d�}|�di �}zt|�}W n ty, } z td|�d|� ��|�d }~ww |di |��S )Nr �OPTIONSzCould not find backend z: r )r �popr � ImportErrorr )r r �backend�options� storage_cls�er r r r / s ��z StorageHandler.create_storager )r r r r r r r r r r r r r s r N) � django.confr r r �django.core.exceptionsr �django.utils.functionalr �django.utils.module_loadingr r r r r r r �<module> s storage/__pycache__/mixins.cpython-310.pyc 0000644 00000002032 15030003247 0014417 0 ustar 00 o �h� � @ s G d d� d�Z dS )c @ s e Zd Zdd� Zdd� ZdS )�StorageSettingsMixinc K sz |dkr| j �dd� | j �dd� dS |dkr!| j �dd� dS |dkr.| j �dd� dS |d kr;| j �d d� dS dS ) z$Reset setting based property values.� MEDIA_ROOT� base_locationN�location� MEDIA_URL�base_url�FILE_UPLOAD_PERMISSIONS�file_permissions_mode�!FILE_UPLOAD_DIRECTORY_PERMISSIONS�directory_permissions_mode)�__dict__�pop)�self�setting�kwargs� r �V/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/storage/mixins.py�_clear_cached_properties s �z-StorageSettingsMixin._clear_cached_propertiesc C s |d u r|S |S )Nr )r �valuer r r r �_value_or_setting s z&StorageSettingsMixin._value_or_settingN)�__name__� __module__� __qualname__r r r r r r r s r N)r r r r r �<module> s storage/__pycache__/base.cpython-310.pyc 0000644 00000014400 15030003247 0014024 0 ustar 00 o �hs � @ s^ d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlm Z d dl m Z G dd� d�Z dS ) � N)�SuspiciousFileOperation)�File)�validate_file_name��get_random_string��get_valid_filenamec @ s� e Zd ZdZd"dd�Zd#dd�Zdd � Zd d � Zd#d d �Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd d!� ZdS )$�Storagez� A base storage class, providing some default behaviors that all other storage systems can inherit or override, as necessary. �rbc C s | � ||�S )z)Retrieve the specified file from storage.)�_open)�self�name�mode� r �T/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/storage/base.py�open s z Storage.openNc C sd |du r|j }t|d�st||�}t|dd� | j||d�}t|dd� | �||�}t|dd� |S )z� Save new content to the file specified by name. The content should be a proper File object or any Python file-like object, ready to be read from the beginning. N�chunksT)�allow_relative_path)� max_length)r �hasattrr r �get_available_name�_save)r r �contentr r r r �save s z Storage.savec C s t |�S )z� Return a filename, based on the provided filename, that's suitable for use in the target storage system. r �r r r r r �get_valid_name8 � zStorage.get_valid_namec C s d|t d�|f S )z� Return an alternative filename, by adding an underscore and a random 7 character alphanumeric string (before the file extension, if one exists) to the filename. z%s_%s%s� r )r � file_root�file_extr r r �get_alternative_name? s z Storage.get_alternative_namec C s� t |��dd�}tj�|�\}}dt�|�jv r td| ��t |� tj� |�\}}| � |�s7|rxt |�|krxtj� || �||��}|du rGq*t |�| }|dkrk|d| � }|s`td| ��tj� || �||��}| � |�s7|rxt |�|ks7|S )z� Return a filename that's free on the target storage system and available for new content to be written to. �\�/�..�'Detected path traversal attempt in '%s'Nr z�Storage can not find an available filename for "%s". Please make sure that the corresponding file field allows sufficient "max_length".)�str�replace�os�path�split�pathlib�PurePath�partsr r �splitext�exists�len�joinr )r r r �dir_name� file_namer r � truncationr r r r G s8 � � �� ��zStorage.get_available_namec C sX t |��dd�}tj�|�\}}dt�|�jv r td| ��tj� tj� || � |���S )z� Validate the filename by calling get_valid_name() and return a filename to be passed to the save() method. r! r" r# r$ ) r% r& r' r( r) r* r+ r, r �normpathr0 r )r �filename�dirnamer r r �generate_filenamep s � zStorage.generate_filenamec C � t d��)z� Return a local filesystem path where the file can be retrieved using Python's built-in open() function. Storage systems that can't be accessed using open() should *not* implement this method. z,This backend doesn't support absolute paths.��NotImplementedErrorr r r r r( ~ s z Storage.pathc C r8 )zD Delete the specified file from the storage system. z4subclasses of Storage must provide a delete() methodr9 r r r r �delete� s �zStorage.deletec C r8 )z� Return True if a file referenced by the given name already exists in the storage system, or False if the name is available for a new file. z5subclasses of Storage must provide an exists() methodr9 r r r r r. � � �zStorage.existsc C r8 )z� List the contents of the specified path. Return a 2-tuple of lists: the first item being directories, the second item being files. z5subclasses of Storage must provide a listdir() methodr9 )r r( r r r �listdir� r< zStorage.listdirc C r8 )zQ Return the total size, in bytes, of the file specified by name. z2subclasses of Storage must provide a size() methodr9 r r r r �size� s z Storage.sizec C r8 )zu Return an absolute URL where the file's contents can be accessed directly by a web browser. z1subclasses of Storage must provide a url() methodr9 r r r r �url� r z Storage.urlc C r8 )z� Return the last accessed time (as a datetime) of the file specified by name. The datetime will be timezone-aware if USE_TZ=True. z?subclasses of Storage must provide a get_accessed_time() methodr9 r r r r �get_accessed_time� r< zStorage.get_accessed_timec C r8 )z� Return the creation time (as a datetime) of the file specified by name. The datetime will be timezone-aware if USE_TZ=True. z>subclasses of Storage must provide a get_created_time() methodr9 r r r r �get_created_time� r< zStorage.get_created_timec C r8 )z� Return the last modified time (as a datetime) of the file specified by name. The datetime will be timezone-aware if USE_TZ=True. z?subclasses of Storage must provide a get_modified_time() methodr9 r r r r �get_modified_time� r< zStorage.get_modified_time)r )N)�__name__� __module__� __qualname__�__doc__r r r r r r7 r( r; r. r= r> r? r@ rA rB r r r r r s" ) r ) r' r* �django.core.exceptionsr �django.core.filesr �django.core.files.utilsr �django.utils.cryptor �django.utils.textr r r r r r �<module> s storage/__pycache__/filesystem.cpython-310.pyc 0000644 00000014442 15030003247 0015304 0 ustar 00 o �hp � @ s� d dl Z d dlmZmZ d dlmZ d dlmZ d dlmZm Z d dl m Z d dl m Z d dlmZ d d lmZ d d lmZ d d lmZ d d lmZ d dlmZ edd�G dd� dee��ZdS )� N)�datetime�timezone)�urljoin)�settings)�File�locks)�file_move_safe)�setting_changed)� safe_join)�deconstructible)�filepath_to_uri)�cached_property� )�Storage)�StorageSettingsMixinz+django.core.files.storage.FileSystemStorage)�pathc @ s� e Zd ZdZejejB ejB eedd�B Z d,dd�Z e dd� �Z e d d � �Z e d d � �Ze d d� �Ze dd� �Zd-dd�Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d*d+� Z dS ).�FileSystemStoragez% Standard filesystem storage �O_BINARYr Nc C s( || _ || _|| _|| _t�| j� d S �N)� _location� _base_url�_file_permissions_mode�_directory_permissions_moder �connect�_clear_cached_properties)�self�location�base_url�file_permissions_mode�directory_permissions_mode� r �Z/usr/local/CyberPanel/lib/python3.10/site-packages/django/core/files/storage/filesystem.py�__init__ s zFileSystemStorage.__init__c C � | � | jtj�S r )�_value_or_settingr r � MEDIA_ROOT�r r r r! � base_location) s z FileSystemStorage.base_locationc C s t j�| j�S r )�osr �abspathr' r& r r r! r - s zFileSystemStorage.locationc C s4 | j d ur| j �d�s| j d7 _ | �| j tj�S )N�/)r �endswithr$ r � MEDIA_URLr& r r r! r 1 s zFileSystemStorage.base_urlc C r# r )r$ r r �FILE_UPLOAD_PERMISSIONSr& r r r! r 7 � �z'FileSystemStorage.file_permissions_modec C r# r )r$ r r �!FILE_UPLOAD_DIRECTORY_PERMISSIONSr& r r r! r = r. z,FileSystemStorage.directory_permissions_mode�rbc C s t t| �|�|��S r )r �openr )r �name�moder r r! �_openC s zFileSystemStorage._openc C s� | � |�}tj �|�}z.| jd ur1t�d| j @ �}ztj|| jdd� W t�|� n t�|� w tj|dd� W n tyF td| ��w zit|d�rVt|� � |� nZt� || j d�}d }z;t � |t j� |�� D ]}|d u r�t|t�rydnd} t�|| �}|�|� qlW t �|� |d ur�|�� nt�|� nt �|� |d ur�|�� w t�|� w W n ty� | �|�}| � |�}Y nw nqH| jd ur�t�|| j� tj �|| j�}| �|� t |�� d d �S ) Ni� T)�exist_okz!%s exists and is not a directory.�temporary_file_pathi� �wb�wt�\r* ) r r( �dirnamer �umask�makedirs�FileExistsError�hasattrr r6 r1 � OS_OPEN_FLAGSr �lock�LOCK_EX�chunks� isinstance�bytes�fdopen�write�unlock�close�get_available_namer �chmod�relpathr �_ensure_location_group_id�str�replace) r r2 �content� full_path� directory� old_umask�fd�_file�chunkr3 r r r! �_saveF sb �� � � � � �� zFileSystemStorage._savec C s` t jdkr,t �|�j}t �| j�j}||kr.z t j|d|d� W d S ty+ Y d S w d S d S )N�posix���)�uid�gid)r( r2 �stat�st_gidr �chown�PermissionError)r rP �file_gid� location_gidr r r! rL � s ��z+FileSystemStorage._ensure_location_group_idc C sX |st d��| �|�}ztj�|�rt�|� W d S t�|� W d S ty+ Y d S w )Nz#The name must be given to delete().)� ValueErrorr r( �isdir�rmdir�remove�FileNotFoundError�r r2 r r r! �delete� s �zFileSystemStorage.deletec C � t j�| �|��S r )r( r �lexistsrf r r r! �exists� � zFileSystemStorage.existsc C sx | � |�}g g }}t�|��!}|D ]}|�� r |�|j� q|�|j� qW d � ||fS 1 s3w Y ||fS r )r r( �scandir�is_dir�appendr2 )r r � directories�files�entries�entryr r r! �listdir� s � ��zFileSystemStorage.listdirc C s t | j|�S r )r r rf r r r! r � s zFileSystemStorage.pathc C rh r )r( r �getsizerf r r r! �size� rk zFileSystemStorage.sizec C s8 | j d u r td��t|�}|d ur|�d�}t| j |�S )Nz&This file is not accessible via a URL.r* )r ra r �lstripr )r r2 �urlr r r! rw � s zFileSystemStorage.urlc C s t jrtjnd}tj||d�S )z� If timezone support is enabled, make an aware datetime object in UTC; otherwise make a naive one in the local timezone. N)�tz)r �USE_TZr �utcr � fromtimestamp)r �tsrx r r r! �_datetime_from_timestamp� s z*FileSystemStorage._datetime_from_timestampc C � | � tj�| �|���S r )r} r( r �getatimerf r r r! �get_accessed_time� � z#FileSystemStorage.get_accessed_timec C r~ r )r} r( r �getctimerf r r r! �get_created_time� r� z"FileSystemStorage.get_created_timec C r~ r )r} r( r �getmtimerf r r r! �get_modified_time� r� z#FileSystemStorage.get_modified_time)NNNN)r0 ) �__name__� __module__� __qualname__�__doc__r( �O_WRONLY�O_CREAT�O_EXCL�getattrr? r" r r' r r r r r4 rV rL rg rj rs r ru rw r} r� r� r� r r r r! r s> � E r )r( r r � urllib.parser � django.confr �django.core.filesr r �django.core.files.mover �django.core.signalsr �django.utils._osr �django.utils.deconstructr �django.utils.encodingr �django.utils.functionalr �baser �mixinsr r r r r r! �<module> s storage/mixins.py 0000644 00000001274 15030003247 0010067 0 ustar 00 class StorageSettingsMixin: def _clear_cached_properties(self, setting, **kwargs): """Reset setting based property values.""" if setting == "MEDIA_ROOT": self.__dict__.pop("base_location", None) self.__dict__.pop("location", None) elif setting == "MEDIA_URL": self.__dict__.pop("base_url", None) elif setting == "FILE_UPLOAD_PERMISSIONS": self.__dict__.pop("file_permissions_mode", None) elif setting == "FILE_UPLOAD_DIRECTORY_PERMISSIONS": self.__dict__.pop("directory_permissions_mode", None) def _value_or_setting(self, value, setting): return setting if value is None else value storage/filesystem.py 0000644 00000017160 15030003247 0010745 0 ustar 00 import os from datetime import datetime, timezone from urllib.parse import urljoin from django.conf import settings from django.core.files import File, locks from django.core.files.move import file_move_safe from django.core.signals import setting_changed from django.utils._os import safe_join from django.utils.deconstruct import deconstructible from django.utils.encoding import filepath_to_uri from django.utils.functional import cached_property from .base import Storage from .mixins import StorageSettingsMixin @deconstructible(path="django.core.files.storage.FileSystemStorage") class FileSystemStorage(Storage, StorageSettingsMixin): """ Standard filesystem storage """ # The combination of O_CREAT and O_EXCL makes os.open() raise OSError if # the file already exists before it's opened. OS_OPEN_FLAGS = os.O_WRONLY | os.O_CREAT | os.O_EXCL | getattr(os, "O_BINARY", 0) def __init__( self, location=None, base_url=None, file_permissions_mode=None, directory_permissions_mode=None, ): self._location = location self._base_url = base_url self._file_permissions_mode = file_permissions_mode self._directory_permissions_mode = directory_permissions_mode setting_changed.connect(self._clear_cached_properties) @cached_property def base_location(self): return self._value_or_setting(self._location, settings.MEDIA_ROOT) @cached_property def location(self): return os.path.abspath(self.base_location) @cached_property def base_url(self): if self._base_url is not None and not self._base_url.endswith("/"): self._base_url += "/" return self._value_or_setting(self._base_url, settings.MEDIA_URL) @cached_property def file_permissions_mode(self): return self._value_or_setting( self._file_permissions_mode, settings.FILE_UPLOAD_PERMISSIONS ) @cached_property def directory_permissions_mode(self): return self._value_or_setting( self._directory_permissions_mode, settings.FILE_UPLOAD_DIRECTORY_PERMISSIONS ) def _open(self, name, mode="rb"): return File(open(self.path(name), mode)) def _save(self, name, content): full_path = self.path(name) # Create any intermediate directories that do not exist. directory = os.path.dirname(full_path) try: if self.directory_permissions_mode is not None: # Set the umask because os.makedirs() doesn't apply the "mode" # argument to intermediate-level directories. old_umask = os.umask(0o777 & ~self.directory_permissions_mode) try: os.makedirs( directory, self.directory_permissions_mode, exist_ok=True ) finally: os.umask(old_umask) else: os.makedirs(directory, exist_ok=True) except FileExistsError: raise FileExistsError("%s exists and is not a directory." % directory) # There's a potential race condition between get_available_name and # saving the file; it's possible that two threads might return the # same name, at which point all sorts of fun happens. So we need to # try to create the file, but if it already exists we have to go back # to get_available_name() and try again. while True: try: # This file has a file path that we can move. if hasattr(content, "temporary_file_path"): file_move_safe(content.temporary_file_path(), full_path) # This is a normal uploadedfile that we can stream. else: # The current umask value is masked out by os.open! fd = os.open(full_path, self.OS_OPEN_FLAGS, 0o666) _file = None try: locks.lock(fd, locks.LOCK_EX) for chunk in content.chunks(): if _file is None: mode = "wb" if isinstance(chunk, bytes) else "wt" _file = os.fdopen(fd, mode) _file.write(chunk) finally: locks.unlock(fd) if _file is not None: _file.close() else: os.close(fd) except FileExistsError: # A new name is needed if the file exists. name = self.get_available_name(name) full_path = self.path(name) else: # OK, the file save worked. Break out of the loop. break if self.file_permissions_mode is not None: os.chmod(full_path, self.file_permissions_mode) # Ensure the saved path is always relative to the storage root. name = os.path.relpath(full_path, self.location) # Ensure the moved file has the same gid as the storage root. self._ensure_location_group_id(full_path) # Store filenames with forward slashes, even on Windows. return str(name).replace("\\", "/") def _ensure_location_group_id(self, full_path): if os.name == "posix": file_gid = os.stat(full_path).st_gid location_gid = os.stat(self.location).st_gid if file_gid != location_gid: try: os.chown(full_path, uid=-1, gid=location_gid) except PermissionError: pass def delete(self, name): if not name: raise ValueError("The name must be given to delete().") name = self.path(name) # If the file or directory exists, delete it from the filesystem. try: if os.path.isdir(name): os.rmdir(name) else: os.remove(name) except FileNotFoundError: # FileNotFoundError is raised if the file or directory was removed # concurrently. pass def exists(self, name): return os.path.lexists(self.path(name)) def listdir(self, path): path = self.path(path) directories, files = [], [] with os.scandir(path) as entries: for entry in entries: if entry.is_dir(): directories.append(entry.name) else: files.append(entry.name) return directories, files def path(self, name): return safe_join(self.location, name) def size(self, name): return os.path.getsize(self.path(name)) def url(self, name): if self.base_url is None: raise ValueError("This file is not accessible via a URL.") url = filepath_to_uri(name) if url is not None: url = url.lstrip("/") return urljoin(self.base_url, url) def _datetime_from_timestamp(self, ts): """ If timezone support is enabled, make an aware datetime object in UTC; otherwise make a naive one in the local timezone. """ tz = timezone.utc if settings.USE_TZ else None return datetime.fromtimestamp(ts, tz=tz) def get_accessed_time(self, name): return self._datetime_from_timestamp(os.path.getatime(self.path(name))) def get_created_time(self, name): return self._datetime_from_timestamp(os.path.getctime(self.path(name))) def get_modified_time(self, name): return self._datetime_from_timestamp(os.path.getmtime(self.path(name))) storage/memory.py 0000644 00000023021 15030003247 0010062 0 ustar 00 """ Based on dj-inmemorystorage (BSD) by Cody Soyland, Seán Hayes, Tore Birkeland, and Nick Presta. """ import errno import io import os import pathlib from urllib.parse import urljoin from django.conf import settings from django.core.files.base import ContentFile from django.core.signals import setting_changed from django.utils._os import safe_join from django.utils.deconstruct import deconstructible from django.utils.encoding import filepath_to_uri from django.utils.functional import cached_property from django.utils.timezone import now from .base import Storage from .mixins import StorageSettingsMixin __all__ = ("InMemoryStorage",) class TimingMixin: def _initialize_times(self): self.created_time = now() self.accessed_time = self.created_time self.modified_time = self.created_time def _update_accessed_time(self): self.accessed_time = now() def _update_modified_time(self): self.modified_time = now() class InMemoryFileNode(ContentFile, TimingMixin): """ Helper class representing an in-memory file node. Handle unicode/bytes conversion during I/O operations and record creation, modification, and access times. """ def __init__(self, content="", name=""): self.file = None self._content_type = type(content) self._initialize_stream() self._initialize_times() def open(self, mode): self._convert_stream_content(mode) self._update_accessed_time() return super().open(mode) def write(self, data): super().write(data) self._update_modified_time() def _initialize_stream(self): """Initialize underlying stream according to the content type.""" self.file = io.BytesIO() if self._content_type == bytes else io.StringIO() def _convert_stream_content(self, mode): """Convert actual file content according to the opening mode.""" new_content_type = bytes if "b" in mode else str # No conversion needed. if self._content_type == new_content_type: return content = self.file.getvalue() content = content.encode() if isinstance(content, str) else content.decode() self._content_type = new_content_type self._initialize_stream() self.file.write(content) class InMemoryDirNode(TimingMixin): """ Helper class representing an in-memory directory node. Handle path navigation of directory trees, creating missing nodes if needed. """ def __init__(self): self._children = {} self._initialize_times() def resolve(self, path, create_if_missing=False, leaf_cls=None, check_exists=True): """ Navigate current directory tree, returning node matching path or creating a new one, if missing. - path: path of the node to search - create_if_missing: create nodes if not exist. Defaults to False. - leaf_cls: expected type of leaf node. Defaults to None. - check_exists: if True and the leaf node does not exist, raise a FileNotFoundError. Defaults to True. """ path_segments = list(pathlib.Path(path).parts) current_node = self while path_segments: path_segment = path_segments.pop(0) # If current node is a file node and there are unprocessed # segments, raise an error. if isinstance(current_node, InMemoryFileNode): path_segments = os.path.split(path) current_path = "/".join( path_segments[: path_segments.index(path_segment)] ) raise NotADirectoryError( errno.ENOTDIR, os.strerror(errno.ENOTDIR), current_path ) current_node = current_node._resolve_child( path_segment, create_if_missing, leaf_cls if len(path_segments) == 0 else InMemoryDirNode, ) if current_node is None: break if current_node is None and check_exists: raise FileNotFoundError(errno.ENOENT, os.strerror(errno.ENOENT), path) # If a leaf_cls is not None, check if leaf node is of right type. if leaf_cls and not isinstance(current_node, leaf_cls): error_cls, error_code = ( (NotADirectoryError, errno.ENOTDIR) if leaf_cls is InMemoryDirNode else (IsADirectoryError, errno.EISDIR) ) raise error_cls(error_code, os.strerror(error_code), path) return current_node def _resolve_child(self, path_segment, create_if_missing, child_cls): if create_if_missing: self._update_accessed_time() self._update_modified_time() return self._children.setdefault(path_segment, child_cls()) return self._children.get(path_segment) def listdir(self): directories, files = [], [] for name, entry in self._children.items(): if isinstance(entry, InMemoryDirNode): directories.append(name) else: files.append(name) return directories, files def remove_child(self, name): if name in self._children: self._update_accessed_time() self._update_modified_time() del self._children[name] @deconstructible(path="django.core.files.storage.InMemoryStorage") class InMemoryStorage(Storage, StorageSettingsMixin): """A storage saving files in memory.""" def __init__( self, location=None, base_url=None, file_permissions_mode=None, directory_permissions_mode=None, ): self._location = location self._base_url = base_url self._file_permissions_mode = file_permissions_mode self._directory_permissions_mode = directory_permissions_mode self._root = InMemoryDirNode() self._resolve( self.base_location, create_if_missing=True, leaf_cls=InMemoryDirNode ) setting_changed.connect(self._clear_cached_properties) @cached_property def base_location(self): return self._value_or_setting(self._location, settings.MEDIA_ROOT) @cached_property def location(self): return os.path.abspath(self.base_location) @cached_property def base_url(self): if self._base_url is not None and not self._base_url.endswith("/"): self._base_url += "/" return self._value_or_setting(self._base_url, settings.MEDIA_URL) @cached_property def file_permissions_mode(self): return self._value_or_setting( self._file_permissions_mode, settings.FILE_UPLOAD_PERMISSIONS ) @cached_property def directory_permissions_mode(self): return self._value_or_setting( self._directory_permissions_mode, settings.FILE_UPLOAD_DIRECTORY_PERMISSIONS ) def _relative_path(self, name): full_path = self.path(name) return os.path.relpath(full_path, self.location) def _resolve(self, name, create_if_missing=False, leaf_cls=None, check_exists=True): try: relative_path = self._relative_path(name) return self._root.resolve( relative_path, create_if_missing=create_if_missing, leaf_cls=leaf_cls, check_exists=check_exists, ) except NotADirectoryError as exc: absolute_path = self.path(exc.filename) raise FileExistsError(f"{absolute_path} exists and is not a directory.") def _open(self, name, mode="rb"): create_if_missing = "w" in mode file_node = self._resolve( name, create_if_missing=create_if_missing, leaf_cls=InMemoryFileNode ) return file_node.open(mode) def _save(self, name, content): file_node = self._resolve( name, create_if_missing=True, leaf_cls=InMemoryFileNode ) fd = None for chunk in content.chunks(): if fd is None: mode = "wb" if isinstance(chunk, bytes) else "wt" fd = file_node.open(mode) fd.write(chunk) if hasattr(content, "temporary_file_path"): os.remove(content.temporary_file_path()) file_node.modified_time = now() return self._relative_path(name).replace("\\", "/") def path(self, name): return safe_join(self.location, name) def delete(self, name): path, filename = os.path.split(name) dir_node = self._resolve(path, check_exists=False) if dir_node is None: return None dir_node.remove_child(filename) def exists(self, name): return self._resolve(name, check_exists=False) is not None def listdir(self, path): node = self._resolve(path, leaf_cls=InMemoryDirNode) return node.listdir() def size(self, name): return len(self._open(name, "rb").file.getvalue()) def url(self, name): if self.base_url is None: raise ValueError("This file is not accessible via a URL.") url = filepath_to_uri(name) if url is not None: url = url.lstrip("/") return urljoin(self.base_url, url) def get_accessed_time(self, name): file_node = self._resolve(name) return file_node.accessed_time def get_created_time(self, name): file_node = self._resolve(name) return file_node.created_time def get_modified_time(self, name): file_node = self._resolve(name) return file_node.modified_time storage/__init__.py 0000644 00000002250 15030003247 0010312 0 ustar 00 import warnings from django.conf import DEFAULT_STORAGE_ALIAS, settings from django.utils.deprecation import RemovedInDjango51Warning from django.utils.functional import LazyObject from django.utils.module_loading import import_string from .base import Storage from .filesystem import FileSystemStorage from .handler import InvalidStorageError, StorageHandler from .memory import InMemoryStorage __all__ = ( "FileSystemStorage", "InMemoryStorage", "Storage", "DefaultStorage", "default_storage", "get_storage_class", "InvalidStorageError", "StorageHandler", "storages", ) GET_STORAGE_CLASS_DEPRECATED_MSG = ( "django.core.files.storage.get_storage_class is deprecated in favor of " "using django.core.files.storage.storages." ) def get_storage_class(import_path=None): warnings.warn( GET_STORAGE_CLASS_DEPRECATED_MSG, RemovedInDjango51Warning, stacklevel=2, ) return import_string(import_path or settings.DEFAULT_FILE_STORAGE) class DefaultStorage(LazyObject): def _setup(self): self._wrapped = storages[DEFAULT_STORAGE_ALIAS] storages = StorageHandler() default_storage = DefaultStorage() uploadhandler.py 0000644 00000016013 15030003247 0007733 0 ustar 00 """ Base file upload handler classes, and the built-in concrete subclasses """ import os from io import BytesIO from django.conf import settings from django.core.files.uploadedfile import InMemoryUploadedFile, TemporaryUploadedFile from django.utils.module_loading import import_string __all__ = [ "UploadFileException", "StopUpload", "SkipFile", "FileUploadHandler", "TemporaryFileUploadHandler", "MemoryFileUploadHandler", "load_handler", "StopFutureHandlers", ] class UploadFileException(Exception): """ Any error having to do with uploading files. """ pass class StopUpload(UploadFileException): """ This exception is raised when an upload must abort. """ def __init__(self, connection_reset=False): """ If ``connection_reset`` is ``True``, Django knows will halt the upload without consuming the rest of the upload. This will cause the browser to show a "connection reset" error. """ self.connection_reset = connection_reset def __str__(self): if self.connection_reset: return "StopUpload: Halt current upload." else: return "StopUpload: Consume request data, then halt." class SkipFile(UploadFileException): """ This exception is raised by an upload handler that wants to skip a given file. """ pass class StopFutureHandlers(UploadFileException): """ Upload handlers that have handled a file and do not want future handlers to run should raise this exception instead of returning None. """ pass class FileUploadHandler: """ Base class for streaming upload handlers. """ chunk_size = 64 * 2**10 # : The default chunk size is 64 KB. def __init__(self, request=None): self.file_name = None self.content_type = None self.content_length = None self.charset = None self.content_type_extra = None self.request = request def handle_raw_input( self, input_data, META, content_length, boundary, encoding=None ): """ Handle the raw input from the client. Parameters: :input_data: An object that supports reading via .read(). :META: ``request.META``. :content_length: The (integer) value of the Content-Length header from the client. :boundary: The boundary from the Content-Type header. Be sure to prepend two '--'. """ pass def new_file( self, field_name, file_name, content_type, content_length, charset=None, content_type_extra=None, ): """ Signal that a new file has been started. Warning: As with any data from the client, you should not trust content_length (and sometimes won't even get it). """ self.field_name = field_name self.file_name = file_name self.content_type = content_type self.content_length = content_length self.charset = charset self.content_type_extra = content_type_extra def receive_data_chunk(self, raw_data, start): """ Receive data from the streamed upload parser. ``start`` is the position in the file of the chunk. """ raise NotImplementedError( "subclasses of FileUploadHandler must provide a receive_data_chunk() method" ) def file_complete(self, file_size): """ Signal that a file has completed. File size corresponds to the actual size accumulated by all the chunks. Subclasses should return a valid ``UploadedFile`` object. """ raise NotImplementedError( "subclasses of FileUploadHandler must provide a file_complete() method" ) def upload_complete(self): """ Signal that the upload is complete. Subclasses should perform cleanup that is necessary for this handler. """ pass def upload_interrupted(self): """ Signal that the upload was interrupted. Subclasses should perform cleanup that is necessary for this handler. """ pass class TemporaryFileUploadHandler(FileUploadHandler): """ Upload handler that streams data into a temporary file. """ def new_file(self, *args, **kwargs): """ Create the file object to append to as data is coming in. """ super().new_file(*args, **kwargs) self.file = TemporaryUploadedFile( self.file_name, self.content_type, 0, self.charset, self.content_type_extra ) def receive_data_chunk(self, raw_data, start): self.file.write(raw_data) def file_complete(self, file_size): self.file.seek(0) self.file.size = file_size return self.file def upload_interrupted(self): if hasattr(self, "file"): temp_location = self.file.temporary_file_path() try: self.file.close() os.remove(temp_location) except FileNotFoundError: pass class MemoryFileUploadHandler(FileUploadHandler): """ File upload handler to stream uploads into memory (used for small files). """ def handle_raw_input( self, input_data, META, content_length, boundary, encoding=None ): """ Use the content_length to signal whether or not this handler should be used. """ # Check the content-length header to see if we should # If the post is too large, we cannot use the Memory handler. self.activated = content_length <= settings.FILE_UPLOAD_MAX_MEMORY_SIZE def new_file(self, *args, **kwargs): super().new_file(*args, **kwargs) if self.activated: self.file = BytesIO() raise StopFutureHandlers() def receive_data_chunk(self, raw_data, start): """Add the data to the BytesIO file.""" if self.activated: self.file.write(raw_data) else: return raw_data def file_complete(self, file_size): """Return a file object if this handler is activated.""" if not self.activated: return self.file.seek(0) return InMemoryUploadedFile( file=self.file, field_name=self.field_name, name=self.file_name, content_type=self.content_type, size=file_size, charset=self.charset, content_type_extra=self.content_type_extra, ) def load_handler(path, *args, **kwargs): """ Given a path to a handler, return an instance of that handler. E.g.:: >>> from django.http import HttpRequest >>> request = HttpRequest() >>> load_handler( ... 'django.core.files.uploadhandler.TemporaryFileUploadHandler', ... request, ... ) <TemporaryFileUploadHandler object at 0x...> """ return import_string(path)(*args, **kwargs) locks.py 0000644 00000007035 15030003247 0006230 0 ustar 00 """ Portable file locking utilities. Based partially on an example by Jonathan Feignberg in the Python Cookbook [1] (licensed under the Python Software License) and a ctypes port by Anatoly Techtonik for Roundup [2] (license [3]). [1] https://code.activestate.com/recipes/65203/ [2] https://sourceforge.net/p/roundup/code/ci/default/tree/roundup/backends/portalocker.py # NOQA [3] https://sourceforge.net/p/roundup/code/ci/default/tree/COPYING.txt Example Usage:: >>> from django.core.files import locks >>> with open('./file', 'wb') as f: ... locks.lock(f, locks.LOCK_EX) ... f.write('Django') """ import os __all__ = ("LOCK_EX", "LOCK_SH", "LOCK_NB", "lock", "unlock") def _fd(f): """Get a filedescriptor from something which could be a file or an fd.""" return f.fileno() if hasattr(f, "fileno") else f if os.name == "nt": import msvcrt from ctypes import ( POINTER, Structure, Union, WinDLL, byref, c_int64, c_ulong, c_void_p, sizeof, ) from ctypes.wintypes import BOOL, DWORD, HANDLE LOCK_SH = 0 # the default LOCK_NB = 0x1 # LOCKFILE_FAIL_IMMEDIATELY LOCK_EX = 0x2 # LOCKFILE_EXCLUSIVE_LOCK # --- Adapted from the pyserial project --- # detect size of ULONG_PTR if sizeof(c_ulong) != sizeof(c_void_p): ULONG_PTR = c_int64 else: ULONG_PTR = c_ulong PVOID = c_void_p # --- Union inside Structure by stackoverflow:3480240 --- class _OFFSET(Structure): _fields_ = [("Offset", DWORD), ("OffsetHigh", DWORD)] class _OFFSET_UNION(Union): _anonymous_ = ["_offset"] _fields_ = [("_offset", _OFFSET), ("Pointer", PVOID)] class OVERLAPPED(Structure): _anonymous_ = ["_offset_union"] _fields_ = [ ("Internal", ULONG_PTR), ("InternalHigh", ULONG_PTR), ("_offset_union", _OFFSET_UNION), ("hEvent", HANDLE), ] LPOVERLAPPED = POINTER(OVERLAPPED) # --- Define function prototypes for extra safety --- kernel32 = WinDLL("kernel32") LockFileEx = kernel32.LockFileEx LockFileEx.restype = BOOL LockFileEx.argtypes = [HANDLE, DWORD, DWORD, DWORD, DWORD, LPOVERLAPPED] UnlockFileEx = kernel32.UnlockFileEx UnlockFileEx.restype = BOOL UnlockFileEx.argtypes = [HANDLE, DWORD, DWORD, DWORD, LPOVERLAPPED] def lock(f, flags): hfile = msvcrt.get_osfhandle(_fd(f)) overlapped = OVERLAPPED() ret = LockFileEx(hfile, flags, 0, 0, 0xFFFF0000, byref(overlapped)) return bool(ret) def unlock(f): hfile = msvcrt.get_osfhandle(_fd(f)) overlapped = OVERLAPPED() ret = UnlockFileEx(hfile, 0, 0, 0xFFFF0000, byref(overlapped)) return bool(ret) else: try: import fcntl LOCK_SH = fcntl.LOCK_SH # shared lock LOCK_NB = fcntl.LOCK_NB # non-blocking LOCK_EX = fcntl.LOCK_EX except (ImportError, AttributeError): # File locking is not supported. LOCK_EX = LOCK_SH = LOCK_NB = 0 # Dummy functions that don't do anything. def lock(f, flags): # File is not locked return False def unlock(f): # File is unlocked return True else: def lock(f, flags): try: fcntl.flock(_fd(f), flags) return True except BlockingIOError: return False def unlock(f): fcntl.flock(_fd(f), fcntl.LOCK_UN) return True __init__.py 0000644 00000000074 15030003247 0006650 0 ustar 00 from django.core.files.base import File __all__ = ["File"] utils.py 0000644 00000005053 15030003247 0006253 0 ustar 00 import os import pathlib from django.core.exceptions import SuspiciousFileOperation def validate_file_name(name, allow_relative_path=False): # Remove potentially dangerous names if os.path.basename(name) in {"", ".", ".."}: raise SuspiciousFileOperation("Could not derive file name from '%s'" % name) if allow_relative_path: # Ensure that name can be treated as a pure posix path, i.e. Unix # style (with forward slashes). path = pathlib.PurePosixPath(str(name).replace("\\", "/")) if path.is_absolute() or ".." in path.parts: raise SuspiciousFileOperation( "Detected path traversal attempt in '%s'" % name ) elif name != os.path.basename(name): raise SuspiciousFileOperation("File name '%s' includes path elements" % name) return name class FileProxyMixin: """ A mixin class used to forward file methods to an underlaying file object. The internal file object has to be called "file":: class FileProxy(FileProxyMixin): def __init__(self, file): self.file = file """ encoding = property(lambda self: self.file.encoding) fileno = property(lambda self: self.file.fileno) flush = property(lambda self: self.file.flush) isatty = property(lambda self: self.file.isatty) newlines = property(lambda self: self.file.newlines) read = property(lambda self: self.file.read) readinto = property(lambda self: self.file.readinto) readline = property(lambda self: self.file.readline) readlines = property(lambda self: self.file.readlines) seek = property(lambda self: self.file.seek) tell = property(lambda self: self.file.tell) truncate = property(lambda self: self.file.truncate) write = property(lambda self: self.file.write) writelines = property(lambda self: self.file.writelines) @property def closed(self): return not self.file or self.file.closed def readable(self): if self.closed: return False if hasattr(self.file, "readable"): return self.file.readable() return True def writable(self): if self.closed: return False if hasattr(self.file, "writable"): return self.file.writable() return "w" in getattr(self.file, "mode", "") def seekable(self): if self.closed: return False if hasattr(self.file, "seekable"): return self.file.seekable() return True def __iter__(self): return iter(self.file)
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings