o ^i|@sddlmZddlZddlZddlZddlZddlmZmZmZddl m Z m Z m Z m Z ddlmZmZmZmZmZGdddejZdd Zd d ZdS) ) annotationsN)adaptercommonlauncher)jsonlog messagingsockets)clients components launchersserverssessionscseZdZUdZejjZded< GdddejZGdddejZ fdd Z d d Z d d Z eddZ eddZeddZddZeddZeddZeddZeddZeddZed d!Zed"d#Zed$d%Zed&d'Zfd(d)Zd*d+Zd,d-ZZS).Clientz+Handles the client side of a debug session.zset[servers.Connection]known_subprocessesc@seZdZdddddddZdS)zClient.CapabilitiesF)supportsVariableTypesupportsVariablePagingsupportsRunInTerminalRequestsupportsMemoryReferences#supportsArgsCanBeInterpretedByShellsupportsStartDebuggingRequestN)__name__ __module__ __qualname__ PROPERTIESrrR/home/ubuntu/hpml_nyu/venv/lib/python3.10/site-packages/debugpy/adapter/clients.py Capabilitiess rc@s$eZdZdddejddddZdS)zClient.Expectationszen-USTpathoptional)locale linesStartAt1columnsStartAt1 pathFormatN)rrrrenumrrrrr Expectations$s   r&cs:|dkr1td|d|_tj}ttjdt _ }t |j ttjdt _}t |j n d|_tj|}t5}t||d|_ d|_ d|_ d|_ d|_ g|_ d|_t|_||_| Wdn1svwY|jddd d t j!id |jddd d t j!id t"dS) Nstdioz"Connecting to client over stdio...TrwFoutput telemetryptvsdpackageVersion)categoryr*datadebugpy)#rinfo using_stdior JsonIOStream from_stdioopenosdevnullsysstdinatexitregisterclosestdout from_socketrSessionsuper__init__ client_id has_started start_requestrestart_requested_initialize_request_deferred_events_forward_terminate_requestsetrclientchannel send_eventr0 __version__report_sockets)selfsockstreamr9r=session __class__rrrA,sX      & zClient.__init__cCs6|jdur|j|tddS|jj|dS)NzPropagation deferred.)rGappendrdebugrJrK propagaterOeventrrrpropagate_after_startss  zClient.propagate_after_startcCsPtd|j|jD]}td||jj|q td|jd|_dS)Nz%Propagating deferred events to {0}...zPropagating deferred {0}z&All deferred events propagated to {0}.)rrVrJrGdescriberKrWr1rXrrr_propagate_deferred_events~s   z!Client._propagate_deferred_eventscCs|jr |jj|dSdSN)serverrKrWrXrrrrYsz Client.eventcCs|jj|Sr])r^rKdelegaterOrequestrrrraszClient.requestcCs|jdur |d|dd|_||||_||||_||_dddddd d d d dd ddddg}idd dd dd dd dd dd dd dd dd dd dd dd dd dd dd dd d d d d |d d!S)"NzSession is already initializedclientIDraisedzRaised ExceptionsFz'Break whenever any exception is raised.)filterlabeldefault descriptionuncaughtzUncaught ExceptionsTz=Break when the process is exiting due to unhandled exception. userUnhandledzUser Uncaught Exceptionsz/Break when exception escapes into library code.supportsCompletionsRequestsupportsConditionalBreakpoints supportsConfigurationDoneRequestsupportsDebuggerProperties supportsDelayedStackTraceLoadingsupportsEvaluateForHoverssupportsExceptionInfoRequestsupportsExceptionOptionssupportsFunctionBreakpoints!supportsHitConditionalBreakpointssupportsLogPointssupportsModulesRequestsupportsSetExpressionsupportsSetVariablesupportsValueFormattingOptionssupportsTerminateDebuggeesupportsTerminateRequest)supportsGotoTargetsRequestsupportsClipboardContextexceptionBreakpointFilterssupportsStepInTargetsRequest)rF isnt_validrBr capabilitiesr& expectations)rOraexception_breakpoint_filtersrrrinitialize_requests|        zClient.initialize_requestcstjjfdd}|S)Nc s|ddsJ|jdur|d|js|jr|d|dtd|j_|jjr/t t |dt t |j_}|||jdurIdS|jr|j|jd|_|j}|jr|dd k}d |vrvt|}t|d h|d<d }|d rt|}|d =d }||d <z |jj|j|Wn6tjy|i|jd|jt|jYdStjy}z ||WYd}~nd}~ww|jjr||_ d |_!|i|"dS|j#d||_ tj$S)NlaunchattachzSession is not initialized yetzSession is already startednoDebugF debugOptionsconsoleinternalConsoleRedirectOutputTredirectOutputisOutputRedirected){0} disconnected before responding to {1} initialized)% is_requestrFrrr^rrgrRno_debugr dont_wait_for_first_connectionrIarraystr debug_optionsresponse initialize argumentsgetdictlistrKracommandrNoMoreMessagesrespondfinalizeformatreprMessageHandlingErrorrWrDrCr\rL NO_RESPONSE)rOrarr redirectingexcfrrhandlesn           z-Client._start_message_handler..handle)r Componentmessage_handler)rrrrr_start_message_handlersLzClient._start_message_handlerc sPddlm}|jjdksttrdtdt t fdd}d}|vr8d vr7 d nd vr>d }|t j t d d d }t|sQt jg}|dt j t d d7}|ddjd<|jd<dt d d}|dkrz|d}d}}} dvrdt }|g} |jd<dvrdt }d|g} |jd<dvrdt j t d dd } dd| g} djd<tdd||| fD} | dkrӈ d| dkr܈ ddt jd d!d"d d} d#t d$} d%t j t d d&}| |7} t|dko tjd%t }|r%|jd's d(| d kr% d)d*t d d}|dkrA|dkr8dntj|p@d}t|d+d,}|rVt jd-krVd.d/t d d}|re|d0k|_d1tjtj}t}d2|}zt|Wnt y}zd3|j|d}~ww|!|j|g||| ||| | | dS)4Nr)r z"attach" expectedrcsh|dr |dsJ|tdd}|dkrd}|vr2|dur0dt|t|d}|S)NrTrrFz9{0}:false and "debugOptions":[{1}] are mutually exclusive)islowerisupperboolrrr) prop_name flag_namevaluerrarrproperty_or_debug_option*sz7Client.launch_request..property_or_debug_optionpython pythonPathz2"pythonPath" is not valid if "python" is specifiedT)r) vectorizesize pythonArgs)rdebugLauncherPythonrrprogram processNamemodulez-mcode)rz-c cSsg|]}|dkr|qS)rr).0xrrr `sz)Client.launch_request..z7either "program", "module", or "code" must be specifiedz6"program", "module", and "code" are mutually exclusiverrintegratedTerminalexternalTerminal consoleTitlezPython Debug Consoleargs)rrz8Shell expansion in "args" is not supported by the clientzJShell expansion in "args" is not available for "console":"internalConsole"cwdsudoSudowin32z("sudo":true is not supported on Windows. onTerminateKeyboardInterruptdebugLauncherPathdebugAdapterHostz4{0} couldn't create listener socket for servers: {1})"debugpy.adapterr rRidlenr connections cant_handlerIrrrrr8 executablerjoinr%rg isinstancerr6rdirnamerplatformrHr__file__r get_default_localhostserve Exceptionspawn_debuggee)rOrar r python_keyrlauncher_pythonrrrr num_targetsr console_title target_argsshell_expand_argsrr on_terminate launcher_path localhost adapter_hostrrrrlaunch_requests                  zClient.launch_requestc s2jjr |d|dtdd}|dtdd}|dtdd}|dtdd}|dttfdd|d tdd|d tdd}|rC|d k_|d ksK|d kr]|d krT|d |d kr]|d|d kr||d krj|dd krs|dd kr||dd krd kr|dt }|d krt r|d|d|}|dt}dt _ |dd_t ||\}}nt st |tt j\}}d kr)ttsztWn ty|dw|dtt}fdd} z t || Wn#ty} ztjdt| fWYd} ~ dSd} ~ wwtj} fdd} nd kr=dd} |d kr:tjnd} nfdd} d} jd ||d!t j| | } | dur~d krq|ijd" dS|!| rzd#d$z | "jWdSt#y|!d%| YdSw)&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 supportedrestartFz$"processId" must be parseable as int debugpyArgscsjd||ddS)Nr*r.r*)rKrLrrOrr on_output s z(Client.attach_request..on_outputz&Error when trying to attach to PID: %sc |jkSr]pidconnrrr  z'Client.attach_request..cSsdS)NTrrrrrr#scrr]rr)sub_pidrrr&rrdebugpyWaitingForServerrrz+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.)$rRrrrintrrrHr rr is_servingr access_tokenrEr get_addresslistenerrrrrinjectrswallow_exceptionrrPROCESS_SPAWN_TIMEOUTrKrLwait_for_connectionrrrattach_to_session ValueError)rOrarrrrrr debugpy_argsretimeoutpredrr)rrOrrattach_requests                    zClient.attach_requestc Csj|jdus|jr |dz{zMd|_z |jj|}Wn9tjyT|i|ji|j d |jt |jYWW|jjdurR|ji|dSdSw||Wntjyv}z|jt|WYd}~nd}~wwW|jjdur|ji|n|jjdur|ji|wwtD]}|jdur|j|j jkr||qdS)NzX"configurationDone" is only allowed during handling of a "launch" or an "attach" requestTr)rDrCrr^rKr_rrrrRrrrrrrr\rrr rppidrnotify_of_subprocess)rOraresultrrrrrconfigurationDone_requestEsT            z Client.configurationDone_requestcs*|jj}fdd}||tjS)Ncs|jdSr])rbody)rrarrhandle_responsersz0Client.evaluate_request..handle_response)r^rKrW on_responserr)rOrapropagated_requestrrrrevaluate_requestns  zClient.evaluate_requestcCsd|jd<|jj|S)N*threadId)rr^rKr_r`rrr pause_requestys zClient.pause_requestcCs8d|jd<z|jj|WStjyddiYSw)NrrallThreadsContinuedT)rr^rKr_rrr`rrrcontinue_request~s  zClient.continue_requestcCsJddtjii}|jr#z |jjd}Wn tyY|Sw|||S)Nr0versionpydevdSystemInfo)r0rMr^rKrarupdate)rOrar pydevd_inforrrdebugpySystemInfo_requests  z Client.debugpySystemInfo_requestcCs.d|_|jr |jj|S|jjdddiS)NFzclient requested "terminate"T)terminate_debuggee)rErHr^rKr_rRrr`rrrterminate_requests zClient.terminate_requestc Csd|_|dtdd}|dkrd}|jd||i|jrDtt d|t D]}z|j Wq-t yCtYq-wz|j WdSt y\tjdd YdSw) NFterminateDebuggeeTrrzclient requested "disconnect"zB{0} disconnected from stdio; closing remaining server connections.warninglevel)rErrRrrr2r stop_servingrr1rrKr<rr)rOrar"rrrrdisconnect_requests(      zClient.disconnect_requestcstdSr])r@ disconnectrrSrrr*szClient.disconnectcCs0ddtjtjtjfD}|jdd|idS)NcSs4g|]}|durt|\}}|||tjudqS)N)rrinternal)r rr r)rrrrrrrrsz)Client.report_sockets..debugpySocketsr )r rr r rKrL)rOsocksrrrrNs zClient.report_socketscCstd|||jI|jdus||jvr WddSd|jjvr4td|j WddStd||t|jj}|j||j Wdn1sVwYdD]}| |dq]d |j |d<|j |d<d D]}| |dqu| d d}| d d}d |vri|d <d |d vrt }|p||d d <d |d vr|durt t\}}||d d <|jd r|jdd|ddSd|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}.)rr preLaunchTask postDebugTaskrarzSubprocess {0}namer)rrrrrrrstartDebuggingr)ra configurationra debugpyAttach)rr1rRrDrrr%raddnotify_changedpoprrr rrrrrKrarL)rOrrkeyrrr_rrrrsR            zClient.notify_of_subprocess)rrr__doc__r rr__annotations__rr&rArZr\rYrarrrr rrrrr!r#r)r*rNr __classcell__rrrSrrsP  G    :P   (       rcCs"tdt||atttS)Nr)r rrrrrNrrrrrr s rcCsDtdurztWntytjddYnwdatdS)Nr%r&)rr<rrrrrNrrrrr(s   r() __future__rr:r6r8r0rrrdebugpy.commonrrrr rr r r r rrrrr(rrrrs"