File: //snap/core20/2599/usr/share/subiquity/subiquitycore/__pycache__/snapd.cpython-38.pyc
U
K��^, � @ s� d dl Z d dlmZ d dlZd dlZd dlZd dlZd dlZd dlm Z m
Z
d dl m Z d dl
mZ d dlZe�d�ZG dd� d�ZG d d
� d
�ZG d d � d �ZG d
d� d�ZG dd� d�ZG dd� d�ZdS )� N)�partial)�
quote_plus� urlencode)�
run_in_thread)� run_commandzsubiquitycore.snapdc @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�SnapdConnectionc C s$ || _ d�t|��| _t�� | _d S )Nzhttp+unix://{}/)�root�formatr �url_base�requests_unixsocketZSession�session)�selfr Zsock� r �+/usr/share/subiquity/subiquitycore/snapd.py�__init__' s zSnapdConnection.__init__c K s* |r|dt |� 7 }| jj| j| dd�S )N�?�< )�timeout)r r �getr
)r
�path�argsr r r r , s zSnapdConnection.getc K s2 |r|dt |� 7 }| jj| j| t�|�dd�S )Nr r )�datar )r r �postr
�json�dumps�r
r �bodyr r r r r 1 s �zSnapdConnection.postc C s� t �d� tj�| jd�}tj|dd� ttj�|d�d��}|�|� � � W 5 Q R X | jdkrtdd gdd
d gg}n
d d
gg}|D ] }t
|� q�d S )Nz(restarting snapd to pick up proxy configz"etc/systemd/system/snapd.service.dT)�exist_okzsnap_proxy.conf�w�/Z systemctlz
daemon-reloadZrestartz
snapd.service�sleep�2) �log�debug�osr �joinr �makedirs�open�writeZproxy_systemd_dropinr )r
�proxyZ
dropin_dir�fpZcmds�cmdr r r �configure_proxy8 s
�
�
z SnapdConnection.configure_proxyN)�__name__�
__module__� __qualname__r r r r, r r r r r & s r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�_FakeFileResponsec C s
|| _ d S �N)r )r
r r r r r L s z_FakeFileResponse.__init__c C s d S r1 r �r
r r r �raise_for_statusO s z"_FakeFileResponse.raise_for_statusc
C s, t | j��}t�|�W 5 Q R � S Q R X d S r1 )r' r r �load)r
r* r r r r R s z_FakeFileResponse.jsonN�r- r. r/ r r3 r r r r r r0 J s r0 c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�_FakeMemoryResponsec C s
|| _ d S r1 �r )r
r r r r r Y s z _FakeMemoryResponse.__init__c C s d S r1 r r2 r r r r3 \ s z$_FakeMemoryResponse.raise_for_statusc C s | j S r1 r7 r2 r r r r _ s z_FakeMemoryResponse.jsonNr5 r r r r r6 W s r6 c @ s e Zd ZdZdd� Zdd� ZdS )� ResponseSetzqResponses for a endpoint that returns different data each time.
Motivating example is v2/changes/$change_id.c C s || _ d| _d S )Nr )�files�index)r
r9 r r r r h s zResponseSet.__init__c C sb | j | j }ttj�dd��}|dkrL| j| t| j �krLt| j �d | _n| j|7 _t|�S )NZSUBIQUITY_REPLAY_TIMESCALE� )r9 r: �intr$ �environr �lenr0 )r
�f�dr r r �nextl s zResponseSet.nextN)r- r. r/ �__doc__r rA r r r r r8 c s r8 c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�FakeSnapdConnectionc C s || _ || _i | _d S r1 )�
snap_data_dir� scale_factor�
response_sets)r
rD rE r r r r y s z FakeSnapdConnection.__init__c C s t �d� t�d| j � d S )Nz3pretending to restart snapd to pick up proxy config� )r" r# �timer rE )r
r) r r r r, ~ s
z#FakeSnapdConnection.configure_proxyc K sb |dkr&|d dkr&t ddddd��S |dkrL|d d krLt dd
dd d��S td �||f���d S )
Nzv2/snaps/subiquity�actionZrefresh�async� �� ZOK)�type�changez status-code�statusZswitch� ZAcceptedz*Don't know how to fake POST response to {})r6 � Exceptionr r r r r r � s" �� �zFakeSnapdConnection.postc K s� t �d| j � |�dd�}|r8|dtt|�� �� 7 }|| jkrP| j| �� S t j
� | j |�}t j
�
|d �r|t|d �S t j
�|�r�tt�t j
� |d���}t|� }| j|< |�� S td�||f���d S )Nr; r �-z.jsonz*.jsonz)Don't know how to fake GET response to {})rH r rE �replacer �sorted�itemsrF rA r$ r r% rD �existsr0 �isdir�globr8 rQ r )r
r r �filename�filepathr9 Zrsr r r r � s
�zFakeSnapdConnection.getN)r- r. r/ r r, r r r r r r rC x s rC c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�
AsyncSnapdc C s
|| _ d S r1 )�
connection)r
r\ r r r r � s zAsyncSnapd.__init__c � s, t t| jj|f|��I d H }|�� |�� S r1 )r r r\ r r3 r )r
r r �responser r r r � s
�
zAsyncSnapd.getc � s2 t t| jj||f|��I d H }|�� |�� d S )NrN )r r r\ r r3 r )r
r r r r] r r r r � s
�
zAsyncSnapd.postc � sX | j ||f|�I d H }d�|�}| �|�I d H }|d d dkrBqTt�d�I d H q d S )Nz
v2/changes/{}�resultrO ZDoneg�������?)r r r �asyncior )r
r r r rN Z change_pathr^ r r r �
post_and_wait� s
zAsyncSnapd.post_and_waitN)r- r. r/ r r r r` r r r r r[ � s r[ )r_ � functoolsr rX r Zloggingr$ rH Z urllib.parser r Zsubiquitycore.async_helpersr Zsubiquitycore.utilsr r Z getLoggerr" r r0 r6 r8 rC r[ r r r r �<module> s"
$
.