g'ddlZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZGd d ZGd d eZy) N)md5LocalFileSystem)AbstractCopyTests)AbstractGetTests)AbstractOpenTests)AbstractPipeTests)AbstractPutTestsceZdZdZej dZej dZej dZej dZ ej dZ ej dZ ej dZ ej d Z ej d Zej d Zd Zd ZdZdZy)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. c#`K|j|||}||j|dyw)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_pathsources S/var/www/openai/venv/lib/python3.12/site-packages/fsspec/tests/abstract/__init__.pyfs_bulk_operations_scenario_0z2BaseAbstractFixtures.fs_bulk_operations_scenario_0s111"gwG  f%,.c#`K|j|||}||j|dyw)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. TrN_glob_edge_cases_filesrrs rfs_glob_edge_cases_filesz-BaseAbstractFixtures.fs_glob_edge_cases_files s1,,R'B  f%rc#`K|j|||}||j|dyw)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. TrN#_dir_and_file_with_same_name_prefixrrs r%fs_dir_and_file_with_same_name_prefixz:BaseAbstractFixtures.fs_dir_and_file_with_same_name_prefix+s199"gwO  f%rc#`K|j|||}||j|dyw)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. TrN_10_files_with_hashed_namesrrs rfs_10_files_with_hashed_namesz2BaseAbstractFixtures.fs_10_files_with_hashed_names7s111"gwG  f%rc#pK||d}||j|r|j|dyyw)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. targetTrNexistsr)rrrrr)s r fs_targetzBaseAbstractFixtures.fs_targetCs:(+ 99V  EE&DE ) 46c#`K|j|||}||j|dyw)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. TrNrrlocal_fs local_join local_pathrs r local_bulk_operations_scenario_0z5BaseAbstractFixtures.local_bulk_operations_scenario_0Os111(J S  Fd +rc#`K|j|||}||j|dyw)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. TrNrr/s rlocal_glob_edge_cases_filesz0BaseAbstractFixtures.local_glob_edge_cases_filesZs1,,Xz:N  Fd +rc#`K|j|||}||j|dyw)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. TrNr!r/s r(local_dir_and_file_with_same_name_prefixz=BaseAbstractFixtures.local_dir_and_file_with_same_name_prefixes699 j*   Fd +rc#`K|j|||}||j|dyw)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. TrNr%r/s r local_10_files_with_hashed_namesz5BaseAbstractFixtures.local_10_files_with_hashed_namesus111(J S  Fd +rc#pK||d}||j|r|j|dyyw)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)TrNr*)rr0r1r2r)s r local_targetz!BaseAbstractFixtures.local_targets:J1 ??6 " KK$K / #r-ct||d}|j||d|j||dtdD]p}||d|}||d}|j||j||d|j||d|j||d r|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_pathr subdir_idxr@rAs rrz+BaseAbstractFixtures._glob_edge_cases_filess&9h/ i01 i01(Jv |'<=F!&+6I   Y ' MM)FJ7 8 MM)FJ7 8 MM)I|< = # cN||d}||d}||d}|j||j||d|j||d|j||d|j||d|j||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 rr@rAr=r>rBrCrDrGrE)rrHrIrJrr@rAs rrz0BaseAbstractFixtures._bulk_operations_scenario_0s9h/68,fk2 # i01 i01 i 34 i 34 i <89 rLc||d}||d}||d}||d}|j||j||j||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 rr@z subdir.txtz subfile.txtrN)rrHrIrJrr@filesubfiles rr"z8BaseAbstractFixtures._dir_and_file_with_same_name_prefixs_9h/68,.FM2  d g rLc||d}tdD]a}tt|jdj }|||d}|j ||jc|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)rFrstrencode hexdigestpipe)rrHrIrJrihashed_irTs rr&z0BaseAbstractFixtures._10_files_with_hashed_namessp9h/rA3q6==12<<>HVz%67D LLdQC--/L : rLN)__name__ __module__ __qualname____doc__pytestfixturerrr#r'r,r3r5r7r9r;rrr"r&rLrr r s   ^^&& ^^&& ^^ & & ^^ & & ^^ * * ^^,, ^^,, ^^ , , ^^ , , ^^ 0 0B2& rLr c>eZdZdZej dZej dZej dZej ddZ ej dZ ej d Z ej d Z ej d Z y ) 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``. ctdNz3This function must be overridden in derived classesNotImplementedErrorrs rrzAbstractFixtures.fs!"WXXrLc6tjjS)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. osrTjoinris rrzAbstractFixtures.fs_joinsww||rLctdrfrgris rrzAbstractFixtures.fs_pathrjrLclass)scopectdS)NT) auto_mkdirrris rr0zAbstractFixtures.local_fss$//rLc6tjjS)zs Return a function that joins its arguments together into a path, on the local filesystem. rlris rr1zAbstractFixtures.local_join s ww||rLc|SNrb)rtmpdirs rr2zAbstractFixtures.local_paths rLcy)zP Return whether this implementation supports empty directories. Trbris rsupports_empty_directoriesz+AbstractFixtures.supports_empty_directoriess rLcdS)Nc|Srvrb)xs rz3AbstractFixtures.fs_sanitize_path..!srLrbris rfs_sanitize_pathz!AbstractFixtures.fs_sanitize_pathsrLN)r\r]r^r_r`rarrrr0r1r2ryr~rbrLrrdrds ^^YY ^^ ^^YYV^^'"0#0  ^^ ^^ ^^  ^^rLrd)rmhashlibrr`fsspec.implementations.localrfsspec.tests.abstract.copyrfsspec.tests.abstract.getrfsspec.tests.abstract.openrfsspec.tests.abstract.piper fsspec.tests.abstract.putr r rdrbrLrrs:  886886YYx7+7rL