a ތxd3@sddlZddlmZmZddlmZddlmZddlmZm Z m Z m Z m Z ddl mZddlmZddlmZdd lmZdd lmZdd lmZdd lmZmZmZmZeGd ddeZddZddZ dZ!eGdddeZ"dS)N)datetime timedelta)SpooledTemporaryFile)ResourceNotFoundError) BlobClientBlobSasPermissionsBlobServiceClientContentSettingsgenerate_blob_sas)SuspiciousOperation)File)timezone)deconstructible) force_bytes) BaseStorage) clean_nameget_available_overwrite_name safe_joinsettingcsReZdZddZddZddZeeeZfddZfd d Z d d Z Z S) AzureStorageFilecCs.||_||_||_d|_d|_|||_dS)NF)name_mode_storage _is_dirty_file_get_valid_path_path)selfrmodeZstoragerW/var/www/html/Ranjet/env/lib/python3.9/site-packages/storages/backends/azure_storage.py__init__s zAzureStorageFile.__init__cCs|jdur|jSt|jjdtddd}d|jvsz |jjWStyYn0z|jWSty8Yn0dSr0)r. content_typer3)r=rrr _content_typeSs   rGcCsL|d}t|tkr"tdtt|s2td|ddkrHtd|S)Nz./zFile name max len is %dz7File name must contain one or more printable characters/z0File name must not contain more than 256 slashes)striplen_AZURE_NAME_MAX_LEN ValueErrorcount)srrr r_s  ricseZdZfddZddZddZeddZed d Zd d Z ed dZ ddZ ddZ d4ddZ effdd ZddZddZddZddZd d!Zd5d#d$Zd6d%d&Zd'd(Zd)d*Zd+d,Zd7d.d/Zd8d0d1Zd2d3ZZS)9 AzureStoragec s2tjfi|d|_d|_d|_t|_dSr0)r4r!_service_client_client_user_delegation_keyrutcnow_user_delegation_key_expiry)rsettingsr8rr r!zs zAzureStorage.__init__cCsvtdtdtditdtddtddtd d td d td tddtdddtdtdtdtdtddS)NZAZURE_ACCOUNT_NAMEZAZURE_ACCOUNT_KEYZAZURE_OBJECT_PARAMETERSZAZURE_CONTAINERZ AZURE_SSLTZAZURE_UPLOAD_MAX_CONNZAZURE_CONNECTION_TIMEOUT_SECSZAZURE_BLOB_MAX_MEMORY_SIZEi ZAZURE_URL_EXPIRATION_SECSZAZURE_OVERWRITE_FILESFZAZURE_LOCATIONzapplication/octet-streamZAZURE_CACHE_CONTROLZAZURE_SAS_TOKENZAZURE_CUSTOM_DOMAINZAZURE_CONNECTION_STRINGZAZURE_TOKEN_CREDENTIAL) account_name account_keyobject_parametersazure_container azure_sslupload_max_connr(r+expiration_secsoverwrite_fileslocationdefault_content_type cache_control sas_token custom_domainconnection_stringtoken_credential)rr@rrr get_default_settingss$z!AzureStorage.get_default_settingscCsj|jdurt|jS|jpd}d|j|j|}d}|jrD|j}n|jrR|j}n |j r^|j }t||dS)Nzblob.core.windows.netz {}://{}.{} credential) rgrZfrom_connection_stringrfformatazure_protocolrZr[rerh)rZaccount_domainZ account_urlrkrrr _get_service_clients    z AzureStorage._get_service_clientcCs|jdur||_|jSr0)rQrnr@rrr service_clients  zAzureStorage.service_clientcCs |jdur|j|j|_|jSr0)rRroZget_container_clientr]r@rrr r,s  zAzureStorage.clientcCsV|jdurdS|jdus"||jkrPt}|tdd}|jj||d|_||_|jS)N)days)Zkey_start_timekey_expiry_time)rhrSrUrrTrroget_user_delegation_key)rexpirynowrrrrr rss z$AzureStorage.get_user_delegation_keycCs|jr dSdSdS)Nhttpshttp)r^r@rrr rmszAzureStorage.azure_protocolcCs2zt|j|WSty,td|Yn0dS)Nz Attempted access to '%s' denied.)rrbrMr rrrrr _normalize_names zAzureStorage._normalize_namecCst|t|Sr0)rryrrxrrr rs zAzureStorage._get_valid_pathrbcCs t|||Sr0)r)rrrrrr _openszAzureStorage._opencs&t|}|jrt||St||S)z Returns a filename that's free on the target storage system, and available for new content to be written to. )rrarr4get_available_name)rr max_lengthr8rr r|s zAzureStorage.get_available_namecCs:|j||}z|WdSty4YdS0dS)NTF)r,get_blob_clientrget_blob_propertiesr)rr blob_clientrrr existss  zAzureStorage.existscCs4z|jj|||jdWnty.Yn0dSNr')r,Z delete_blobrr(rrxrrr deletes  zAzureStorage.deletecCs&|j||}|j|jd}|jSr)r,r~rrr(size)rrr propertiesrrr rszAzureStorage.sizecCsdt|}||}|||}t|tr.|j}|d|jj||t fi||j |j |j d|S)Nr)Zcontent_settingsr*r( overwrite) rr _get_content_settings_parameters isinstancer r.r-r,Z upload_blobr r_r(ra)rrr=Z cleaned_nameparamsrrr r>s     zAzureStorage._savecCstt|dS)N)seconds)rrTr)rexpirerrr _expire_atszAzureStorage._expire_atNc Csx||}|dur|j}d}|rZ||}||}t|j|j||j|tdd|d}|}|j |j }t j ||dj S)NT)r5)r[user_delegation_keyZ permissionrtrj)rr`rrsr rZr]r[rr,r~urlrZ from_blob_url)rrrrkrtrreZcontainer_blob_urlrrr rs&   zAzureStorage.urlcCsRi}t|\}}t|p"|p"|j}|j|d<||d<||d<||||S)NrdrFcontent_encoding) mimetypes guess_typerGrcrdupdateget_object_parameters)rrr=rZ guessed_typerrFrrr r-s z-AzureStorage._get_content_settings_parameterscCs |jS)z Returns a dictionary that is passed to content settings. Override this method to adjust this on a per-object basis to set e.g ContentDisposition. By default, returns the value of AZURE_OBJECT_PARAMETERS. )r\copyrxrrr r=sz"AzureStorage.get_object_parameterscCs\|jj|||jd}tdds.t|jSt}t |jrPt |j|S|j |S)z Returns an (aware) datetime object containing the last modified time if USE_TZ is True, otherwise returns a naive datetime in the local timezone. r'ZUSE_TZF) r,rrr(rr make_naiveZ last_modifiedZget_current_timezoneis_naiveZ make_aware astimezone)rrrtzrrr get_modified_timeFs   zAzureStorage.get_modified_timecCs"||}t|r|St|S)zBReturns a naive datetime object containing the last modified time.)rr rr)rrmtimerrr modified_timeYs  zAzureStorage.modified_timerYcCs@|r||}|r$|ds$|d7}dd|jj||jdDS)z!Return all files for a given pathrHcSsg|] }|jqSr)r).0Zblobrrr gsz)AzureStorage.list_all..)Zname_starts_withr()rendswithr,Z list_blobsr()rpathrrr list_all`s zAzureStorage.list_allcCs`g}t}||D]>}|t|d}d|vrH||dddq||qt||fS)z Return directories and files for a given path. Leave the path empty to list the root. Order of dirs and files is undefined. NrHr)r)setrrKaddsplitappendlist)rrfilesdirsrnrrr listdirms zAzureStorage.listdircCs0tt|dtd}|js,|td8}|S)NZfooZ_1234567)rLrKrra)rmax_lenrrr get_name_max_len}s zAzureStorage.get_name_max_len)rz)N)N)rY)rY)rArBrCr!rirnrDror,rsrmryrr{rLr|rrrr>rrrrrrrrrrErrr8r rPxs6          rP)#rrrtempfilerZazure.core.exceptionsrZazure.storage.blobrrrr r Zdjango.core.exceptionsr Zdjango.core.files.baser Z django.utilsr Zdjango.utils.deconstructrZdjango.utils.encodingrZ storages.baserZstorages.utilsrrrrrrGrrLrPrrrr s$        <