U /ew@sddlmZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z m Z ddlmZmZmZGdddejZdd Zd d ZdS) ) annotationsN)adaptercommonlauncher)jsonlog messagingsockets) componentsserverssessionscseZdZUdZejjZded<GdddejZGdddejZ fdd Z d d Z d d Z eddZ eddZeddZddZeddZeddZeddZeddZeddZed d!Zed"d#Zed$d%Zed&d'Zfd(d)Zd*d+ZZS),Clientz+Handles the client side of a debug session.zset[servers.Connection]known_subprocessesc@seZdZdddddddZdS)zClient.CapabilitiesF)ZsupportsVariableTypeZsupportsVariablePagingZsupportsRunInTerminalRequestZsupportsMemoryReferences#supportsArgsCanBeInterpretedByShellsupportsStartDebuggingRequestN)__name__ __module__ __qualname__ PROPERTIESrr;/tmp/pip-unpacked-wheel-dg3irmqq/debugpy/adapter/clients.py Capabilitiessrc@s$eZdZdddejddddZdS)zClient.Expectationszen-USTpathoptional)localeZ linesStartAt1ZcolumnsStartAt1Z pathFormatN)rrrrenumrrrrr Expectations$s  rc s|dkrbtd|d|_tj}ttjdt _ }t |j ttjdt _}t |j nd|_tj|}tT}t||d|_d|_d|_d|_d|_g|_d|_t|_||_| W5QRX|jddd d t j!id |jddd d t j!id dS) NZstdioz"Connecting to client over stdio...TrwFoutputZ telemetryZptvsdZpackageVersion)categoryr datadebugpy)"rinfo using_stdiorZ JsonIOStreamZ from_stdioopenosdevnullsysstdinatexitregisterclosestdoutZ from_socketr Sessionsuper__init__ client_id has_started start_requestrestart_requested_initialize_request_deferred_events_forward_terminate_requestsetrclientchannel send_eventr# __version__)selfsockstreamr*r.session __class__rrr1,sH     zClient.__init__cCs4|jdk r"|j|tdn|jj|dS)NzPropagation deferred.)r7appendrdebugr:r; propagater>eventrrrpropagate_after_startrs   zClient.propagate_after_startcCsPtd|j|jD]"}td||jj|qtd|jd|_dS)Nz%Propagating deferred events to {0}...zPropagating deferred {0}z&All deferred events propagated to {0}.)rrEr:r7Zdescriber;rFr$rGrrr_propagate_deferred_events}s  z!Client._propagate_deferred_eventscCs|jr|jj|dSN)serverr;rFrGrrrrHsz Client.eventcCs|jj|SrK)rLr;delegater>requestrrrrOszClient.requestcCs|jdk r|d|dd|_||||_||||_||_dddddd d d d dd ddddg}d d d d d d d d d d d d d d d d d d |d dS)NzSession is already initializedZclientIDZraisedzRaised ExceptionsFz'Break whenever any exception is raised.)filterlabeldefault descriptionZuncaughtzUncaught ExceptionsTz=Break when the process is exiting due to unhandled exception.Z userUnhandledzUser Uncaught Exceptionsz/Break when exception escapes into library code.)ZsupportsCompletionsRequestZsupportsConditionalBreakpointsZ supportsConfigurationDoneRequestZsupportsDebuggerPropertiesZ supportsDelayedStackTraceLoadingZsupportsEvaluateForHoversZsupportsExceptionInfoRequestZsupportsExceptionOptionsZsupportsFunctionBreakpointsZ!supportsHitConditionalBreakpointsZsupportsLogPointsZsupportsModulesRequestZsupportsSetExpressionZsupportsSetVariableZsupportsValueFormattingOptionsZsupportsTerminateRequestZsupportsGotoTargetsRequestZsupportsClipboardContextZexceptionBreakpointFiltersZsupportsStepInTargetsRequest)r6 isnt_validr2r capabilitiesrZ expectations)r>rOZexception_breakpoint_filtersrrrinitialize_requestsV   zClient.initialize_requestcstjjfdd}|S)Nc s|ddst|jdkr$|d|js0|jr:|d|dtd|j_ |jj r^t t |dt t|j_}|||jdk rdS|jr|j|jd|_|j}|jr|dd k}d |krt|}t|d h|d<d }|d rt|}|d =d }||d <z|jj|j|Wnptjk rn|i|jd|jt|jYdStjk r}z| |W5d}~XYnX|jj r||_!d |_"|i|#dS|j$d||_!tj%S)NZlaunchattachzSession is not initialized yetzSession is already startedZnoDebugF debugOptionsconsoleinternalConsoleZRedirectOutputTZredirectOutputZisOutputRedirected){0} disconnected before responding to {1}Z initialized)&Z is_requestAssertionErrorr6rUrrLrrSrAno_debugr Zdont_wait_for_first_connectionr9arraystr debug_optionsresponseZ initialize argumentsgetdictlistr;rOcommandrNoMoreMessagesrespondfinalizeformatreprMessageHandlingErrorrFr4r3rJr< NO_RESPONSE)r>rOrarcZ redirectingexcfrrhandlesj             z-Client._start_message_handler..handle)r Componentmessage_handler)rqrrrrpr_start_message_handlersLzClient._start_message_handlerc s^ddlm}|jjdks$ttr.dtdt t fdd}d}|krpd kr| d n d kr|d }|t j t d d d }t|st jg}|dt j t d d7}|ddjd<|jd<dt d d}|dkr|d}d}}} dkr$dt }|g} |jd<dkrJdt }d|g} |jd<dkrdt j t d dd } dd| g} djd<tdd||| fD} | dkr dn| dkrĈ ddt jd d!d"d d} d#t d$} d%t j t d d&}| |7} t|dko$tjd%t }|rV|jd'sB d(| d krV d)d*t d d}|dkr|dkr|dntj|pd}t|d+d,}|rt jd-krd.d/t d d}|r|d0k|_d1tjtj}d2d3}zt|Wn4tk r6}zd4|j|W5d}~XYnX||j|g||| ||| | | dS)5Nr) launchersz"attach" expectedrYcsh|dr|dst|tdd}|dkr6d}|krd|dkr`dt|t|d}|S)NrTrrFz9{0}:false and "debugOptions":[{1}] are mutually exclusive)islowerisupperr]boolrUrrl)Z prop_nameZ flag_namevaluerarOrrproperty_or_debug_option(sz7Client.launch_request..property_or_debug_optionpythonZ pythonPathz2"pythonPath" is not valid if "python" is specifiedT)r) vectorizesize pythonArgs)rZdebugLauncherPythonrrprogram processNamemodulez-mcode)rwz-c cSsg|]}|dkr|qS)rr).0xrrr ^sz)Client.launch_request..z7either "program", "module", or "code" must be specifiedz6"program", "module", and "code" are mutually exclusiverZr[ZintegratedTerminalZexternalTerminalZ consoleTitlezPython Debug Consoleargs)rrz8Shell expansion in "args" is not supported by the clientzJShell expansion in "args" is not available for "console":"internalConsole"cwdsudoZSudowin32z("sudo":true is not supported on Windows. onTerminateKeyboardInterruptZdebugLauncherPathZdebugAdapterHost 127.0.0.1z4{0} couldn't create listener socket for servers: {1}) debugpy.adapterrvrAidlenr connections cant_handler9rr_r`rUr) executablercjoinrrS isinstancerVr'rdirnamerzplatformr8r__file__serve ExceptionZspawn_debuggee)r>rOrvr}Z python_keyr~Zlauncher_pythonrrrrZ num_targetsrZZ console_titleZ target_argsZshell_expand_argsrr on_terminateZ launcher_pathZ adapter_hostrorr|rlaunch_requests                      zClient.launch_requestc s:jjr|d|dtdd}|dtdd}|dtdd}|dtdd}|dttfdd|d tdd|d tdd}|r|d k_|d ks|d kr|d kr|d |d kr|d|d kr|d kr|dd kr|dd kr|dd krd kr|d|d krlt r4|d|dd}|dt}dt _ |dd_ t ||\}}n t s~t tj\}}d kr\ttsz tWn tk r|dYnX|dtt}fdd}zt||WnHtk rF} z(tjdt| fWYdSd} ~ XYnXtj} fdd} n8d krdd} |d kr~tjnd} nfdd} d } jd!||d"tj| | } | dkrd kr|ijd#dS|| rd$nd%z| jWn"t!k r4|d&| YnXdS)'Nz'"noDebug" is not supported for "attach"hostTrportlistenconnect processId subProcessIdrrrz1"listen" and "host"/"port" are mutually exclusivez2"connect" and "host"/"port" are mutually exclusivez-"listen" and "connect" are mutually exclusivez/"listen" and "processId" are mutually exclusivez2"listen" and "subProcessId" are mutually exclusivez5"processId" and "subProcessId" are mutually exclusivez7Multiple concurrent "listen" sessions are not supportedrrestartFz$"processId" must be parseable as intZ debugpyArgscsjd||ddS)Nr r!r )r;r<rr>rr on_output s z(Client.attach_request..on_outputz&Error when trying to attach to PID: %scs |jkSrKpidconnrrrz'Client.attach_request..cSsdS)NTrrrrrrrcs |jkSrKrr)sub_pidrrr"rrZdebugpyWaitingForServerrrz+No known subprocess with "subProcessId":{0}z.Timed out waiting for debug server to connect.z3There is no debug server connected to this adapter.z{0} is already being debugged.)"rAr^rUr`intrerzr8r Z is_servingrZ access_tokenr5rlistener getsocknamerrrr_Zinjectrswallow_exceptionrjrZPROCESS_SPAWN_TIMEOUTr;r<Zwait_for_connectionrirkrZattach_to_session ValueError) r>rOrrrrrZ debugpy_argsretimeoutpredrr)rr>rrattach_requests                   zClient.attach_requestc Cs&|jdks|jr|dzzzd|_z|jj|}WnRt j k r|i|ji|j d |jt|jYWWLdSX||Wn4t jk r}z|jt|W5d}~XYnXW5|jjdkr|ji|XtD]&}|jdkr|j|j jkr||qdS)NzX"configurationDone" is only allowed during handling of a "launch" or an "attach" requestTr\)r4r3rrbrirJrLr;rMrrhrArjrkrrlrgrmr`r rZppidrnotify_of_subprocess)r>rOresultrorrrrconfigurationDone_requestAs6   &    z Client.configurationDone_requestcs*|jj}fdd}||tjS)Ncs|jdSrK)ribody)rbrOrrhandle_responsensz0Client.evaluate_request..handle_response)rLr;rFZ on_responserrn)r>rOZpropagated_requestrrrrevaluate_requestjs  zClient.evaluate_requestcCsd|jd<|jj|S)N*threadId)rcrLr;rMrNrrr pause_requestus zClient.pause_requestcCs>d|jd<z|jj|WStjk r8ddiYSXdS)NrrZallThreadsContinuedT)rcrLr;rMrrhrNrrrcontinue_requestzs  zClient.continue_requestcCsJddtjii}|jrFz|jjd}Wntk r:Yn X|||S)Nr#versionZpydevdSystemInfo)r#r=rLr;rOrupdate)r>rOrZ pydevd_inforrrdebugpySystemInfo_requests z Client.debugpySystemInfo_requestcCs.d|_|jr|jj|S|jjdddiS)NFzclient requested "terminate"T)terminate_debuggee)r5r8rLr;rMrArjrNrrrterminate_requests zClient.terminate_requestc Csd|_|dtdd}|dkr d}|jd||i|jrtt d|t D]0}z|j WqZt k rtYqZXqZdS)NFZterminateDebuggeeTrrzclient requested "disconnect"zB{0} disconnected from stdio; closing remaining server connections.)r5rzrArjrir%r stop_servingrr$rr;r-rr)r>rOrrrrrdisconnect_requests   zClient.disconnect_requestcstdSrK)r0 disconnectrrBrrrszClient.disconnectc Cstd|||j|jdks*||jkr8W5QRdSd|jjkr`td|jW5QRdStd||t|jj}|j||j W5QRXdD]}| |dqd |j |d<|j |d<d D]}| |dq| d d}| d d}d |kr i|d <d |d kr2|dk r&|nd |d d <d |d krb|dkrVt \}}||d d <|jdr|jdd|dnd|d<|jd|dS)Nz{1} is a subprocess of {0}.rzrNot reporting subprocess for {0}, because the parent process was attached to using "processId" rather than "port".zNotifying {0} about {1}.)rrZ preLaunchTaskZ postDebugTaskrOrzSubprocess {0}namer)rrrrrrrrZstartDebuggingrX)rO configurationrOZ debugpyAttach)rr$rAr4rrcwarningreaddZnotify_changedpoprkrrrrVr;rOr<)r>rrkeyrr_rrrrsJ            zClient.notify_of_subprocess)rrr__doc__r rsrt__annotations__rrr1rIrJrHrOrWrurrrrrrrrrrr __classcell__rrrBrr sJ   F     9P   (       r cCstdt||atS)Nr )r rr rrrrrrrsrcCs2z tWn tk r,tjddYnXdS)Nr)level)rr-rrrrrrrrs r) __future__rr+r'r)r#rrrZdebugpy.commonrrrr rr r r rsr rrrrrrs d