File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/auto.tar
Back
full_auto_attach/v1.py 0000644 00000015673 15030104162 0010766 0 ustar 00 from typing import List, Optional, Tuple from uaclient import actions, contract, event_logger, lock, messages, util from uaclient.api import exceptions from uaclient.api.api import APIEndpoint from uaclient.api.data_types import AdditionalInfo from uaclient.api.u.pro.status.is_attached.v1 import _is_attached from uaclient.clouds import identity from uaclient.config import UAConfig from uaclient.data_types import DataObject, Field, StringDataValue, data_list from uaclient.entitlements import order_entitlements_for_enabling from uaclient.entitlements.entitlement_status import CanEnableFailure from uaclient.files import machine_token event = event_logger.get_event_logger() class FullAutoAttachOptions(DataObject): fields = [ Field( "enable", data_list(StringDataValue), False, doc="Optional list of services to enable after auto-attaching.", ), Field( "enable_beta", data_list(StringDataValue), False, doc=( "Optional list of beta services to enable after" " auto-attaching." ), ), Field( "cloud_override", StringDataValue, False, doc=( "Ignore the result of ``cloud-id`` and act as if running on" " this cloud." ), ), ] def __init__( self, enable: Optional[List[str]] = None, enable_beta: Optional[List[str]] = None, cloud_override: Optional[str] = None, ): self.enable = enable self.enable_beta = enable_beta self.cloud_override = cloud_override class FullAutoAttachResult(DataObject, AdditionalInfo): pass def _enable_services_by_name( cfg: UAConfig, services: List[str] ) -> List[Tuple[str, messages.NamedMessage]]: failed_services = [] for name in order_entitlements_for_enabling(cfg, services): try: ent_ret, reason = actions.enable_entitlement_by_name(cfg, name) except exceptions.UbuntuProError as e: failed_services.append( (name, messages.NamedMessage(e.msg_code or "unknown", e.msg)) ) continue if not ent_ret: if ( reason is not None and isinstance(reason, CanEnableFailure) and reason.message is not None ): failed_services.append((name, reason.message)) else: failed_services.append( ( name, messages.NamedMessage("unknown", "failed to enable"), ) ) return failed_services def full_auto_attach(options: FullAutoAttachOptions) -> FullAutoAttachResult: return _full_auto_attach(options, UAConfig()) def _full_auto_attach( options: FullAutoAttachOptions, cfg: UAConfig, *, mode: event_logger.EventLoggerMode = event_logger.EventLoggerMode.JSON ) -> FullAutoAttachResult: """ This endpoint runs the whole auto-attach process on the system. """ try: with lock.RetryLock( lock_holder="pro.api.u.pro.attach.auto.full_auto_attach.v1", ): ret = _full_auto_attach_in_lock(options, cfg, mode=mode) except Exception as e: lock.clear_lock_file_if_present() raise e return ret def _full_auto_attach_in_lock( options: FullAutoAttachOptions, cfg: UAConfig, mode: event_logger.EventLoggerMode, ) -> FullAutoAttachResult: event.set_event_mode(mode) machine_token_file = machine_token.get_machine_token_file(cfg) if _is_attached(cfg).is_attached: raise exceptions.AlreadyAttachedError( account_name=machine_token_file.account.get("name", "") ) if util.is_config_value_true( config=cfg.cfg, path_to_value="features.disable_auto_attach" ): raise exceptions.AutoAttachDisabledError() instance = identity.cloud_instance_factory( cloud_override=options.cloud_override ) enable_default_services = ( options.enable is None and options.enable_beta is None ) actions.auto_attach(cfg, instance, allow_enable=enable_default_services) failed = [] if options.enable is not None: failed += _enable_services_by_name(cfg, options.enable) if options.enable_beta is not None: failed += _enable_services_by_name(cfg, options.enable_beta) contract_client = contract.UAContractClient(cfg) contract_client.update_activity_token() if len(failed) > 0: raise exceptions.EntitlementsNotEnabledError(failed) return FullAutoAttachResult() endpoint = APIEndpoint( version="v1", name="FullAutoAttach", fn=_full_auto_attach, options_cls=FullAutoAttachOptions, ) _doc = { "introduced_in": "27.11", "requires_network": True, "extra_args_content": """ .. note:: If none of the lists are set, the services will be enabled based on the contract definitions. """, "example_python": """ from uaclient.api.u.pro.attach.auto.full_auto_attach.v1 import full_auto_attach, FullAutoAttachOptions options = FullAutoAttachOptions(enable=["<service1>", "<service2>"], enable_beta=["<beta_service3>"]) result = full_auto_attach(options) """, # noqa: E501 "result_class": FullAutoAttachResult, "exceptions": [ ( exceptions.AlreadyAttachedError, ( "Raised if running on a machine which is already attached to a" " Pro subscription." ), ), ( exceptions.AutoAttachDisabledError, "Raised if ``disable_auto_attach: true`` in ``uaclient.conf``.", ), ( exceptions.ConnectivityError, ( "Raised if it is not possible to connect to the contracts" " service." ), ), ( exceptions.ContractAPIError, ( "Raised if there is an unexpected error in the contracts" " service interaction." ), ), ( exceptions.EntitlementsNotEnabledError, ( "Raised if the Client fails to enable any of the entitlements" " (whether present in any of the lists or listed in the" " contract)." ), ), ( exceptions.LockHeldError, ( "Raised if another Client process is holding the lock on the" " machine." ), ), ( exceptions.NonAutoAttachImageError, ( "Raised if the cloud where the system is running does not" " support auto-attach." ), ), ], "example_cli": 'pro api u.pro.attach.auto.full_auto_attach.v1 --data {"enable": ["esm-infra", "esm-apps"]}', # noqa: E501 "example_json": """ {} """, } full_auto_attach/__pycache__/__init__.cpython-310.pyc 0000644 00000000267 15030104162 0016527 0 ustar 00 o �ϴf � @ s d S )N� r r r �Z/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/full_auto_attach/__init__.py�<module> s full_auto_attach/__pycache__/v1.cpython-310.pyc 0000644 00000013165 15030104162 0015317 0 ustar 00 o �(�f� � @ s� d dl mZmZmZ d dlmZmZmZmZm Z m Z d dl m Z d dl mZ d dlmZ d dlmZ d dlmZ d dlmZ d d lmZmZmZmZ d d l m Z d d l m Z d d l m!Z! e�"� Z#G d d� de�Z$G dd� dee�Z%dedee& deee&e j'f fdd�Z(de$de%fdd�Z)ej*j+d�de$dedej*de%fdd �Z,de$dedej*de%fd d �Z-ed d e,e$d!�Z.d"d#d$d%e%e j/d&fe j0d'fe j1d(fe j2d)fe j3d*fe j4d+fe j5d,fgd-d.d/�Z6d0S )1� )�List�Optional�Tuple)�actions�contract� event_logger�lock�messages�util)� exceptions)� APIEndpoint)�AdditionalInfo)� _is_attached)�identity)�UAConfig)� DataObject�Field�StringDataValue� data_list)� order_entitlements_for_enabling)�CanEnableFailure)� machine_tokenc @ st e Zd Zedee�ddd�edee�ddd�ededdd�gZ d deee deee dee fd d �Z d S ) �FullAutoAttachOptions�enableFz9Optional list of services to enable after auto-attaching.)�doc� enable_betaz>Optional list of beta services to enable after auto-attaching.�cloud_overridezFIgnore the result of ``cloud-id`` and act as if running on this cloud.Nc C s || _ || _|| _d S �N)r r r )�selfr r r � r �T/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/full_auto_attach/v1.py�__init__. s z FullAutoAttachOptions.__init__)NNN) �__name__� __module__� __qualname__r r r �fieldsr r �strr! r r r r r s< �� �� � � ��r c @ s e Zd ZdS )�FullAutoAttachResultN)r" r# r$ r r r r r' 9 s r' �cfg�services�returnc C s� g }t | |�D ]S}z t�| |�\}}W n" tjy5 } z|�|t�|jp%d|j �f� W Y d }~qd }~ww |sZ|d urOt |t �rO|j d urO|�||j f� q|�|t�dd�f� q|S )N�unknownzfailed to enable) r r �enable_entitlement_by_namer �UbuntuProError�appendr � NamedMessage�msg_code�msg� isinstancer �message)r( r) �failed_services�name�ent_ret�reason�er r r �_enable_services_by_name= s0 � ��� ���r9 �optionsc C s t | t� �S r )�_full_auto_attachr )r: r r r �full_auto_attachZ s r< ��moder> c C sj z"t jdd�� t| ||d�}W d � W |S 1 sw Y W |S ty4 } zt �� |�d}~ww )zI This endpoint runs the whole auto-attach process on the system. z-pro.api.u.pro.attach.auto.full_auto_attach.v1)� lock_holderr= N)r � RetryLock�_full_auto_attach_in_lock� Exception�clear_lock_file_if_present)r: r( r> �retr8 r r r r; ^ s � �����r; c C s� t �|� t�|�}t|�jrtj|j� dd�d��t j |j dd�r&t� � �tj| jd�}| jd u o6| jd u }tj|||d� g }| jd urN|t|| j�7 }| jd ur[|t|| j�7 }t�|�}|�� t|�dkrot�|��t� S ) Nr5 � )� account_namez features.disable_auto_attach)�config� path_to_value)r )� allow_enabler ) �event�set_event_moder �get_machine_token_filer � is_attachedr �AlreadyAttachedError�account�getr �is_config_value_truer( �AutoAttachDisabledErrorr �cloud_instance_factoryr r r r � auto_attachr9 r �UAContractClient�update_activity_token�len�EntitlementsNotEnabledErrorr' )r: r( r> �machine_token_file�instance�enable_default_services�failed�contract_clientr r r rA r s4 ���� rA �v1�FullAutoAttach)�versionr5 �fn� options_clsz27.11Tzr .. note:: If none of the lists are set, the services will be enabled based on the contract definitions. z� from uaclient.api.u.pro.attach.auto.full_auto_attach.v1 import full_auto_attach, FullAutoAttachOptions options = FullAutoAttachOptions(enable=["<service1>", "<service2>"], enable_beta=["<beta_service3>"]) result = full_auto_attach(options) zORaised if running on a machine which is already attached to a Pro subscription.z=Raised if ``disable_auto_attach: true`` in ``uaclient.conf``.zARaised if it is not possible to connect to the contracts service.zLRaised if there is an unexpected error in the contracts service interaction.z}Raised if the Client fails to enable any of the entitlements (whether present in any of the lists or listed in the contract).zDRaised if another Client process is holding the lock on the machine.zMRaised if the cloud where the system is running does not support auto-attach.zZpro api u.pro.attach.auto.full_auto_attach.v1 --data {"enable": ["esm-infra", "esm-apps"]}z {} )� introduced_in�requires_network�extra_args_content�example_python� result_classr � example_cli� example_jsonN)7�typingr r r �uaclientr r r r r r � uaclient.apir �uaclient.api.apir �uaclient.api.data_typesr �(uaclient.api.u.pro.status.is_attached.v1r �uaclient.cloudsr �uaclient.configr �uaclient.data_typesr r r r �uaclient.entitlementsr �(uaclient.entitlements.entitlement_statusr �uaclient.filesr �get_event_loggerrJ r r' r& r/ r9 r< �EventLoggerMode�JSONr; rA �endpointrN rR �ConnectivityError�ContractAPIErrorrX � LockHeldError�NonAutoAttachImageError�_docr r r r �<module> s� '�� � ���� ���� �)������ ���1 � full_auto_attach/__init__.py 0000644 00000000000 15030104162 0012151 0 ustar 00 __pycache__/__init__.cpython-310.pyc 0000644 00000000246 15030104162 0013206 0 ustar 00 o �ϴf � @ s d S )N� r r r �I/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/__init__.py�<module> s configure_retry_service/v1.py 0000644 00000005303 15030104162 0012363 0 ustar 00 from uaclient import system from uaclient.api.api import APIEndpoint from uaclient.api.data_types import AdditionalInfo from uaclient.api.u.pro.attach.auto.full_auto_attach.v1 import ( FullAutoAttachOptions, ) from uaclient.config import UAConfig from uaclient.daemon import retry_auto_attach from uaclient.data_types import DataObject from uaclient.files import state_files ConfigureRetryServiceOptions = FullAutoAttachOptions class ConfigureRetryServiceResult(DataObject, AdditionalInfo): pass def configure_retry_service( options: ConfigureRetryServiceOptions, ) -> ConfigureRetryServiceResult: return _configure_retry_service(options, UAConfig()) def _configure_retry_service( options: ConfigureRetryServiceOptions, cfg: UAConfig ) -> ConfigureRetryServiceResult: """ This endpoint configures options for the retry auto-attach functionality, and creates files that will activate the retry auto-attach functionality if ``ubuntu-advantage.service`` runs. Note that this does not start ``ubuntu-advantage.service``. This makes it useful for calling during the boot process ``Before: ubuntu-advantage.service`` so that when ``ubuntu-advantage.service`` starts, its ``ConditionPathExists`` check passes and activates the retry auto-attach function. If you call this function outside of the boot process and would like the retry auto-attach functionality to actually start, you'll need to call something like ``systemctl start ubuntu-advantage.service``. """ state_files.retry_auto_attach_options_file.write( state_files.RetryAutoAttachOptions( enable=options.enable, enable_beta=options.enable_beta ) ) system.create_file(retry_auto_attach.FLAG_FILE_PATH) return ConfigureRetryServiceResult() endpoint = APIEndpoint( version="v1", name="ConfigureRetryService", fn=_configure_retry_service, options_cls=ConfigureRetryServiceOptions, ) _doc = { "introduced_in": "27.12", "requires_network": False, "extra_args_content": """ .. note:: If none of the lists are set, the services will be enabled based on the contract definitions. """, "example_python": """ from uaclient.api.u.pro.attach.auto.configure_retry_service.v1 import configure_retry_service, ConfigureRetryServiceOptions options = ConfigureRetryServiceOptions(enable=["<service1>", "<service2>"], enable_beta=["<beta_service3>"]) result = configure_retry_service(options) """, # noqa: E501 "result_class": ConfigureRetryServiceResult, "exceptions": [], "example_cli": 'pro api u.pro.attach.auto.configure_retry_service.v1 --data {"enable": ["esm-infra", "esm-apps"]}', # noqa: E501 "example_json": """ {} """, } configure_retry_service/__pycache__/__init__.cpython-310.pyc 0000644 00000000276 15030104162 0020137 0 ustar 00 o �ϴf � @ s d S )N� r r r �a/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/configure_retry_service/__init__.py�<module> s configure_retry_service/__pycache__/v1.cpython-310.pyc 0000644 00000005517 15030104162 0016731 0 ustar 00 o �(�f� � @ s� d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl m Z d dl m Z d dlmZ eZG d d � d e e�Zd ed efd d�Zd ede d efdd�Zeddeed�Zddddeg ddd�Zd S ) � )�system)� APIEndpoint)�AdditionalInfo)�FullAutoAttachOptions)�UAConfig)�retry_auto_attach)� DataObject)� state_filesc @ s e Zd ZdS )�ConfigureRetryServiceResultN)�__name__� __module__� __qualname__� r r �[/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/configure_retry_service/v1.pyr s r �options�returnc C s t | t� �S )N)�_configure_retry_servicer )r r r r �configure_retry_service s r �cfgc C s, t j�t j| j| jd�� t�tj � t � S )a� This endpoint configures options for the retry auto-attach functionality, and creates files that will activate the retry auto-attach functionality if ``ubuntu-advantage.service`` runs. Note that this does not start ``ubuntu-advantage.service``. This makes it useful for calling during the boot process ``Before: ubuntu-advantage.service`` so that when ``ubuntu-advantage.service`` starts, its ``ConditionPathExists`` check passes and activates the retry auto-attach function. If you call this function outside of the boot process and would like the retry auto-attach functionality to actually start, you'll need to call something like ``systemctl start ubuntu-advantage.service``. )�enable� enable_beta) r � retry_auto_attach_options_file�write�RetryAutoAttachOptionsr r r � create_filer �FLAG_FILE_PATHr )r r r r r r s �� r �v1�ConfigureRetryService)�version�name�fn� options_clsz27.12Fzr .. note:: If none of the lists are set, the services will be enabled based on the contract definitions. a from uaclient.api.u.pro.attach.auto.configure_retry_service.v1 import configure_retry_service, ConfigureRetryServiceOptions options = ConfigureRetryServiceOptions(enable=["<service1>", "<service2>"], enable_beta=["<beta_service3>"]) result = configure_retry_service(options) zapro api u.pro.attach.auto.configure_retry_service.v1 --data {"enable": ["esm-infra", "esm-apps"]}z {} )� introduced_in�requires_network�extra_args_content�example_python� result_class� exceptions� example_cli� example_jsonN)�uaclientr �uaclient.api.apir �uaclient.api.data_typesr �2uaclient.api.u.pro.attach.auto.full_auto_attach.v1r �uaclient.configr �uaclient.daemonr �uaclient.data_typesr �uaclient.filesr � ConfigureRetryServiceOptionsr r r �endpoint�_docr r r r �<module> sJ � ��� �� � configure_retry_service/__init__.py 0000644 00000000000 15030104162 0013561 0 ustar 00 should_auto_attach/v1.py 0000644 00000003417 15030104162 0011313 0 ustar 00 from uaclient import exceptions from uaclient.api.api import APIEndpoint from uaclient.api.data_types import AdditionalInfo from uaclient.apt import is_installed from uaclient.clouds.identity import cloud_instance_factory from uaclient.config import UAConfig from uaclient.data_types import BoolDataValue, DataObject, Field class ShouldAutoAttachResult(DataObject, AdditionalInfo): fields = [ Field( "should_auto_attach", BoolDataValue, doc="True if the system should run auto-attach on boot", ), ] def __init__(self, should_auto_attach: bool): self.should_auto_attach = should_auto_attach def should_auto_attach() -> ShouldAutoAttachResult: return _should_auto_attach(UAConfig()) def _should_auto_attach(cfg: UAConfig) -> ShouldAutoAttachResult: """ This endpoint checks if a given system should run auto-attach on boot. """ try: cloud_instance_factory() except exceptions.CloudFactoryError: return ShouldAutoAttachResult( should_auto_attach=False, ) return ShouldAutoAttachResult( should_auto_attach=is_installed("ubuntu-advantage-pro") or is_installed("ubuntu-pro-auto-attach"), ) endpoint = APIEndpoint( version="v1", name="ShouldAutoAttach", fn=_should_auto_attach, options_cls=None, ) _doc = { "introduced_in": "27.11", "requires_network": False, "example_python": """ from uaclient.api.u.pro.attach.auto.should_auto_attach.v1 import should_auto_attach result = should_auto_attach() """, # noqa: E501 "result_class": ShouldAutoAttachResult, "exceptions": [], "example_cli": "pro api u.pro.attach.auto.should_auto_attach.v1", "example_json": """ { "should_auto_attach": false } """, } should_auto_attach/__pycache__/__init__.cpython-310.pyc 0000644 00000000271 15030104162 0017056 0 ustar 00 o �ϴf � @ s d S )N� r r r �\/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/should_auto_attach/__init__.py�<module> s should_auto_attach/__pycache__/v1.cpython-310.pyc 0000644 00000003726 15030104162 0015655 0 ustar 00 o �(�f � @ s� d dl mZ d dlmZ d dlmZ d dlmZ d dlm Z d dl m Z d dl m Z mZmZ G dd � d ee�Zd efd d �Zd e d efdd�Zeddedd�Zdddeg ddd�ZdS )� )� exceptions)� APIEndpoint)�AdditionalInfo)� is_installed)�cloud_instance_factory)�UAConfig)� BoolDataValue� DataObject�Fieldc @ s* e Zd Zededd�gZdefdd�ZdS )�ShouldAutoAttachResult�should_auto_attachz1True if the system should run auto-attach on boot)�docc C s || _ d S �N�r )�selfr � r �V/usr/lib/python3/dist-packages/uaclient/api/u/pro/attach/auto/should_auto_attach/v1.py�__init__ � z ShouldAutoAttachResult.__init__N)�__name__� __module__� __qualname__r r �fields�boolr r r r r r s ��r �returnc C s t t� �S r )�_should_auto_attachr r r r r r r r �cfgc C s@ zt � W n tjy tdd� Y S w ttd�p td�d�S )zP This endpoint checks if a given system should run auto-attach on boot. Fr zubuntu-advantage-prozubuntu-pro-auto-attach)r r �CloudFactoryErrorr r )r r r r r s ���r �v1�ShouldAutoAttachN)�version�name�fn� options_clsz27.11Fzt from uaclient.api.u.pro.attach.auto.should_auto_attach.v1 import should_auto_attach result = should_auto_attach() z/pro api u.pro.attach.auto.should_auto_attach.v1z% { "should_auto_attach": false } )� introduced_in�requires_network�example_python� result_classr � example_cli� example_json)�uaclientr �uaclient.api.apir �uaclient.api.data_typesr � uaclient.aptr �uaclient.clouds.identityr �uaclient.configr �uaclient.data_typesr r r r r r �endpoint�_docr r r r �<module> s0 � � should_auto_attach/__init__.py 0000644 00000000000 15030104162 0012505 0 ustar 00 __init__.py 0000644 00000000000 15030104162 0006633 0 ustar 00
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings