䚾jZddlZddlZddlZddlmZddlZddlmZddlm Z m Z m Z m Z m Z mZmZmZddlmZmZmZddlmZddlmZed e Zd ed e fd ZGddej8e eZy)N)Path)TemporaryDirectory)ClassVarGenericCallableIterableOptionalTupleTypeVarUnion)CloudImplementation CloudPathimplementation_registry) FileCacheMode)InvalidConfigurationExceptionBoundedCloudPath)boundkeyreturnc,dtdtffd }|S)Nclsrct|ts td|t_t_t|_|S)Nz,Only subclasses of Client can be registered.) issubclassClient TypeErrorr _client_classname _cloud_meta)rrs ]/home/spazio/kingdom_calls/work5/transenv/lib/python3.12/site-packages/cloudpathlib/client.py decoratorz(register_client_class..decoratorsF#v&JK K58$2,/$)1#6 )type)rr!s` r register_client_classr$st r"c eZdZUeed<dZeeded<ddejfdee e e fdee e e jfdeefdZd!d Zed"d Zd!d Zd e e efde d efdZdZej2d ede e e jfd efdZej2d ed efdZej2d eded eeeeffdZ ej2 d#dededed efdZ!ej2d#deded dfdZ"ej2de e e jfd ed efdZ#ej2d ed e fdZ$ej2 d$d ede%d e fd Z&y)%rrNClient[BoundedCloudPath]_default_clientfile_cache_modelocal_cache_dircontent_type_methodcfd|_d|_|jjt |t r t |}|t j}|'tjjdd}|dk(rd}|r|t j}|t jk(r|tdt jd|7t|_|jj}|t j}t!||_||_|t j}||_y)NCLOUDPATHLIB_LOCAL_CACHE_DIRzIf you use the 'zP' cache mode, you must pass a `local_cache_dir` when you instantiate the client.)r(_cache_tmp_dirrvalidate_completeness isinstancestrrfrom_environmentosenvironget persistentrrrtmp_dirr_local_cache_dirr*)selfr(r)r*s r __init__zClient.__init__ s0 $" ..0 os ++OO  " jjnn-KTRO"$"& 6+66O m66 6?;R/"=#;#;"<=MN   ""4"6D "1166O&"/"7"7 $_ 5#6   "+33O.r"rct|ddtjtjtjfvrF|j |j jr|j jyyy)Nr() getattrrr7 close_filecloudpath_object clear_cacher8existsrmdirr9s r __del__zClient.__del__Tsr 4*D 1  ! !  $ $  * *6     $$++-%%++-. r"cJ|j ||_|jS)zGet the default client, which the one that is used when instantiating a cloud path instance for this cloud without a client specified. )r')rs r get_default_clientzClient.get_default_clientas&    &"%%C """r"c&||j_y)zSet this client instance as the default one used when instantiating cloud path instances for this cloud without a client specified.N) __class__r'rBs r set_as_default_clientzClient.set_as_default_clientjs*.&r" cloud_pathpartscB|jj|g|d|iS)Nclient)r path_class)r9rIrJs r rzClient.CloudPathos%*t**:KKdKKr"c|jjrV|jjD]8}|jr|j $t j |:yy)zqClears the contents of the cache folder. Does not remove folder so it can keep being written to. N)r8r@iterdiris_fileunlinkshutilrmtree)r9ps r r?zClient.clear_cachersW  ' ' )**224 %99;HHJMM!$  % *r" local_pathcyN)r9rIrUs r _download_filezClient._download_file} r"cyrWrXr9rIs r _existszClient._exists r" recursivecy)aList all the files and folders in a directory. Parameters ---------- cloud_path : CloudPath The folder to start from. recursive : bool Whether or not to list recursively. Returns ------- contents : Iterable[Tuple] Of the form [(CloudPath, is_dir), ...] for every child of the dir. NrX)r9rIr_s r _list_dirzClient._list_dirs$ r"srcdst remove_srccyrWrX)r9rbrcrds r _move_filezClient._move_filerZr"path missing_okcy)zRemove a file or folder from the server. Parameters ---------- path : CloudPath The file or folder to remove. NrX)r9rgrhs r _removezClient._removes r"cyrWrX)r9rUrIs r _upload_filezClient._upload_filerZr"cyrWrXr\s r _get_public_urlzClient._get_public_urlr^r"expire_secondscyrWrX)r9rIros r _generate_presigned_urlzClient._generate_presigned_urlrZr")rN)rr&)T)i)'__name__ __module__ __qualname__r__annotations__r'rr mimetypes guess_typer r1rr3PathLikerr:rC classmethodrErHrrr?abcabstractmethodrrYboolr]rr rarfrjrlrnintrqrXr"r rrs|$$FJOXh'ABCJ@D=A2;2F2F 2/!%](:";<2/"%R[[(8"9:2/&h/ 2/h .##. LE#/?*?$@L#LRbL %  * 8=c2;;>N8O     "2 t    * 7; %($./ 0  & OS # *: HL     , $ $    R[[ 01 ?O     *: s   BI * rsg   'YYYNN 5-Y? s x ^ SWWg./^ r"