
    7ThL/                     2    S SK Jr  S SKJr   " S S\5      rg)   )
filesystem)AsyncFileSystemc                     ^  \ rS rSrSrSr     SEU 4S jjrS rS r\	S 5       r
S rS	 rS
 rS rS rS rS rS rS rS rS rS rS rS rS rS rS rS rS rS rS rS r S r!S r"S  r#S! r$S" r%S# r&S$ r'S% r(S& r)S' r*S( r+S) r,S* r-SFS+ jr.SFS, jr/S- r0S. r1S/ r2S0 r3S1 r4S2 r5S3 r6S4 r7S5 r8S6 r9S7 r:S8 r;S9 r<S: r=S; r>S< r?S= r@S> rAS? rBS@ rCSA rDSB rESC rFSDrGU =rH$ )GDirFileSystem   zDirectory prefix filesystem

The DirFileSystem is a filesystem-wrapper. It assumes every path it is dealing with
is relative to the `path`. After performing the necessary paths operation it
delegates everything to the wrapped filesystem.
dirc                 l  > [         TU ]  " S0 UD6  Uc  [        SSU0U=(       d    0 D6nU=(       d    UnU R                  (       a  UR                  (       d  [        S5      eUR                  (       a%  U R                  UR                  :w  a  [        S5      eUR                  U5      U l        X l        g)z
Parameters
----------
path: str
    Path to the directory.
fs: AbstractFileSystem
    An instantiated filesystem to wrap.
target_protocol, target_options:
    if fs is none, construct it from these
fo: str
    Alternate for path; do not provide both
Nprotocolz(can't use asynchronous with non-async fsz7both dirfs and fs should be in the same sync/async mode )	super__init__r   asynchronous
async_impl
ValueError_strip_protocolpathfs)selfr   r   fotarget_protocoltarget_optionsstorage_options	__class__s          T/var/www/auris/envauris/lib/python3.13/site-packages/fsspec/implementations/dirfs.pyr   DirFileSystem.__init__   s    * 	+?+:O_O9M2OBzrR]]GHH==T.."//AVWW&&t,	    c                    [        U[        5      (       af  U R                  (       d  U$ U(       d  U R                  $ U R                  R                  R                  U R                  U R                  U5      45      $ [        U[        5      (       a5  UR                  5        VVs0 s H  u  p#U R                  U5      U_M     snn$ U Vs/ s H  o R                  U5      PM     sn$ s  snnf s  snf N)

isinstancestrr   r   sepjoinr   dictitems_join)r   r   _pathvalues       r   r%   DirFileSystem._join2   s    dC  99yy 77;;##TYY0D0DT0J$KLLdD!!AENDJJu%u,NN/34te

