o hx@sbddlZddlmZmZmZmZdZGdddeZGdddej Z dd Z Gd d d e Z dS) N)jsonlog messagingutil<cseZdZfddZZS)ComponentNotAvailablecst|jddS)Nz is not available)super__init____name__)selftype __class__Pc:\Users\shubh\Videos\agent\nova\Lib\site-packages\debugpy/adapter/components.pyr szComponentNotAvailable.__init__)r __module__ __qualname__r __classcell__rrr rr srcsjeZdZdZdfdd ZddZeddZed d Zed d Z d dZ e ddZ ddZ ZS) 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. Ncs|du|duAs Jz|jjdd}|sJdW|jn|jwt|_|durAt|_t |}| n t|_|j _|_ |_ d_jfddg7_dS)NF)blockingz6__init__ of a Component subclass must lock its SessionTcs jSN)sessionZnotify_changed)_r rr:s z$Component.__init__..)lockacquirereleaserr rstrnamerZJsonMessageChannelstartstreamhandlerschannel is_connectedZ observers)r rr!r# lock_heldr rrr "s     zComponent.__init__cCst|jd|jjdS)N[])r r ridrrrr__str__<szComponent.__str__cC|jjSr)rclientrrrrr+?zComponent.clientcCr*r)rlauncherrrrrr-Cr,zComponent.launchercCr*r)rserverrrrrr.Gr,zComponent.servercOs|jj|i|Sr)rwait_for)r argskwargsrrrr/KszComponent.wait_forcstfdd}|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 sz|j||WdWS1swYWdSty0}z|jd|ddd}~wtjyN}z|j|ur>||WYd}~dSd}~wtjyd}z |jd|jj ddd}~ww)N{0}T)Zsilentz{0} disconnected unexpectedly) rrZ cant_handlerMessageHandlingErrorcause propagateZ JsonIOErrorr!r)r messageexcfrrlock_and_handleWs$(  z2Component.message_handler..lock_and_handle) functoolswraps)r9r:rr8rmessage_handlerNs zComponent.message_handlercCsD|jd|_|jd|WddS1swYdS)NFz{0} has disconnected)rr$finalizeformatrrrr disconnectjs"zComponent.disconnect)NN)r rr__doc__r r)propertyr+r-r.r/ staticmethodr=r@rrrr rrs    rcs(Gfdddt}fdd|S)Ncs,eZdZdZfddZZddZZdS)zmissing..MissingzoA dummy component that raises ComponentNotAvailable whenever some attribute is accessed on it. csSrr)r rreportrrrvsz!missing..Missing.cSsdS)NFrrrrrrwsN)r rrrA __getattr__ __setattr____bool__ __nonzero__rrDrrMissingqsrJc s>ztty}ztd|WYd}~dSd}~ww)Nz {0} in {1})r ExceptionrZreraise_exception)r7)rr rrrEys zmissing..report)object)rr rJr)rErr rmissingpsrMc@s.eZdZdZiZ ddZddZddZdS) 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 Cs|ds |ds J||_|j}|jD]?\}}||d}t|s*t |}z||}Wnt yF}z | dt ||d}~ww|dksRJ|d|||<qt d|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. Z initializerz{0} {1}Nz5 must provide a default value for missing properties.r2)Z is_requestZ is_response componentpayload PROPERTIESitemsgetcallablerdefaultrKZ isnt_validreprrdebug)r rOr6rPrvalidatevaluer7rrrr s$     zCapabilities.__init__cCst|jdtt|S)Nz: )r r rrVdictrrrr__repr__szCapabilities.__repr__cGs2|D]}||st|jdt|qdS)Nz does not have capability )rr3rOrrV)r keyskeyrrrrequireszCapabilities.requireN)r rrrArQr r[r^rrrrrNs  rN)r;Zdebugpy.commonrrrrZACCEPT_CONNECTIONS_TIMEOUTrKrZ ObservablerrMrZrNrrrrs^