+ 4jG(\Rt^RIHt^RIt^RIt^RIHt^RIHtH t ]'d ^RI H t ^RI H t .R'Ot^t^t^t^t^t^t^t^t!RR]4tR R ltR R ltR RltRRltRRltRRltRRltRRlt RRlt!RRlt"RRlt#RR lt$R!R"lt%R#R$lt&R%R&lt'R#)(aCodec for the parsed-listing cache: records <-> opaque cache blob. Stores the post-:func:`nab_index.client._parse_files` records so a warm resolve skips ``json.loads`` and wheel/sdist filename parsing. This module owns the record<->bytes translation; :class:`~nab_index.cache.OnDiskCache` treats the blob as opaque and knows nothing about record shapes. Wire form (UTF-8 JSON of ``[header, rows]``): * header ``[format, codec, key_scheme, body_digest]`` is checked before anything is trusted. A reader on a different ``format``, ``codec``, or ``key_scheme`` treats the entry as a miss and rebuilds, so a cache written by an older build self-heals instead of misdecoding. ``body_digest`` binds the blob to the raw body it was parsed from; :func:`decode` rejects a blob whose digest does not equal the policy's, so a raw-body update invalidates the derived form. * rows hold one entry per surviving record, in the order the wire parse returned them, so a downstream stable-sort tie-break stays identical. Each row is a flat list tagged wheel or sdist by its first element. Every field is type-checked on the way back, and ``requires_python`` and hash-algorithm names are re-interned via ``sys.intern`` so the round trip reproduces the dedup the wire parse builds. The blob is portable: one entry serves every interpreter that shares the cache, and a body this module will not parse is a miss, never an exception reaching the caller. ) annotationsN) TYPE_CHECKING) SdistFile WheelFile)Sequence) CachePolicyc]tRt^=tRtRtR#) _BadRowErrorzEA row whose tag, arity, or field types are not what this codec wrote.N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r j/home/user/pdf2html-billing-ledger-validate/.venv/lib/python3.14/site-packages/nab_index/parsed_listing.pyr r =sOrr c$V^8dQhRRRRRR/#)fileslist[WheelFile | SdistFile] body_digeststrreturnbytesr )formats"r __annotate__rAs"**-*C*E*rc t.pVFp\V\4'd|VP\VPVP VP VPVPVPVPVPVP. 4KVP\VPVP VP VPVPVPVP.4K \\\ V.p\"P$!WB.RRR7P'4#)a|Encode parsed listing ``files`` into a cache blob bound to ``body_digest``. ``body_digest`` is the sha256 hex of the raw body the records were parsed from; :func:`decode` rehydrates only when it matches the policy's digest. ``local_path`` is not stored (a parsed-cache entry always comes from a remote body) and ``metadata_url`` is a derived property, so neither rides the wire. F) ensure_ascii separators),:) isinstancerappend _TAG_WHEELfilenameurlversionrequires_python has_metadata upload_timehashessize metadata_hash _TAG_SDISTFORMAT_VERSIONCODEC KEY_SCHEMEjsondumpsencode)rrrowsrecordheaders&& rr4r4As "D fi ( ( KKOOJJNN**''&&MMKK((   KKOOJJNN**&&MMKK  #:eZ =F :: Uz  fhrc$V^8dQhRRRRRR/#)rblobrpolicyrrz"list[WheelFile | SdistFile] | Noner )rs"rrrns"!!! !0R!rc\P!V4p\T\4'd\ T4\ 8XgR#Twr4\T\4'd\ T4\8XgR#TwrVrxT\8wg5T\8wg*T\8wgTPeYP8wdR#\T4# \dR#i;i \\3dR#i;i)aDecode a cache blob back to parsed records, or ``None`` to force a miss. Returns ``None`` (treat as a cache miss and rebuild from the raw body) when the blob does not decode, is the wrong shape, was written by a different build (``format`` / ``codec`` / ``key_scheme``), or is not bound to ``policy``'s body (``body_digest``). Otherwise rehydrates the records, re-interning ``requires_python`` and hash-algorithm names so string identity matches a fresh parse. N)r2loads ValueErrorr"listlen_TOP_LEN _HEADER_LENr/r0r1r _decode_rows TypeError) r9r:loadedr7r5format_codec key_schemers && rdecoderHnsD! vt $ $V)@LF vt $ $V )C.4+GJ>! E>  #    % ,, ,D!!' (  "s#C; C CCC-,C-c V^8dQhRRRR/#)rr9rr str | Noner )rs"rrrsEjrc\P!V4p\T\4'd\ T4\ 8XgR#Twr#\T\4'd\ T4\8XgR#TwrErgT\8wgT\8wg T\8wdR#\T4R# \dR#i;i \\3dR#i;i)anReturn a reason if ``blob`` is structurally corrupt, else ``None``. Distinguishes genuine corruption (garbage or truncated bytes, or a same-build blob whose rows are the wrong shape) from a benign miss, where the header names a different build or binds a different body. The read path warns only on the former. The row check runs only once the header names this exact build, since a foreign build may have written a shape this one never did; checking it earlier would misreport version skew as corruption. This is a second pass used only to gate that warning; :func:`decode` returns ``None`` for every miss reason alike. znot valid JSONzunexpected top-level shapezunexpected header shapeNzunexpected row shape) r2r<r=r"r>r?r@rAr/r0r1rBrC)r9rDr7r5rErFrG _body_digests& rcorruption_reasonrMs D! vt $ $V)@+LF vt $ $V )C(/5,GJ. EUNjJ6N&T #     "&%&s#B* B<* B98B9<CCc V^8dQhRRRR/#)rr5objectrrr )rs"rrrs..v."=.rcz\V\4'g\hVUu.uFp\V4NK up#uupi)zHRehydrate every row, raising :class:`_BadRowError` on the first bad one.)r"r>r _decode_row)r5rows& rrBrBs2 dD ! !(, -K  -- -s8c V^8dQhRRRR/#)rrRrOrzWheelFile | SdistFiler )rs"rrrs  V  5 rc\V\4'd V'g\hV^,p\V4\Jd\hV\ 8Xd \ V4#V\8Xd \V4#\h)zDRehydrate one row, dispatching on the tag its first element carries.) r"r>r typeintr$ _decode_wheelr. _decode_sdist)rRtags& rrQrQs^ c4  a&C Cy jS!! jS!! rc V^8dQhRRRR/#)rrRSequence[object]rrr )rs"rrrs'Irc Vw ppppppppp p \\V4\V4\V4\V4\V4\ V4\ V4\ V 4\V 4R7 #)) r%r&r'r(r)r*r+r,r-)r_text_interned_or_none_flag _text_or_none_hashes_count_or_none _pair_or_none) rR_r%r&r'r(r)r*r+r,r-s & rrWrWs{      x #Jg)/:<(!+.v D !#M2  rc V^8dQhRRRR/#)rrRr[rrr )rs"rrrs  ' I rc Vwrr4rVrx\\V4\V4\V4\V4\V4\ V4\ V4R7#))r%r&r'r(r*r+r,)rr]r^r`rarb) rRrdr%r&r'r(r*r+r,s & rrXrXsQLOIAV x #Jg)/:!+.v D ! rc V^8dQhRRRR/#)rvaluerOrrr )rs"rrrsCrc8\V4\Jd\hV#N)rUrr rhs&rr]r]s E{# Lrc V^8dQhRRRR/#rrhrOrrJr )rs"rrrs333J3rc$VfR#\V4#rj)r]rks&rr`r`=42eEl2rc V^8dQhRRRR/#rmr )rs"rrrs??V? ?rcLVfR#\P!\V44#rj)sysinternr]rks&rr^r^s =4>cjju&>>rc V^8dQhRRRR/#)rrhrOrboolr )rs"rrrsDrc8\V4\Jd\hV#rj)rUrur rks&rr_r_s E{$ Lrc V^8dQhRRRR/#)rrhrOrz int | Noner )rs"rrr s&ZrcDVfR#\V4\Jd\hV#rj)rUrVr rks&rrbrb s! } E{# Lrc V^8dQhRRRR/#)rrhrOrztuple[str, str]r )rs"rrrs...O.rc\V\4'd\V4\8wd\h\ V^,4\ V^,43#))r"r>r? _PAIR_LENr r]rks&r_pairr}s; eT " "c%jI&= %(OU58_ --rc V^8dQhRRRR/#)rrhrOrztuple[str, str] | Noner )rs"rrrs333$:3rc$VfR#\V4#rj)r}rks&rrcrcrorc V^8dQhRRRR/#)rrhrOrztuple[tuple[str, str], ...]r )rs"rrrsSS6S9Src\V\4'g\h\;QJd".R\ \ V44FNK 5#!R\ \ V444#)z4Return the hash pairs with algorithm names interned.c3V"TFwr\P!V4V3xK! R#5irj)rrrs).0algodigests& r _hashes..!s"R@Q #**T"F+@Qs'))r"r>r tuplemapr}rks&rrarasE eT " " 5RE5@QR5R5RE5@QR RRr)rMrHr4)(r __future__rr2rrtypingrclientrrcollections.abcrcacher__all__r/r0r1r@rAr|r$r.r=r r4rHrMrBrQrWrXr]r`r^r_rbr}rcrar rrrs8# ((" 3     P:P*Z!HD. 4 " 3?  . 3Sr