5!t44 O4s   $C'
C-c                    [        U[        5      (       Ga  U R                  (       d  U$ XR                  :X  dF  U R                  R                  U R                  R
                  5      (       a  XR                  SS  :X  a  gU R                  U R                  R
                  -   nU R                  R                  U R                  R
                  5      (       a/  UR                  U R                  R
                  5      (       d  USS  nUR                  U5      (       d   eU[        U5      S  $ U Vs/ s H  o0R                  U5      PM     sn$ s  snf )N    )r   r    r   
startswithr   r!   len_relpath)r   r   prefixr&   s       r   r.   DirFileSystem._relpath=   s    dC  99 yy 		$$TWW[[11diim6KYY,Fyy##DGGKK009U9U??6****F&&267$e$$777s   0Ec                 .    U R                   R                  $ r   )r   r!   r   s    r   r!   DirFileSystem.sepP   s    ww{{r   c                 V   #    U R                   R                  " U0 UD6I S h  vN $  N7fr   )r   set_session)r   argskwargss      r   r5   DirFileSystem.set_sessionT   s%     WW(($9&9999s    )')c                 v   #    U R                   R                  " U R                  U5      40 UD6I S h  vN $  N7fr   )r   _rm_filer%   r   r   r7   s      r   r:   DirFileSystem._rm_fileW   s.     WW%%djj&6A&AAAA   0979c                 Z    U R                   R                  " U R                  U5      40 UD6$ r   )r   rm_filer%   r;   s      r   r?   DirFileSystem.rm_fileZ   s#    wwtzz$/:6::r   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   _rmr%   r   r   r6   r7   s       r   rB   DirFileSystem._rm]   s1     WW[[D!1CDCFCCCC   3<:<c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   rmr%   rC   s       r   rG   DirFileSystem.rm`   s(    wwzz$**T*<T<V<<r   c                    #    U R                   R                  " U R                  U5      U R                  U5      40 UD6I S h  vN $  N7fr   )r   _cp_filer%   r   path1path2r7   s       r   rJ   DirFileSystem._cp_filec   s9     WW%%djj&7E9JUfUUUUs   A A	AA	c                 z    U R                   R                  " U R                  U5      U R                  U5      40 UD6$ r   )r   cp_filer%   rK   s       r   rP   DirFileSystem.cp_filef   s.    wwtzz%0$**U2CNvNNr   c                    #    U R                   R                  " U R                  U5      U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   _copyr%   r   rL   rM   r6   r7   s        r   rS   DirFileSystem._copyi   sR      WW]]JJuJJu
 
 	
 
 	
 
s   AAA
Ac                     U R                   R                  " U R                  U5      U R                  U5      /UQ70 UD6$ r   )r   copyr%   rT   s        r   rW   DirFileSystem.copyw   sC    ww||JJuJJu
 
 	
 	
r   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   _piper%   rC   s       r   rZ   DirFileSystem._pipe   s1     WW]]4::d#3EdEfEEEErE   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   piper%   rC   s       r   r]   DirFileSystem.pipe   (    ww||DJJt,>t>v>>r   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   
_pipe_filer%   rC   s       r   ra   DirFileSystem._pipe_file   s3     WW''

4(8J4J6JJJJrE   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   	pipe_filer%   rC   s       r   rd   DirFileSystem.pipe_file   s*    ww  D!1CDCFCCr   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   	_cat_filer%   rC   s       r   rg   DirFileSystem._cat_file   3     WW&&tzz$'7I$I&IIIIrE   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   cat_filer%   rC   s       r   rk   DirFileSystem.cat_file   *    ww

4 0B4B6BBr   c                    #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN n[        U[        5      (       a5  UR                  5        VVs0 s H  u  pVU R                  U5      U_M     snn$ U$  NPs  snnf 7fr   )r   _catr%   r   r#   r$   r.   r   r   r6   r7   retkeyr'   s          r   ro   DirFileSystem._cat   s     GGLLJJt

 
 
 c4  @C		L*#DMM#&-LL

 Ms!   3BB,B"B BBc                    U R                   R                  " U R                  U5      /UQ70 UD6n[        U[        5      (       a5  UR                  5        VVs0 s H  u  pVU R                  U5      U_M     snn$ U$ s  snnf r   )r   catr%   r   r#   r$   r.   rp   s          r   ru   DirFileSystem.cat   sw    ggkkJJt

 
 c4  @C		L*#DMM#&-LL
 Ms   A<c                 v   #    U R                   R                  " XR                  U5      40 UD6I S h  vN $  N7fr   )r   	_put_filer%   r   lpathrpathr7   s       r   rx   DirFileSystem._put_file   s.     WW&&ujj.?J6JJJJr=   c                 Z    U R                   R                  " XR                  U5      40 UD6$ r   )r   put_filer%   ry   s       r   r~   DirFileSystem.put_file   s%    wwzz%'8CFCCr   c                 ~   #    U R                   R                  " UU R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   _putr%   r   rz   r{   r6   r7   s        r   r   DirFileSystem._put   sI      WW\\JJu
 
 	
 
 	
 
s   4=;=c                 b    U R                   R                  " UU R                  U5      /UQ70 UD6$ r   )r   putr%   r   s        r   r   DirFileSystem.put   s:    ww{{JJu
 
 	
 	
r   c                 x   #    U R                   R                  " U R                  U5      U40 UD6I S h  vN $  N7fr   )r   	_get_filer%   r   r{   rz   r7   s       r   r   DirFileSystem._get_file   s0     WW&&tzz%'8%J6JJJJs   1:8:c                 \    U R                   R                  " U R                  U5      U40 UD6$ r   )r   get_filer%   r   s       r   r   DirFileSystem.get_file   s'    ww

5 15CFCCr   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   _getr%   r   r{   r6   r7   s       r   r   DirFileSystem._get   s1     WW\\$**U"3EdEfEEEErE   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   getr%   r   s       r   r   DirFileSystem.get   s(    ww{{4::e,>t>v>>r   c                 r   #    U R                   R                  U R                  U5      5      I S h  vN $  N7fr   )r   _isfiler%   r   r   s     r   r   DirFileSystem._isfile   '     WW__TZZ%56666   .757c                 V    U R                   R                  U R                  U5      5      $ r   )r   isfiler%   r   s     r   r   DirFileSystem.isfile       ww~~djj.//r   c                 r   #    U R                   R                  U R                  U5      5      I S h  vN $  N7fr   )r   _isdirr%   r   s     r   r   DirFileSystem._isdir   s'     WW^^DJJt$45555r   c                 V    U R                   R                  U R                  U5      5      $ r   )r   isdirr%   r   s     r   r   DirFileSystem.isdir       ww}}TZZ-..r   c                 r   #    U R                   R                  U R                  U5      5      I S h  vN $  N7fr   )r   _sizer%   r   s     r   r   DirFileSystem._size   s'     WW]]4::d#34444r   c                 V    U R                   R                  U R                  U5      5      $ r   )r   sizer%   r   s     r   r   DirFileSystem.size   s    ww||DJJt,--r   c                 r   #    U R                   R                  U R                  U5      5      I S h  vN $  N7fr   )r   _existsr%   r   s     r   r   DirFileSystem._exists   r   r   c                 V    U R                   R                  U R                  U5      5      $ r   )r   existsr%   r   s     r   r   DirFileSystem.exists   r   r   c                    #    U R                   R                  " U R                  U5      40 UD6I S h  vN nUR                  5       nU R	                  US   5      US'   U$  N-7fNname)r   _infor%   rW   r.   r   r   r7   infos       r   r   DirFileSystem._info   sS     WW]]4::d#3>v>>yy{}}T&\2V ?s   0A"A .A"c                     U R                   R                  " U R                  U5      40 UD6nUR                  5       nU R	                  US   5      US'   U$ r   )r   r   r%   rW   r.   r   s       r   r   DirFileSystem.info   sH    ww||DJJt,77yy{}}T&\2Vr   c                 P  #    U R                   R                  " U R                  U5      4SU0UD6I S h  vN R                  5       nU(       aE  / nU H;  nUR                  5       nU R	                  US   5      US'   UR                  U5        M=     U$ U R	                  U5      $  No7fNdetailr   )r   _lsr%   rW   r.   appendr   r   r   r7   rq   outentrys          r   r   DirFileSystem._ls   s     WW[[D!1K&KFKKQQSC

 $eFm <f

5!  J}}S!! Ls   2B&B$A0B&c                 4   U R                   R                  " U R                  U5      4SU0UD6R                  5       nU(       aE  / nU H;  nUR                  5       nU R	                  US   5      US'   UR                  U5        M=     U$ U R	                  U5      $ r   )r   lsr%   rW   r.   r   r   s          r   r   DirFileSystem.ls  s    ggjjD)C&CFCHHJC

 $eFm <f

5!  J}}S!!r   c                   #    U R                   R                  " U R                  U5      /UQ70 UD6  S h  vN u  pEnU R                  U5      XV47v   M$   N
 g 7fr   )r   _walkr%   r.   r   r   r6   r7   rootdirsfiless          r   r   DirFileSystem._walk  sQ     '+ww}}TZZ5E'W'WPV'W 	3#$e--%t22	3'Ws%   0AAAAAAAc              /      #    U R                   R                  " U R                  U5      /UQ70 UD6 H  u  pEnU R                  U5      XV4v   M     g 7fr   )r   walkr%   r.   r   s          r   r   DirFileSystem.walk  sI     !%djj.>!P!P!PD--%t22 "Qs   AAc                 @  #    UR                  SS5      nU R                  R                  " U R                  U5      40 UD6I S h  vN nU(       a5  UR	                  5        VVs0 s H  u  pU R                  U5      U_M     snn$ U R                  U5      $  NQs  snnf 7fNr   F)r   r   _globr%   r$   r.   r   r   r7   r   rq   r   s         r   r   DirFileSystem._glob  s}     He,GGMM$**T"2=f==@C		L*$DMM$'-LL}}S!! >Ls$   ABBB#BBBc                 $   UR                  SS5      nU R                  R                  " U R                  U5      40 UD6nU(       a5  UR	                  5        VVs0 s H  u  pU R                  U5      U_M     snn$ U R                  U5      $ s  snnf r   )r   r   globr%   r$   r.   r   s         r   r   DirFileSystem.glob  su    He,ggll4::d+6v6@C		L*$DMM$'-LL}}S!! Ms   Bc                 (  #    UR                  SS5      nU R                  R                  " U R                  U5      /UQ70 UD6I S h  vN nU(       a  U$ UR	                  5        VVs0 s H  u  pU R                  U5      U_M     snn$  NBs  snnf 7fNtotalT)r   r   _dur%   r$   r.   r   r   r6   r7   r   rq   r   s          r   r   DirFileSystem._du#  s|     

7D)GGKK

4 0B4B6BBJ<?IIKHKjdd#T)KHH	 C Is$   ABB
 B(BBBc                    UR                  SS5      nU R                  R                  " U R                  U5      /UQ70 UD6nU(       a  U$ UR	                  5        VVs0 s H  u  pU R                  U5      U_M     snn$ s  snnf r   )r   r   dur%   r$   r.   r   s          r   r   DirFileSystem.du+  sm    

7D)ggjjD);D;F;J<?IIKHKjdd#T)KHHHs   B c                 F  #    UR                  SS5      nU R                  R                  " U R                  U5      /UQ70 UD6I S h  vN nU(       a5  UR	                  5        VVs0 s H  u  pU R                  U5      U_M     snn$ U R                  U5      $  NQs  snnf 7fr   )r   r   _findr%   r$   r.   r   r   r6   r7   r   rq   r   s          r   r   DirFileSystem._find3  s     He,GGMM$**T"2DTDVDD@C		L*$DMM$'-LL}}S!! ELs$   AB!BB!&BB!B!c                 *   UR                  SS5      nU R                  R                  " U R                  U5      /UQ70 UD6nU(       a5  UR	                  5        VVs0 s H  u  pU R                  U5      U_M     snn$ U R                  U5      $ s  snnf r   )r   r   findr%   r$   r.   r   s          r   r   DirFileSystem.find:  sz    He,ggll4::d+=d=f=@C		L*$DMM$'-LL}}S!! Ms   Bc                    #    U R                  U R                  R                  " U R                  U5      /UQ70 UD6I S h  vN 5      $  N7fr   )r.   r   _expand_pathr%   rC   s       r   r   DirFileSystem._expand_pathA  sA     }}''&&tzz$'7I$I&II
 	
Is   >A A		Ac                 ~    U R                  U R                  R                  " U R                  U5      /UQ70 UD65      $ r   )r.   r   expand_pathr%   rC   s       r   r   DirFileSystem.expand_pathF  s3    }}TWW00D1ASDSFSTTr   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   _mkdirr%   rC   s       r   r   DirFileSystem._mkdirI  s1     WW^^DJJt$4FtFvFFFFrE   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   mkdirr%   rC   s       r   r   DirFileSystem.mkdirL  s(    ww}}TZZ-????r   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   	_makedirsr%   rC   s       r   r   DirFileSystem._makedirsO  ri   rE   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   makedirsr%   rC   s       r   r   DirFileSystem.makedirsR  rm   r   c                 V    U R                   R                  U R                  U5      5      $ r   )r   rmdirr%   r   s     r   r   DirFileSystem.rmdirU  r   r   c                 z    U R                   R                  " U R                  U5      U R                  U5      40 UD6$ r   )r   mvr%   rK   s       r   r   DirFileSystem.mvX  s9    wwzzJJuJJu
 
 	
r   c                 Z    U R                   R                  " U R                  U5      40 UD6$ r   )r   touchr%   r;   s      r   r  DirFileSystem.touch_  s#    ww}}TZZ-888r   c                 V    U R                   R                  U R                  U5      5      $ r   )r   createdr%   r   s     r   r  DirFileSystem.createdb  s    wwtzz$/00r   c                 V    U R                   R                  U R                  U5      5      $ r   )r   modifiedr%   r   s     r   r  DirFileSystem.modifiede  s     ww

