U xʹj'@sddlZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZGd d d ZGd d d eZdS) N)md5LocalFileSystem)AbstractCopyTests)AbstractGetTests)AbstractOpenTests)AbstractPipeTests)AbstractPutTestsc@seZdZdZejddZejddZejddZejdd Z ejd d Z ejd d Z ejddZ ejddZ ejddZejddZddZddZddZddZdS)BaseAbstractFixturesz Abstract base class containing fixtures that are used by but never need to be overridden in derived filesystem-specific classes to run the abstract tests on such filesystems. ccs&||||}|V|j|dddS)z Scenario on remote filesystem that is used for many cp/get/put tests. Cleans up at the end of each test it which it is used. T recursiveN_bulk_operations_scenario_0rmselffsfs_joinfs_pathsourcer]/var/www/html/bwave/python/venv/lib/python3.8/site-packages/fsspec/tests/abstract/__init__.pyfs_bulk_operations_scenario_0sz2BaseAbstractFixtures.fs_bulk_operations_scenario_0ccs&||||}|V|j|dddS)z Scenario on remote filesystem that is used for glob edge cases cp/get/put tests. Cleans up at the end of each test it which it is used. Tr N_glob_edge_cases_filesrrrrrfs_glob_edge_cases_files sz-BaseAbstractFixtures.fs_glob_edge_cases_filesccs&||||}|V|j|dddS)z Scenario on remote filesystem that is used to check cp/get/put on directory and file with the same name prefixes. Cleans up at the end of each test it which it is used. Tr N#_dir_and_file_with_same_name_prefixrrrrr%fs_dir_and_file_with_same_name_prefix+sz:BaseAbstractFixtures.fs_dir_and_file_with_same_name_prefixccs&||||}|V|j|dddS)z Scenario on remote filesystem that is used to check cp/get/put files order when source and destination are lists. Cleans up at the end of each test it which it is used. Tr N_10_files_with_hashed_namesrrrrrfs_10_files_with_hashed_names7sz2BaseAbstractFixtures.fs_10_files_with_hashed_namesccs,||d}|V||r(|j|dddS)z Return name of remote directory that does not yet exist to copy into. Cleans up at the end of each test it which it is used. targetTr Nexistsr)rrrrr"rrr fs_targetCs  zBaseAbstractFixtures.fs_targetccs&||||}|V|j|dddS)z Scenario on local filesystem that is used for many cp/get/put tests. Cleans up at the end of each test it which it is used. Tr Nr rlocal_fs local_join local_pathrrrr local_bulk_operations_scenario_0Osz5BaseAbstractFixtures.local_bulk_operations_scenario_0ccs&||||}|V|j|dddS)z Scenario on local filesystem that is used for glob edge cases cp/get/put tests. Cleans up at the end of each test it which it is used. Tr Nrr&rrrlocal_glob_edge_cases_filesZsz0BaseAbstractFixtures.local_glob_edge_cases_filesccs&||||}|V|j|dddS)z Scenario on local filesystem that is used to check cp/get/put on directory and file with the same name prefixes. Cleans up at the end of each test it which it is used. Tr Nrr&rrr(local_dir_and_file_with_same_name_prefixes z=BaseAbstractFixtures.local_dir_and_file_with_same_name_prefixccs&||||}|V|j|dddS)z Scenario on local filesystem that is used to check cp/get/put files order when source and destination are lists. Cleans up at the end of each test it which it is used. Tr Nrr&rrr local_10_files_with_hashed_namesusz5BaseAbstractFixtures.local_10_files_with_hashed_namesccs,||d}|V||r(|j|dddS)z Return name of local directory that does not yet exist to copy into. Cleans up at the end of each test it which it is used. r"Tr Nr#)rr'r(r)r"rrr local_targets  z!BaseAbstractFixtures.local_targetcCs||d}|||d|||dtdD]X}||d|}||d}|||||d|||d|||d q2|S) uL Scenario that is used for glob edge cases cp/get/put tests. Creates the following directory and file structure: 📁 source ├── 📄 file1 ├── 📄 file2 ├── 📁 subdir0 │ ├── 📄 subfile1 │ ├── 📄 subfile2 │ └── 📁 nesteddir │ └── 📄 nestedfile └── 📁 subdir1 ├── 📄 subfile1 ├── 📄 subfile2 └── 📁 nesteddir └── 📄 nestedfile rfile1file2subdir nesteddirsubfile1subfile2 nestedfile)touchrangemakedirs)rsome_fs some_join some_pathrZ subdir_idxr2r3rrrrs    z+BaseAbstractFixtures._glob_edge_cases_filescCs|||d}||d}||d}|||||d|||d|||d|||d|||d|S) u Scenario that is used for many cp/get/put tests. Creates the following directory and file structure: 📁 source ├── 📄 file1 ├── 📄 file2 └── 📁 subdir ├── 📄 subfile1 ├── 📄 subfile2 └── 📁 nesteddir └── 📄 nestedfile rr2r3r/r0r4r5r6r9r7)rr:r;r<rr2r3rrrrs    z0BaseAbstractFixtures._bulk_operations_scenario_0cCsJ||d}||d}||d}||d}|||||||S)u& Scenario that is used to check cp/get/put on directory and file with the same name prefixes. Creates the following directory and file structure: 📁 source ├── 📄 subdir.txt └── 📁 subdir └── 📄 subfile.txt rr2z subdir.txtz subfile.txtr=)rr:r;r<rr2fileZsubfilerrrrs       z8BaseAbstractFixtures._dir_and_file_with_same_name_prefixcCsV||d}tdD]>}tt|d}|||d}|j||dq|S)u Scenario that is used to check cp/get/put files order when source and destination are lists. Creates the following directory and file structure: 📁 source └── 📄 {hashed([0-9])}.txt r zutf-8z.txt)pathvalue)r8rstrencode hexdigestpipe)rr:r;r<riZhashed_ir@rrrr s   z0BaseAbstractFixtures._10_files_with_hashed_namesN)__name__ __module__ __qualname____doc__pytestfixturerrrr!r%r*r+r,r-r.rrrr rrrrr s2          !r c@seZdZdZejddZejddZejddZejdd d d Z ejd d Z ejddZ ejddZ ejddZ dS)AbstractFixturesa} Abstract base class containing fixtures that may be overridden in derived filesystem-specific classes to run the abstract tests on such filesystems. For any particular filesystem some of these fixtures must be overridden, such as ``fs`` and ``fs_path``, and others may be overridden if the default functions here are not appropriate, such as ``fs_join``. cCs tddSNz3This function must be overridden in derived classesNotImplementedErrorrrrrrszAbstractFixtures.fscCstjjS)z Return a function that joins its arguments together into a path. Most fsspec implementations join paths in a platform-dependent way, but some will override this to always use a forward slash. osr@joinrQrrrrszAbstractFixtures.fs_joincCs tddSrNrOrQrrrrszAbstractFixtures.fs_pathclass)scopecCs tddS)NT)Z auto_mkdirrrQrrrr'szAbstractFixtures.local_fscCstjjS)zs Return a function that joins its arguments together into a path, on the local filesystem. rRrQrrrr( szAbstractFixtures.local_joincCs|SNr)rZtmpdirrrrr)szAbstractFixtures.local_pathcCsdS)zP Return whether this implementation supports empty directories. TrrQrrrsupports_empty_directoriessz+AbstractFixtures.supports_empty_directoriescCsddS)NcSs|SrWr)xrrr!z3AbstractFixtures.fs_sanitize_path..rrQrrrfs_sanitize_pathsz!AbstractFixtures.fs_sanitize_pathN)rGrHrIrJrKrLrrrr'r(r)rXr\rrrrrMs"         rM)rShashlibrrKZfsspec.implementations.localrZfsspec.tests.abstract.copyrZfsspec.tests.abstract.getrZfsspec.tests.abstract.openrZfsspec.tests.abstract.piperZfsspec.tests.abstract.putr r rMrrrrs       ]