MhddlZddlmZmZmZmZdZGddeZGddej Z dZ Gd d e Z dS) N)jsonlog messagingutil<ceZdZfdZxZS)ComponentNotAvailablecZt|jddS)Nz is not available)super__init____name__)selftype __class__s Z/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/debugpy/adapter/components.pyr zComponentNotAvailable.__init__s, DM<<<=====)r __module__ __qualname__r __classcell__rs@rr r s8>>>>>>>>>rr ceZdZdZd fd ZdZedZedZedZ dZ e d Z d Z xZS) ComponentaA component managed by a debug adapter: client, launcher, or debug server. Every component belongs to a Session, which is used for synchronization and shared data. Every component has its own message channel, and provides message handlers for that channel. All handlers should be decorated with @Component.message_handler, which ensures that Session is locked for the duration of the handler. Thus, only one handler is running at any given time across all components, unless the lock is released explicitly or via Session.wait_for(). Components report changes to their attributes to Session, allowing one component to wait_for() a change caused by another component. NcB|du|duz sJ |jd}|s Jd |jn#|jwxYwt|_|>t |_tj |}| n't x|_|j _|_ |_ d_xjfdgz c_dS)NF)blockingz6__init__ of a Component subclass must lock its SessionTc6jSN)sessionnotify_changed)_rs rz$Component.__init__..:sdl&A&A&C&Cr)lockacquirereleaser r rstrnamerJsonMessageChannelstartstreamhandlerschannel is_connected observers)rrr(r* lock_heldrs` rr zComponent.__init__"s$$7d?3333 # ,,e,<.#G    CCCCDDs 'AA,cJt|jd|jjdS)N[])rr ridrs r__str__zComponent.__str__<s&t**%:: ::::rc|jjSr)rclientr2s rr5zComponent.client? |""rc|jjSr)rlauncherr2s rr8zComponent.launcherCs |$$rc|jjSr)rserverr2s rr:zComponent.serverGr6rc&|jj|i|Sr)rwait_for)rargskwargss rr<zComponent.wait_forKs$t|$d5f555rcFtjfd}|S)aApplied to a message handler to automatically lock and unlock the session for its duration, and to validate the session state. If the handler raises ComponentNotAvailable or JsonIOError, converts it to Message.cant_handle(). c |j5||cdddS#1swxYwYdS#t$r}|d|dd}~wtj$r*}|j|ur||Yd}~dSd}~wtj$r'}|d|jj dd}~wwxYw)N{0}T)silentz{0} disconnected unexpectedly) rr cant_handlerMessageHandlingErrorcause propagate JsonIOErrorr(r%)rmessageexcfs rlock_and_handlez2Component.message_handler..lock_and_handleWsN \,,1T7++,,,,,,,,,,,,,,,,,,( C C C))%T)BBB1 + + +9''MM'*********(   ))3SZ_T* sD0 # 0'0'0 CAC$B  C"B==C) functoolswraps)rJrKs` rmessage_handlerzComponent.message_handlerNs;           rc|j5d|_|jd|ddddS#1swxYwYdS)NFz{0} has disconnected)rr+finalizeformatr2s r disconnectzComponent.disconnectjs \ G G %D  L ! !"8"?"?"E"E F F F G G G G G G G G G G G G G G G G G Gs5A  AA)NN)r rr__doc__r r3propertyr5r8r:r< staticmethodrNrRrrs@rrrs  EEEEEE4;;;##X#%%X%##X#666\6GGGGGGGrrcRGfddt}fd|S)Nc,eZdZdZfdxZZdxZZdS)missing..MissingzoA dummy component that raises ComponentNotAvailable whenever some attribute is accessed on it. cSr)rrreports rr z!missing..Missing.vs VVXXrcdS)NFrZr2s rr z!missing..Missing.wserN)r rrrS __getattr__ __setattr____bool__ __nonzero__)r[srMissingrXqs;  %>$=$=$== k!3!33;;;rrac t#t$r!}tjd|Yd}~dSd}~wwxYw)Nz {0} in {1})r Exceptionrreraise_exception)rIrrs rr[zmissing..reportys\ >'-- - > > >  !,W = = = = = = = = = >s =8=)object)rrrar[s`` @rmissingrfpse4444444&444>>>>>> 799rc*eZdZdZiZ dZdZdZdS) CapabilitieszA collection of feature flags for a component. Corresponds to JSON properties in the DAP "initialize" request or response, other than those that identify the party. c|ds|dsJ||_|j}|jD]\}}||d}t|stj |} ||}n;#t$r.}| dtj ||d}~wwxYw|dks J|d|||<tjd|dS)zParses an "initialize" request or response and extracts the feature flags. For every "X" in self.PROPERTIES, sets self["X"] to the corresponding value from message.payload if it's present there, or to the default value otherwise. initializerZz{0} {1}Nz5 must provide a default value for missing properties.rA) is_request is_response componentpayload PROPERTIESitemsgetcallablerdefaultrc isnt_validreprrdebug)rrmrHrnr%validatevaluerIs rr zCapabilities.__init__s/!!,//T73F3F|3T3TTTT"/"o3355  ND(KKb))EH%% 2<11 J  J J J((DIdOOSIII J QQQ DJJ %s B C))CCcrt|jdtjt |S)Nz: )rr rrudictr2s r__repr__zCapabilities.__repr__s/t**%@@4::)>)>@@@rc|D]:}||s0tj|jdtj|;dS)Nz does not have capability )rrDrmrru)rkeyskeys rrequirezCapabilities.requires\  C9 4~QQ3QQ   rN)r rrrSror r{rrZrrrhrhsZ J:AAArrh)rLdebugpy.commonrrrrACCEPT_CONNECTIONS_TIMEOUTrcr ObservablerrfrzrhrZrrrs 555555555555 >>>>>I>>> [G[G[G[G[G[G[G[G|$55555455555r