k:i<dZddlmZddlZddlZddlZddlZddlmZddl m Z ddl m Z m Z mZmZmZmZddlmZmZerdd lmZeeeedfZGd d ZGd d eZy)aG pyte.streams ~~~~~~~~~~~~ This module provides three stream implementations with different features; for starters, here's a quick example of how streams are typically used: >>> import pyte >>> screen = pyte.Screen(80, 24) >>> stream = pyte.Stream(screen) >>> stream.feed("") # Move the cursor down 5 rows. >>> screen.cursor.y 5 :copyright: (c) 2011-2012 by Selectel. :copyright: (c) 2012-2017 by pyte authors and contributors, see AUTHORS for details. :license: LGPL, see LICENSE for more details. ) annotationsN) defaultdict)Mapping)AnyCallableDict GeneratorOptional TYPE_CHECKING)controlescape)ScreencpeZdZdZej dej dejdejdejdejdejdejdejdi Zej d ej"d ej$dej&d ej(d ej*d ej,diZej0diZiej4dej6dej8dej:dej<dej>dej@dejBdejDdejFdejHdejJdejLdejNdejPdejRdejTdejVd ejXdejZdej\d!ej^d"ej`d#ejbd$ejdd%ejfd&ejhdi Z5e6e7jpejsejsejse5jsd'gd(d)gd*d+gZ:e;ejxejzej|ej~ejgZAeAjeeCjd,d-jeFeCj.eAzd.zZG[Ad8d9d0ZHd:d1ZId:d2ZJd;d3ZKdd6ZNd?d7ZOy/)@StreamaA stream is a state machine that parses a stream of bytes and dispatches events based on what it sees. :param pyte.screens.Screen screen: a screen to dispatch events to. :param bool strict: check if a given screen implements all required events. .. note:: Stream only accepts text as input, but if for some reason you need to feed it with bytes, consider using :class:`~pyte.streams.ByteStream` instead. .. versionchanged 0.6.0:: For performance reasons the binding between stream events and screen methods was made static. As a result, the stream **will not** dispatch events to methods added to screen **after** the stream was created. .. seealso:: `man console_codes `_ For details on console codes listed bellow in :attr:`basic`, :attr:`escape`, :attr:`csi`, :attr:`sharp`. bell backspacetablinefeedcarriage_return shift_outshift_inresetindex reverse_index set_tab_stop save_cursorrestore_cursoralignment_displayinsert_characters cursor_up cursor_downcursor_forward cursor_back cursor_down1 cursor_up1cursor_to_columncursor_positionerase_in_display erase_in_line insert_lines delete_linesdelete_characterserase_charactersreport_device_attributescursor_to_lineclear_tab_stopset_mode reset_modeselect_graphic_renditionreport_device_status set_marginsdefine_charset set_icon_name set_titledrawdebugz[^z]+Ncdd|_||_d|_d|_||j |yyNT)listenerstrictuse_utf8_taking_plain_textattach)selfscreenr@s C/var/www/html/bot/venv/lib/python3.12/site-packages/pyte/streams.py__init__zStream.__init__s6*.  " 26   KK  cF|j3tjdj|jt|j r8|j D])}t||rtdj||||_d|_ |jy)zvAdds a given screen to the listener queue. :param pyte.screens.Screen screen: a screen to attach to. NzqAs of version 0.6.0 the listener queue is restricted to a single element. Existing listener {0} will be replaced.z{0} is missing {1}) r?warningswarnformatDeprecationWarningr@eventshasattr TypeError_parser_initialize_parser)rDrEevents rFrCz Stream.attachs == $ MM;"6$--02D F ;; Pvu-#$8$?$?$NOO P 26  !rHc0||jurd|_yy)zRemove a given screen from the listener queue and fails silently if it's not attached. :param pyte.screens.Screen screen: a screen to detach. N)r?)rDrEs rFdetachz Stream.detachs T]] " DM #rHc||j}|j td|jj}|jj }|j }t|}d}||krH|r-|||}|r|j\} }||| |nd}n||||dz}|dz }||krH||_y)zvConsume some data and advances the state as necessary. :param str data: a blob of data to feed from. NzListener is not setrFr ) _send_to_parserr? RuntimeErrorr: _text_patternmatchrBlenspan) rDdatasendr: match_texttaking_plain_textlengthoffsetrZstarts rFfeedz Stream.feeds ## == 45 5}}!!''--  33Tvo "40$)JJLME6eF+,(-%$(fVaZ)@$A!! vo#4rHc |jJ|jj|S#t$r|jwxYwN)rQr^ ExceptionrR)rDr]s rFrWzStream._send_to_parsersL <<+ ++<<$$T* *   # # %   s (+Acb|j|_t|j|_yrf) _parser_fsmrQnextrB)rDs rFrRzStream._initialize_parsers#'') "&t||"4rHc #*K|j}|jJ|jj}jtj tj }}tj}tjdz}tjtjz}tjtjz}djtjtjtj tj"tj$tj&tj(g} t+tj,tj.tjg} dfd } | |} | |j0} | |j2}| |j4} d}||k(rsd}|dk(r|}ng|dk(r|}n_|dk(r | dnL|d k(r|j7dn3|d vr%d}|j8r^j;|| n ||}||vr?|tj<k(s|tj>k(r |j8r| |n||k(rg}d}d } d}|d k(rd}n|| vr | |ny||vrnt||vr ||n|jAr||z }nQ|dk(rdn|jCtEtG|xsdd|dk(rd}n|r |||ddin|||nr||k(r`d}|dk(rq|dk(rxd} d}||k(r|dz }|| vrn||z }|dd}|dvrjI||dvrjK|n ||vr||ӭw)aRAn FSM implemented as a coroutine. This generator is not the most beautiful, but it is as performant as possible. When a process generates a lot of output, then this will be the bottleneck, because it processes just one character at a time. Don't change anything without profiling first. N>r<cbtfdtfd|jDS)NcSrf)r;srFz?Stream._parser_fsm..create_dispatcher..surHc3@K|]\}}|t|fywrf)getattr).0rSattrr?s rF z@Stream._parser_fsm..create_dispatcher..s)34E4$/034s)rdictitems)mappingr;r?s rFcreate_dispatcherz-Stream._parser_fsm..create_dispatchers,}d34#*==?34/45 5rHT[]#%z())modeF?$ri';privateRPr 0102)rxzMapping[str, str]returnzDict[str, Callable[..., None]])&basicr?r:r;ctrlESCCSI_C1OSC_C1SPNULDELCANSUBjoinBELBSHTLFVTFFCRsetST_C0ST_C1sharprcsiselect_other_charsetrAr7SISOisdigitappendminintr8r9)rDrr:rrrSP_OR_GT NUL_OR_DEL CAN_OR_SUBALLOWED_IN_CSIOSC_TERMINATORSrybasic_dispatchsharp_dispatchescape_dispatch csi_dispatchcharcodeparamscurrentrparamr;r?s @@rFrizStream._parser_fsmsx }}(((==}}hh V77S=XX( XX( $((DGGTWWdgg"&''477DGG"=>tzz4::txx@A 5 +51*4::6+DKK8(2 :Ds{"z3;!DS[!Ds{4d 4611:?%)z==$!//4/@--/u}DGGOttwwDMM$t$&!%:Ds{"&/,t,.)+ T 4#  c#gl*;T&BC3;&(G& 2 T 2F ID I 2 T 2F ;!AB!z3;S[!%:Ds{d *. ab 4<**514<&&u-Z'T ssNNcy)a,Select other (non G0 or G1) charset. :param str code: character set code, should be a character from ``"@G8"``, otherwise ignored. .. note:: We currently follow ``"linux"`` and only use this command to switch from ISO-8859-1 to UTF-8 and back. .. versionadded:: 0.6.0 .. seealso:: `Standard ECMA-35, Section 15.4 `_ for a description of VTXXX character set machinery. NrorDrs rFrzStream.select_other_charset~srHr>)rEzOptional[Screen]r@boolrNone)rErrr)r]strrr)r]rrzOptional[bool])rr)rParserGeneratorrrrr)P__name__ __module__ __qualname____doc__rrrrrrrrrrrescRISINDNELRIHTSDECSCDECRCrDECALNrICHCUUCUDCUFCUBCNLCPLCHACUPEDELILDLDCHECHHPRDAVPAVPRHVPTBCSMRMSGRDSRDECSTBMHPAr frozenset itertoolschainvaluesrNrrrrrr_specialupdaterecompilermaprYrGrCrUrdrWrRrirrorHrFrr's&: &      "   E      = #F ' E   $      !           #  "  "        $  #  !! " *# $ !  " !     + ' ] #7 C>y    +&  FDHHdkk488TXXt{{KLH OOEBJJ rwws299h/00479M "(!4:5\| rHrc8eZdZdZdfd Zdfd ZddZxZS) ByteStreamaEA stream which takes bytes as input. Bytes are decoded to text using either UTF-8 (default) or the encoding selected via :meth:`~pyte.Stream.select_other_charset`. .. attribute:: use_utf8 Assume the input to :meth:`~pyte.streams.ByteStream.feed` is encoded using UTF-8. Defaults to ``True``. cltt| |i|tjdd|_y)Nzutf-8replace)superrrGcodecsgetincrementaldecoder utf8_decoder)rDargskwargs __class__s rFrGzByteStream.__init__s1 j$($9&9AF88A)LrHc|jr|jj|}ndjt t |}t t|#|y)Nr<) rArdecoderrchrrrrd)rDr]data_strrs rFrdzByteStream.feedsC ==((//5Hwws3~.H j$$X.rHcj|dk(r"d|_|jjy|dvrd|_yy)N@FG8T)rArrrs rFrzByteStream.select_other_charsets5 3;!DM    # # % T\ DMrH)rrrr)r]bytesrrr)rrrrrGrdr __classcell__)rs@rFrrs M /!rHr)r __future__rrrrrJ collectionsrcollections.abcrtypingrrrr r r r<r rrrscreensrrrrrrrorHrFrs`(#  ##JJ,HTNC56g g V !!rH