]jd4ddlZddlmZmZddlmZddlmZddlmZm Z m Z m Z m Z ddl mZddlmZddlmZdd lmZdd lmZdd lmZdd lmZmZmZmZeGd deZdZdZ dZ!eGddeZ"y)N)datetime timedelta)SpooledTemporaryFile)ResourceNotFoundError) BlobClientBlobSasPermissionsBlobServiceClientContentSettingsgenerate_blob_sas)SuspiciousOperation)File)timezone)deconstructible) force_bytes) BaseStorage) clean_nameget_available_overwrite_name safe_joinsettingcReZdZdZdZdZeeeZfdZfdZ dZ xZ S)AzureStorageFilecv||_||_||_d|_d|_|j ||_y)NF)name_mode_storage _is_dirty_file_get_valid_path_path)selfrmodestorages I/root/env/lib/python3.12/site-packages/storages/backends/azure_storage.py__init__zAzureStorageFile.__init__s7    ,,T2 c|j |jSt|jjdt dd}d|j vsd|j vrX|jj j|j|jj}|j|dd|j vr|jd ||_|jS) Nz.AzureStorageFileFILE_UPLOAD_TEMP_DIR)max_sizesuffixdirratimeout)max_concurrencyr) rrrmax_memory_sizerrclient download_blobrr.download_to_streamseek)r filedownload_streams r# _get_filezAzureStorageFile._get_file!s :: !:: #]]22&.57 $** tzz 1#mm22@@ DMM$9$9A;O  . .tQ . G $**  IIaL zzr%c||_yN)r)r values r# _set_filezAzureStorageFile._set_file6s  r%cpd|jvrd|jvr tdt| |i|S)Nr+r,z!File was not opened in read mode.)rAttributeErrorsuperread)r argskwargs __class__s r#r@zAzureStorageFile.read;s: djj S %: !DE Ew|T,V,,r%cd|jvr'd|jvrd|jvr tdd|_t|t |S)Nw+r,z"File was not opened in write mode.T)rr>rr?writer)r contentrCs r#rGzAzureStorageFile.write@sN tzz !4::%4::% !EF Fw}[122r%c|jy|jrR|jjd|jj |j |jd|_|jj d|_y)NrF)rrr5r_savercloser s r#rKzAzureStorageFile.closeHs` ::   >> JJOOA  MM   4:: 6"DN  r%) __name__ __module__ __qualname__r$r8r<propertyr6r@rGrK __classcell__rCs@r#rrs/3* Iy )D- 3r%rc |jjS#t$rYnwxYw |jS#t$rYywxYwr:)r6 content_typer>)rHs r# _content_typerUSsO ||(((     ###    s $$ 4 AAc|jd}t|tkDrtdtzt|s td|j ddkDr td|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)ss r#rr_sx  A 1v## %(; ;= = q6 #$ $ wws|c $% % Hr%iceZdZfdZdZdZedZedZdZ edZ dZ d Z dd Z effd Zd Zd ZdZdZdZddZddZdZdZdZddZddZdZxZS) AzureStoragec t|di|d|_d|_d|_t j |_y)N)r?r$_service_client_client_user_delegation_keyrutcnow_user_delegation_key_expiry)r settingsrCs r#r$zAzureStorage.__init__zs9 $8$# $(!+3??+<(r%cidtddtddtdidtdd td d d td ddtdddtdddtddtdddtdddddtd d!td"d#td$d%td&d'td(S))N account_nameAZURE_ACCOUNT_NAME account_keyAZURE_ACCOUNT_KEYobject_parametersAZURE_OBJECT_PARAMETERSazure_containerAZURE_CONTAINER azure_ssl AZURE_SSLTupload_max_connAZURE_UPLOAD_MAX_CONNr.AZURE_CONNECTION_TIMEOUT_SECSr1AZURE_BLOB_MAX_MEMORY_SIZEi expiration_secsAZURE_URL_EXPIRATION_SECSoverwrite_filesAZURE_OVERWRITE_FILESFlocationAZURE_LOCATIONdefault_content_typezapplication/octet-stream cache_controlAZURE_CACHE_CONTROL sas_tokenAZURE_SAS_TOKEN custom_domainAZURE_CUSTOM_DOMAINconnection_stringAZURE_CONNECTION_STRINGtoken_credentialAZURE_TOKEN_CREDENTIAL)rrLs r#get_default_settingsz!AzureStorage.get_default_settingssB G$89 7#67  )BB!G  w'89  d3  w'>B   w>C  w'C[Q  w'BC  w'>F   0"5  #$>  W%:;  !23  W%:; )B!C! " (@ A#  r%c|jtj|jS|jxsdj |j }dj |j |}d}|jr|j |jd}n1|jr |j}n|jr |j}t||S)Nz{}.blob.core.windows.netz{}://{})rjrl credential) rr from_connection_stringrformatrjazure_protocolrlrr)r account_domain account_urlrs r#_get_service_clientz AzureStorage._get_service_clients  ! ! -$;;D>r%cf t|j|S#t$rtd|zwxYw)Nz Attempted access to '%s' denied.)rr~r\r r rs r#_normalize_namezAzureStorage._normalize_names; QT]]D1 1 Q%&H4&OP P Qs0cHt|jt|Sr:)rrrrs r#rzAzureStorage._get_valid_paths%  4  "# #r%ct|||Sr:)r)r rr!s r#_openzAzureStorage._opensdD11r%cjt|}|jr t||St|||S)z Returns a filename that's free on the target storage system, and available for new content to be written to. )rr|rr?get_available_name)r r max_lengthrCs r#rzAzureStorage.get_available_names7 $   /jA Aw)$ ;;r%c|jj|j|} |jy#t$rYywxYw)NTF)r2get_blob_clientrget_blob_propertiesr)r r blob_clients r#existszAzureStorage.existssGkk11$2F2Ft2LM    + + -$  s= A A c |jj|j||jy#t$rYywxYwNr-)r2 delete_blobrr.rrs r#deletezAzureStorage.deletesG  KK # #$$T*  $ &%   s69 AAc|jj|j|}|j|j}|j Sr)r2rrrr.size)r rr propertiess r#rzAzureStorage.sizesBkk11$2F2Ft2LM  44T\\4J r%c Lt|}|j|}|j||}t|tr |j }|j d|jj||tdi||j|j|j|S)Nr)content_settingsr0r. overwriterb) rr _get_content_settings_parameters isinstancer r6r5r2 upload_blobr rtr.r|)r rrH cleaned_nameparamss r#rJzAzureStorage._saves!$' ##D)66tWE gt $llG Q   ,6v6 00LL**  ,r%cDtjt|zS)N)seconds)rrfr)r expires r# _expire_atzAzureStorage._expire_ats 9V#<<))F __V,F"&">">v"F )!!$$ !,,$7-48  I#J![[88>BB''(:zRVVVr%ci}tj|\}}t|xs|xs |j}|j|d<||d<||d<|j |j ||S)NrrTcontent_encoding) mimetypes guess_typerUrrupdateget_object_parameters)r rrHr guessed_typerrTs r#rz-AzureStorage._get_content_settings_parameters4s)2)=)=d)C& & ' " &  &  % %  #'"4"4!-~%5!" d0067 r%c6|jjS)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. )rncopyrs r#rz"AzureStorage.get_object_parametersDs%%**,,r%c|jj|j||j}t ddst j |jSt j}t j|jr t j|j|S|jj|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-USE_TZF) r2rrr.rr make_naive last_modifiedget_current_timezoneis_naive make_aware astimezone)r rrtzs r#get_modified_timezAzureStorage.get_modified_timeMs [[44   &LL5" x'&&z'?'?@ @  * * ,   Z55 6&&z'?'?D D''22266r%c||j|}tj|r|Stj|S)zBReturns a naive datetime object containing the last modified time.)rrrr)r rmtimes r# modified_timezAzureStorage.modified_time`s6&&t,   U #L""5))r%c|r|j|}|r|jds|dz }|jj||jDcgc]}|j c}Scc}w)z!Return all files for a given pathrW)name_starts_withr.)rendswithr2 list_blobsr.r)r pathblobs r#list_allzAzureStorage.list_allgsp ''-D  c* CKD ..!% /&' II' ''sA+cg}t}|j|D]J}|t|d}d|vr%|j|j ddd:|j |Lt ||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. NrWr/r)setrrZaddsplitappendlist)r rfilesdirsrns r#listdirzAzureStorage.listdirtsv uMM$' DSYZ Aaxa+, Q  Dz5  r%ctt|jdz tdz }|js|tdz}|S)Nfoo_1234567)r[rZrr|)r max_lens r#get_name_max_lenzAzureStorage.get_name_max_lensA%D,@,@,G(HH3u:U## s: &Gr%)rb)NNr:)r)rMrNrOr$rrrPrr2rrrrrr[rrrrrJrrrrrrrrrrQrRs@r#r`r`xs= *E*$$ )* Q # 23F< &=W4 -7&* '! r%r`)#rrrtempfilerazure.core.exceptionsrazure.storage.blobrrr r r django.core.exceptionsr django.core.files.baser django.utilsrdjango.utils.deconstructrdjango.utils.encodingr storages.baserstorages.utilsrrrrrrUrr[r`rbr%r#rs()77'!4-% 9t99x  ,O;OOr%