a  ak@sddlmZmZmZmZddlZddlZddlZddlZddlm Z m Z m Z ddl m Z mZmZmZmZmZddlmZddlmZmZmZGdddejZd d Zd d ZdS) )absolute_importdivisionprint_functionunicode_literalsN)adaptercommonlauncher)compatfmtjsonlog messagingsockets)unicode) componentsserverssessionscseZdZdZejjZGdddejZGdddejZfddZ dd Z d d Z ed d Z eddZ eddZddZeddZeddZeddZeddZeddZeddZed d!Zed"d#Zed$d%Zd&d'ZZS)(Clientz+Handles the client side of a debug session.c@seZdZdddddZdS)zClient.CapabilitiesF)ZsupportsVariableTypeZsupportsVariablePagingZsupportsRunInTerminalRequestZsupportsMemoryReferencesN)__name__ __module__ __qualname__ PROPERTIESrr6lib/python3.9/site-packages/debugpy/adapter/clients.py Capabilitiess rc@s$eZdZdddejddddZdS)zClient.Expectationszen-USTpathZoptional)ZlocaleZ linesStartAt1ZcolumnsStartAt1Z pathFormatN)rrrr enumrrrrr Expectationss  rcs|dkr\td|tj}ttjdt_ }t |j ttjdt_ }t |j n tj|}tV}tt|||d|_d|_d|_d|_g|_t|_||_| Wdn1s0Y|jdddd tjid |jddd d tjid dS) NZstdioz"Connecting to client over stdio...rwFoutputZ telemetryZptvsdZpackageVersion)categoryr!datadebugpy) r infor Z JsonIOStreamZ from_stdioopenosdevnullsysstdinatexitregisterclosestdoutZ from_socketrZSessionsuperr__init__ client_id has_started start_request_initialize_request_deferred_eventsset_known_subprocessesclientchannel send_eventr$ __version__)selfZsockstreamr*r.session __class__rrr0's@     &zClient.__init__cCs4|jdur"|j|tdn|jj|dS)NzPropagation deferred.)r5appendr debugr8r9 propagater<eventrrrpropagate_after_startgs   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}.)r rBr8r5Zdescriber9rCr%rDrrr_propagate_deferred_eventsrs  z!Client._propagate_deferred_eventscCs|jr|jj|dSN)serverr9rCrDrrrrE}sz Client.eventcCs|jj|SrH)rIr9delegater<requestrrrrLszClient.requestcCs|jdur|d|dd|_||||_||||_||_dddddd d dd d ddg}d d d d d d d d d d d d d d d d d d |d d S)NzSession is already initializedZclientIDZraisedzRaised ExceptionsF)filterZlabeldefaultZuncaughtzUncaught ExceptionsTZ userUnhandledzUser Uncaught Exceptions)ZsupportsCompletionsRequestZsupportsConditionalBreakpointsZ supportsConfigurationDoneRequestZsupportsDebuggerPropertiesZ supportsDelayedStackTraceLoadingZsupportsEvaluateForHoversZsupportsExceptionInfoRequestZsupportsExceptionOptionsZsupportsFunctionBreakpointsZ!supportsHitConditionalBreakpointsZsupportsLogPointsZsupportsModulesRequestZsupportsSetExpressionZsupportsSetVariableZsupportsValueFormattingOptionsZsupportsTerminateDebuggeeZsupportsGotoTargetsRequestZsupportsClipboardContextZexceptionBreakpointFiltersZsupportsStepInTargetsRequest)r4 isnt_validr1rZ capabilitiesrZ expectations)r<rLZexception_breakpoint_filtersrrrinitialize_requestsD      zClient.initialize_requestcstjjfdd}|S)Nc s|ddsJ|jdur$|d|js0|jr:|d|dtd|j_|jjr^t t |dt t |j_}|||jdurdS|jrv|j|jd|_|j}|jrd|vrt|}t|dh|d<|d rt|}|d =z|jj|j|WnjtjyD|i|jtd |j|jYdStjyt}z||WYd}~n d}~00|jjr||_d |_ |i|!dSd d h|@rd}n(ddh|@rd}nt"j#dkrdnd}|jjdddd |d|j$d||_tj%S)NZlaunchattachzSession is not initialized yetzSession is already startedZnoDebugF debugOptionsZRedirectOutputZredirectOutput+{0} disconnected before responding to {1!j}TZ WindowsClientZWindowsZWINDOWSZ UnixClientZUNIXwin32ZsetDebuggerProperty) BaseException) NameError)Z skipSuspendOnBreakpointExceptionZskipPrintBreakpointExceptionZmultiThreadsSingleNotificationZideOSZ initialized)&Z is_requestr4rPrrIr rOr>no_debugrZdont_wait_for_first_connectionr6arrayr debug_optionsresponseZ initialize argumentsdictlistgetr9rLcommandr NoMoreMessagesrespondfinalizer MessageHandlingErrorrCr3r2rGr)platformr: NO_RESPONSE)r<rLrZr\excZclient_os_typefrrhandles~             z-Client._start_message_handler..handle)r Componentmessage_handler)rirjrrhr_start_message_handlersXzClient._start_message_handlerc sddlm}|jjdks$ttr.dtdt t fdd}d}|vrpd vr| d n d vr|d }|t j t d d d }t|st tjg}|dt j t d d7}|ddjd<|jd<dt d d}|dkr|d}d}}} dvr*dt }|g} |jd<dvrPdt }d|g} |jd<dvrdt j t d dd } dd| g} djd<tdd||| fD} | dkr dn| dkrʈ ddt jd d!d d} | d kr | d"t t 7} jd"dd#t d d} | dkrD|dkr2dntj|pBd} d$t jd%d&d'd d}d(t d)}t|d*d+}|rtjd,krd-d.tjtj}d/d0}zt|Wn6ty}zd1|j|WYd}~n d}~00||j|g||| | ||| dS)2Nr) launchersz"attach" expectedrScs\|dr|dsJ|tdd}|dkr6d}|vrX|durTd||d}|S)NrTrrFz={0!j}:false and "debugOptions":[{1!j}] are mutually exclusive)islowerisupperboolrP)Z prop_nameZ flag_namevaluerZrLrrproperty_or_debug_optionsz7Client.launch_request..property_or_debug_optionpythonZ pythonPathz2"pythonPath" is not valid if "python" is specifiedT)r)Z vectorizesize pythonArgs)rwZdebugLauncherPythonrrprogram processNamemodulez-mcode)roz-c cSsg|]}|dkr|qS)rr).0xrrr Tz)Client.launch_request..z7either "program", "module", or "code" must be specifiedz6"program", "module", and "code" are mutually exclusiveZ argsExpansionshellZnoneargscwdconsoleZinternalConsoleZintegratedTerminalZexternalTerminalZ consoleTitlezPython Debug ConsolesudoZSudorUz("sudo":true is not supported on Windows.ZdebugLauncherPathZdebugAdapterHost 127.0.0.1z4{0} couldn't create listener socket for servers: {1}) debugpy.adapterrnr>idlenr connections cant_handler6r rYrrPr filenamer) executabler\joinrpopr'rdirnamerOrrrer__file__serve ExceptionZspawn_debuggee)r<rLrnruZ python_keyrvZlauncher_pythonryr{r|rZ num_targetsZargs_expansionrrZ console_titlerZ launcher_pathZ adapter_hostrgrrtrlaunch_requests                    zClient.launch_requestc s|jjr|d|dtdd}|dtdd}|dtdd}|dtdd}|dttfdd|d tdd|d ksz|d kr|d kr|d |d kr|d |d kr|d kr|d d kr|dd kr|dd krd kr|d|d kr,|dd}|dt}dt_t ||\}}n t \}}d krt tszz tWnt yx|dYn0|dt t}t|tj}fdd}n8d krdd}|d krtjnd}nfdd}d}|jd||dt|j||} | durPd kr:|i|jtddS||rHdndz| |jWn ty|d| Yn0dS)Nz'"noDebug" is not supported for "attach"hostTrportlistenconnect processId subProcessIdrz1"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 exclusiverz$"processId" must be parseable as intZ debugpyArgscs |jkSrHpidconnrrrrz'Client.attach_request..cSsdS)NTrrrrrrrcs |jkSrHrr)sub_pidrrrrrZdebugpyWaitingForServerrrz+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.)r>rXrPrintr]rZ access_tokenrr isinstancerr rYZinjectrZPROCESS_SPAWN_TIMEOUTr9r:Zwait_for_connectionrbrcr rZattach_to_session ValueError) r<rLrrrrZ debugpy_argsZtimeoutZpredrr)rrrattach_requests               zClient.attach_requestc Csh|jdus|jr|dzzd|_z|jj|}Wnhtjy|i|ji|j t d|j|j YWW|jj dur|ji|dS0||Wn6tjy}z|jt|WYd}~n d}~00W|jj dur.|ji|n$|jj dur,|ji|0tD],}|jdur6|j|j jkr6||q6dS)NzX"configurationDone" is only allowed during handling of a "launch" or an "attach" requestTrT)r3r2rrIr9rJr rarbr>rcr r`r[rGrdstrrrZppidrnotify_of_subprocess)r<rLresultrgrrrrconfigurationDone_request sF    (     z Client.configurationDone_requestcs*|jj}fdd}||tjS)Ncs|jdSrH)rbbody)r[rLrrhandle_response8sz0Client.evaluate_request..handle_response)rIr9rCZ on_responser rf)r<rLZpropagated_requestrrrrevaluate_request4s  zClient.evaluate_requestcCsd|jd<|jj|S)N*threadId)r\rIr9rJrKrrr pause_request?s zClient.pause_requestcCs<d|jd<z|jj|WStjy6ddiYS0dS)NrrZallThreadsContinuedT)r\rIr9rJr rarKrrrcontinue_requestDs  zClient.continue_requestcCsHddtjii}|jrDz|jjd}Wnty8Yn 0|||S)Nr$versionZpydevdSystemInfo)r$r;rIr9rLrupdate)r<rLrZ pydevd_inforrrdebugpySystemInfo_requestPs  z Client.debugpySystemInfo_requestcCs|jjdddiS)Nzclient requested "terminate"T)terminate_debuggee)r>rcrKrrrterminate_request^szClient.terminate_requestcCs,|dtdd}|dkrd}|jd|iS)NZterminateDebuggeeTrrzclient requested "disconnect")rrr>rc)r<rLrrrrdisconnect_requestcs zClient.disconnect_requestcCs||j|jdus||jvr,WddSd|jjvrVtd|jWddStd||t|jj}|j|Wdn1s0YdD]}| |dqt d|j |d<d|d<|j |d <d D]}| |dq| d d}| d d}d |vri|d <d |d vr:|dur.|nd|d d <d |d vrj|dur^t \}}||d d <|jd|dS)NrzrNot reporting subprocess for {0}, because the parent process was attached to using "processId" rather than "port".zNotifying {0} about {1}.)rrZ preLaunchTaskZ postDebugTaskzSubprocess {0}namerRrLr)rrzrxrrrrZ debugpyAttach)r>r3r7r\r warningr%r]addrr rlistener getsocknamer9r:)r<rrkeyrr_rrrrks<  *       zClient.notify_of_subprocess)rrr__doc__rrkrlrrr0rFrGrErLrQrmrrrrrrrrrr __classcell__rrr?rrsD @     .\  u )      rcCstdt||atS)Nr)rrrrrrrrrrsrcCs0z tWnty*tjddYn0dS)Nr)level)rr-rr Zswallow_exceptionrrrr stop_servings  r)Z __future__rrrrr+r'r)r$rrrZdebugpy.commonr r r r r rZdebugpy.common.compatrrrrrrkrrrrrrrs