^h*R:SrSSKJr SSKrSSKrSSKrSSKrSSKJrJ r SSK J r SSK J r SSKrSSKJr SSKJr SS KJrJr SS KJr SS KJr SS KJrJrJr S rSrSSjr SSjr!Sr"Sr#\ SSj5r$\ SSj5r%"SS\\5r&"SS\&5r'g)z9 Utilities for file-based Contents/Checkpoints managers. ) annotationsN) decodebytes encodebytes)contextmanager)partial)run_sync) HTTPError)BoolEnum) Configurable)LoggingConfigurable)ApiPath to_api_path to_os_pathc0[R"X5 g)zreplace dst with srcN)osreplacesrcdsts a/home/james-whalen/.local/lib/python3.13/site-packages/jupyter_server/services/contents/fileio.py replace_filersJJscT# [[RX5IShvN gN7f)z#replace dst with src asynchronouslyN)rrrrs rasync_replace_filer s 2::s (((s (&(cp[R"U[R5(d5U(aURSUSS9 [ [ R SU35e[R"X5 [R"X5 g![a U(aURSUSS9 ggf=f)zRcopy src to dst like shutil.copy2, but log errors in copystat instead of raising Source file, %s, is not writableTexc_infoFile is not writable: copystat on %s failedN) raccessW_OKdebugPermissionErrorerrnoEACCESshutilcopyfilecopystatOSErrorrrlogs r copy2_safer.%s 99S"'' " "  II8#I Mell.DSE,JKK OOCC! C  II-sTI B Cs7B"B54B5c# [R"U[R5(d5U(aURSUSS9 [ [ R SU35e[[RX5IShvN [[RX5IShvN gN(N![a U(aURSUSS9 ggf=f7f)zacopy src to dst asynchronously like shutil.copy2, but log errors in copystat instead of raising rTrr Nr!) rr"r#r$r%r&r'rr(r)r*r+r,s rasync_copy2_safer08s 99S"'' " "  II8#I Mell.DSE,JKK 6??C ---Cv111.1 C  II-sTI B CsHA=C?B(CB,"B*#B,'C*B,,"CCCCc[RRU5up[RRUSU-5$)zpName of the intermediate file used in atomic writes. The .~ prefix will make Dropbox ignore the temporary file.z.~rpathsplitjoinr3dirnamebasenames rpath_to_intermediater9Js2 d+G 77<< 11rc[RRU5up[RRXS-5$)zEName of invalid file after a failed atomic write and subsequent read.z.invalidr2r6s rpath_to_invalidr;Rs/ d+G 77<<J!6 77rc+F# [RRU5(aQ[RR[RR U5[R "U55n[RR U5=(d [R "5n[RRU5(a[R"U[R5(dm[R"U[R5(aCU(aSOSnU(a[X4SU0UD6nO [X40UD6nUv UR5 g[U5n[RRU5(a [XUS9 U(a"URSS5 [US4SU0UD6nO [US40UD6nUv UR#5 [R$"UR'55 UR5 [RRU5(a[R("U5 gg!UR5 f=f![a UR5 [!X5 ef=f7f)aContext manager to write to a file only if the entire write is successful. This works by copying the previous file contents to a temporary file in the same directory, and renaming that file back to the target if the context exits with an error. If the context is successful, the new data is synced to disk and the temporary file is removed. Parameters ---------- path : str The target file to write to. text : bool, optional Whether to open the file in text mode (i.e. to write unicode). Default is True. encoding : str, optional The encoding to use for files opened in text mode. Default is UTF-8. **kwargs Passed to :func:`io.open`. wwbencodingNr-newline )rr3islinkr5r7readlinkgetcwdisfiler"r#opencloser9r. setdefault BaseExceptionrflushfsyncfilenoremove) r3textr?r-kwargsdirpathmodefileobjtmp_paths ratomic_writingrUXs0 ww~~dww||BGGOOD12;;t3DEggood#2ryy{G ww~~dBIIgrww$?$?BIIdTVT[T[D\D\s 4CCFCG400G M MMO#D)H ww~~d4s+ )T*tS>8>v>tT,V,  MMOHHW^^  MMO ww~~h ( ; MMO"  X$ s8EJ!I"BJ!I7"BJ!"I44J!7'JJ!c+# [RRU5(aQ[RR[RR U5[R "U55nU(a"UR SS5 [US4SU0UD6nO [US40UD6nUv UR5 g![a UR5 ef=f7f)aContext manager to write file without doing atomic writing (for weird filesystem eg: nfs). Parameters ---------- path : str The target file to write to. text : bool, optional Whether to open the file in text mode (i.e. to write unicode). Default is True. encoding : str, optional The encoding to use for files opened in text mode. Default is UTF-8. **kwargs Passed to :func:`io.open`. rArBr=r?r>N) rr3rCr5r7rDrIrGrJrH)r3rOr?r-rPrSs r_simple_writingrWs( ww~~dww||BGGOOD12;;t3DE )T*tS>8>v>tT,V,  MMO   sB,C#/C3C#C  C#c\rSrSrSr\"SSSS9r\"\RSSSS9r \ S 5r \ S 5r \ SS j5rS rS rSSSjjrSSjrSSjrSSSjjrSrSrg)FileManagerMixinas Mixin for ContentsAPI classes that interact with the filesystem. Provides facilities for reading, writing, and copying files. Shared by FileContentsManager and FileCheckpoints. Note ---- Classes using this mixin must provide the following attributes: root_dir : unicode A directory against against which API-style paths are to be resolved. log : logging.Logger TaBy default notebooks are saved on disk on a temporary file and then if successfully written, it replaces the old ones. This procedure, namely 'atomic_writing', causes some bugs on file system without operation order enforcement (like some networked fs). If set to False, the new notebook is written directly on the old one which could fail (eg: full filesystem or quota ))confighelpsha256z:Hash algorithm to use for file content, support by hashlib) default_valuer[r\c/# URU5 [U/UQ70UD6nUv SSS5 SSS5 g!,(df  N=f!,(df  g=f7f)z=%W>t>v>!G? ' &>=?> ' &sLB*0BA7 B!B&B. B*7 B B B B B'#B*c## Sv g![asnUR[R[R1;a?U(dUR=(d Sn[ XR S9n[SSU-5UeeSnAff=f7f)z7context manager for turning permission errors into 403.Nz unknown file)rootizPermission denied: %s)r+r&EPERMr'filenamerroot_dirr )rbrcer3s rr`FileManagerMixin.perm_to_403sn   ww5;; 55jj:NG"7?%?T I Js6C++ D7DNcURUSUS9n[R"USUUS9nU(aXeS4$U$![a nUnSnAOSnAff=f[ U5n UR (a$[ RRU 5(d[SSUS U<35e[U5n [X5 [X5 URXX4S 9$) Read a notebook from an os path.rO)rawr as_versioncapture_validation_errorNUnreadable Notebook:  rr) _read_filenbformatreads Exceptionr9rhrr3existsr r;r_read_notebook rbrcrrranswernbroe_origrT invalid_files rrFileManagerMixin._read_notebook;s&c: q %)AB '*Bq ? 1r 1 F  (0&&bggnnX.F.F'y&<  'w/ W+X'"" :R#  s%;; AA  AcURUSS9n[R"UU[RUS9 SSS5 g!,(df  g=fzSave a notebook to an os_path.utf-8)r?)versionrN)rUrwrite NO_CONVERTrbrcrrres r_save_notebookFileManagerMixin._save_notebook_sA  7 ;q NN ++)A  < ; ;s &A AcURn[R"U5nURU5 UR 5US.$)aCompute the hash hexdigest for the provided bytes. The hash algorithm is provided by the `hash_algorithm` attribute. Parameters ---------- byte_content : bytes The bytes to hash Returns ------- A dictionary to be appended to a model {"hash": str, "hash_algorithm": str}. )hashhash_algorithm)rhashlibnewupdate hexdigest)rb byte_content algorithmhs r _get_hashFileManagerMixin._get_hashis:'' KK "  CCrcT[RRU5(d[SSU-5eUR US5nUR 5nSSS5 US:XaU(aWSU4$WS4$UbUS:Xa/U(aWR S5SU4$WR S5S4$U(a[W5R S 5S U4$[W5R S 5S 4$!,(df  N=f![anUS:Xa[SSU-S S 9UeSnANuSnAff=f a-Read a non-notebook file. Parameters ---------- os_path: str The path to be read. format: str If 'text', the contents will be decoded as UTF-8. If 'base64', the raw bytes contents will be encoded as base64. If 'byte', the raw bytes contents will be returned. If not specified, try to decode as UTF-8, and fall back to base64 raw: bool [Optional] If True, will return as third argument the raw bytes content Returns ------- (content, format, byte_content) It returns the content in the given format as well as the raw byte content. rzCannot read non-file %srbNbyterOutf8z%s is not UTF-8 encodedz bad format)reasonasciibase64) rr3rFr rGreaddecode UnicodeErrorrrbrcformatrrebcontentros rrFileManagerMixin._read_file|sG,ww~~g&&C!:W!DE E YYw %vvxH& V 36Hfh/ NXvVv- __V,fh?!/" " ) )' 2Hh G H%,,W5 5& %&  V##1G;+ $ s*C-?C>C>- C;> D'D""D'cTUS;a [SS5eUS:XaURS5nOURS5n[U5nUR US S 9nUR U5 S S S 5 g ![an[SSUSU35UeS nAff=f!,(df  g =f zSave content of a generic file.>rOrrz:Must specify format of file contents as 'text' or 'base64'rOrrzEncoding error saving z: NF)rO)r encoderrrUrrbrccontentrr b64_bytesrores r _save_fileFileManagerMixin._save_files + +L  Q">>&1#NN73 &y1 u 5 GGH 6 5 QC#9'"QC!HIq P Q6 5s(A4A4B4 B>BB B')NFrboolN)rbytesreturnzdict[str, str]Frcstrrz str | Nonerrrz8tuple[str | bytes, str] | tuple[str | bytes, str, bytes])__name__ __module__ __qualname____firstlineno____doc__r rhr ralgorithms_availablerrrGrUr`rur~rrrrr__static_attributes__rrrrYrYs" $$ I N    ,%PQV" IM" HD(=B: : $.: 59: A: xrrYc^\rSrSrSrSrS S SjjrS SjrS SSjjrSr S r g)AsyncFileManagerMixinizQ Mixin for ContentsAPI classes that interact with the filesystem asynchronously. cH# [XURS9IShvN gN7frr)r0r-rss rruAsyncFileManagerMixin._copys sdhh777s " "Nc8# URUSU5IShvN n[[[RUUS9US5IShvN nU(aXeS4$U$NBN![ a nUnSnAOSnAff=f[ U5n UR(a$[RRU 5(d[SSUSU<35e[U5n [X5IShvN [X5IShvN URXX4S 9IShvN nU$7f) rrONrrrrrrr)rrrrrrr9rhrr3rr r;rrrs rr$AsyncFileManagerMixin._read_notebooksw<< NN)-E q B'*Bq ? 1r 1= F  (0&&bggnnX.F.F'y&<  'w/  777 333** :R+    s{DAD)A A A DA DA A6*A1,D1A66A/D%C(&D9C<:DDDc # URUSS9n[[[R[R US9UU5IShvN SSS5 gN !,(df  g=f7fr)rUrrrrrrs rr$AsyncFileManagerMixin._save_notebooksd  7 ;qNN$//-E   < ; < ;s.A*6A A A A*A A'#A*cz# [RRU5(d[SSU-5eUR US5n[ UR 5IShvN nSSS5 US:XaU(aWSU4$WS4$UbUS:Xa/U(aWRS5SU4$WRS5S4$U(a[W5RS 5S U4$[W5RS 5S 4$N!,(df  N=f![anUS:Xa[SSU-S S 9UeSnANwSnAff=f7fr) rr3rFr rGrrrrrrs rr AsyncFileManagerMixin._read_file sQ,ww~~g&&C!:W!DE E YYw %%aff--H& V 36Hfh/ NXvVv- __V,fh?!/" " ) )' 2Hh G h'..w7B 3.& %&  V##1G;+ $ sgAD;C>!C<"C>&'D;D(D;)D;AD;<C>> D D; D8D3.D;3D88D;cz# US;a [SS5eUS:XaURS5nOURS5n[U5nUR US S 9n[ UR U5IS hvN S S S 5 g ![an[SSUSU35UeS nAff=fN2!,(df  g =f7fr)r rrrrUrrrs rr AsyncFileManagerMixin._save_fileFs + +L  Q">>&1#NN73 &y1 u 5177H- - -6 5 QC#9'"QC!HIq P Q .6 5s\B;BB;B B;B*5B(6B*: B; B% B  B%%B;(B** B84B;rrrrrr) rrrrrrurrrrrrrrrrsW8QV&IM&P =B7 7 $.7 597 A7 r.rrr)TrN)(r __future__rr&rrr(rrr contextlibr functoolsrranyio.to_threadr tornado.webr traitletsr r traitlets.configr traitlets.config.configurabler jupyter_server.utilsrrrrrr.r0r9r;rUrWrYrrrrrs #  +%$! )=AA ) C&C$28 DDN##LB*LBJK.,K.r