4 011r   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   signr%   rC   s       r   r  DirFileSystem.signh  r_   r   c                 h    U R                   R                   SU R                   SU R                   S3$ )Nz(path='z', fs=))r   __qualname__r   r   r2   s    r   __repr__DirFileSystem.__repr__k  s.    ..--.gdii[twwiqQQr   c                 `    U R                   R                  " U R                  U5      /UQ70 UD6$ r   )r   openr%   rC   s       r   r  DirFileSystem.openn  s7     ww||JJt

 
 	
r   c                 |   #    U R                   R                  " U R                  U5      /UQ70 UD6I S h  vN $  N7fr   )r   
open_asyncr%   rC   s       r   r  DirFileSystem.open_asyncz  sF      WW''JJt

 
 
 	
 
rE   )r   r   )NNNNN)T)I__name__
__module__r  __firstlineno____doc__r
   r   r%   r.   propertyr!   r5   r:   r?   rB   rG   rJ   rP   rS   rW   rZ   r]   ra   rd   rg   rk   ro   ru   rx   r~   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r  r  r  r  __static_attributes____classcell__)r   s   @r   r   r      s    H !F	58&  :B;D=VO

F?KDJC

KD

KDF?706/5.70
"
"33""II""

UG@JC/
912?R



 

r   r   N)r+   r   asynr   r   r   r   r   <module>r      s     "
O 
r   