+j!$SrSSKJr SSKrSSKrSSKJr SSKJrJr SSK J r J r "SS\ 5r S rS rS r\"S S 9"SS55rSrSSSjjrSSSjjrSSSjjrS SjrS!Sjr\"SSS\R0S9rS"SjrS#Sjrg)$uOpaque keyset-pagination cursor for /api/assets. Payload JSON uses short keys to keep the encoded length small: {"s": , "v": , "id": , "o": } The `o` key binds the cursor to the sort direction it was minted under, so replaying a `desc` cursor against an `asc` request fails with ``INVALID_CURSOR`` rather than silently walking the wrong direction. `o` is mandatory on every payload — a cursor without it is rejected as malformed. Encoding is base64url with no padding. Cursors are opaque tokens: the payload format is internal to this server, and clients must treat a cursor as a black box handed back via `next_cursor`. No byte-level compatibility with any other implementation is required. Time values are serialized as Unix microseconds (UTC) — microsecond precision is sufficient to round-trip the timestamps stored by the database without rounding rows in the same millisecond bucket. ) annotationsN) dataclass)datetimetimezone)IterableOptionalc\rSrSrSrSrg)InvalidCursorErrorzRaised on a malformed, oversized, or unsupported-sort-field cursor. Map to a 400 response with code ``INVALID_CURSOR`` at the handler. N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r :/home/wildlama/comfy/ComfyUI/app/assets/services/cursor.pyr r srr i iT)frozenc>\rSrSr%S\S'S\S'S\S'S\S'Srg) CursorPayload:str sort_fieldvalueidorderr N)r rrr__annotations__rr rrrr:sO J G Jrr)ascdesccU[;a[S[SU<35eU(d [S5e[U5[:a [S5e[U5[:a [S5eXX#S.n[ R "USSS 9n[R"URS 55RS 5RS 5$) aEncode a cursor payload as a base64url (no-padding) string. `order` binds the cursor to the sort direction it was minted under so a later request with a flipped `order` query parameter is rejected with ``INVALID_CURSOR`` rather than silently walking the wrong direction. zorder must be one of z, got zid must be non-emptyid exceeds maximum lengthvalue exceeds maximum length)svro),:F) separators ensure_asciizutf-8=ascii) _VALID_ORDERSr lenMAX_CURSOR_ID_LENGTHMAX_CURSOR_VALUE_LENGTHjsondumpsbase64urlsafe_b64encodeencoderstripdecode)rrrrpayloadraws r encode_cursorr;Es M! #8veY!WXX  !788 2w%% !<== 5z++ !?@@"AG **W% HC  # #CJJw$7 8 ? ? E L LW UUrcURc [S5e[UR[R 55n[ U[U5X#S9$)zEncode a time-typed cursor at Unix microsecond precision. Accepts an aware datetime (any timezone) and normalizes to UTC. Naive datetimes are rejected so callers can't accidentally encode the local wall-clock value of a UTC-stored timestamp. z2encode_cursor_from_time requires an aware datetime)r)tzinfo ValueError_datetime_to_unix_micros astimezonerutcr;r)rtrrmicross rencode_cursor_from_timerD_sD xxMNN %all8<<&@ AF S[" BBrct[U5[:a [S5eS[U5*S--n[R"X-5n[R"U5n[U[5(d [S5eURS5nURS 5nURS 5n URS 5n [U[5(a*[U[5(a[U [5(d [S 5eU S :Xa [S5e[U 5[ :a [S5e[U5[":a [S5eXq;a[SU<35e[U [5(d [S5eU [$;a[SU <35eUbX:wa[SU <SU<35e['XxXS9$![ [R R4an[SU35UeSnAff=f![R[4an[SU35UeSnAff=f)u Parse an opaque cursor. ``allowed_sort_fields`` is the endpoint's accepted sort-field list — a cursor carrying a field outside this set is rejected so a cursor minted for one column can't be replayed against another (e.g. a ``created_at`` timestamp string compared against a ``name`` column). ``expected_order`` (``"asc"``/``"desc"``), when supplied, must match the payload's ``o`` field. ``o`` is required on every payload; a cursor missing it is rejected as malformed. Passing no allowed fields rejects every cursor. zcursor exceeds maximum length=z encoding: Nz payload: zpayload: expected objectr%r&rr'z%payload: missing or non-string s/v/idz missing idr#r$zunsupported sort field zmissing or non-string ozunsupported order z cursor order z does not match request order )rrrr)r/MAX_ENCODED_CURSOR_LENGTHr r4urlsafe_b64decoder>binasciiErrorr2loadsJSONDecodeErrorUnicodeDecodeError isinstancedictgetrr0r1r.r) cursorallowed_sort_fieldsexpected_orderpaddingr:edecodedrrrrs r decode_cursorrYls$ 6{.. !@AA:#f+)*&&v'789**S/ gt $ $ !;<<S!J KK E T B KK E j# & &j.D.DJWY[^L_L_ !HII Rx .. 2w%% !<== 5z++ !?@@, #::.!IJJ eS ! ! !:;; M! #5eY!?@@!e&= E9$B>BT U   J PPM -- .: :aS!129:  "4 59 9QC1q89s/*G H $H2HH H7#H22H7cUc [S5e[UR5n[ U5$![an[SU35UeSnAff=f![ [ [4an[SU35UeSnAff=f)zDParse a time-typed cursor value as Unix microseconds, returning UTC.Nnil cursor payloadz value is not a valid timestamp: z%value is out of representable range: )r intrr>_unix_micros_to_datetime OverflowErrorOSError)r9rCrWs rdecode_cursor_timer`s !566PW]]#U'// P #CA3!GHaOP 7J /U!#H!LMSTTUs+1 A AA  AA;'A66A;cUc [S5e[UR5$![an[SU35UeSnAff=f)z*Parse a cursor value as a base-10 integer.Nr[zvalue is not a valid integer: )r r\rr>)r9rWs rdecode_cursor_intrbsO !566N7==!! N #A!!EFAMNs% A>Ai)r=clU[- nURS-UR-S-UR-$)zBConvert an aware UTC datetime to Unix microseconds (integer math).iQ@B)_EPOCHdaysseconds microseconds)rBdeltas rr?r?s3 JE JJ %-- /9 r rIr1r0rr.r;rDrYr`rbrArfr?r]r rrrws*# !'%,! $ V4 C "&@Q @Q&@Q@Q @QF U N $1X\\ 2R ar