o vh}< @s&dZddlZddlmZddlmZmZddlmZddlm Z ddl m Z m Z m Z mZmZmZddlmZmZgd Zd Z d d Zd dZddZdZdZdkdeedefddZdefddZdkdedefddZdefddZ dld d!Z!dmde"fd"d#Z#de"fd$d%Z$dmd&e"fd'd(Z%ed)d*Gd+d,d,Z&Gd-d.d.e'Z(Gd/d0d0e(Z)Gd1d2d2e)Z*Gd3d4d4e)Z+Gd5d6d6e(Z,Gd7d8d8e)Z-d9d:Z.Gd;d<dd>eZ0Gd?d@d@Z1ddAdBe2dCe fdDdEZ3edFZ4edGZ5edHZ6dIe e4de6fdJe e4ge5fde e5de6ffdKdLZ7dMe e4de e4ddffdNdOZ8 dkdPee9e:fde ee9e:ffdQdRZ;dkdPe9fdSdTZZ?dYdZZ@d[d\ZAd]d^ZBde eCgeffd_d`ZDdaeCdefdbdcZEGdddedeee4ZFdfe e4dee4fdgdhZGdidjZHdS)nz Utility functions for PDF library. Taken from PyPDF2 with modifications and additions, see :ref:`here ` for the original license of the PyPDF2 project. Generally, all of these constitute internal API, except for the exception classes. N) dataclass)datetimetimezone)Enum)BytesIO)Callable GeneratorIterableOptionalTypeVarUnion)CancelableAsyncIteratorConsList)PdfError PdfReadErrorPdfStrictReadError PdfWriteErrorPdfStreamErrorIndirectObjectExpected get_and_apply OrderedEnumStringWithLanguageis_regular_characterread_non_whitespaceread_until_whitespaceread_until_delimiterread_until_regexskip_over_whitespaceskip_over_comment instance_testpeek!assert_writable_and_random_accessprepare_rw_output_streamfinalise_outputDEFAULT_CHUNK_SIZE chunked_writechunked_digest chunk_streamr Singletonrdisoparselift_iterable_asyncicCs t|dS)N)roundxr0T/var/www/html/hyperkenya/venv/lib/python3.10/site-packages/pyhanko/pdf_utils/misc.py9 r2cs fddS)Ncs t|SN) isinstancer.clsr0r1r2=r3zinstance_test..r0r6r0r6r1r<s rccs^t|} zt|}Wn tyYdSwzt|}Wn ty(tdw||fVq)NTzList has odd number of elements)iternext StopIteration ValueError)lstix1x2r0r0r1 pair_iter@s     r@s s ()<>[]{}/%maxcharsreturncCstt||dS)a Reads non-whitespace characters and returns them. Stops upon encountering whitespace, or, if ``maxchars`` is not ``None``, when maxchars is reached. :param stream: stream to read :param maxchars: maximal number of bytes to read before returning )rA)_read_until_classPDF_WHITESPACE)streamrAr0r0r1rRs rcCs ttt|}|dtj|S)z Read until a token delimiter (i.e. a delimiter character or a PDF whitespace character) is encountered, and rewind the stream to the previous character. :param stream: A stream. :return: The bytes read. )rCrDPDF_DELIMITERSseekosSEEK_CUR)rEresultr0r0r1ras r class_charscs(dkrdSfdd}d|S)Nrc3sjdurdn}dus|kr3d}|vs"|s$dS|Vdus|ksdSdS)N)tellread)stop_attokrLrArEr0r1_buildus  z!_read_until_class.._build)join)rLrErArTr0rSr1rCqs rC byte_valuecCs|tvo|tvSr4)rDrG)rVr0r0r1rsrFcCsxtd} |tvr|s|rdStd|d}|tvs |dkr!n|dtjt|td}q|r:|dtj|S)zQ Finds and reads the next non-whitespace character (ignores whitespace). rTrMStream ended prematurelyrN%rF)rDrrPrHrIrJr)rE seek_back allow_eofrRr0r0r1rs$ rcCstd}d}|tvr;|d}|std|d7}|r7|dkr#|dkS|dkr7|d}|dks2|s6|dkSn|tvs |dtj|dkS)a Similar to :func:`read_non_whitespace`, but returns a ``bool`` if more than one whitespace character was read. Will return the cursor to before the first non-whitespace character encountered, or after the first end-of-line sequence if one is encountered. rrNrW  rF)rDrPrrHrIrJ)rEstop_after_eolrRcntnxtr0r0r1rs$   rcCsd|d}|dd|dkr0|dvr|d}|dvs|d}|r.|dkr.|dtjdSdS)a Skip over a comment and position the cursor at the first byte after the EOL sequence following the comment. If there is no comment under the cursor, do nothing. :param stream: stream to read :return: ``True`` if a comment was read. rNrFrX)r[r\rMr[TF)rPrHrIrJ)rErRr_r0r0r1rs    r ignore_eofcCsrd} |d}|s|r|Std||}|dur4||d|7}||t|d |S||7}q)ah Reads until the regular expression pattern matched (ignore the match) Raise :class:`PdfStreamError` on premature end-of-file. :param stream: stream to search :param regex: regex to match :param ignore_eof: if true, ignore end-of-line and return immediately :raises PdfStreamError: on premature EOF rMTzStream has ended unexpectedlyNrN)rPrsearchstartrHlen)rEregexr`namerRmr0r0r1rs  rT)frozenc@sBeZdZUdZeed<dZeeed<dZeeed<ddZ dS)rz2 A string with a language attached to it. valueN lang_code country_codecCs|jSr4)riselfr0r0r1__str__szStringWithLanguage.__str__) __name__ __module__ __qualname____doc__str__annotations__rjr rkrnr0r0r0r1rs  rcs"eZdZdeffdd ZZS)rmsgcs||_tj|g|RdSr4)rusuper__init__)rmruargs __class__r0r1rwszPdfError.__init__)rorprqrsrw __classcell__r0r0ryr1rsrc@ eZdZdS)rNrorprqr0r0r0r1r rc@r|)rNr}r0r0r0r1r r~rcs(eZdZddeeffdd ZZS)rNrucstj|pdddS)Nzindirect object expected)ru)rvrw)rmruryr0r1rwszIndirectObjectExpected.__init__r4)rorprqr rsrwr{r0r0ryr1rs rc@r|)rNr}r0r0r0r1rr~rc@r|)rNr}r0r0r0r1rr~rcs(ttfdd}|fS)Nc3sVEdHdSr4r0r0firstitrr0r1_itr"szpeek.._itr)r8r9)rrr0rr1r s r c@0eZdZdZddZddZddZdd Zd S) rz6 Ordered enum (from the Python documentation) cCs|j|jur |j|jkStr4rzriNotImplementedErrorrmotherr0r0r1__ge__.  zOrderedEnum.__ge__cCs|j|jur |j|jkStr4rrr0r0r1__gt__3rzOrderedEnum.__gt__cCs|j|jur |j|jkStr4rrr0r0r1__le__8rzOrderedEnum.__le__cCs|j|jur |j|jkStr4rrr0r0r1__lt__=rzOrderedEnum.__lt__Nrorprqrrrrrrr0r0r0r1r)s  rc@r) VersionEnumz Ordered enum with support for ``None``, for future-proofing version-based enums. In such enums, the value ``None`` can be used as a stand-in for "any future version". cCs<|j|jur|j}|j}|durdS|durdS||kStNTFrrmrval other_valr0r0r1rJ zVersionEnum.__ge__cCs@|j|jur|j}|j}|dur|duS|durdS||kStNFrrr0r0r1rV zVersionEnum.__gt__cCs<|j|jur|j}|j}|durdS|durdS||kStrrrr0r0r1rbrzVersionEnum.__le__cCs@|j|jur|j}|j}|dur|duS|durdS||kStrrrr0r0r1rnrzVersionEnum.__lt__Nrr0r0r0r1rCs   rc@seZdZddZddZdS)LazyJoincCs||_||_dSr4)sepiterator)rmrrr0r0r1rw|s zLazyJoin.__init__cCs|j|jSr4)rrUrrlr0r0r1rnzLazyJoin.__str__N)rorprqrwrnr0r0r0r1r{s r)default dictionaryfunctioncCs*z ||}W||Sty|YSwr4)KeyError)rkeyrrrir0r0r1rs   rXYRgenfuncc csD z |t|VWnty }z |jWYd}~Sd}~wwqr4)r9r:ri)rrer0r0r1map_with_returnsrr/ccs|EdHdSr4r0r.r0r0r1_as_gensr temp_bufferccsd}|dus ||krN|}|dur#||}|t|kr#t|d|}||}||7}|s0dS|t|kr?t|d|}n|}|V|dus ||ks dSdS)Nr)rd memoryviewreadinto)rrEmax_read total_read read_bufferto_read bytes_readto_feedr0r0r1r's"   r'cC"t|||dD]}||qdSN)r)r'update)rrEmdrchunkr0r0r1r& r&cCrr)r'write)rrEoutputrrr0r0r1r%rr%c@seZdZddZdS)r(cs,t||||}t|fdd|_|S)NcsSr4r0)_instancer0r1r2sz#Singleton.__new__..)type__new____call__)mcsrfbasesdctr7r0rr1rs zSingleton.__new__N)rorprqrr0r0r0r1r(s r(cCs |std|o|S)z Raise an error if the buffer in question is not writable, and return a boolean to indicate whether it supports random-access reading. :param output: :return: zOutput buffer is not writable)writableIOErrorseekablereadablerr0r0r1r!s r!cCs$|dur t}|St|st}|S)aB Prepare an output stream that supports both reading and writing. Intended to be used for writing & updating signed files: when producing a signature, we render the PDF to a byte buffer with placeholder values for the signature data, or straight to the provided output stream if possible. More precisely: this function will return the original output stream if it is writable, readable and seekable. If the ``output`` parameter is ``None``, not readable or not seekable, this function will return a :class:`.BytesIO` instance instead. If the ``output`` parameter is not ``None`` and not writable, :class:`.IOError` will be raised. :param output: A writable file-like object, or ``None``. :return: A file-like object that supports reading, writing and seeking. N)rr!rr0r0r1r"s r"cCs@|dur||urt|tsJ|}||||S|S)z Several internal APIs transparently replaces non-readable/seekable buffers with BytesIO for signing operations, but we don't want to expose that to the public API user. This internal API function handles the unwrapping. N)r5r getbufferrrelease) orig_outputreturned_outputraw_bufr0r0r1r#s r#cCs,z ddlm}|WStytjYSw)Nr)r*)dateutil.parserr* ImportErrorr fromisoformat)parser0r0r1 _get_isoparse s    rdt_strcCs*t}||}|jdur|jtjd}|S)N)tzinfo)rrreplacerutc)rrdtr0r0r1r*s  r*c@s4eZdZdefddZddZdeefddZd S) _LiftedIterablerBcs t|jSr4)r9r=rlr0r0r1 __anext__"s z_LiftedIterable.__anext__csdSr4r0rlr0r0r1cancel%sz_LiftedIterable.cancelr=cCst||_dSr4)r8r=)rmr=r0r0r1rw(rz_LiftedIterable.__init__N)rorprqrrrr rwr0r0r0r1r!srr=cCst|Sr4)r)r=r0r0r1r+,sr+cGs|D] }|dur |SqdSr4r0)rxargr0r0r1coalesce0s rr4)FF)F)IrrrI dataclassesrrrenumriortypingrrr r r r pyhanko_certvalidator.utilr r__all__r$r)rr@rDrGintbytesrrrCrrboolrrrr Exceptionrrrrrrr rrrdictrrrrrr bytearrayrr'r&r%rr(r!r"r#rsrr*rr+rr0r0r0r1s    !    8