gi'ddlZddlmZddlZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZGd d ZGd d eZdS) N)md5LocalFileSystem)AbstractCopyTests)AbstractGetTests)AbstractOpenTests)AbstractPipeTests)AbstractPutTestscjeZdZdZejdZejdZejdZejdZ ejdZ ejdZ ejdZ ejd Z ejd Zejd Zd Zd ZdZdZdS)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#nK||||}|V||ddS)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 v/var/www/development/aibuddy-work/election-extract/venv/lib/python3.11/site-packages/fsspec/tests/abstract/__init__.pyfs_bulk_operations_scenario_0z2BaseAbstractFixtures.fs_bulk_operations_scenario_0sD11"gwGG  f%%%%%c#nK||||}|V||ddS)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 sD,,R'BB  f%%%%%rc#nK||||}|V||ddS)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+sD99"gwOO  f%%%%%rc#nK||||}|V||ddS)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_names7sD11"gwGG  f%%%%%rc#K||d}|V||r||ddSdS)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 ) ) ) ) ) * *rc#nK||||}|V||ddS)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_0OsD11(J SS  Fd +++++rc#nK||||}|V||ddS)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_filesZsD,,Xz:NN  Fd +++++rc#nK||||}|V||ddS)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_prefixesK99 j*    Fd +++++rc#nK||||}|V||ddS)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_namesusD11(J SS  Fd +++++rc#K||d}|V||r||ddSdS)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*)rr/r0r1r)s r local_targetz!BaseAbstractFixtures.local_targets\J11 ??6 " " 0 KK$K / / / / / 0 0rc||d}|||d|||dtdD]}||d|}||d}|||||d|||d|||d |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?r@s rrz+BaseAbstractFixtures._glob_edge_cases_filess&9h// ii00111 ii00111(( > >JYv'< '<'<==F! &+66I   Y ' ' ' MM))FJ77 8 8 8 MM))FJ77 8 8 8 MM))I|<< = = = = rc||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 rr?r@r<r=rArBrCrFrD)rrGrHrIrr?r@s rrz0BaseAbstractFixtures._bulk_operations_scenario_0s9h//68,,Ifk22 ### ii00111 ii00111 ii 33444 ii 33444 ii <88999 rc||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 rr?z subdir.txtz subfile.txtrL)rrGrHrIrr?filesubfiles rr"z8BaseAbstractFixtures._dir_and_file_with_same_name_prefixs9h//68,,y..)FM22    d g rc6||d}tdD]|}tt|d}|||d}|||}|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)rErstrencode hexdigestpipe)rrGrHrIrihashed_irRs rr&z0BaseAbstractFixtures._10_files_with_hashed_namess9h//r ; ;A3q66==1122<<>>H9V%6%6%677D LLdQ&--//L : : : : rN)__name__ __module__ __qualname____doc__pytestfixturerrr#r'r,r2r4r6r8r:rrr"r&rrr r s}  ^&&^& ^&&^& ^ & &^ & ^ & &^ & ^ * *^ * ^,,^, ^,,^, ^ , ,^ , ^ , ,^ , ^ 0 0^ 0B2&     rr c&eZdZdZejdZejdZejdZejddZ ejdZ ejd Z ejd Z ejd Z d S) 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``. c tdNz3This function must be overridden in derived classesNotImplementedErrorrs rrzAbstractFixtures.fs!"WXXXrc$tjjS)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. osrRjoinrgs rrzAbstractFixtures.fs_joinsw|rc tdrdrergs rrzAbstractFixtures.fs_pathrhrclass)scopec"tdS)NT) auto_mkdirrrgs rr/zAbstractFixtures.local_fss$////rc$tjjS)zs Return a function that joins its arguments together into a path, on the local filesystem. rjrgs rr0zAbstractFixtures.local_join s w|rc|SNr`)rtmpdirs rr1zAbstractFixtures.local_paths rcdS)zP Return whether this implementation supports empty directories. Tr`rgs rsupports_empty_directoriesz+AbstractFixtures.supports_empty_directoriess trcdS)Nc|Srtr`)xs rz3AbstractFixtures.fs_sanitize_path..!srr`rgs rfs_sanitize_pathz!AbstractFixtures.fs_sanitize_paths {rN)rZr[r\r]r^r_rrrr/r0r1rwr|r`rrrbrbs ^YY^Y ^^ ^YY^YV^'"""00#"0  ^^ ^^ ^^  ^^rrb)rkhashlibrr^fsspec.implementations.localrfsspec.tests.abstract.copyrfsspec.tests.abstract.getrfsspec.tests.abstract.openrfsspec.tests.abstract.piper fsspec.tests.abstract.putr r rbr`rrrs  888888888888666666888888888888666666YYYYYYYYx77777+77777r