Format: application/x-python-code
1 o
2
3 ��hx � @ sb d dl Z d dlmZmZmZmZ dZG dd� de�ZG dd� dej �Z
4 dd � Z G d
5 d � d e �Z
6 dS ) � N)�json�log� messaging�util�< c s e Zd Z� fdd�Z� ZS )�ComponentNotAvailablec s t � �|j� d�� d S )Nz is not available)�super�__init__�__name__)�self�type�� __class__� �Pc:\Users\shubh\Videos\agent\nova\Lib\site-packages\debugpy/adapter/components.pyr s z ComponentNotAvailable.__init__)r
7 �
8 __module__� __qualname__r �
9 __classcell__r r r
10 r r
11 s r c sj e Zd ZdZd� fdd� Zdd� Zedd� �Zed d
12 � �Zed d � �Z d
13 d� Z
14 e dd� �Z dd� Z
15 � ZS )� Componenta� A component managed by a debug adapter: client, launcher, or debug server.
16
17 Every component belongs to a Session, which is used for synchronization and
18 shared data.
19
20 Every component has its own message channel, and provides message handlers for
21 that channel. All handlers should be decorated with @Component.message_handler,
22 which ensures that Session is locked for the duration of the handler. Thus, only
23 one handler is running at any given time across all components, unless the lock
24 is released explicitly or via Session.wait_for().
25
26 Components report changes to their attributes to Session, allowing one component
27 to wait_for() a change caused by another component.
28 Nc s� |d u |d u A s
29 J �z|j jdd�}|sJ d��W |j �� n|j �� w t� �� |� _|d u rAt� �|_t� |� �}|�
30 � n t� � |_|j _� |_ |� _
31 d� _� j� fdd�g7 _d S )NF)�blockingz6__init__ of a Component subclass must lock its SessionTc s
32 � j �� S �N)�sessionZnotify_changed)�_�r r r �<lambda>: s
33 z$Component.__init__.<locals>.<lambda>)�lock�acquire�releaser r r �str�namer ZJsonMessageChannel�start�stream�handlers�channel� is_connectedZ observers)r r r! r# � lock_heldr
34 r r r " s
35
36
37 zComponent.__init__c C s t | �j� d| jj� d�S )N�[�])r r
38 r �idr r r r �__str__< s zComponent.__str__c C � | j jS r )r �clientr r r r r+ ? � zComponent.clientc C r* r )r �launcherr r r r r- C r, zComponent.launcherc C r* r )r �serverr r r r r. G r, zComponent.serverc O s | j j|i |��S r )r �wait_for)r �args�kwargsr r r r/ K s zComponent.wait_forc s t �� �� fdd��}|S )a Applied to a message handler to automatically lock and unlock the session
39 for its duration, and to validate the session state.
40
41 If the handler raises ComponentNotAvailable or JsonIOError, converts it to
42 Message.cant_handle().
43 c
44 s� z | j � � | |�W d � W S 1 sw Y W d S ty0 } z|jd|dd��d }~w tjyN } z|j|u r>� |�|� W Y d }~d S d }~w tjyd } z
45 |jd|jj dd��d }~ww )N�{0}T)Zsilentz {0} disconnected unexpectedly)
46 r r Z cant_handler �MessageHandlingError�cause� propagateZ JsonIOErrorr! r )r �message�exc��fr r �lock_and_handleW s$ (��
47 �
48 ���z2Component.message_handler.<locals>.lock_and_handle)� functools�wraps)r9 r: r r8 r �message_handlerN s zComponent.message_handlerc C sD | j � d| _| j �d�| �� W d � d S 1 sw Y d S )NFz{0} has disconnected)r r$ �finalize�formatr r r r �
49 disconnectj s "�zComponent.disconnect)NN)r
50 r r �__doc__r r) �propertyr+ r- r. r/ � staticmethodr= r@ r r r r
51 r r s
52
53
54
55 r c s( G � fdd�dt �}��fdd�� |� S )Nc s, e Zd ZdZ� fdd� ZZdd� ZZdS )zmissing.<locals>.MissingzoA dummy component that raises ComponentNotAvailable whenever some
56 attribute is accessed on it.
57 c s � � S r r )r r ��reportr r r v s z!missing.<locals>.Missing.<lambda>c S s dS )NFr r r r r r w s N)r
58 r r rA � __getattr__� __setattr__�__bool__� __nonzero__r rD r r �Missingq s rJ c
59 s> zt ��� ty } zt�d| � � W Y d } ~ d S d } ~ ww )Nz
60 {0} in {1})r � Exceptionr Zreraise_exception)r7 )r r r r rE y s ��zmissing.<locals>.report)�object)r r rJ r )rE r r r �missingp s rM c @ s. e Zd ZdZi Z dd� Zdd� Zdd� ZdS ) � Capabilitiesz�A collection of feature flags for a component. Corresponds to JSON properties
61 in the DAP "initialize" request or response, other than those that identify the
62 party.
63 c C s� |� d�s |�d�s J �|| _|j}| j�� D ]?\}}|�|d�}t|�s*t� |�}z||�}W n t
64 yF } z
65 |� dt� |�|��d}~ww |dksRJ |� d���|| |< qt
66 �d| � dS )z�Parses an "initialize" request or response and extracts the feature flags.
67
68 For every "X" in self.PROPERTIES, sets self["X"] to the corresponding value
69 from message.payload if it's present there, or to the default value otherwise.
70 Z
71 initializer z{0} {1}Nz5 must provide a default value for missing properties.r2 )Z
72 is_requestZ is_response� component�payload�
73 PROPERTIES�items�get�callabler �defaultrK Z
74 isnt_valid�reprr �debug)r rO r6 rP r �validate�valuer7 r r r r � s$
75 ��
76 �
77 zCapabilities.__init__c C s t | �j� dt�t| ��� �S )Nz: )r r
78 r rV �dictr r r r �__repr__� s zCapabilities.__repr__c G s2 |D ]}| | st �| j� dt�|�� ���qd S )Nz does not have capability )r r3 rO r rV )r �keys�keyr r r �require� s ���zCapabilities.requireN)r
79 r r rA rQ r r[ r^ r r r r rN � s rN )r; Zdebugpy.commonr r r r ZACCEPT_CONNECTIONS_TIMEOUTrK r Z
80 Observabler rM rZ rN r r r r �<module> s ^