Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/bakauth/__pycache__/__init__.cpython-39.pyc
Ðазад
a � h�� � @ s d Z ddlZddlmZmZ ddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZ ddlmZmZmZmZmZmZmZ ddlmZmZmZm Z m Z ddl m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z, d Z-d Z.d Z/d Z0d Z1h d�Z2G dd� d�Z3dS )a� Code for accessing the backup authority server api .. data:: bakauth.AUTH_JSON: "/opt/backups/etc/auth.json" *(str)* .. data:: bakauth.BAKAUTH1: "ash-sys-pro-bakauth1.imhadmin.net" *(str)* .. data:: bakauth.BAKAUTH2: "ash-sys-dev-bakauth2.imhadmin.net" *(str)* .. data:: bakauth.BAKAUTH3: "lax-sys-pro-bakauth3.imhadmin.net" *(str)* .. data:: bakauth.SHARED_CLASSES: {'imh_reseller', 'imh_shared', 'hub_shared'} *(set)* � N)�Union�Any)�Restic� ResticRepo� )�SharedFailoverLocks�AgentClientLookup�AgentCpuserLookup�VznodeBackupLookup�VznodeRestoreLookup� UserBuckets� RegDetails)�Status�MdsState�post�DEFAULT_TIMEOUT�DEFAULT_RETRIES)� BakAuthError� BakAuthDown�ClusterUnavailable� AMPDownError�WrongServerClass�BakAuthLoginFailed�BakAuthWrongLogin� VpsRestricted� LookupMissing�WrongSharedServer� NoAmpAccount�DedicatedMoved� InternalQuota� Unregisteredz1.5.5z!ash-sys-pro-bakauth1.imhadmin.netz!ash-sys-dev-bakauth2.imhadmin.netz!lax-sys-pro-bakauth3.imhadmin.netz/opt/backups/etc/auth.json> Z hub_sharedZ imh_resellerZ imh_sharedc @ s� e Zd ZdZdd� Zdd�eeeeee e f d�dd�Z ddd �eeeeeee e ef d �d d �Z dd�eeeeee e f d�d d�Z ddeeed�eeeeeedd�dd�Zedd�eeeeeef d�dd��Zdeed�eeef eedf eeed �d d �Zdeed�eedf eedf eeed �d d!�Zeefeeeed"�d#d$�Zeed%�ee eeeeef eedd&�d'd(�Z eed%�eeee e eeedd)�d*d+�Z eed%�eeeeeedd,�d-d.�Z eed%�eeeeef f e e e e eedd/�d0d1�Z!ddeed2�eeeeeedd3�d4d5�Z"eefeeeee#d6�d7d8�Z$eefeeeee%d9�d:d;�Z&eefeeeee%d<�d=d>�Z'ddeed?�e e eeeedf eee(d@�dAdB�Z)eed%�eeeeee*f d"�dCdD�Z+eed%�eeeeee*ef d"�dEdF�Z,eed%�eeedG�dHdI�Z-deedJ�edK�dLdM�Z.deedJ�eeef dK�dNdO�Z/ddeedP�eedf eeee0dQ�dRdS�Z1eedfeeeddT�dUdV�Z2eeddW�eeeeeedf ddX�dYdZ�Z3dcdd\�eee4d]�d^d_�Z5ddee e df eeee4f d`�dadb�Z6dS )e�BakAuthz!Handles backup authority requestsc C s� z:t tdd��}t�|�}W d � n1 s.0 Y W n2 tyl } ztt|��|�W Y d }~n d }~0 0 tjt |d |d fd�| _ d S )Nzutf-8)�encodingZapiuser�authkey)�auth) �open� AUTH_JSON�json�load�FileNotFoundErrorr �str� functools�partialr �_post)�self�handle�data�exc� r2 �?/opt/imh-python/lib/python3.9/site-packages/bakauth/__init__.py�__init__R s ,$�zBakAuth.__init__T)� log_retries)�uri�timeout�retriesr5 �returnc K s | j t|||||d�S )a� Perform a post request that only the primary bakauth server can handle Args: uri (str): HTTP request URI timeout (int): HTTP request timeout in seconds retries (int): HTTP request auto-retries after timeout log_retries (bool): whether to log on auto-retries. Defaults False **data: POST form data Returns: tuple[Status, Any]: (``Status`` enum, data) �� bakauth_hostr6 r7 r8 r5 r0 )r- �BAKAUTH1)r. r6 r7 r8 r5 r0 r2 r2 r3 � _post_main\ s �zBakAuth._post_main)r5 � pref_main)r6 r7 r8 r5 r> r9 c K s� |||||d�}|r t tg}ntt g}| jf d|d i|��\} }| tju r�|rht�d|d ||d � | jf d|d i|��} g | �|d �R S | ||d fS )a� Perform a post request that the primary bakauth server should handle, but will failover to a replicant bakauth server if needed Args: uri (str): HTTP request URI timeout (int): HTTP request timeout in seconds retries (int): HTTP request auto-retries after timeout log_retries (bool): whether to log on auto-retries. Defaults False pref_main (bool): If true, try bakauth1 first. If false, try bakauth3 first. Defaults True. **data: POST form data Returns: tuple[Status, Any, str]: (``Status`` enum, data, bakauth host used) �r6 r7 r8 r5 r0 r; r z-%s::%s: request exception - retrying using %sr )r< �BAKAUTH3r- r �REQUEST_EXCEPTION�logging�warning) r. r6 r7 r8 r5 r> r0 �kwargsZ bakauth_hosts�status�retr2 r2 r3 � _post_pref{ s* � �zBakAuth._post_prefc K s� t tg}t�|� |||||d�}| jf d|d i|��\}}|tju r||rdt�d|d ||d � | jf d|d i|��S ||fS )a� Perform a post request that any production bakauth server can handle (round robin) Args: uri (str): HTTP request URI timeout (int): HTTP request timeout in seconds retries (int): HTTP request auto-retries after timeout log_retries (bool): whether to log on auto-retries. Defaults False **data: POST form data Returns: tuple[Status, Any]: (``Status`` enum, data) r? r; r z,%s:%s: request exception - retrying using %sr ) r< r@ �random�shuffler- r rA rB rC ) r. r6 r7 r8 r5 r0 �priorD rE r2 r2 r3 � _post_either� s& � �zBakAuth._post_either�� � )� wait_mins� poll_secsr; r7 r8 N)�task_idrN rO r; r7 r8 r9 c C sp d}|d }t � � } |dv rlt � � | |k rlt �|� | j|d||dd|id�\} }| tjurt| |d��qd S ) aV Wait for a celery task to finish on the Backup Authority server Args: task_id (str): task identifier string wait_mins (int, optional): max minutes to wait. Defaults to 240. poll_secs (int, optional): secondss between checking the state of the task. Defaults to 3. timeout (int, optional): request timeout in secs (per poll request, not in total) retries (int): number of times to retry the request on timeout Raises: BakAuthError: error checking the state of the task �QUEUED�< )rQ ZSTARTEDz/lookup/check_taskTrP r: �rE r0 N)�time�sleepr- r �OKAYr ) r. rP rN rO r; r7 r8 Z state_msg�wait�startrE r2 r2 r3 � task_wait� s � zBakAuth.task_waitF)� require_amp)� svr_class�hostrZ r9 c C sB t tdttd|| |rdndd�d�\}}|tjur>t||d��|S )aT Register a (non-internal) server in backup authority Args: svr_class (str): server classification, one in: imh_vps, imh_reseller, imh_shared, hub_shared, or imh_ded host (str): short hostname which should match what AMP knows require_amp (bool): if True, instruct bakauth to reject registration if the supplied host does not match a known AMP account Raises: BakAuthError: any error registering the server Returns: dict[str, str]: contains keys "authkey" and "apiuser" z /registerT�1�0)r\ r[ rZ r: rS )r r< r r r rV r )r[ r\ rZ rE r0 r2 r2 r3 �register� s �� zBakAuth.register)�netr7 r8 )�veidsr` r7 r8 r9 c C s� | j dt�|�|||d�\}}|tjur4t||d��|d D ]J}z| j|||d� W q< ty� } zt�d|� W Y d}~q<d}~0 0 q<|d t f i |d ��d d � |d � � D �d d � |d � � D �d�S )a� Requests information form bakauth needed to backup a vz node Args: veids (dict[int, str]): If performing a vps backup run, provide the IDs of all vps found on this compute node, mapped to their FQDNs. If only backing up mds, send an empty dict net (str | None): set "lan" or "wan" to override which ceph network to use timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error looking up data Returns: VznodeBackupLookup: restic info needed to backup a vznode. Contains keys "endpoints", "node_keys", and "vps_keys" z/vzclient/backup)r6 ra r` r7 r8 rS �task_ids�r7 r8 z%sN� endpoints� node_keysc S s$ i | ] \}}t |�tf i |���qS r2 )�intr ��.0�k�vr2 r2 r3 � <dictcomp>P s z+BakAuth.vzclient_backup.<locals>.<dictcomp>�vps_keysc S s i | ]\}}t |�|�qS r2 )rf rg r2 r2 r3 rk S � �changed)rd re rl rn ) r= r' �dumpsr rV r rY rB rC r �items) r. ra r` r7 r8 rE r0 rP r1 r2 r2 r3 �vzclient_backup% s* � $ ��zBakAuth.vzclient_backup)�veidr` r7 r8 r9 c C sh |du rddi}nd|i}| j f d|||d�|��\}}|tjurNt||d��tf i |d ��|d< |S ) a� Requests information from bakauth needed to restore data for a vps from a vznode Args: veid (int | None): ID for the vps you're trying to restore. Explicitly set to None to fetch info for the node itself. net (str | None): set "lan" or "wan" to override which ceph network to use timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthDown: if bakauth could not be reached BakAuthLoginFailed: API user/password is wrong LookupMissing: if a requested vps's keys do not exist VpsRestricted: if a requested vps is internal BakAuthError: catch-all for any other api error Returns: VznodeRestoreLookup: restic info needed to restore a vps from a vznode. The dict has keys "this_endpoint", "key_info", and "all_endpoints" N�noder] rr z/vzclient/restore)r6 r` r7 r8 rS �key_info)rK r rV r r )r. rr r` r7 r8 rD rE r0 r2 r2 r3 �vzclient_restoreV s �� zBakAuth.vzclient_restore)�userr7 r8 r9 c C s4 | j d||d|d�\}}}|tjur0t||d��|S )z2Check which failover backups should not be rotatedz/failover/get_shared_locksF)r6 r7 r8 r> rv rS )rG r rV r )r. rv r7 r8 rE r0 �_r2 r2 r3 �get_shared_failover_locks� s � z!BakAuth.get_shared_failover_locksrc )�version� mds_state�vps_crit�vps_warn� vps_sizesr7 r8 r9 c C sf t j}| jd||j||t�|�t�t�� �|d � d|d � �||d� \} } | tj urbt | | d��dS )aG Post backup monitoring status for a vznode Args: version (str): RPM version mds_state (MdsState): MDS status enum vps_crit (int): number of vps old enough to be a nrpe critical vps_warn (int): number of vps behind schedule but not critical vps_sizes (dict[int, int]): veids mapped to VPS sizes in MiB timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error updating monitoring status z/monitoring/vz_updater �.r ) r6 ry rz r{ r| r} �os_info�py_infor7 r8 rS N) �sys� version_infor= �valuer' ro �distro�infor rV r ) r. ry rz r{ r| r} r7 r8 � py_versionrE r0 r2 r2 r3 �monitoring_vz_update� s � z BakAuth.monitoring_vz_update)ry �running� ded_moved�errors�num_oldr7 r8 r9 c C st t j}| jd||||rdnd|r$dndt�|�|t�t�� �|d � d|d � �d� \} } | tjurpt | | d��dS )a~ Updates bakauth with client server status Args: version (str): backup client RPM version running (bool): whether the backup runner daemon is running ded_moved (bool): True if this is a dedi and its bucket was moved to a new server errors (list[str]): error messages to display in monitoring dash num_old (int): number of old tasks in queue timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error updating monitoring status z/monitoring/updater r r~ ) r6 r7 r8 ry r� r� r� r� r r� rS N) r� r� r= r' ro r� r� r rV r ) r. ry r� r� r� r� r7 r8 r� rE r0 r2 r2 r3 �monitoring_update� s � zBakAuth.monitoring_update)�task�pluginrv �ipaddrr7 r8 r9 c C s6 | j d||||||d�\}}|tjur2t||d��dS )a� Add an account note when a ticket is generated Args: task (str): backup/restore task name plugin (str): plugin task name (e.g. "cPanel Backup Manager") user (str): username ipaddr (str): IP address of user timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: error posting note z/note/auto_ticket)r6 r7 r8 r� r� rv r� rS N�r= r rV r ) r. r� r� rv r� r7 r8 rE r0 r2 r2 r3 �note_auto_ticket� s � zBakAuth.note_auto_ticket)� user_sizes�notify�resetr7 r8 r9 c C sF | j d||t�|�t�|�t�|�d�\}}|tjurBt||d��dS )a Post a user's account size for AMP to access Args: user_sizes (dict[str, dict[str, int]]): user account sizes (in MiB). each dict should have keys "total_mb" and "usage_mb" notify (list[str]): users over quota reset (list[str]): users under quota (to reset their notify times) timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error updating usage z/usage/set/shared)r6 r7 r8 �usersr� r� rS N)r= r' ro r rV r )r. r� r� r� r7 r8 rE r0 r2 r2 r3 �post_user_sizes s � zBakAuth.post_user_sizes)r� r� r7 r8 )�usage�totalr� r� r7 r8 r9 c C sF | j d|||||rdnd|r dndd�\}}|tjurBt||d��dS )a& Post a v/ded server's size for AMP to access Args: usage (int): disk usage of selected backups (in MiB) total (int): disk usage of all account data (in MiB) notify (bool, optional): notify as over quota. Defaults to False. reset (bool, optional): reset notify counter. Defaults to False. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error updating usage z/usage/set/vdedr] r^ )r6 r7 r8 r� r� r� r� rS Nr� ) r. r� r� r� r� r7 r8 rE r0 r2 r2 r3 �post_vded_size. s � zBakAuth.post_vded_size)rv �keyr7 r8 r9 c C sL | j d||||d�\}}|tjur.t||d��|�d�}|tf i |��d�S )a Used by support tooling to request a shared user's bucket details from a server other than where the bucket belongs Args: user (str): username key (str): agent key from cpjump timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: AgentCpuserLookup: restic auth info and wans available z/agent/get_bucket/cpuser)r6 r7 r8 Zcpuserr� rS �wans)r� �repo�r= r rV r �popr )r. rv r� r7 r8 rE r0 r� r2 r2 r3 �agent_get_user_bucketQ s � z BakAuth.agent_get_user_bucket)r\ r� r7 r8 r9 c C sX | j d||||d�\}}|tjur.t||d��|�d�}|�d�}||tf i |��d�S )a4 Used by support tooling to request v/ded bucket details for a server with an active registration, from a server other than where the bucket belongs Args: host (str): short hostname key (str): agent key from cpjump timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: AgentClientLookup: restic auth info and wans available �/agent/get_bucket/client)r6 r7 r8 r\ r� rS r� r[ �r� r[ r� r� ) r. r\ r� r7 r8 rE r0 r� r[ r2 r2 r3 �agent_get_server_buckets s � �z BakAuth.agent_get_server_bucket)�bucketr� r7 r8 r9 c C sX | j d||||d�\}}|tjur.t||d��|�d�}|�d�}||tf i |��d�S )a Used by support tooling (baksync) to request v/ded bucket details for a bucket which is marked for deletion Args: bucket (str): full bucket name from cpjump key (str): agent key from cpjump timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: AgentClientLookup: restic auth info and wans available r� )r6 r7 r8 Zstashed_bucketr� rS r� r[ r� r� ) r. r� r� r7 r8 rE r0 r� r[ r2 r2 r3 �agent_get_stashed_bucket� s � �z BakAuth.agent_get_stashed_bucket)�nocache�suspendsr7 r8 )r� rN r� r� r7 r8 r9 c C s t |t�st�t�|�|r dndd�}|dur<t�|�|d< | jf d||d�|��\}} } |tjurpt|| d��|r�| d D ]H} z| j | |d � W q| ty� } zt � d | � W Y d} ~ q|d} ~ 0 0 q|d d � | d � � D �} | d | dd � | d � � D �| d d�S )ay Get quota and bucket details for multiple shared users Args: users (list[str]): users to get bucket data for wait_mins (int): max number of minutes to wait for bucket creation (per cluster) nocache (bool): Instruct bakauth to skip cache when looking up quota information. Defaults to False. suspends (dict | None): only used by the scheduler cron. This is a dict of suspended users and when/why. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting bucket details Returns: UserBuckets: dict where "quotas_gb" contains a dict of usernames to quotas in GiB. "repos" contains a dict of usernames to ResticRepo objects. "missing" is specific to the replicant, ``BAKAUTH3``. If ``BAKAUTH1`` did not reply, we use ``BAKAUTH3``, which is unable to setup new users. "copy_users" are users which get cross-coast backups r r )r� r� Nr� z/buckets/users�r6 r7 r8 rS rb )rN z*error when waiting for ceph user setup: %sc S s i | ]\}}||� d ��qS )�quota)r� rg r2 r2 r3 rk � rm z,BakAuth.get_user_buckets.<locals>.<dictcomp>r� � copy_usersc S s i | ]\}}|t f i |���qS r2 )r rg r2 r2 r3 rk � rm �missing)r� � quotas_gb�reposr� ) � isinstance�list� TypeErrorr' ro rG r rV r rY rB rC rp )r. r� rN r� r� r7 r8 rD rE r0 rw rP r1 Zquotasr2 r2 r3 �get_user_buckets� s8 " �� � �zBakAuth.get_user_bucketsc C s� t |t�std|�d���| j|gdd||d�}||d vrPttj|� d�d��||d v rpttjd t � �d��|d | |d | fS ) a Like get_user_buckets but for only one user and wait_mins=0. Args: user (str): username timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: WrongSharedServer: The requested user does not belong here BakAuthDown: Backup Authority server was unreachable BakAuthError: any other error Returns: tuple[int, ResticRepo]: quota in GiB and ResticRepo object �get_user_bucket(user=�)Tr �r� rN r7 r8 r� � is not assigned to this serverrS r� �Could not connect to r� � r� r* r� r� r r �ERRORr rA r< )r. rv r7 r8 �lookupr2 r2 r3 �get_user_bucket s � � �zBakAuth.get_user_bucketc C s� t |t�std|�d���| j|gdd||d�}||d vrPttj|� d�d��||d v rpttjd t � �d��||d v }|d | |d | |fS ) aV Like get_user_buckets but for only one user and wait_mins=0. Args: user (str): username timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: WrongSharedServer: The requested user does not belong here BakAuthDown: Backup Authority server was unreachable BakAuthError: any other error Returns: tuple[int, ResticRepo, bool]: quota in GiB, ResticRepo object, and whether this user gets cross-coast backups. r� r� Tr r� r� r� rS r� r� r� r� r� )r. rv r7 r8 r� �geor2 r2 r3 �get_user_bucket_v2, s" � � � zBakAuth.get_user_bucket_v2)r7 r8 r9 c C s2 | j d||d�\}}|tjur*t||d��|d S )af Get the shared failover account size limit in GiB Args: timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting the size limit Returns: int: shared failover account size limit in GiB z/buckets/failover_limitr� rS Z failover_gib�rK r rV r )r. r7 r8 rE r0 r2 r2 r3 �get_failover_limitY s � zBakAuth.get_failover_limit)r� r7 r8 )r9 c C s6 | j d||dt|�d�\}}|tjur2t||d��|S )a� Get this v/ded server's quota as an int in GiB Args: nocache (bool): Instruct bakauth to skip cache when looking up quota information. Defaults to False. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting the server's quota Returns: int: this v/ded server's quota as an int in GiB �/buckets/vded_quotar �r6 r7 r8 �verr� rS �rK rf r rV r �r. r� r7 r8 rE r0 r2 r2 r3 �get_vded_quotat s � zBakAuth.get_vded_quotac C sB | j d||dt|�d�\}}|tjur2t||d��|d |d fS )a( Get this v/ded server's quota as an int in GiB Args: nocache (bool): Instruct bakauth to skip cache when looking up quota information. Defaults to False. timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthError: any error requesting the server's quota Returns: int: this v/ded server's quota as an int in GiB bool: whether this server gets cross-coast backups r� � r� rS r� �copyr� r� r2 r2 r3 �get_vded_quota_v2� s � zBakAuth.get_vded_quota_v2)r` �startupr7 r8 )r` r� r7 r8 r9 c C s� i }|r||d< |r d|d< | j f d||d�|��\}}|tjurNt||d��|d tv r�|d t�� �d �d kr�ttj d |d ��d��|d |d |d |d |d |d |d t |d |d |d |d d�d�S )a8 Fetch registration details needed for backup-runner to start Args: startup (bool): If True, bakauth performs extra checks on buckets. This should only be set to True on initial backup-runner startup. Defaults false. net(str, optional): "wan" or "lan" to request that ceph endpoint timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout Raises: BakAuthLoginFailed: auth.json is invalid BakAuthWrongLogin: this server has the wrong server's auth.json BakAuthError: any other error getting the server's registration info Returns: RegDetails: contains "svr_class", "client_host", "endpoint", and "repo" r` r] r� z/buckets/reg_detailsr� rS r[ � client_hostr~ r z4Shared server registration incorrect! Registered as �name�endpoint�locationr� r� r� � restic_pass� access_key� secret_key)r� r� r� r� )r� r[ r� r� r� r� r� r� ) rK r rV r �SHARED_CLASSES�platformrs �splitr r� r )r. r` r� r7 r8 r0 rE r2 r2 r3 �get_reg_details� sH �� ����zBakAuth.get_reg_details)r7 r8 r5 r9 c C s0 | j d|||d�\}}|tjur,t||d��dS )ay Check if backup authority is reachable and raise an exception if not Args: timeout (int): request timeout in seconds retries (int): number of times to retry each server on timeout log_retries (bool): whether to log on auto-retries. Defaults False Raises: BakAuthError: backup authority is not reachable z/monitoring/ping)r6 r7 r8 r5 rS Nr� )r. r7 r8 r5 rE r0 r2 r2 r3 �ping� s � z BakAuth.ping)r7 r8 r� )rv r� r7 r8 r� r9 c C sj |du ri }n dt |�i}| jf d||d||d�|��\}}} |tjurTt||d��| j|dd| d � dS ) a# Tell ceph to repair a bucket's index Args: user (str): username that owns the bucket (root if v/ded) bucket (str): full bucket name timeout (int): request timeout in seconds retries (int): number of times to retry the request on timeout geo (bool | None): if True, check opposite coast; if False, check same-coast. If None (default), check both if present. Raises: BakAuthError: error either requesting the repair, or checking on it Nr� z/buckets/queue_repairF)r6 r7 r8 r> rv r� rS � � )rN rO r; )rf rG r rV r rY ) r. rv r� r7 r8 r� rD rE r0 Z auth_hostr2 r2 r3 �check_bucket_index s �� zBakAuth.check_bucket_index�root)r� )rv r� r9 c K s� | � � }|rZt|d d |d d |d d f�s@ttjdd��|d d }|d d }n|d }|d }|d tv }|s�|dkr�td |�d |d � ���|dkr�tf |||d d �|��S | �|�\}} tf ||| d �|��S ) av Get a Restic instance for a specific user on a backups 3.x client, assuming the current server is setup with it Args: user (str): If on a shared server, this is the username to get the Restic instance for. For reseller children, supply their reseller's name. If on vps/dedicated, always lookup "root" geo (bool): If True, use the secondary, geographically separated cluster. **kwargs: other keyword arguments to send as-is to the Restic() constructor Raises: ValueError: Incorrect user argument supplied WrongSharedServer: The requested user does not belong here BakAuthDown: Backup Authority server was unreachable BakAuthError: Any other API error Returns: Restic: restic instance r� r� r� r� � This cluster is not availablerS r[ r� zuser=z; should be root on r� �r� �clusterr� ) r� �allr r r� r� � ValueErrorr r� ) r. rv r� rD �regr� r� Z is_sharedrw r� r2 r2 r3 � get_restic9 s4 ��� ��zBakAuth.get_restic)r� r� r9 c K s� |du rt �� }| j|dd�d }| �� }|rzt|d d |d d |d d �s`ttjd d ��|d d }|d d }n|d }|d }d tf |||d d �|��i}|� � D ]"\} } tf ||| d �|��|| < q�|S )a If users are not supplied, get all restic instances for this shared server, including root. Otherwise, get that set of users Args: users (list[str] | None): List of users to obtain restic instances for. This function will not resolve child account names to resellers, so be sure to only request main cpanel users geo (bool): If True, use the secondary, geographically separated cluster. **kwargs: other keyword arguments to send as-is to the Restic() constructor Raises: BakAuthDown: Backup Authority server was unreachable WrongServerClass: The current server is not a shared server BakAuthError: Any other API error Returns: dict[str, Restic]: usernames mapped to Restic instances. If users was supplied, not all usernames requested may be in the result, if bakauth did not recognize some as belonging to this server Nr )r� rN r� r� r� r� r� r� rS r� r� r� ) �rads� main_cpusersr� r� r� r r r� r rp ) r. r� r� rD r� r� r� r� rF rv r� r2 r2 r3 � all_resticsl s< �� ����� zBakAuth.all_restics)r� )NF)7�__name__� __module__� __qualname__�__doc__r4 r* rf �bool�tupler r r= rG rK r< r rY � staticmethod�dictr_ r r r rq r ru r rx r r� r� r� r� r� r� r r� r r� r� r r� r r� r� r� r� r� r r� r� r� r r� r� r2 r2 r2 r3 r! O s� � � %� � 7� � /�� (� �)� � 5� � 2�� � � 1�� 1�� )�� &�� '�� &�� ,�� ,� � C� � /� � 0�� �� #� � $� � B�� � � , ��� 4 � �r! )4r� r� �typingr r r+ rB rH r' rT r� r� r� �resticr r �hintsr r r r r r r Zsessr r r r r r1 r r r r r r r r r r r r r r � __version__r< ZBAKAUTH2r@ r& r� r! r2 r2 r2 r3 �<module> s* $ @
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка