Nh# SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK J r SSK Jr SSKJr SSKJrJrJrJrJrJr SS KJr SS KJr SS KJrJr SS KJ r SS K!J"r" SSK#J$r$J%r%J&r&J'r'J(r( SSK)J*r* SSK+J,r, SSK-J.r.J/r/ SSK0J1r1J2r2 SSK3J4r4J5r5 SSK6J7r7J8r8J9r9 SSK:J;r;Jr>J?r? /SQr@\R"\B5rC"SS\D5rE"SS\5rF"SS5rG\R"S5rI"SS 5rJ\S!/S4rK\S!/\L4rM"S"S!5rN\"S#\S$\\\S44S%9rOS,S&jrP"S'S(\D5rQS-S.S)jjrRS-S.S*jjrSS/S+jrTg)0zU Data structures for the Buffer. It holds the text, cursor position, history, etc... ) annotationsN)deque)Enum)wraps)AnyCallable CoroutineIterableTypeVarcast)get_app)run_in_terminal) AutoSuggest Suggestion) FastDictCache) ClipboardData) CompleteEvent Completer CompletionDummyCompleterget_common_complete_suffix)Document)aclosing) FilterOrBool to_filter)HistoryInMemoryHistory)SearchDirection SearchState) PasteModeSelectionState SelectionType)Eventto_str)ValidationError Validator)EditReadOnlyBufferBufferCompletionStateindentunindent reshape_textc\rSrSrSrSrg)r(6z.Attempt editing of read-only :class:`.Buffer`.N__name__ __module__ __qualname____firstlineno____doc____static_attributes__r0R/home/mande/repo/quber/.venv/lib/python3.13/site-packages/prompt_toolkit/buffer.pyr(r(6s4r8r(c$\rSrSrSrSrSrSrSrg)ValidationState:zCThe validation state of a buffer. This is set after the validation.VALIDINVALIDUNKNOWNr0N) r2r3r4r5r6r=r>r?r7r0r8r9r;r;:sI EGGr8r;cj\rSrSrSrS S SjjrS SjrS SjrSSjr\ SSj5r S r g)r*Bz3 Immutable class that contains a completion state. Nc<XlU=(d /UlX0lgN)original_document completionscomplete_index)selfrDrErFs r9__init__CompletionState.__init__Gs!"3',"-r8cURRSUR<S[UR5<SUR <S3$)N(z, completions, index=)) __class__r2rDlenrErFrGs r9__repr__CompletionState.__repr__Xs_..))*!D,B,B+ESTM]M]I^Haavw{xKxKwNNOP Pr8cUR(a/Ub%SUs=::a[UR5:de eXlgg)zt Create a new :class:`.CompletionState` object with the new index. When `index` is `None` deselect the completion. Nr)rErNrFrGindexs r9 go_to_indexCompletionState.go_to_index[sC   =A$FT5E5E1F$F FF$F FF"'  r8cURc,URRURR4$URRnURR nUR URnURS:XaUnOUSURnXCR-U-n[U5[UR5-nXV4$)z= Return (new_text, new_cursor_position) for this completion. Nr) rFrDtextcursor_positiontext_before_cursortext_after_cursorrEstart_positionrN)rGoriginal_text_before_cursororiginal_text_after_cursorcbeforenew_textnew_cursor_positions r9new_text_and_position%CompletionState.new_text_and_positiones    &))..0F0F0V0VV V*.*@*@*S*S ')-)?)?)Q)Q &  !4!45A1$445Gq7G7GH)CCH"%f+AFF "; 0 0r8cPURbURUR$g)zQ Return the current completion, or return `None` when no completion is selected. N)rFrErOs r9current_completion"CompletionState.current_completionys*    *##D$7$78 8r8)rFrErD)NN)rDrrEzlist[Completion] | NonerF int | NonereturnNoneristrrTrhrirj)riztuple[str, int])rizCompletion | None) r2r3r4r5r6rHrPrUrcpropertyrfr7r0r8r9r*r*Bs^04%) -#---# -  -"P(1(r8r*z(\s+|".*?"|'.*?')c@\rSrSrSrSSSjjrS SjrSrg) YankNthArgStatezL For yank-last-arg/yank-nth-arg: Keep track of where we are in the history. c(XlX0lX lgrC)history_positionprevious_inserted_wordn)rGrsrurts r9rHYankNthArgState.__init__s!1&<#r8cURRSUR<SUR<SUR<S3$)Nz(history_position=z, n=z, previous_inserted_word=rL)rMr2rsrurtrOs r9rPYankNthArgState.__repr__sa..))**SUS=jr?S]S|S>jjr@SUS?jrASUS@jrBS}S~SAjjrCSSBjrDSSSCjjrESSSDjjrFSUSEjrGSSFjrHSSGjrIS]SSHjjrJSSIjrKSSSJjjrLSSKjrMSSLjrNSSMjrOSUSNjrPSOrQg)r)a The core data structure that holds the text and cursor position of the current input line and implements all text manipulations on top of it. It also implements the history, undo stack and the completion state. :param completer: :class:`~prompt_toolkit.completion.Completer` instance. :param history: :class:`~prompt_toolkit.history.History` instance. :param tempfile_suffix: The tempfile suffix (extension) to be used for the "open in editor" function. For a Python REPL, this would be ".py", so that the editor knows the syntax highlighting to use. This can also be a callable that returns a string. :param tempfile: For more advanced tempfile situations where you need control over the subdirectories and filename. For a Git Commit Message, this would be ".git/COMMIT_EDITMSG", so that the editor knows the syntax highlighting to use. This can also be a callable that returns a string. :param name: Name for this buffer. E.g. DEFAULT_BUFFER. This is mostly useful for key bindings where we sometimes prefer to refer to a buffer by their name instead of by reference. :param accept_handler: Called when the buffer input is accepted. (Usually when the user presses `enter`.) The accept handler receives this `Buffer` as input and should return True when the buffer text should be kept instead of calling reset. In case of a `PromptSession` for instance, we want to keep the text, because we will exit the application, and only reset it during the next run. :param max_number_of_completions: Never display more than this number of completions, even when the completer can produce more (limited by default to 10k for performance). Events: :param on_text_changed: When the buffer text changes. (Callable or None.) :param on_text_insert: When new text is inserted. (Callable or None.) :param on_cursor_position_changed: When the cursor moves. (Callable or None.) :param on_completions_changed: When the completions were changed. (Callable or None.) :param on_suggestion_set: When an auto-suggestion text has been set. (Callable or None.) Filters: :param complete_while_typing: :class:`~prompt_toolkit.filters.Filter` or `bool`. Decide whether or not to do asynchronous autocompleting while typing. :param validate_while_typing: :class:`~prompt_toolkit.filters.Filter` or `bool`. Decide whether or not to do asynchronous validation while typing. :param enable_history_search: :class:`~prompt_toolkit.filters.Filter` or `bool` to indicate when up-arrow partial string matching is enabled. It is advised to not enable this at the same time as `complete_while_typing`, because when there is an autocompletion found, the up arrows usually browse through the completions, rather than through the history. :param read_only: :class:`~prompt_toolkit.filters.Filter`. When True, changes will not be allowed. :param multiline: :class:`~prompt_toolkit.filters.Filter` or `bool`. When not set, pressing `Enter` will call the `accept_handler`. Otherwise, pressing `Esc-Enter` is required. Nc[U 5n [U5n[U 5n [U 5n [U5nU=(d [5UlX lX@lXPlX`lXplXlXl Xl Xl Xl Xl XlSUlUc [!5OUUlSUl['UU5Ul['UU5Ul['UU5Ul['UU5Ul['UU5Ul[3[4SS9UlUR95UlUR=5UlURA5Ul!SUl"URGU S9 g)Nr )size)document)$rr completer auto_suggest validatortempfile_suffixtempfilenameaccept_handlercomplete_while_typingvalidate_while_typingenable_history_search read_only multilinemax_number_of_completions text_widthrhistory_Buffer__cursor_positionr$on_text_changedon_text_inserton_cursor_position_changedon_completions_changedon_suggestion_setrr_document_cache_create_auto_suggest_coroutine_async_suggester_create_completer_coroutine_async_completer_create_auto_validate_coroutine_async_validator_load_history_taskreset)rGrrrrrrrrrrrrrrrrrrrrs r9rHBuffer.__init__sm0!**? @ )*? @ )*? @i( i( "6n&6(".  ,&;"%:"%:""")B& -4O( !"/4D/.J-24-H9> ,: '6;4AW5X#05d)rNrXrid)rGrXs r9rPBuffer.__repr__(sR tyy>B 99D99Sb>E)Dtyym74(%4|1MMr8cU(aUR5 U=(d [5nURUlSUl[ R UlSUl/Ul SUl SUl SUl SUl SUlSUl/Ul/UlUR$bUR$R'5 SUl[)UR*/5UlSUlg)zB :param append_to_history: Append current input to history first. Nr)append_to_historyrrYrvalidation_errorr;r?validation_stateselection_statemultiple_cursor_positionspreferred_columncomplete_stateyank_nth_arg_statedocument_before_paste suggestionhistory_search_text _undo_stack _redo_stackrcancelrrX_working_lines_Buffer__working_index)rGrrs r9r Buffer.reset0s   " " $)xz!)!9!99=8G8O8O7; 57&-17;;?7;".204 3524  " " .  # # * * ,"&+0*@ r8c^TRcLSU4Sjjn[5RU"55TlSSjnTRRU5 gg)a~ Create task for populating the buffer history (if not yet done). Note:: This needs to be called from within the event loop of the application, because history loading is async, and we need to be sure the right event loop is active. Therefor, we call this method in the `BufferControl.create_content`. There are situations where prompt_toolkit applications are created in one thread, but will later run in a different thread (Ptpython is one example. The REPL runs in a separate thread, in order to prevent interfering with a potential different event loop in the main thread. The REPL UI however is still created in the main thread.) We could decide to not support creating prompt_toolkit objects in one thread and running the application in a different thread, but history loading is the only place where it matters, and this solves it. Nc># TRR5ShvN nTRRU5 T=RS- slM;N6 g7f)Nr )rloadr appendleftr)itemrGs r9 load_history;Buffer.load_history_if_not_yet_loaded..load_historysJ"&,,"3"3"5.$''2248((A-(."5s%AAAA3AAAcUR5 g![Ra g[a g[a [ R S5 gf=f)z\ Handle `load_history` result when either done, cancelled, or when an exception was raised. zLoading history failedN)resultasyncioCancelledError GeneratorExit BaseExceptionlogger exception)fs r9load_history_done@Buffer.load_history_if_not_yet_loaded..load_history_donesP ?HHJ--$$?$$%=>?sA AAArirj)rzasyncio.Future[None]rirj)rrcreate_background_taskadd_done_callback)rGrrs` r9load_history_if_not_yet_loaded%Buffer.load_history_if_not_yet_loadedqsP*  " " * . '.i&F&F|~&VD # ?*  # # 5 56G H= +r8cURnURnX2nXU'[U5[U5:wagX:wagg)z=set text at current working_index. Return whether it changed.TF) working_indexrrN)rGvaluer working_linesoriginal_values r9 _set_textBuffer._set_textsL** ++ &5',m$ u:^, ,   $r8cZURn[SU5UlURU:g$)z/Set cursor position. Return whether it changed.r)rmax)rGroriginal_positions r9_set_cursor_positionBuffer._set_cursor_positions. 22!$Q%%):::r8c4URUR$rC)rrrOs r9rX Buffer.texts""4#5#566r8cUR[U5:a[U5UlUR5(a [5eUR U5nU(aUR 5 SUlgg)z Setting text. (When doing this, make sure that the cursor_position is valid for this text. text/cursor_position should be consistent at any time, otherwise set a Document instead.) N)rYrNrr(r _text_changedrrGrchangeds r9rXrsf   #e* ,#&u:D  >>  $& &..'     (,D $ r8cUR$rC)rrOs r9rYBuffer.cursor_positions%%%r8c[U[5(deU[UR5:a[UR5nUS:aSnUR U5nU(aUR 5 gg)z Setting cursor position. rN) isinstancer{rNrXr_cursor_position_changedrs r9rYrsf %%%%% 3tyy> ! NE 19E++E2   ) ) + r8cUR$rC)rrOs r9rBuffer.working_indexs###r8c`URU:waXlSUlUR5 gg)Nr)rrYrrGrs r9rrs1   5 (#( $%D    )r8cbSUl[RUlSUlSUlSUlSUlSUlSUl URR5 UR(a>UR5(a([5RUR!55 gggrC)rr;r?rrrrrrrrfirerrrrrrOs r9rBuffer._text_changeds $ / 7 7""&%)"# $ !!# >>d88:: I , ,T-B-B-D E;>r8cpSUlSUlSUlSUlURR 5 grC)rrrrrrrOs r9rBuffer._cursor_position_changeds:#"&%)"!% '',,.r8cbURURURUR4$)zx Return :class:`~prompt_toolkit.document.Document` instance from the current text, cursor position and selection state. )rrXrYrrOs r9rBuffer.document+s1 ## IIt++T-A-A A  r8c&URU5 g)z Set :class:`~prompt_toolkit.document.Document` instance. This will set both the text and cursor position at the same time, but atomically. (Change events will be triggered only after both have been set.) N) set_documentrs r9rr5s % r8c(U(dUR5(a [5eURUR5nUR UR 5nU(aUR 5 SUlU(aUR5 gg)a Set :class:`~prompt_toolkit.document.Document` instance. Like the ``document`` property, but accept an ``bypass_readonly`` argument. :param bypass_readonly: When True, don't raise an :class:`.EditReadOnlyBuffer` exception, even when the buffer is read-only. .. warning:: When this buffer is read-only and `bypass_readonly` was not passed, the `EditReadOnlyBuffer` exception will be caught by the `KeyProcessor` and is silently suppressed. This is important to keep in mind when writing key bindings, because it won't do what you expect, and there won't be a stack trace. Use try/finally around this function if you need some cleanup code. N) rr(rrXrrYrrr)rGrbypass_readonly text_changedcursor_position_changeds r9rBuffer.set_document?st&4>>#3#3$& &~~ejj1 "&";";EUR(aLURSSUR:Xa,URSSUR4URS'O1URRURUR45 U(a/Ulgg)za Safe current state (input text and cursor position), so that we can restore it by calling undo. ryrN)rrXrYappendr)rGclear_redo_stacks r9save_to_undo_stackBuffer.save_to_undo_stackks    0 0 4Q 7499 D$($4$4R$8$;T=Q=Q#RD  R    # #TYY0D0D$E F !D  r8cURRS5nUHnU"X45X4'M SRU5$![a M2f=f)a Transforms the text on a range of lines. When the iterator yield an index not in the range of lines that the document contains, it skips them silently. To uppercase some lines:: new_text = transform_lines(range(5,10), lambda text: text.upper()) :param line_index_iterator: Iterator of line numbers (int) :param transform_callback: callable that takes the original text of a line, and return the new text for this line. :returns: The new text.  )rXsplit IndexErrorjoin)rGline_index_iteratortransform_callbacklinesrTs r9transform_linesBuffer.transform_lines{sZ* %)E 1%,? ) yy  s A AAcURnURUR5-nURUR5-nURSUU"URX45-URUS-Ulg)z Apply the given transformation function to the current line. :param transform_callback: callable that takes a string and return a new string. N)rrYget_start_of_line_positionget_end_of_line_positionrX)rGrrabs r9transform_current_lineBuffer.transform_current_lines} ==  $ $x'J'J'L L  $ $x'H'H'J J MM"1  q!34 5mmAB  r8cX:deSRURSUU"URX5-URUS-/5Ulg)z Transform a part of the input string. :param from_: (int) start position. :param to: (int) end position. :param transform_callback: Callable which accepts a string and returns the transformed string. rzN)rrX)rGfrom_tors r9transform_regionBuffer.transform_regionsYzzGG &5!$TYYu%89:))BC.!   r8r c\U=RURRUS9- slgNcount)rYrget_cursor_left_positionrGrs r9 cursor_leftBuffer.cursor_lefts%  F FU F SSr8c\U=RURRUS9- slgr)rYrget_cursor_right_positionrs r9 cursor_rightBuffer.cursor_rights%  G Ge G TTr8cUR=(d URRnU=RURR XS9- slX lg)z7(for multiline edit). Move cursor to the previous line.rrN)rrcursor_position_colrYget_cursor_up_positionrGroriginal_columns r9 cursor_upBuffer.cursor_upsO//T4==3T3T  D D!E!   !0r8cUR=(d URRnU=RURR XS9- slX lg)z3(for multiline edit). Move cursor to the next line.r%N)rrr&rYget_cursor_down_positionr(s r9 cursor_downBuffer.cursor_downsO//T4==3T3T  F F!G!   !0r8cFUR(aURUS9 gURRS:aUR US9 gUR (dEUR US9 U(a.U=RURR5- slggg)z} If we're not on the first line (of a multiline input) go a line up, otherwise go back in history. (If nothing is selected.) rrN) rcomplete_previousrcursor_position_rowr*rhistory_backwardrYr rGr&go_to_start_of_line_if_history_changess r9auto_upBuffer.auto_ups     " " " / ]] . . 2 NNN '%%  ! ! ! .6$$ (P(P(RR$6 &r8ctUR(aURUS9 gURRURRS- :aUR US9 gUR (dEURUS9 U(a.U=RURR5- slggg)z If we're not on the last line (of a multiline input) go a line down, otherwise go forward in history. (If nothing is selected.) rr N) r complete_nextrr2 line_countr.rhistory_forwardrYr r4s r9 auto_downBuffer.auto_downs      U  + ]] . .1I1IA1M M   5  )%%  u -6$$ (P(P(RR$6 &r8cBUS:deSnURS:aURURU- URnURSURU- URURS-nUR[U5- n[X45UlU$)zR Delete specified number of characters before cursor and return the deleted text. rrzN)rYrXrNrr)rGrdeletedrarbs r9delete_before_cursorBuffer.delete_before_cursors zz   ! #ii 4 4u URR(dU=RURR5- slUR 5 URR U-URR RS5-Ulgg)z[ Join the next line to the current one by deleting the line ending after the current line.  N) r on_last_linerYrrCrZr[lstriprX)rG separators r9join_next_lineBuffer.join_next_line!sx }}))  DMM$J$J$L L KKM 00--1188=> I *r8c UR(de[URURR/5up#URSUnURX#R 5nURUSnUVs/sHowR S5U-PM nn[USRU5-U-[USRUSS5-5S- S9Ul gs snf)z Join the selected lines. NrFrzryr rXrY) rsortedrYoriginal_cursor_positionrX splitlinesrHrrrNr)rGrIrrr`r afterls r9join_selected_linesBuffer.join_selected_lines1s####  ! !4#7#7#P#P Q 6E" %#..0 "#5::Eq#*E:!"''%.(50s)< <=A  ;s?C$cURnUS:aRURUS- nURUS- nURSUS- U-U-URUS-Ulgg)z1 Swap the last two characters before the cursor. r N)rYrX)rGposrrs r9swap_characters_before_cursor$Buffer.swap_characters_before_cursorIsn"" !8 #'"A #'"A )C!G,q014tyyFDI r8cxU[UR5:a!Xl[UR5Ulgg)z! Go to this item in the history. N)rNrrrXrYrSs r9 go_to_historyBuffer.go_to_historyUs2 3t**+ +!& #&tyy>D  ,r8cXUR(a[URR5nURRcSnONURRUS- :Xa SnU(agO&[ US- URRU-5nUR U5 gg)zL Browse to the next completions. (Does nothing if there are no completion.) Nrr )rrNrErFmingo_to_completion)rGrdisable_wrap_aroundcompletions_countrTs r9r9Buffer.complete_next]s    #D$7$7$C$C D ""119$$337H17LL&'%)4+>+>+M+MPU+U  ! !% ( r8cNUR(aURRS:Xa SnU(agO]URRc#[URR5S- nO#[ SURRU- 5nUR U5 gg)zP Browse to the previous completions. (Does nothing if there are no completion.) rNr )rrFrNrErr_)rGrr`rTs r9r1Buffer.complete_previousts   ""11Q6&'$$33;D//;;D  r8cUb[U[5(deURR5n[ U5(dgUR c[ U(aSOSS9nO UR nUbXlURS- nU*[ U5:aSnX5n[RU5Vs/sHowR5PM nnUVs/sH ow(dM UPM nnXRn UR(a$UR[ UR55 URU 5 Xl XTlX@lgs snfs snf![a Sn Nqf=f)aA Pick nth word from previous history entry (depending on current `yank_nth_arg_state`) and insert it at current position. Rotate through history if called repeatedly. If no `n` has been given, take the first argument. (The second word.) :param n: (None or int), The index of the word from the previous line to take. Nryr )rurz)rr{r get_stringsrNrrprurs_QUOTED_WORDS_RErrqrrtr@r) rGru_yank_last_arghistory_stringsr|new_poslinewwordswords r9 yank_nth_argBuffer.yank_nth_arg$sLyJq#....,,224?##   " " *#NbBE++E =G((1, 8c/* *G'$4$:$:4$@A$@q$@A!'EqQE' >D  ' '  % %c%*F*F&G H (,$!("'!B' D s$7E E$E-E E-,E-c$URUSS9 g)zX Like `yank_nth_arg`, but if no argument has been given, yank the last word by default. T)rurN)r)rGrus r9 yank_last_argBuffer.yank_last_argWs Ad3r8c:[URU5Ulg)zB Take the current cursor position as the start of this selection. N)r"rYr)rGselection_types r9start_selectionBuffer.start_selection^s .d.B.BNSr8cfURR5up#U(aX lSUlU$)a Copy selected text and return :class:`.ClipboardData` instance. Notice that this doesn't store the copied data on the clipboard yet. You can store it like this: .. code:: python data = buffer.copy_selection() get_app().clipboard.set_data(data) N)r cut_selectionr)rG_cut new_documentclipboard_datas r9copy_selectionBuffer.copy_selectionfs/(,}}'B'B'D$ (M#r8c URSS9$)zC Delete selected text and return :class:`.ClipboardData` instance. T)r)rrOs r9rBuffer.cut_selectionys"""--r8c[U[5(deU[R[R[R 4;deUR nUR RXUS9UlX@lg)z% Insert the data from the clipboard. ) paste_moderN) rrr! VI_BEFOREVI_AFTEREMACSrpaste_clipboard_datar)rGdatarrrDs r9rBuffer.paste_clipboard_datasn$ ....i1193E3EyWWWW MM :: u;  &7"r8cU(a)URSURR-5 gURS5 g)z/ Insert a line ending at the current position. rN)rr"leading_whitespace_in_current_line)rG copy_margins r9newlineBuffer.newlines2    TDMM$T$TT U   T "r8cU(aURRS-nOSnU=RURR5- slUR U5 U=RS-slg)z* Insert a new line above the current one. rr N)rrrYr rrGrinserts r9insert_line_aboveBuffer.insert_line_aboves] ]]EELFF  H H JJ   !r8cU(aSURR-nOSnU=RURR5- slUR U5 g)z* Insert a new line below the current one. rN)rrrYrrrs r9insert_line_belowBuffer.insert_line_belowsL DMMLLLFF  F F HH  r8cURnURnU(aDXVU[U5-nSU;aUSURS5nUSUU-XV[U5-S-nO USUU-XVS-nU(aUR[U5-n O URn [ X5UlU(aUR R5 UR(a<UR5(a'[5RUR55 UR(a([5RUR55 ggg)z Insert characters at cursor position. :param fire_event: Fire `on_text_insert` event. This is mainly used to trigger autocompletion while typing. rN)rXrYrNfindrrrrrrrrrrr) rGr overwrite move_cursor fire_eventotextocposoverwritten_textrXcposs r9rBuffer.insert_texts: $$  %USY->? ''#34Q6F6K6KD6Q#R %=4'%"> 001F1F1HI   001F1F1HI! r8c$UR(aURR5upXR:wa@URR URUR 45 [ XS9UlgUR(aM~gg)NrY)rpoprXrrrYrrrGrXrWs r9undo Buffer.undoso ((,,.IDyy   ''D4H4H(IJ!) C r8cUR(a:URSS9 URR5up[XS9Ulgg)NF)rr)rrrrrrs r9redo Buffer.redosE     # #U # ;((,,.ID$T?DM r8cUR[R:waUR[R:H$UR(a&URR UR 5 [RUlSUlg![adnU(a8[[SUR5[UR55Ul [RUlX lSnAgSnAff=f)z^ Returns `True` if valid. :param set_cursor: Set the cursor position, if an error was found. rNFT)rr;r?r=rvalidaterr&r^rrYrNrXr>r)rG set_cursores r9rBuffer.validates  O$;$; ;((O,A,AA A >> '' 6!0 5 5 $# +.Aq0013tyy>,D()8(?(?%()% s%B C>AC99C>c# UR[R:wagSnURnUR(a@URR UR5IShvN URU:waMU(a[RUlO[RUlXl [5R5 MNh![ a nUnSnANwSnAff=f7f)a Asynchronous version of `validate()`. This one doesn't set the cursor position. We have both variants, because a synchronous version is required. Handling the ENTER key needs to be completely synchronous, otherwise stuff like type-ahead is going to give very weird results. (People could type input while the ENTER key is still processed.) An asynchronous version is required if we have `validate_while_typing` enabled. N) rr;r?rrvalidate_asyncr&r>r=rr invalidate)rGerrorrrs r9_validate_asyncBuffer._validate_async"s$$(?(??E}}H~~..77 FFF ==H,(7(?(?%(7(=(=%$) ! I "7G&EsCAC/(C+C,C0A$C/C C, C'"C/'C,,C/cUR(adURR5n[U5(aUSUR:wa&URR UR5 ggg)z* Append the current input to the history. ryN)rXrrrN append_string)rGrs r9rBuffer.append_to_historyLsY 99"ll668O''?2+>$))+K **4995,L r8c ^^^ ^ ^ US:deURm URm UR5m SU U UUU 4SjjnTRnTRn[ U5HnU"XV5nUc gUupVM XVR 4$)z Execute search. Return (working_index, cursor_position) tuple when this search is applied. Returns `None` when this text cannot be found. rcl>T[R:XaURTTTS9nUb%U[URUR U-54$[ US-[TR5S-5HbnU[TR5-n[TRUS5nURTSTS9nUcMJU[URU54s $ gURTTS9nUb%U[URUR U-54$[ US- SS5HnU[TR5-n[TRU[TRU55nURTTS9nUcM_U[UR[UR5U-54s $ g) z@ Do search one time. Return (working_index, document) or `None` )include_current_position ignore_caseNr rT)rry) rFORWARDrrrXrYrrNrfind_backwards) rr new_indexrv directionrrrGrXs r9 search_once#Buffer._search..search_oncegsO333$MM-E +* (% 0H0H90TU#=1#4c$:M:M6NQR6RSS!4!455#+D,?,?,BA#F$,MM 4[%2% %0$%x y'I#JJTD/%33Dk3R (% 0H0H90TU #=1#4b"=S!4!455#+ //2C8K8KA8N4O$%-$;$; k%<% %0 ! (HMM8JY8V W$>r8N)rr{rrriztuple[int, Document] | None)rXrrrrrrY) rG search_staterrrrr_rrrrXs ` ` @@@r9_searchBuffer._searchWsqyy   ** "..0 : : *2:  (: : z** ==uA 9F~*0' x 7788r8cURUSS9nUc UR$Uup4X0R:Xa URnOSn[ UR UXES9$)z Return a :class:`~prompt_toolkit.document.Document` instance that has the text/cursor position for this search, if we would apply it. This will be used in the :class:`~prompt_toolkit.layout.BufferControl` to display feedback while searching. T)rN) selection)rrrrrr)rGr search_resultrrYrs r9document_for_searchBuffer.document_for_searchsi \D Q  == -: *M 2 22 00  ##M2O r8cLURXUS9nUc UR$UupVU$)z Get the cursor position for this search. (This operation won't change the `working_index`. It's won't go through the history. Vi text objects can't span multiple items.) rr)rrYrGrrrrrrYs r9get_search_positionBuffer.get_search_positions? SX%   '' '-: *M" "r8cLURXUS9nUbUupVXPlX`lgg)zQ Apply search. If something is found, set `working_index` and `cursor_position`. rN)rrrYrs r9 apply_searchBuffer.apply_searchs> SX%   $-: *M!. #2  %r8cSUlgrC)rrOs r9exit_selectionBuffer.exit_selections #r8c^[UR5n[R"U5unm[R "X R RS55 [R"U5 SU4SjjnTU4$)zI Simple (file) tempfile implementation. Return (tempfile, cleanup_func). utf-8c2>[R"T5 grC)osunlink)filenamesr9cleanup/Buffer._editor_simple_tempfile..cleanups IIh r8r) r%rrmkstemprwriterXencodeclose)rGsuffix descriptorrrs @r9_editor_simple_tempfileBuffer._editor_simple_tempfilesc ,,-'//7 H YY--g67    r8c^[UR5nU(dUR5$[U5n[R R U5up#[R RU5(aUSSn[R"5mU(a [R RTU5m[R"T5 [R RTU5n[USSS9nURUR5 SSS5 SU4SjjnXF4$!,(df  N=f)Nr rr)encodingc2>[R"T5 grC)shutilrmtree)dirpathsr9r0Buffer._editor_complex_tempfile..cleanups MM' "r8r)r%rrrlrpathrisabsmkdtemprmakedirsopenr rX)rGheadtailheadtailrfhrrs @r9_editor_complex_tempfileBuffer._editor_complex_tempfiles$--(//1 1x=WW]]8,  77==  8D""$ ggll7D1G G77<<. (C' 2b HHTYY 3 #  3 2s D// D=c ^^^^TR5(a [5eTR(aTR5ummOTR 5ummSUUUU4Sjjn[ 5R U"55$)zM Open code in editor. This returns a future, and runs in a thread executor. c># [UU4SjSS9IShvN nU(a~[TS5nUR5RS5nUR S5(aUSSn[ U[ U5S9TlSSS5 T(aTR5 T"5 gN!,(df  N/=f!T"5 f=f7f) Nc&>TRT5$rC)_open_file_in_editor)rrGsr94Buffer.open_in_editor..run..6sD55h?r8T) in_executorrbrrryrM) rrreaddecodeendswithrrNrvalidate_and_handle)successrrX cleanup_funcrrGr.s r9run"Buffer.open_in_editor..run/s  !0?T! h- vvxw7 ==..#'9D(0dCPTI(V .+002- .- sDCB<B)B<AB+B<!C)B<+ B95B<< CCr)rr(rr!rrr)rGr.r1r0rs`` @@r9open_in_editorBuffer.open_in_editor sk >>  $& & ==%)%B%B%D "Hl%)%A%A%C "Hl  <y//66r8c@[RRS5n[RRS5nUUSSSSS/nUH@nU(dM [R"[ R "U5U/-5nUS:Hs $ g ![a MRf=f) zK Call editor executable. Return True when we received a zero return code. VISUALEDITORz/usr/bin/editorz /usr/bin/nanoz /usr/bin/picoz /usr/bin/viz/usr/bin/emacsrF)renvironget subprocesscallshlexrOSError)rGrvisualeditoreditorsr returncodes r9r&Buffer._open_file_in_editorOs))         Aq",Q8*1L!MJ%?*  s2B BBc X-U-S::de[5RURUUUU=(d [SS9S95 g)zz Start asynchronous autocompletion of this buffer. (This will do nothing if a previous completion was still in progress.) r T)completion_requested) select_first select_lastinsert_common_partcomplete_eventN)rrrr)rGrErFrGrHs r9start_completionBuffer.start_completionssW),>>!CCC ((  ! !)'#5- < d; "  r8cV^^SSjm[SSUU4Sjjj5nU$)z Create function for asynchronous autocompletion. (This consumes the asynchronous completer generator, which possibly runs the completion algorithm in another thread.) clURnU[U5UR-SnX1R:H$)zj Return `True` if applying this completion doesn't have any effect. (When it doesn't insert any new text. N)rZrNr\rX)rrrZ replaced_texts r9completion_does_nothingCBuffer._create_completer_coroutine..completion_does_nothings@ "*!^ ^# TRnU=(d [SS9nTR(dTR(dg[ TRS9m T TlS U U4Sjjn[ R "5mS UU4Sjjn[ R"U"55n[TRRXC55IShvN nUShvN n T RRU 5 TR5 U"5(d O&[T R5TR:dMg SSS5IShvN UR5 TR R#5 T Rn [U 5S:XaT"XJS5(aU SS2 U"5(Ga2TR(aTRR$bgU (d"STlTR R#5 gU(aTR'S5 gU(aTR'[U 5S- 5 gU(a[)XJ5n U (afTR+U 5 [U 5S:a>U V s/sHn U R-[U 55PM sn U SS&TR/U S9 gSTlg[U 5S:XaTR'S5 gggTRR0UR0:XagTRR0R3UR05(a[4egGNxGNp GNGN!,IShvN (df  GN=f!UR5 TR R#5 f=fs sn f7f) NT) text_inserted)rDc">TRT:H$)zYKeep retrieving completions. Input text has not yet changed while generating completions.)r)rrGsr9proceedLBuffer._create_completer_coroutine..async_completer..proceeds**n<# TRR5 TR5 [R"S5IShvN TR 5IShvN MbNN7f)aeBackground loop to refresh the UI at most 3 times a second while the completion are loading. Calling `on_completions_changed.fire()` for every completion that we receive is too expensive when there are many completions. (We could tune `Application.max_render_postpone_time` and `Application.min_redraw_interval`, but having this here is a better approach.) g333333?N)rrclearrsleepwait)refresh_neededrGsr9refresh_while_loadingZBuffer._create_completer_coroutine..async_completer..refresh_while_loadingsZ//446"((*!--,,,(--/// -/s$AA+A' A+ A)!A+)A+r rrmrirr)rrrrr*rr$ ensure_futurerget_completions_asyncrErrnrNrrrrrFr_rrnew_completion_from_positionrirZrr_Retry)rErFrGrHrrSrZ refresh_taskasync_generatorrrE common_partr_rrYrNrGs @@r9async_completer;Buffer._create_completer_coroutine..async_completers}}H+P}4/PN""$..-t}}MN"0D  = = %]]_N 0 0#001F1HIL 3#NN88R$,; "j&2299*E&**, 'yy!  : :;#==>"!$##%++002(44K;1$)@a.** Nyy++**99E#*.D'//446  ))!, ))#k*:Q*>?'" >s;?O P)4.KN !11k1J26D/{+q0 11!411(>==33x7R7RR==33>>//!L{ "O$##%++002^.sBN$(M+ M M+MM MM AM:M; M+M M+ D4N?$N#B!NM+M  M M+M(M  M(#M++,NN)rrrrrirFFFN rErrFrrGrrHzCompleteEvent | Nonerirj_only_one_at_a_time)rGrdrNs` @r9r"Buffer._create_completer_coroutinesl 4 !& %',37 J !J !J !!%J !1 J !  J !J ! J !Xr8c*^[SU4Sjj5nU$)zT Create function for asynchronous auto suggestion. (This can be in another thread.) c&># TRnTR(dTR(dgTRRTU5IShvN nTRU:Xa"UTlTRR 5 g[ eN<7frC)rrrget_suggestion_asyncrrr`)rrrGs r9async_suggestor>Buffer._create_auto_suggest_coroutine..async_suggestor3sr}}Hd&7&7#00EEdHUUJ}}(",&&++- VsABB=Brrh)rGrns` r9r%Buffer._create_auto_suggest_coroutine-s    $r8c*^[SU4Sjj5nU$)z^ Create a function for asynchronous validation while typing. (This can be in another thread.) cB># TR5IShvN gN7frC)rrOsr9async_validator?Buffer._create_auto_validate_coroutine..async_validatorPs&&( ( (s rrh)rGrss` r9r&Buffer._create_auto_validate_coroutineHs  )  )r8cURSS9nU(aNUR(aURU5nOSnUR5 U(dUR5 ggg)z/ Validate buffer and handle the accept action. T)rFN)rrrr)rGvalid keep_texts r9r.Buffer.validate_and_handleVsY  . "" //5 !  " " $  r8),__cursor_position__working_indexrrrrrrrrrrrrrrYrrrrrrrrrrrrrrrrrrrrrXrrrrrrr)NNNNrzrzrzFFFNNFTi'NNNNN)*rzCompleter | NonerzAutoSuggest | NonerzHistory | NonerzValidator | Nonerstr | Callable[[], str]rr|rrlrrrrrrrDocument | NonerzBufferAcceptHandler | Nonerrrrrr{rBufferEventHandler | Nonerr~rr~rr~rr~rirjrk)NF)rr}rrrirjr)rrlrir)rr{rir)rrlrirj)rir{)rr{rirj)rir)rrrirj)F)rrrrrirjr\)T)rrrirj)rz Iterable[int]rCallable[[str], str]rirl)rrrirj)rr{rr{rrrirjr )rr{rirj)r F)rr{r5rrirj)rr{rirl)rF)rIrlrirj)rTr{rirj)rr{r`rrirj)rEzlist[Completion]rir*rm)rrrirj)rvr{rir)rurhrrrirjrC)rurhrirj)rr#rirj)rrrir)rir)rrrr!rr{rirj)rrrirj)FTT) rrlrrrrrrrirj)rrrir)Fr )rr rrrr{riztuple[int, int] | None)rr rir)Tr )rr rrrr{rir{)rr rrrr{rirj)riztuple[str, Callable[[], None]])r.rrizasyncio.Task[None])rrlrirrfrg)riz(Callable[..., Coroutine[Any, Any, None]])riz'Callable[[], Coroutine[Any, Any, None]])Rr2r3r4r5r6rHrPrrrrrnrXsetterrYrrrrrrrr rrrr"r*r.r6r<r@rCrJrSrXr[r9r1rfriryr_rrrr;r3rrr# CHARACTERSrrrr!rrrrrrrrrrrrrrrrrr!r3r&rIrrrr.r7r0r8r9r)r)st9z'++/"&&*35,..3.3.3$(59"'"&).5948@D<@7;+O&#O&)O& O& $ O& 1 O&*O&O& ,O& ,O& ,O&"O&3O& O& O& $'!O&"3#O&$2%O&&%>'O&(!:)O&*5+O&, -O&bNKP?!'?!CG?! ?!B3In(;77 [[,,2&&,,"$$!!F(/$  __!!!,F))"  * 1   @    ! 7K  *TU00NSSSFJS S&NSSSFJS S$,   0 G2)0;@))37) ),' #"!H$" * , M02*1(f4/<.F.FT+T T&.!* 777 7  7*# " !   2J2J2J 2J  2J  2Jh @>(#T 6*/ V9!V9#'V9 V9 V9p8*. #!##'# # #0*. 3!3#'3 3  3&$! !:-7^"L#!#(/3    !  -    0`D6  0 r8_T.)boundcX^^Sm[T5SUU4Sjj5n[[U5$)z Decorator that only starts the coroutine only if the previous call has finished. (Used to make sure that we have only one autocompleter, auto suggestor and validator running at a time.) When the coroutine raises `_Retry`, it is restarted. Fc># T(agSmT"U0UD6IShvN SmgN![a M%f=f!Smf=f7f)NTF)r`)rkw coroutinerunnings r9 new_coroutine*_only_one_at_a_time..new_coroutinevs[    #Q-"--- G . Gs4 ?8 '%'?' 5858<?)rrrrrir)rr r)rrrs` @r9ririls0G 9( M ""r8c\rSrSrSrSrg)r`izRetry in `_only_one_at_a_time`.r0Nr1r0r8r9r`r`s%r8r`c@^URRnURRn[X5nSU-mUR UU4Sj5n[ U[ U5R US55UlU=RU[T5-- slg)z+ Indent text of a :class:`.Buffer` object.  c>TU-$rCr0)rRindent_contents r9r'indent..s NQTnURU5(aU[U5S$UR5$rC)rrrNrH)rXremovers r9 transformunindent..transforms4 ??6 " "F & &;;= r8rN)rXrlrirlr) rrrrrrrrrars @r9r,r,s//55K//55Kx(Je^N!%%jURRS5nUSUnX2S-SnX1US-nU(Gag[R"SUS5nU(aUR 5OSnUSSUR SS5n SR U5R5n UR=(d S[U 5- n U /n Sn U HynU (aP[U5U -S-U :a%U RS5 U RU 5 Sn OU RS 5 U S- n U RU5 U [U5- n M{ U S S:waU RS5 [SR XL-U-5[SR XL-55S 9Ul gg) zY Reformat text, taking the width into account. `to_row` is included. (Vi 'gq' operator.) TNr z^\s*rrrzPrFryrM) rXrPresearchendreplacerrrrNrrr)rrrr  lines_before lines_afterlines_to_reformatmatchlengthr+rwidth reshaped_text current_widthrs r9r-r-s KK " "4 (E(#L %K!4 '#4Q#78 %1"1%gv.66tR@)*002""(bCK7  Aq6M)A-5!((.!((0$%M!((-!Q&M   # SV #M   $   &#5 CD (D EF ?r8)rrrirr) rr)rr{rr{rr{rirj)rr)rr{rr{rirj)Ur6 __future__rrloggingrrr<rr:r collectionsrenumr functoolsrtypingrrr r r r application.currentrapplication.run_in_terminalrrrrcacher clipboardrrrrrrrrr eventlooprfiltersrrrrrrrr rr!r"r#utilsr$r% validationr&r'__all__ getLoggerr2r Exceptionr(r;r*compilerrpBufferEventHandlerrBufferAcceptHandlerr)rrir`r+r,r-r0r8r9rs? # DD(81 $,-0?? 2    8 $55d??D::67 ^ ^ xj$./z4/0KK\6 T#yc4'@"@AB#D&Y&@&@6- r8