File manager - Edit - /home/newsbmcs.com/public_html/static/img/logo/imc.tar
Back
config_custom_script.py 0000644 00000006064 15030055134 0011343 0 ustar 00 # Copyright (C) 2017 Canonical Ltd. # Copyright (C) 2017-2019 VMware Inc. # # Author: Maitreyee Saikia <msaikia@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. import logging import os import stat from cloudinit import subp, util LOG = logging.getLogger(__name__) class CustomScriptNotFound(Exception): pass class CustomScriptConstant: CUSTOM_TMP_DIR = "/root/.customization" # The user defined custom script CUSTOM_SCRIPT_NAME = "customize.sh" CUSTOM_SCRIPT = os.path.join(CUSTOM_TMP_DIR, CUSTOM_SCRIPT_NAME) POST_CUSTOM_PENDING_MARKER = "/.guest-customization-post-reboot-pending" # The cc_scripts_per_instance script to launch custom script POST_CUSTOM_SCRIPT_NAME = "post-customize-guest.sh" class RunCustomScript: def __init__(self, scriptname, directory): self.scriptname = scriptname self.directory = directory self.scriptpath = os.path.join(directory, scriptname) def prepare_script(self): if not os.path.exists(self.scriptpath): raise CustomScriptNotFound( "Script %s not found!! Cannot execute custom script!" % self.scriptpath ) util.ensure_dir(CustomScriptConstant.CUSTOM_TMP_DIR) LOG.debug( "Copying custom script to %s", CustomScriptConstant.CUSTOM_SCRIPT ) util.copy(self.scriptpath, CustomScriptConstant.CUSTOM_SCRIPT) # Strip any CR characters from the decoded script content = util.load_file(CustomScriptConstant.CUSTOM_SCRIPT).replace( "\r", "" ) util.write_file( CustomScriptConstant.CUSTOM_SCRIPT, content, mode=0o544 ) class PreCustomScript(RunCustomScript): def execute(self): """Executing custom script with precustomization argument.""" LOG.debug("Executing pre-customization script") self.prepare_script() subp.subp([CustomScriptConstant.CUSTOM_SCRIPT, "precustomization"]) class PostCustomScript(RunCustomScript): def __init__(self, scriptname, directory, ccScriptsDir): super(PostCustomScript, self).__init__(scriptname, directory) self.ccScriptsDir = ccScriptsDir self.ccScriptPath = os.path.join( ccScriptsDir, CustomScriptConstant.POST_CUSTOM_SCRIPT_NAME ) def execute(self): """ This method copy the post customize run script to cc_scripts_per_instance directory and let this module to run post custom script. """ self.prepare_script() LOG.debug("Copying post customize run script to %s", self.ccScriptPath) util.copy( os.path.join( self.directory, CustomScriptConstant.POST_CUSTOM_SCRIPT_NAME ), self.ccScriptPath, ) st = os.stat(self.ccScriptPath) os.chmod(self.ccScriptPath, st.st_mode | stat.S_IEXEC) LOG.info("Creating post customization pending marker") util.ensure_file(CustomScriptConstant.POST_CUSTOM_PENDING_MARKER) # vi: ts=4 expandtab boot_proto.py 0000644 00000000513 15030055134 0007277 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class BootProtoEnum: """Specifies the NIC Boot Settings.""" DHCP = "dhcp" STATIC = "static" # vi: ts=4 expandtab nic.py 0000644 00000006357 15030055134 0005676 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. from cloudinit.sources.helpers.vmware.imc.boot_proto import BootProtoEnum from cloudinit.sources.helpers.vmware.imc.nic_base import ( NicBase, StaticIpv4Base, StaticIpv6Base, ) class Nic(NicBase): """ Holds the information about each NIC specified in the customization specification file """ def __init__(self, name, configFile): self._name = name self._configFile = configFile def _get(self, what): return self._configFile.get(self.name + "|" + what, None) def _get_count_with_prefix(self, prefix): return self._configFile.get_count_with_prefix(self.name + prefix) @property def name(self): return self._name @property def mac(self): return self._get("MACADDR").lower() @property def primary(self): value = self._get("PRIMARY") if value: value = value.lower() return value == "yes" or value == "true" else: return False @property def onboot(self): value = self._get("ONBOOT") if value: value = value.lower() return value == "yes" or value == "true" else: return False @property def bootProto(self): value = self._get("BOOTPROTO") if value: return value.lower() else: return "" @property def ipv4_mode(self): value = self._get("IPv4_MODE") if value: return value.lower() else: return "" @property def staticIpv4(self): """ Checks the BOOTPROTO property and returns StaticIPv4Addr configuration object if STATIC configuration is set. """ if self.bootProto == BootProtoEnum.STATIC: return [StaticIpv4Addr(self)] else: return None @property def staticIpv6(self): cnt = self._get_count_with_prefix("|IPv6ADDR|") if not cnt: return None result = [] for index in range(1, cnt + 1): result.append(StaticIpv6Addr(self, index)) return result class StaticIpv4Addr(StaticIpv4Base): """Static IPV4 Setting.""" def __init__(self, nic): self._nic = nic @property def ip(self): return self._nic._get("IPADDR") @property def netmask(self): return self._nic._get("NETMASK") @property def gateways(self): value = self._nic._get("GATEWAY") if value: return [x.strip() for x in value.split(",")] else: return None class StaticIpv6Addr(StaticIpv6Base): """Static IPV6 Address.""" def __init__(self, nic, index): self._nic = nic self._index = index @property def ip(self): return self._nic._get("IPv6ADDR|" + str(self._index)) @property def netmask(self): return self._nic._get("IPv6NETMASK|" + str(self._index)) @property def gateway(self): return self._nic._get("IPv6GATEWAY|" + str(self._index)) # vi: ts=4 expandtab __pycache__/guestcust_event.cpython-310.pyc 0000644 00000001110 15030055134 0014671 0 ustar 00 o �Ad� � @ s G d d� d�Z dS )c @ s e Zd ZdZdZdZdZdZdS )�GuestCustEventEnumz7Specifies different types of Guest Customization Events�d �e �g �h N)�__name__� __module__� __qualname__�__doc__� GUESTCUST_EVENT_CUSTOMIZE_FAILED�$GUESTCUST_EVENT_NETWORK_SETUP_FAILED�GUESTCUST_EVENT_ENABLE_NICS�GUESTCUST_EVENT_QUERY_NICS� r r �V/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/guestcust_event.pyr s r N)r r r r r �<module> s __pycache__/ipv4_mode.cpython-310.pyc 0000644 00000001564 15030055134 0013345 0 ustar 00 o �Ad` � @ s G d d� d�Z dS )c @ s$ e Zd ZdZdZdZdZdZdZdS )� Ipv4ModeEnuma_ The IPv4 configuration mode which directly represents the user's goal. This mode effectively acts as a contract of the in-guest customization engine. It must be set based on what the user has requested and should not be changed by those layers. It's up to the in-guest engine to interpret and materialize the user's request. �BACKWARDS_COMPATIBLE�STATIC�DHCP�DISABLED�AS_ISN) �__name__� __module__� __qualname__�__doc__� IPV4_MODE_BACKWARDS_COMPATIBLE�IPV4_MODE_STATIC�IPV4_MODE_DHCP�IPV4_MODE_DISABLED�IPV4_MODE_AS_IS� r r �P/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/ipv4_mode.pyr s r N)r r r r r �<module> s __pycache__/__init__.cpython-310.pyc 0000644 00000000254 15030055134 0013211 0 ustar 00 o �Ad � @ s d S )N� r r r �O/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/__init__.py�<module> s __pycache__/guestcust_state.cpython-310.pyc 0000644 00000000741 15030055134 0014701 0 ustar 00 o �Ad} � @ s G d d� d�Z dS )c @ s e Zd ZdZdZdZdS )�GuestCustStateEnumz8Specifies different states of Guest Customization engine� � N)�__name__� __module__� __qualname__�__doc__�GUESTCUST_STATE_RUNNING�GUESTCUST_STATE_DONE� r r �V/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/guestcust_state.pyr s r N)r r r r r �<module> s __pycache__/guestcust_error.cpython-310.pyc 0000644 00000001032 15030055134 0014704 0 ustar 00 o �Ad� � @ s G d d� d�Z dS )c @ s e Zd ZdZdZdZdZdS )�GuestCustErrorEnumz8Specifies different errors of Guest Customization engine� � � N)�__name__� __module__� __qualname__�__doc__�GUESTCUST_ERROR_SUCCESS� GUESTCUST_ERROR_SCRIPT_DISABLED�!GUESTCUST_ERROR_WRONG_META_FORMAT� r r �V/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/guestcust_error.pyr s r N)r r r r r �<module> s __pycache__/nic_base.cpython-310.pyc 0000644 00000011026 15030055134 0013214 0 ustar 00 o �Ad6 � @ s. G d d� d�Z G dd� d�ZG dd� d�ZdS )c @ sl e Zd ZdZedd� �Zedd� �Zedd� �Zedd � �Zed d � �Z ed d � �Z edd� �Z dd� Z dS )�NicBasez{ Define what are expected of each nic. The following properties should be provided in an implementation class. c C � t d��)zb Retrieves the mac address of the nic @return (str) : the MACADDR setting �MACADDR��NotImplementedError��self� r �O/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/nic_base.py�mac � z NicBase.macc C r )a Retrieves whether the nic is the primary nic Indicates whether NIC will be used to define the default gateway. If none of the NICs is configured to be primary, default gateway won't be set. @return (bool): the PRIMARY setting �PRIMARYr r r r r �primary s zNicBase.primaryc C r )zu Retrieves whether the nic should be up at the boot time @return (bool) : the ONBOOT setting �ONBOOTr r r r r �onboot" r zNicBase.onbootc C r )z� Retrieves the boot protocol of the nic @return (str): the BOOTPROTO setting, valid values: dhcp and static. � BOOTPROTOr r r r r � bootProto* r zNicBase.bootProtoc C r )z� Retrieves the IPv4_MODE @return (str): the IPv4_MODE setting, valid values: backwards_compatible, static, dhcp, disabled, as_is � IPv4_MODEr r r r r � ipv4_mode2 s zNicBase.ipv4_modec C r )z� Retrieves the static IPv4 configuration of the nic @return (StaticIpv4Base list): the static ipv4 setting z Static IPv4r r r r r � staticIpv4; r zNicBase.staticIpv4c C r )z| Retrieves the IPv6 configuration of the nic @return (StaticIpv6Base list): the static ipv6 setting z Static Ipv6r r r r r � staticIpv6C r zNicBase.staticIpv6c C r )z� Validate the object For example, the staticIpv4 property is required and should not be empty when ipv4Mode is STATIC z Check constraints on propertiesr r r r r �validateK r zNicBase.validateN) �__name__� __module__� __qualname__�__doc__�propertyr r r r r r r r r r r r r s" r c @ �4 e Zd ZdZedd� �Zedd� �Zedd� �ZdS ) �StaticIpv4Basez� Define what are expected of a static IPv4 setting The following properties should be provided in an implementation class. c C r )zV Retrieves the Ipv4 address @return (str): the IPADDR setting z Ipv4 Addressr r r r r �ipZ r zStaticIpv4Base.ipc C r )z_ Retrieves the Ipv4 NETMASK setting @return (str): the NETMASK setting z Ipv4 NETMASKr r r r r �netmaskb r zStaticIpv4Base.netmaskc C r )zl Retrieves the gateways on this Ipv4 subnet @return (str list): the GATEWAY setting z Ipv4 GATEWAYr r r r r �gatewaysj r zStaticIpv4Base.gatewaysN)r r r r r r r r r r r r r T s r c @ r ) �StaticIpv6Basez�Define what are expected of a static IPv6 setting The following properties should be provided in an implementation class. c C r )zX Retrieves the Ipv6 address @return (str): the IPv6ADDR setting z Ipv6 Addressr r r r r r x r zStaticIpv6Base.ipc C r )zc Retrieves the Ipv6 NETMASK setting @return (str): the IPv6NETMASK setting z Ipv6 NETMASKr r r r r r � r zStaticIpv6Base.netmaskc C r )zc Retrieves the Ipv6 GATEWAY setting @return (str): the IPv6GATEWAY setting z Ipv6 GATEWAYr r r r r �gateway� r zStaticIpv6Base.gatewayN)r r r r r r r r" r r r r r! s s r! N)r r r! r r r r �<module> s K __pycache__/boot_proto.cpython-310.pyc 0000644 00000000642 15030055134 0013641 0 ustar 00 o �AdK � @ s G d d� d�Z dS )c @ s e Zd ZdZdZdZdS )� BootProtoEnumz Specifies the NIC Boot Settings.�dhcp�staticN)�__name__� __module__� __qualname__�__doc__�DHCP�STATIC� r r �Q/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/boot_proto.pyr s r N)r r r r r �<module> s __pycache__/config_file.cpython-310.pyc 0000644 00000006471 15030055134 0013725 0 ustar 00 o �Ad� � @ s< d dl Z d dlZd dlmZ e�e�ZG dd� dee�ZdS )� N)� ConfigSourcec @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dS )� ConfigFilez>ConfigFile module to load the content from a specified source.c C s | � |� d S )N)�_loadConfigFile)�self�filename� r �R/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config_file.py�__init__ s zConfigFile.__init__c C sX |� � }|� � }|�d�sd|v rd}nd}|r t�d||� nt�d|� || |< dS )z� Inserts a Key Value pair. Keyword arguments: key -- The key to insert val -- The value to insert for the key �-z|-FTz ADDED KEY-VAL :: '%s' = '%s'z+ADDED KEY-VAL :: '%s' = '*****************'N)�strip� startswith�logger�debug)r �key�val�canLogr r r � _insertKey s zConfigFile._insertKeyc C sr t �d|� t�� }t|_|�|� | �� |�� D ] }t � d|� |� |�D ]\}}| � |d | |� q'qdS )a% Parses properties from the specified config file. Any previously available properties will be removed. Sensitive data will not be logged in case the key starts from '-'. Keyword arguments: filename - The full path to the config file. zParsing the config file %s.zFOUND CATEGORY = '%s'�|N) r �info� configparser� ConfigParser�str� optionxform�read�clear�sectionsr �itemsr )r r �config�categoryr �valuer r r r / s ��zConfigFile._loadConfigFilec C s || vS )z� Determines whether a value for a property must be kept. If the propery is missing, it is treated as it should be not changed by the engine. Keyword arguments: key -- The key to search for. r �r r r r r �should_keep_current_valueH s z$ConfigFile.should_keep_current_valuec C s || v r t | | � S dS )a8 Determines whether a value for the property must be removed. If the specified key is empty, it is treated as it should be removed by the engine. Return true if the value can be removed, false otherwise. Keyword arguments: key -- The key to search for. F)�boolr r r r �should_remove_current_valueV s z&ConfigFile.should_remove_current_valuec s t � fdd�| D ��S )z� Return the total count of keys that start with the specified prefix. Keyword arguments: prefix -- prefix of the key c s g | ] }|� � �r|�qS r )r )�.0r ��prefixr r � <listcomp>p s z4ConfigFile.get_count_with_prefix.<locals>.<listcomp>)�len)r r& r r% r �get_count_with_prefixi s z ConfigFile.get_count_with_prefixN) �__name__� __module__� __qualname__�__doc__r r r r! r# r) r r r r r s r ) r �logging�2cloudinit.sources.helpers.vmware.imc.config_sourcer � getLoggerr* r �dictr r r r r �<module> s __pycache__/config_nic.cpython-310.pyc 0000644 00000016610 15030055134 0013553 0 ustar 00 o �Ad�" � @ sX d dl Z d dlZd dlZd dlmZmZ d dlmZ e �e �Z dd� Z G dd� d�Z dS )� N)�subp�util)�ipv4_mask_to_net_prefixc C s\ | � d�}|� d�}g }ttd��D ]}|�t|| �t|| �@ � qd�dd� |D ��S )z� Return the subnet for a given ip address and a netmask @return (str): the subnet @param ip: ip address @param netmask: netmask �.� c S s g | ]}t |��qS � )�str)�.0�xr r �Q/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config_nic.py� <listcomp> s z gen_subnet.<locals>.<listcomp>)�split�list�range�append�int�join)�ip�netmask�ip_array� mask_array�result�indexr r r � gen_subnet s r c @ sj e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z ddd�Z dd� Z d dd�Z dS ) �NicConfiguratorTc C sR || _ i | _d| _d| _|r| �� n| j D ] }|j| j|j�� < q| �� | _ dS )a Initialize the Nic Configurator @param nics (list) an array of nics to configure @param use_system_devices (Bool) Get the MAC names from the system if this is True. If False, then mac names will be retrieved from the specified nics. N) �nics�mac2Name�ipv4PrimaryGateway�ipv6PrimaryGateway� find_devices�name�mac�lower�get_primary_nic� _primaryNic)�selfr �use_system_devices�nicr r r �__init__# s zNicConfigurator.__init__c C s@ dd� | j D �}|s dS t|�dkr tddd� |D ���|d S )z| Retrieve the primary nic if it exists @return (NicBase): the primary nic if exists, None otherwise c S s g | ]}|j r|�qS r )�primary�r r' r r r r = s z3NicConfigurator.get_primary_nic.<locals>.<listcomp>N� z!There can only be one primary nicc S s g | ]}|j �qS r )r! r* r r r r C s r )r �len� Exception)r% � primary_nicsr r r r# 8 s �z NicConfigurator.get_primary_nicc C sz g d�}t � |�\}}t�dd| �dd� }d}|D ] }t�||�}|s&q|�d��� }|�dd�d } | | j|< qdS ) zb Create the mac2Name dictionary The mac address(es) are in the lower case )r �addr�showz\n\d+: � r+ Nz3link/ether (([0-9A-Fa-f]{2}[:]){5}([0-9A-Fa-f]{2}))�:r )r �rer �search�groupr" r ) r% �cmd�output�_err�sections�macPat�section�matchr! r r r r r H s �z NicConfigurator.find_devicesc C s� |j �� }| j�|�}|std|j ��g }d||d�}g }g }| �||�\}} |�|� |�| � | �||�\}} |�|� |�| � |�d|i� |� |� |rW|�|� |S )z� Return the config list needed to configure a nic @return (list): the subnets and routes list to configure the nic @param nic (NicBase): the nic to configure z No known device has MACADDR: %s�physical)�typer � mac_address�subnets) r! r" r �get� ValueError�gen_ipv4�extend�gen_ipv6�updater ) r% r' r! r � nics_cfg_list�cfg� subnet_list� route_listr@ �routesr r r � gen_one_nicZ s& zNicConfigurator.gen_one_nicc C s i }g }|j r|�ddi� |j�� }|j�� dkr d}|dkr,|�ddi� |g|fS |�ddi� |j}|s=|g|fS |d }|jrL|�d |ji� |jrW|�d |ji� |jrp|j rp|j d | _ |�d | j i� |g|fS | j s�|j r�|�d | � ||j |j�i� |g|fS ) a+ Return the set of subnets and routes needed to configure the IPv4 settings of a nic @return (set): the set of subnet and routes to configure the gateways @param name (str): subnet and route list for the nic @param nic (NicBase): the nic to configure �control�auto�disabled�manual�staticr> �dhcpr �addressr �gatewayrK ) �onbootrF � bootProtor" � ipv4_mode� staticIpv4r r r) �gatewaysr r$ �gen_ipv4_route)r% r r' �subnetrJ � bootproto�addrs�v4r r r rC ~ s8 � zNicConfigurator.gen_ipv4c C s@ g }t |�}|D ]}dt||�|f }|�|d|dd�� q|S )z� Return the routes list needed to configure additional Ipv4 route @return (list): the route list to configure the gateways @param nic (NicBase): the nic to configure @param gateways (str list): the list of gateways z%s/%d�route�' )� destinationr> rT �metric)r r r )r% r' rY r rJ �cidrrT ra r r r rZ � s �� z NicConfigurator.gen_ipv4_routec C sH |j sg g fS g }|j }|D ]}d|j|jd�}|�|� qg }||fS )a Return the set of subnets and routes needed to configure the gateways for a nic @return (set): the set of subnets and routes to configure the gateways @param name (str): name of the nic @param nic (NicBase): the nic to configure �static6)r> rS r )� staticIpv6r r r )r% r r' rI r] r/ r[ rJ r r r rE � s � zNicConfigurator.gen_ipv6c C s& g }|D ] }|� d|jdd�� q|S )Nr_ r` )r> rT rb )r rT )r% r r' r] rJ r/ r r r � _genIpv6Route� s �z NicConfigurator._genIpv6RouteFNc C s< |r t �d� | �|� g }| jD ] }|�| �|�� q|S )z@Return the config elements that are needed to configure the nicsz Configuring the interfaces file)�logger�info� configurer rD rL )r% ri �osfamilyrG r' r r r �generate� s zNicConfigurator.generatec C s2 t �d� tjddgddgd� t�g d�� d S )NzClearing DHCP leases�pkill�dhclientr r+ )�rcs)�rmz-fz/var/lib/dhcp/*)rg rh r )r% r r r � clear_dhcp s zNicConfigurator.clear_dhcpc C s� |r|dkr t �d� dS d}tj�|d�}tj�|d�}tj�|�s/tj�|�r/t�||� g d�}tj|d�|�d � | � � dS ) z^ Configure the /etc/network/interfaces Make a back up of the original �debianz3Debian OS not detected. Skipping the configure stepNz /etc/network� interfacesz&interfaces.before_vmware_customization)zH# DO NOT EDIT THIS FILE BY HAND -- AUTOMATICALLY GENERATED BY cloud-initz"source /etc/network/interfaces.d/*z*source-directory /etc/network/interfaces.dr1 )�content) rg rh �os�pathr �exists�renamer � write_filerp )r% rj � containingDir� interfaceFile� originalFile�linesr r r ri s � zNicConfigurator.configure)T)FN)N)�__name__� __module__� __qualname__r( r# r rL rC rZ rE rf rk rp ri r r r r r " s $2! r ) �loggingrt r3 � cloudinitr r �cloudinit.net.network_stater � getLoggerr} rg r r r r r r �<module> s __pycache__/config_source.cpython-310.pyc 0000644 00000000606 15030055134 0014300 0 ustar 00 o �Ad+ � @ s G d d� d�Z dS )c @ s e Zd ZdZdS )� ConfigSourcez*Specifies a source for the Config Content.N)�__name__� __module__� __qualname__�__doc__� r r �T/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config_source.pyr s r N)r r r r r �<module> s __pycache__/config_namespace.cpython-310.pyc 0000644 00000000737 15030055134 0014741 0 ustar 00 o �Ad~ � @ s d dl mZ G dd� de�ZdS )� )� ConfigSourcec @ s e Zd ZdZdS )�ConfigNamespacez Specifies the Config Namespace.N)�__name__� __module__� __qualname__�__doc__� r r �W/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config_namespace.pyr s r N)�2cloudinit.sources.helpers.vmware.imc.config_sourcer r r r r r �<module> s __pycache__/config_custom_script.cpython-310.pyc 0000644 00000006263 15030055134 0015703 0 ustar 00 o �Ad4 � @ s� d dl Z d dlZd dlZd dlmZmZ e �e�ZG dd� de �Z G dd� d�Z G dd� d�Z G d d � d e �Z G d d � d e �ZdS ) � N)�subp�utilc @ s e Zd ZdS )�CustomScriptNotFoundN)�__name__� __module__� __qualname__� r r �[/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config_custom_script.pyr s r c @ s* e Zd ZdZdZej�ee�ZdZ dZ dS )�CustomScriptConstantz/root/.customizationz customize.shz)/.guest-customization-post-reboot-pendingzpost-customize-guest.shN) r r r �CUSTOM_TMP_DIR�CUSTOM_SCRIPT_NAME�os�path�join� CUSTOM_SCRIPT�POST_CUSTOM_PENDING_MARKER�POST_CUSTOM_SCRIPT_NAMEr r r r r s r c @ s e Zd Zdd� Zdd� ZdS )�RunCustomScriptc C s || _ || _tj�||�| _d S �N)� scriptname� directoryr r r � scriptpath)�selfr r r r r �__init__! s zRunCustomScript.__init__c C sp t j�| j�std| j ��t�tj� t � dtj � t� | jtj � t� tj ��dd�}tjtj |dd� d S )Nz3Script %s not found!! Cannot execute custom script!zCopying custom script to %s� � id )�mode)r r �existsr r r � ensure_dirr r �LOG�debugr �copy� load_file�replace� write_file)r �contentr r r �prepare_script& s" �� � � �z RunCustomScript.prepare_scriptN)r r r r r& r r r r r s r c @ s e Zd Zdd� ZdS )�PreCustomScriptc C s& t �d� | �� t�tjdg� dS )z7Executing custom script with precustomization argument.z"Executing pre-customization script�precustomizationN)r r r& r r r )r r r r �execute> s zPreCustomScript.executeN)r r r r) r r r r r' = s r' c s$ e Zd Z� fdd�Zdd� Z� ZS )�PostCustomScriptc s. t t| ��||� || _tj�|tj�| _ d S r ) �superr* r � ccScriptsDirr r r r r � ccScriptPath)r r r r, �� __class__r r r F s �zPostCustomScript.__init__c C sn | � � t�d| j� t�tj�| j t j �| j� t� | j�}t� | j|jt jB � t�d� t�t j� dS )z� This method copy the post customize run script to cc_scripts_per_instance directory and let this module to run post custom script. z'Copying post customize run script to %sz*Creating post customization pending markerN)r& r r r- r r! r r r r r r �stat�chmod�st_mode�S_IEXEC�info� ensure_filer )r �str r r r) M s �� zPostCustomScript.execute)r r r r r) � __classcell__r r r. r r* E s r* )�loggingr r0 � cloudinitr r � getLoggerr r � Exceptionr r r r' r* r r r r �<module> s __pycache__/config.cpython-310.pyc 0000644 00000011220 15030055134 0012712 0 ustar 00 o �Adw � @ s d dl mZ G dd� d�ZdS )� )�Nicc @ s e Zd ZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdd� Zedd� �Zedd� �Zedd� �Zedd� �Zedd � �Zed d � �Zed d � �Zed!d"� �Z ed#d$� �Z ed%d&� �Z ed'd(� �Z ed)d*� �Z ed+d,� �Z!ed-d.� �Z"ed/d0� �Z#ed1d2� �Z$d3S )4�ConfigzT Stores the Contents specified in the Customization Specification file. zCUSTOM-SCRIPT|SCRIPT-NAMEzDNS|NAMESERVER|zNETWORK|DOMAINNAMEzNETWORK|HOSTNAMEzMISC|MARKER-IDzPASSWORD|-PASSzPASSWORD|RESETz DNS|SUFFIX|zDATETIME|TIMEZONEz DATETIME|UTCzMISC|POST-GC-STATUSz!MISC|DEFAULT-RUN-POST-CUST-SCRIPTzCLOUDINIT|METADATAzCLOUDINIT|USERDATAzCLOUDINIT|INSTANCE-IDc C s || _ d S )N)� _configFile)�self� configFile� r �M/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config.py�__init__" s zConfig.__init__c C � | j �tjd�S )zReturn the hostname.N)r �getr �HOSTNAME�r r r r � host_name% � zConfig.host_namec C r )zReturn the domain name.N)r r r � DOMAINNAMEr r r r � domain_name* r zConfig.domain_namec C r )zReturn the timezone.N)r r r �TIMEZONEr r r r �timezone/ r zConfig.timezonec C r )z.Retrieves whether to set time to UTC or Local.N)r r r �UTCr r r r �utc4 r z Config.utcc C r )z#Return the root password to be set.N)r r r �PASSr r r r �admin_password9 r zConfig.admin_passwordc C �H g }| j �tj�}td|d �D ]}tjt|� }|�| j | � q|S )z Return the list of DNS servers.� )r �get_count_with_prefixr �DNS�range�str�append�r �res�cnt�i�keyr r r � name_servers> � zConfig.name_serversc C r )z Return the list of DNS Suffixes.r )r r r �SUFFIXr r r r r r r � dns_suffixesI r% zConfig.dns_suffixesc C s4 g }| j d }|�d�D ] }|�t|| j �� q |S )z#Return the list of associated NICs.zNIC-CONFIG|NICS�,)r �splitr r )r r �nics�nicr r r r* T s z Config.nicsc C �0 | j �tjd�}|�� }|dvrtd��|dkS )z1Retreives if the root password needs to be reset.�no��yesr- z$ResetPassword value should be yes/nor/ )r r r � RESETPASS�lower� ValueError)r � resetPassr r r �reset_password^ � zConfig.reset_passwordc C r )zReturns marker id.N)r r r �MARKERIDr r r r � marker_idg r zConfig.marker_idc C r )z,Return the name of custom (pre/post) script.N)r r r � CUSTOM_SCRIPTr r r r �custom_script_namel r zConfig.custom_script_namec C r, )z8Return whether to post guestinfo.gc.status VMX property.r- r. z#PostGcStatus value should be yes/nor/ )r r r �POST_GC_STATUSr1 r2 )r � postGcStatusr r r �post_gc_statusq r5 zConfig.post_gc_statusc C r, )z� Return enable-custom-scripts default value if enable-custom-scripts is absent in VM Tools configuration r- r. z+defaultRunPostScript value should be yes/nor/ )r r r �DEFAULT_RUN_POST_SCRIPTr1 r2 )r �defaultRunPostScriptr r r �default_run_post_scriptz s �z Config.default_run_post_scriptc C r )z(Return the name of cloud-init meta data.N)r r r �CLOUDINIT_META_DATAr r r r �meta_data_name� r zConfig.meta_data_namec C r )z(Return the name of cloud-init user data.N)r r r �CLOUDINIT_USER_DATAr r r r �user_data_name� r zConfig.user_data_namec C r )zReturn instance idN)r r r �CLOUDINIT_INSTANCE_IDr r r r � instance_id� r zConfig.instance_idN)%�__name__� __module__� __qualname__�__doc__r8 r r r r6 r r0 r& r r r: r= r@ rB rD r �propertyr r r r r r$ r' r* r4 r7 r9 r< r? rA rC rE r r r r r sd r N)�(cloudinit.sources.helpers.vmware.imc.nicr r r r r r �<module> s __pycache__/guestcust_util.cpython-310.pyc 0000644 00000035077 15030055134 0014550 0 ustar 00 o �AdnN � @ s� d dl Z d dlZd dlZd dlZd dlmZmZ ddlmZ ddl m Z m Z m Z ddl mZ ddlmZ ddlmZ dd lmZ dd lmZ dd lmZ e �e�Zd Z d Z dZ dZ dZ dZ!dd� Z"dXdd�Z#dd� Z$dd� Z%dd� Z&d d � Z'd d � Z(d d!� Z)d"d#� Z*d$d%� Z+ dYd(d)�Z,dZd*d+�Z-d,d-� Z.d.d/� Z/d0d1� Z0d2d3� Z1 d[d6d7�Z2d8d9� Z3d:d;� Z4d<d=� Z5d>d?� Z6d@dA� Z7dBdC� Z8dDdE� Z9dFdG� Z:dHdI� Z;dJdK� Z<dLdM� Z=dNdO� Z>dPdQ� Z?dRdS� Z@dTdU� ZAdVdW� ZBdS )\� N)�subp�util� )�Config)�CustomScriptNotFound�PostCustomScript�PreCustomScript)� ConfigFile)�NicConfigurator)�PasswordConfigurator)�GuestCustErrorEnum)�GuestCustEventEnum)�GuestCustStateEnumz/var/log/cloud-init.log�queryNicsSupported� connected�/var/run/vmware-imc� deployPkgzenable-custom-scriptsc C s� | sd S d}d}z"t �d| � tjd| gdgd�\}}|r&|�� }W ||fS W ||fS tyI } zt �d� t �|� W Y d }~||fS d }~ww )N� z Error sending the RPC commandzSending RPC command: %szvmware-rpctoolr )�rcszFailed to send RPC command)�logger�debugr �rstrip� Exception� exception)�rpc�out�err�e� r �U/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/guestcust_util.py�send_rpc, s$ �� ��r c C s< d}|r t d | }nt }d| ||f }t|�\}}||fS )Nr �@z deployPkg.update.state %d %d %s)�CLOUDINIT_LOG_FILEr )� custstate� custerror� errormessage�messager r r r r r �set_customization_statusB s r' c C sV | sdS d}t j�| �sdS t| d��}|�|�}W d � |S 1 s$w Y |S )z�Reads the NICS from the specified file path and returns the content @param nicsfilepath: Absolute file path to the NICS.txt file. Ni �r)�os�path�exists�open�read)� nicsfilepath� NICS_SIZE�fp�nicsr r r �get_nics_to_enableO s ��r2 c C s� | s t �d� d S d}d}d}td|�D ]O}t �d|� ttjtj| �\}}|s0t � || � q|t kr<t �d� d S td|�D ]!}ttjtj | �\}}|r]|t kr]t �d|� d S t � |� qAqt �d|� d S ) Nz No Nics found� r r z(Trying to connect interfaces, attempt %dz-NICS connection status query is not supportedz NICS are connected on %d secondz2Can't connect network interfaces after %d attempts)r �warning�ranger r' r �GUESTCUST_STATE_RUNNINGr �GUESTCUST_EVENT_ENABLE_NICS�time�sleep�QUERY_NICS_SUPPORTED�GUESTCUST_EVENT_QUERY_NICS�NICS_STATUS_CONNECTED�info)r1 �enableNicsWaitRetries�enableNicsWaitCount�enableNicsWaitSeconds�attemptr �_err�countr r r � enable_nicsd sD � � � �rD c C s� t �d�s t�d� |S ddd| |g}zt � |�}W n2 t jyL } z%|jdkr3t�dd�|�|� n t�d||j� t�|� |W Y d }~S d }~ww |}t � d |j �}|ri|� d �� � }t�d | ||� |S t�d | ||� |S )a$ Return the value of [section] key from VMTools configuration. @param section: String of section to read from VMTools config @returns: String value from key in [section] or defaultVal if [section] is not present or vmware-toolbox-cmd is not installed. zvmware-toolbox-cmdz9vmware-toolbox-cmd not installed, returning default value�config�get�E zRvmware-toolbox-cmd returned 69 (unavailable) for cmd: %s. Return default value: %s� zFailed running %s[%s]Nz ([^=]+)=(.*)� z Get tools config: [%s] %s = %sz<Tools config: [%s] %s is not found, return default value: %s)r �whichr r �ProcessExecutionError� exit_code�join�errorr �re�match�stdout�group�strip)�section�key� defaultVal�cmdr r �retValue�mr r r �get_tools_config� sB � � �� ��rZ c C s | r | j r d| }t|�S d S )Nz info-set guestinfo.gc.status %s)�post_gc_statusr )rE �gcMsgr r r r � set_gc_status� s r] c C s t S �N)� IMC_DIR_PATHr r r r �get_imc_dir_path� s r` c C s� i d d i f\}}}}t |d� t|�\}}t| |�} | r%t||||�s%dS t| |�s,dS zt�d� t|dd|j�|d< W n t yZ } zt dt | �t j |� W Y d } ~ dS d } ~ ww t|� ttjtj� t |d� ||||fS )N�Started)NNNNz#Preparing the Network configurationT�networkz%Error preparing Network Configuration� Successful)r] �)get_non_network_data_from_vmware_cust_cfg� check_markers�do_special_customization�recheck_markersr r �%get_network_data_from_vmware_cust_cfg�osfamilyr �set_cust_error_status�strr �$GUESTCUST_EVENT_NETWORK_SETUP_FAILED� connect_nicsr' r �GUESTCUST_STATE_DONEr �GUESTCUST_ERROR_SUCCESS) � cloud_dir� scripts_cpath�cust_cfg� cust_cfg_dir�distro�md�ud�vd�cfg�is_special_customizationr r r r �get_data_from_imc_cust_cfg� sB � ����� rz c C sN t | d� d\}}}| j}|r�tj�t� |�}tj�|�s)tdd| tj | � dS zt � |�}W n t yM } ztdt |�tj | � W Y d }~dS d }~ww | j}|r�tj�t� |�}tj�|�smtdd| tj | � dS z t � |��dd �}W n t y� } ztd t |�tj | � W Y d }~dS d }~ww ttjtj� t | d � |||fS ) Nra �NNNz,Error locating the cloud-init meta data filez Meta data file is not found: %sz'Error loading cloud-init meta data filez+Error locating the cloud-init userdata filez Userdata file is not found: %s� r z&Error loading cloud-init userdata filerc )r] �meta_data_namer) r* rM r` r+ rj r � GUESTCUST_EVENT_CUSTOMIZE_FAILEDr � load_filer rk �user_data_name�replacer' r rn r ro ) rr ru rv rw �md_file�md_pathr �ud_file�ud_pathr r r �#get_data_from_imc_raw_data_cust_cfg� sl ���� ���� � r� c C s^ i i }}| j r| jr| j d | j |d< n| j |d< | jr#| j|d< | jr+| j|d< ||fS )N�.zlocal-hostname�timezonez instance-id)� host_name� domain_namer� � instance_id)rr ru rx r r r rd * s � rd TFc C s( t | j|�}|�||�}t|| j| j�S r^ )r r1 �generate�get_v1_network_config� name_servers� dns_suffixes)rr �use_system_devices� configureri �nicConfigurator� nics_cfg_listr r r rh : s �rh c C s( | }|s|r|� d||d�� d|d�S )N� nameserver)�type�address�searchr )�versionrE )�append)r� � nameserversr� � config_listr r r r� E s � r� c C s: t j�| d�}t j�|�rt�d|� tt|�� d S d S )Nznics.txtz %s file found, to connect nics)r) r* rM r+ r r rD r2 )rs � nics_filer r r rm P s �rm c C s t �| dd� S )N� disable_vmware_customizationT�r �get_cfg_option_bool)�sys_cfgr r r �is_vmware_cust_enabledW s �r� c C s t �| dd�S )N�allow_raw_dataTr� )�ds_cfgr r r �is_raw_data_cust_enabled] s r� c C sB t | �}tjtjdtd|fd�}|rt�d|� |S t�d� d S )N�3Waiting for VMware customization configuration filezcust.cfg)�logfunc�msg�func�argsz3Found VMware customization configuration file at %sz0No VMware customization configuration file found)�get_max_wait_from_cfgr �log_timer r �wait_for_cust_cfg_file)r� �max_wait�cust_cfg_file_pathr r r �get_cust_cfg_filea s �� r� � r3 c C s^ d}||krd}||k r-t j�|| �}t j�|�r|S t�d� t�|� ||7 }||k s d S )Nr r r� )r) r* rM �isfiler r r8 r9 )�filename�maxwait�naplen�dirpath�waited� fileFullPathr r r r� z s �r� c C sj d}d}|}| s |S z t | �||��}W n ty$ t�d||� Y nw |dk r3t�d|||� |}|S )N� �vmware_cust_file_max_waitz Failed to get '%s', using %sr z/Invalid value '%s' for '%s', using '%s' instead)�intrF � ValueErrorr r4 )r� �default_max_wait�max_wait_cfg_optionr� r r r r� � s. ���r� c C s$ |j }t|tj�| d��}|o| S )N�data)� marker_id�check_marker_existsr) r* rM )rp rr �product_marker�has_marker_filer r r re � s � re c C s2 | sdS t j�|d| d �}t j�|�rdS dS )ag Check the existence of a marker file. Presence of marker file determines whether a certain code path is to be executed. It is needed for partial guest customization in VMware. @param markerid: is an unique string representing a particular product marker. @param: marker_dir: The directory in which markers exist. F� .markerfile-�.txtT)r) r* rM r+ )�markerid� marker_dir� markerfiler r r r� � s r� c C s |j }|r t| |�s dS dS )NFT)r� �create_marker_file)rp rr r� r r r rg � s rg c C sX zt |jtj�| d�� W dS ty+ } ztdt|�tj |� W Y d }~dS d }~ww )Nr� zError creating marker filesFT) �setup_marker_filesr� r) r* rM r rj rk r r~ )rp rr r r r r r� � s ����r� c C s` t �d� tj�|d| d �}t�|�D ]}|�d�r&t�tj�||�� qt |d�� � dS )a# Create a new marker file. Marker files are unique to a full customization workflow in VMware environment. @param marker_id: is an unique string representing a particular product marker. @param: marker_dir: The directory in which markers exist. zHandle marker creationr� r� z .markerfile�wN) r r r) r* rM �listdir� startswithr �del_filer, �close)r� r� � marker_file�fnamer r r r� � s �r� c C st d}d}d}d}|j }|rt|�}|rt|||�}t||�}|r0|r0tj�| d�} t|||| �}|r8|o7|o7|S |S )NFz per-instance)�custom_script_name� check_custom_script_enablement�do_pre_custom_script�do_password_customizationr) r* rM �do_post_custom_script) rq rr rs rt �is_pre_custom_successful� is_password_custom_successful�is_post_custom_successful�is_custom_script_enabled� custom_script� ccScriptsDirr r r rf � s0 � ���rf c C sT z t ||�}|�� W dS ty) } ztdt|�tj| � W Y d }~dS d }~ww )Nz(Error executing pre-customization scriptFT)r �executer rj rk r r~ )rr r� rs �precustr r r r r� � s ����r� c C sV z t |||�}|�� W dS ty* } ztdt|�tj| � W Y d }~dS d }~ww )Nz)Error executing post-customization scriptFT)r r� r rj rk r r~ )rr r� rs r� �postcustr r r r r� s ����r� c C sP d}d}| j rt�d� d}ttt|�}|�� dkr$tddtj | � |S d}|S )NF�falsez=Set default value to true due to customization configuration.�truez-Custom script is disabled by VM Administratorz'Error checking custom script enablementT) �default_run_post_scriptr r rZ �IMC_TOOLS_CONF_GROUPNAME�"IMC_TOOLS_CONF_ENABLE_CUST_SCRIPTS�lowerrj r � GUESTCUST_ERROR_SCRIPT_DISABLED)rr r� � default_value�custom_script_enablementr r r r� s, �� ��r� c C s� t �d� t� }| j}z| j}|s|r |�|||� W dS t �d� W dS tyA } ztdt|�t j | � W Y d }~dS d }~ww )Nz Applying password customizationz Changing password is not neededz%Error applying password configurationFT) r r r �admin_password�reset_passwordr� r rj rk r r~ )rr rt �pwdConfigurator� admin_pwd� reset_pwdr r r r r� 6 s( � ����r� c C s t t| ��S r^ )r r )�cfg_filer r r �parse_cust_cfgK s r� c C s: d\}}| j rd}t�d� ||fS d}t�d� ||fS )N)FFTz!raw cloudinit data cust cfg foundzvmware cust cfg found)r} r r )rr �is_vmware_cust_cfg�is_raw_data_cust_cfgr r r �get_cust_cfg_typeO s � r� c C s6 d} d}| D ]}t ||�}|rt�d|� dS qdS )N)z/usr/lib/vmware-toolsz/usr/lib64/vmware-toolsz/usr/lib/open-vm-toolsz/usr/lib64/open-vm-toolsz'/usr/lib/x86_64-linux-gnu/open-vm-toolsz(/usr/lib/aarch64-linux-gnu/open-vm-toolszlibdeployPkgPlugin.soz$Found the customization plugin at %sTF)� search_filer r )� search_paths� cust_pluginr* �cust_plugin_pathr r r �is_cust_plugin_availableZ s ��r� c C s@ | r|sd S t �| �D ]\}}}||v r t j�||� S q d S r^ )r) �walkr* rM )r� r� �root�_dirs�filesr r r r� n s �r� c C s* t �td| |� ttj|� t|| � dS )zS Set customization status to the underlying VMware Virtualization Platform z%s: %sN)r �logexcr r' r r6 r] )�prefixrN �eventrr r r r rj y s rj r^ )TFNr{ )r� r3 r )C�loggingr) rO r8 � cloudinitr r rE r �config_custom_scriptr r r � config_filer � config_nicr � config_passwdr �guestcust_errorr �guestcust_eventr �guestcust_stater � getLogger�__name__r r" r: r< r_ r� r� r r' r2 rD rZ r] r` rz r� rd rh r� rm r� r� r� r� r� re r� rg r� r� rf r� r� r� r� r� r� r� r� rj r r r r �<module> sn *2(7 � � __pycache__/nic.cpython-310.pyc 0000644 00000010164 15030055134 0012224 0 ustar 00 o �Ad� � @ sT d dl mZ d dlmZmZmZ G dd� de�ZG dd� de�ZG dd� de�Zd S ) � )� BootProtoEnum)�NicBase�StaticIpv4Base�StaticIpv6Basec @ s� e Zd ZdZdd� Zdd� Zdd� Zedd � �Zed d � �Z ed d � �Z edd� �Z edd� �Z edd� �Z edd� �Zedd� �ZdS )�Niczd Holds the information about each NIC specified in the customization specification file c C � || _ || _d S �N)�_name� _configFile)�self�name� configFile� r �J/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/nic.py�__init__ � z Nic.__init__c C s | j �| jd | d �S )N�|)r �getr )r �whatr r r �_get s zNic._getc C s | j �| j| �S r )r �get_count_with_prefixr )r �prefixr r r �_get_count_with_prefix s zNic._get_count_with_prefixc C s | j S r )r �r r r r r s zNic.namec C s | � d��� S )N�MACADDR�r �lowerr r r r �mac$ s zNic.macc C �* | � d�}|r|�� }|dkp|dkS dS )N�PRIMARY�yes�trueFr �r �valuer r r �primary( � z Nic.primaryc C r )N�ONBOOTr r! Fr r" r r r �onboot1 r% z Nic.onbootc C � | � d�}|r |�� S dS )N� BOOTPROTO� r r" r r r � bootProto: � z Nic.bootProtoc C r( )N� IPv4_MODEr* r r" r r r � ipv4_modeB r, z Nic.ipv4_modec C s | j tjkr t| �gS dS )z� Checks the BOOTPROTO property and returns StaticIPv4Addr configuration object if STATIC configuration is set. N)r+ r �STATIC�StaticIpv4Addrr r r r � staticIpv4J s zNic.staticIpv4c C s> | � d�}|s d S g }td|d �D ] }|�t| |�� q|S )Nz |IPv6ADDR|� )r �range�append�StaticIpv6Addr)r �cnt�result�indexr r r � staticIpv6U s zNic.staticIpv6N)�__name__� __module__� __qualname__�__doc__r r r �propertyr r r$ r' r+ r. r1 r9 r r r r r s* r c @ �< e Zd ZdZdd� Zedd� �Zedd� �Zedd � �Zd S ) r0 zStatic IPV4 Setting.c C s || _ d S r )�_nic)r �nicr r r r f s zStaticIpv4Addr.__init__c C � | j �d�S )N�IPADDR�r@ r r r r r �ipi � zStaticIpv4Addr.ipc C rB )N�NETMASKrD r r r r �netmaskm rF zStaticIpv4Addr.netmaskc C s( | j �d�}|rdd� |�d�D �S d S )N�GATEWAYc S s g | ]}|� � �qS r )�strip)�.0�xr r r � <listcomp>u s z+StaticIpv4Addr.gateways.<locals>.<listcomp>�,)r@ r �splitr" r r r �gatewaysq s zStaticIpv4Addr.gatewaysN) r: r; r< r= r r> rE rH rP r r r r r0 c s r0 c @ r? ) r5 zStatic IPV6 Address.c C r r )r@ �_index)r rA r8 r r r r } r zStaticIpv6Addr.__init__c C � | j �dt| j� �S )Nz IPv6ADDR|�r@ r �strrQ r r r r rE � � zStaticIpv6Addr.ipc C rR )Nz IPv6NETMASK|rS r r r r rH � rU zStaticIpv6Addr.netmaskc C rR )Nz IPv6GATEWAY|rS r r r r �gateway� rU zStaticIpv6Addr.gatewayN) r: r; r< r= r r> rE rH rV r r r r r5 z s r5 N) �/cloudinit.sources.helpers.vmware.imc.boot_protor �-cloudinit.sources.helpers.vmware.imc.nic_baser r r r r0 r5 r r r r �<module> s S __pycache__/config_passwd.cpython-310.pyc 0000644 00000004300 15030055134 0014274 0 ustar 00 o �Ad{ � @ s< d dl Z d dlZd dlmZmZ e �e�ZG dd� d�ZdS )� N)�subp�utilc @ s e Zd ZdZdd� Zdd� ZdS )�PasswordConfiguratorzv Class for changing configurations related to passwords in a VM. Includes setting and expiring passwords. c C s� t �d� |r t�|�}g }tdd�D ]}|�d�d dkr(|�|�d�d � qg }tdd�D ]}|�d�d }||v rB|�|� q0|rPt �d � |�d |� |rW| �|� t �d � d S ) a+ Main method to perform all functionalities based on configuration file inputs. @param passwd: encoded admin password. @param resetPasswd: boolean to determine if password needs to be reset. @return cfg: dict to be used by cloud-init set_passwd code. z Starting password configurationz /etc/passwd�r�:� �0r z /etc/shadowzSetting admin password�rootz Configure Password completed!N) �LOG�infor �b64d�open�split�append� set_passwd�reset_password)�self�passwd� resetPasswd�distro� allRootUsers�line� uidUsersList�user� r �T/usr/lib/python3/dist-packages/cloudinit/sources/helpers/vmware/imc/config_passwd.py� configure s( � � z PasswordConfigurator.configurec C s� t �d� |D ]6}z t�dd|g� W q tjy= } z tj�d�r,t�ddd|g� nt �d||� W Y d }~qd }~ww d S ) z� Method to reset password. Use passwd --expire command. Use chage if not succeeded using passwd command. Log failure message otherwise. @param: list of users for which to expire password. zExpiring password.r z--expirez/usr/bin/chage�chagez-dr z/Failed to expire password for %s with error: %sN)r r r �ProcessExecutionError�os�path�exists�warning)r � uidUserListr �er r r r 3 s ����z#PasswordConfigurator.reset_passwordN)�__name__� __module__� __qualname__�__doc__r r r r r r r s r ) �loggingr � cloudinitr r � getLoggerr% r r r r r r �<module> s nic_base.py 0000644 00000007466 15030055134 0006672 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class NicBase: """ Define what are expected of each nic. The following properties should be provided in an implementation class. """ @property def mac(self): """ Retrieves the mac address of the nic @return (str) : the MACADDR setting """ raise NotImplementedError("MACADDR") @property def primary(self): """ Retrieves whether the nic is the primary nic Indicates whether NIC will be used to define the default gateway. If none of the NICs is configured to be primary, default gateway won't be set. @return (bool): the PRIMARY setting """ raise NotImplementedError("PRIMARY") @property def onboot(self): """ Retrieves whether the nic should be up at the boot time @return (bool) : the ONBOOT setting """ raise NotImplementedError("ONBOOT") @property def bootProto(self): """ Retrieves the boot protocol of the nic @return (str): the BOOTPROTO setting, valid values: dhcp and static. """ raise NotImplementedError("BOOTPROTO") @property def ipv4_mode(self): """ Retrieves the IPv4_MODE @return (str): the IPv4_MODE setting, valid values: backwards_compatible, static, dhcp, disabled, as_is """ raise NotImplementedError("IPv4_MODE") @property def staticIpv4(self): """ Retrieves the static IPv4 configuration of the nic @return (StaticIpv4Base list): the static ipv4 setting """ raise NotImplementedError("Static IPv4") @property def staticIpv6(self): """ Retrieves the IPv6 configuration of the nic @return (StaticIpv6Base list): the static ipv6 setting """ raise NotImplementedError("Static Ipv6") def validate(self): """ Validate the object For example, the staticIpv4 property is required and should not be empty when ipv4Mode is STATIC """ raise NotImplementedError("Check constraints on properties") class StaticIpv4Base: """ Define what are expected of a static IPv4 setting The following properties should be provided in an implementation class. """ @property def ip(self): """ Retrieves the Ipv4 address @return (str): the IPADDR setting """ raise NotImplementedError("Ipv4 Address") @property def netmask(self): """ Retrieves the Ipv4 NETMASK setting @return (str): the NETMASK setting """ raise NotImplementedError("Ipv4 NETMASK") @property def gateways(self): """ Retrieves the gateways on this Ipv4 subnet @return (str list): the GATEWAY setting """ raise NotImplementedError("Ipv4 GATEWAY") class StaticIpv6Base: """Define what are expected of a static IPv6 setting The following properties should be provided in an implementation class. """ @property def ip(self): """ Retrieves the Ipv6 address @return (str): the IPv6ADDR setting """ raise NotImplementedError("Ipv6 Address") @property def netmask(self): """ Retrieves the Ipv6 NETMASK setting @return (str): the IPv6NETMASK setting """ raise NotImplementedError("Ipv6 NETMASK") @property def gateway(self): """ Retrieves the Ipv6 GATEWAY setting @return (str): the IPv6GATEWAY setting """ raise NotImplementedError("Ipv6 GATEWAY") # vi: ts=4 expandtab guestcust_util.py 0000644 00000047156 15030055134 0010212 0 ustar 00 # Copyright (C) 2016 Canonical Ltd. # Copyright (C) 2016-2022 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # Pengpeng Sun <pegnpengs@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. import logging import os import re import time from cloudinit import subp, util from .config import Config from .config_custom_script import ( CustomScriptNotFound, PostCustomScript, PreCustomScript, ) from .config_file import ConfigFile from .config_nic import NicConfigurator from .config_passwd import PasswordConfigurator from .guestcust_error import GuestCustErrorEnum from .guestcust_event import GuestCustEventEnum from .guestcust_state import GuestCustStateEnum logger = logging.getLogger(__name__) CLOUDINIT_LOG_FILE = "/var/log/cloud-init.log" QUERY_NICS_SUPPORTED = "queryNicsSupported" NICS_STATUS_CONNECTED = "connected" # Path to the VMware IMC directory IMC_DIR_PATH = "/var/run/vmware-imc" # Customization script configuration in tools conf IMC_TOOLS_CONF_GROUPNAME = "deployPkg" IMC_TOOLS_CONF_ENABLE_CUST_SCRIPTS = "enable-custom-scripts" # This will send a RPC command to the underlying # VMware Virtualization Platform. def send_rpc(rpc): if not rpc: return None out = "" err = "Error sending the RPC command" try: logger.debug("Sending RPC command: %s", rpc) (out, err) = subp.subp(["vmware-rpctool", rpc], rcs=[0]) # Remove the trailing newline in the output. if out: out = out.rstrip() except Exception as e: logger.debug("Failed to send RPC command") logger.exception(e) return (out, err) # This will send the customization status to the # underlying VMware Virtualization Platform. def set_customization_status(custstate, custerror, errormessage=None): message = "" if errormessage: message = CLOUDINIT_LOG_FILE + "@" + errormessage else: message = CLOUDINIT_LOG_FILE rpc = "deployPkg.update.state %d %d %s" % (custstate, custerror, message) (out, err) = send_rpc(rpc) return (out, err) def get_nics_to_enable(nicsfilepath): """Reads the NICS from the specified file path and returns the content @param nicsfilepath: Absolute file path to the NICS.txt file. """ if not nicsfilepath: return None NICS_SIZE = 1024 if not os.path.exists(nicsfilepath): return None with open(nicsfilepath, "r") as fp: nics = fp.read(NICS_SIZE) return nics # This will send a RPC command to the underlying VMware Virtualization platform # and enable nics. def enable_nics(nics): if not nics: logger.warning("No Nics found") return enableNicsWaitRetries = 5 enableNicsWaitCount = 5 enableNicsWaitSeconds = 1 for attempt in range(0, enableNicsWaitRetries): logger.debug("Trying to connect interfaces, attempt %d", attempt) (out, _err) = set_customization_status( GuestCustStateEnum.GUESTCUST_STATE_RUNNING, GuestCustEventEnum.GUESTCUST_EVENT_ENABLE_NICS, nics, ) if not out: time.sleep(enableNicsWaitCount * enableNicsWaitSeconds) continue if out != QUERY_NICS_SUPPORTED: logger.warning("NICS connection status query is not supported") return for count in range(0, enableNicsWaitCount): (out, _err) = set_customization_status( GuestCustStateEnum.GUESTCUST_STATE_RUNNING, GuestCustEventEnum.GUESTCUST_EVENT_QUERY_NICS, nics, ) if out and out == NICS_STATUS_CONNECTED: logger.info("NICS are connected on %d second", count) return time.sleep(enableNicsWaitSeconds) logger.warning( "Can't connect network interfaces after %d attempts", enableNicsWaitRetries, ) def get_tools_config(section, key, defaultVal): """Return the value of [section] key from VMTools configuration. @param section: String of section to read from VMTools config @returns: String value from key in [section] or defaultVal if [section] is not present or vmware-toolbox-cmd is not installed. """ if not subp.which("vmware-toolbox-cmd"): logger.debug( "vmware-toolbox-cmd not installed, returning default value" ) return defaultVal cmd = ["vmware-toolbox-cmd", "config", "get", section, key] try: out = subp.subp(cmd) except subp.ProcessExecutionError as e: if e.exit_code == 69: logger.debug( "vmware-toolbox-cmd returned 69 (unavailable) for cmd: %s." " Return default value: %s", " ".join(cmd), defaultVal, ) else: logger.error("Failed running %s[%s]", cmd, e.exit_code) logger.exception(e) return defaultVal retValue = defaultVal m = re.match(r"([^=]+)=(.*)", out.stdout) if m: retValue = m.group(2).strip() logger.debug("Get tools config: [%s] %s = %s", section, key, retValue) else: logger.debug( "Tools config: [%s] %s is not found, return default value: %s", section, key, retValue, ) return retValue # Sets message to the VMX guestinfo.gc.status property to the # underlying VMware Virtualization Platform. def set_gc_status(config, gcMsg): if config and config.post_gc_status: rpc = "info-set guestinfo.gc.status %s" % gcMsg return send_rpc(rpc) return None def get_imc_dir_path(): return IMC_DIR_PATH def get_data_from_imc_cust_cfg( cloud_dir, scripts_cpath, cust_cfg, cust_cfg_dir, distro, ): md, ud, vd, cfg = {}, None, None, {} set_gc_status(cust_cfg, "Started") (md, cfg) = get_non_network_data_from_vmware_cust_cfg(cust_cfg) is_special_customization = check_markers(cloud_dir, cust_cfg) if is_special_customization: if not do_special_customization( scripts_cpath, cust_cfg, cust_cfg_dir, distro ): return (None, None, None, None) if not recheck_markers(cloud_dir, cust_cfg): return (None, None, None, None) try: logger.debug("Preparing the Network configuration") md["network"] = get_network_data_from_vmware_cust_cfg( cust_cfg, True, True, distro.osfamily ) except Exception as e: set_cust_error_status( "Error preparing Network Configuration", str(e), GuestCustEventEnum.GUESTCUST_EVENT_NETWORK_SETUP_FAILED, cust_cfg, ) return (None, None, None, None) connect_nics(cust_cfg_dir) set_customization_status( GuestCustStateEnum.GUESTCUST_STATE_DONE, GuestCustErrorEnum.GUESTCUST_ERROR_SUCCESS, ) set_gc_status(cust_cfg, "Successful") return (md, ud, vd, cfg) def get_data_from_imc_raw_data_cust_cfg(cust_cfg): set_gc_status(cust_cfg, "Started") md, ud, vd = None, None, None md_file = cust_cfg.meta_data_name if md_file: md_path = os.path.join(get_imc_dir_path(), md_file) if not os.path.exists(md_path): set_cust_error_status( "Error locating the cloud-init meta data file", "Meta data file is not found: %s" % md_path, GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return (None, None, None) try: md = util.load_file(md_path) except Exception as e: set_cust_error_status( "Error loading cloud-init meta data file", str(e), GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return (None, None, None) ud_file = cust_cfg.user_data_name if ud_file: ud_path = os.path.join(get_imc_dir_path(), ud_file) if not os.path.exists(ud_path): set_cust_error_status( "Error locating the cloud-init userdata file", "Userdata file is not found: %s" % ud_path, GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return (None, None, None) try: ud = util.load_file(ud_path).replace("\r", "") except Exception as e: set_cust_error_status( "Error loading cloud-init userdata file", str(e), GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return (None, None, None) set_customization_status( GuestCustStateEnum.GUESTCUST_STATE_DONE, GuestCustErrorEnum.GUESTCUST_ERROR_SUCCESS, ) set_gc_status(cust_cfg, "Successful") return (md, ud, vd) def get_non_network_data_from_vmware_cust_cfg(cust_cfg): md, cfg = {}, {} if cust_cfg.host_name: if cust_cfg.domain_name: md["local-hostname"] = ( cust_cfg.host_name + "." + cust_cfg.domain_name ) else: md["local-hostname"] = cust_cfg.host_name if cust_cfg.timezone: cfg["timezone"] = cust_cfg.timezone if cust_cfg.instance_id: md["instance-id"] = cust_cfg.instance_id return (md, cfg) def get_network_data_from_vmware_cust_cfg( cust_cfg, use_system_devices=True, configure=False, osfamily=None ): nicConfigurator = NicConfigurator(cust_cfg.nics, use_system_devices) nics_cfg_list = nicConfigurator.generate(configure, osfamily) return get_v1_network_config( nics_cfg_list, cust_cfg.name_servers, cust_cfg.dns_suffixes ) def get_v1_network_config(nics_cfg_list=None, nameservers=None, search=None): config_list = nics_cfg_list if nameservers or search: config_list.append( {"type": "nameserver", "address": nameservers, "search": search} ) return {"version": 1, "config": config_list} def connect_nics(cust_cfg_dir): nics_file = os.path.join(cust_cfg_dir, "nics.txt") if os.path.exists(nics_file): logger.debug("%s file found, to connect nics", nics_file) enable_nics(get_nics_to_enable(nics_file)) def is_vmware_cust_enabled(sys_cfg): return not util.get_cfg_option_bool( sys_cfg, "disable_vmware_customization", True ) def is_raw_data_cust_enabled(ds_cfg): return util.get_cfg_option_bool(ds_cfg, "allow_raw_data", True) def get_cust_cfg_file(ds_cfg): # When the VM is powered on, the "VMware Tools" daemon # copies the customization specification file to # /var/run/vmware-imc directory. cloud-init code needs # to search for the file in that directory which indicates # that required metadata and userdata files are now # present. max_wait = get_max_wait_from_cfg(ds_cfg) cust_cfg_file_path = util.log_time( logfunc=logger.debug, msg="Waiting for VMware customization configuration file", func=wait_for_cust_cfg_file, args=("cust.cfg", max_wait), ) if cust_cfg_file_path: logger.debug( "Found VMware customization configuration file at %s", cust_cfg_file_path, ) return cust_cfg_file_path else: logger.debug("No VMware customization configuration file found") return None def wait_for_cust_cfg_file( filename, maxwait=180, naplen=5, dirpath="/var/run/vmware-imc" ): waited = 0 if maxwait <= naplen: naplen = 1 while waited < maxwait: fileFullPath = os.path.join(dirpath, filename) if os.path.isfile(fileFullPath): return fileFullPath logger.debug("Waiting for VMware customization configuration file") time.sleep(naplen) waited += naplen return None def get_max_wait_from_cfg(ds_cfg): default_max_wait = 15 max_wait_cfg_option = "vmware_cust_file_max_wait" max_wait = default_max_wait if not ds_cfg: return max_wait try: max_wait = int(ds_cfg.get(max_wait_cfg_option, default_max_wait)) except ValueError: logger.warning( "Failed to get '%s', using %s", max_wait_cfg_option, default_max_wait, ) if max_wait < 0: logger.warning( "Invalid value '%s' for '%s', using '%s' instead", max_wait, max_wait_cfg_option, default_max_wait, ) max_wait = default_max_wait return max_wait def check_markers(cloud_dir, cust_cfg): product_marker = cust_cfg.marker_id has_marker_file = check_marker_exists( product_marker, os.path.join(cloud_dir, "data") ) return product_marker and not has_marker_file def check_marker_exists(markerid, marker_dir): """ Check the existence of a marker file. Presence of marker file determines whether a certain code path is to be executed. It is needed for partial guest customization in VMware. @param markerid: is an unique string representing a particular product marker. @param: marker_dir: The directory in which markers exist. """ if not markerid: return False markerfile = os.path.join(marker_dir, ".markerfile-" + markerid + ".txt") if os.path.exists(markerfile): return True return False def recheck_markers(cloud_dir, cust_cfg): product_marker = cust_cfg.marker_id if product_marker: if not create_marker_file(cloud_dir, cust_cfg): return False return True def create_marker_file(cloud_dir, cust_cfg): try: setup_marker_files(cust_cfg.marker_id, os.path.join(cloud_dir, "data")) except Exception as e: set_cust_error_status( "Error creating marker files", str(e), GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return False return True def setup_marker_files(marker_id, marker_dir): """ Create a new marker file. Marker files are unique to a full customization workflow in VMware environment. @param marker_id: is an unique string representing a particular product marker. @param: marker_dir: The directory in which markers exist. """ logger.debug("Handle marker creation") marker_file = os.path.join(marker_dir, ".markerfile-" + marker_id + ".txt") for fname in os.listdir(marker_dir): if fname.startswith(".markerfile"): util.del_file(os.path.join(marker_dir, fname)) open(marker_file, "w").close() def do_special_customization(scripts_cpath, cust_cfg, cust_cfg_dir, distro): is_pre_custom_successful = False is_password_custom_successful = False is_post_custom_successful = False is_custom_script_enabled = False custom_script = cust_cfg.custom_script_name if custom_script: is_custom_script_enabled = check_custom_script_enablement(cust_cfg) if is_custom_script_enabled: is_pre_custom_successful = do_pre_custom_script( cust_cfg, custom_script, cust_cfg_dir ) is_password_custom_successful = do_password_customization(cust_cfg, distro) if custom_script and is_custom_script_enabled: ccScriptsDir = os.path.join(scripts_cpath, "per-instance") is_post_custom_successful = do_post_custom_script( cust_cfg, custom_script, cust_cfg_dir, ccScriptsDir ) if custom_script: return ( is_pre_custom_successful and is_password_custom_successful and is_post_custom_successful ) return is_password_custom_successful def do_pre_custom_script(cust_cfg, custom_script, cust_cfg_dir): try: precust = PreCustomScript(custom_script, cust_cfg_dir) precust.execute() except CustomScriptNotFound as e: set_cust_error_status( "Error executing pre-customization script", str(e), GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return False return True def do_post_custom_script(cust_cfg, custom_script, cust_cfg_dir, ccScriptsDir): try: postcust = PostCustomScript(custom_script, cust_cfg_dir, ccScriptsDir) postcust.execute() except CustomScriptNotFound as e: set_cust_error_status( "Error executing post-customization script", str(e), GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return False return True def check_custom_script_enablement(cust_cfg): is_custom_script_enabled = False default_value = "false" if cust_cfg.default_run_post_script: logger.debug( "Set default value to true due to customization configuration." ) default_value = "true" custom_script_enablement = get_tools_config( IMC_TOOLS_CONF_GROUPNAME, IMC_TOOLS_CONF_ENABLE_CUST_SCRIPTS, default_value, ) if custom_script_enablement.lower() != "true": set_cust_error_status( "Custom script is disabled by VM Administrator", "Error checking custom script enablement", GuestCustErrorEnum.GUESTCUST_ERROR_SCRIPT_DISABLED, cust_cfg, ) else: is_custom_script_enabled = True return is_custom_script_enabled def do_password_customization(cust_cfg, distro): logger.debug("Applying password customization") pwdConfigurator = PasswordConfigurator() admin_pwd = cust_cfg.admin_password try: reset_pwd = cust_cfg.reset_password if admin_pwd or reset_pwd: pwdConfigurator.configure(admin_pwd, reset_pwd, distro) else: logger.debug("Changing password is not needed") except Exception as e: set_cust_error_status( "Error applying password configuration", str(e), GuestCustEventEnum.GUESTCUST_EVENT_CUSTOMIZE_FAILED, cust_cfg, ) return False return True def parse_cust_cfg(cfg_file): return Config(ConfigFile(cfg_file)) def get_cust_cfg_type(cust_cfg): is_vmware_cust_cfg, is_raw_data_cust_cfg = False, False if cust_cfg.meta_data_name: is_raw_data_cust_cfg = True logger.debug("raw cloudinit data cust cfg found") else: is_vmware_cust_cfg = True logger.debug("vmware cust cfg found") return (is_vmware_cust_cfg, is_raw_data_cust_cfg) def is_cust_plugin_available(): search_paths = ( "/usr/lib/vmware-tools", "/usr/lib64/vmware-tools", "/usr/lib/open-vm-tools", "/usr/lib64/open-vm-tools", "/usr/lib/x86_64-linux-gnu/open-vm-tools", "/usr/lib/aarch64-linux-gnu/open-vm-tools", ) cust_plugin = "libdeployPkgPlugin.so" for path in search_paths: cust_plugin_path = search_file(path, cust_plugin) if cust_plugin_path: logger.debug( "Found the customization plugin at %s", cust_plugin_path ) return True return False def search_file(dirpath, filename): if not dirpath or not filename: return None for root, _dirs, files in os.walk(dirpath): if filename in files: return os.path.join(root, filename) return None def set_cust_error_status(prefix, error, event, cust_cfg): """ Set customization status to the underlying VMware Virtualization Platform """ util.logexc(logger, "%s: %s", prefix, error) set_customization_status(GuestCustStateEnum.GUESTCUST_STATE_RUNNING, event) set_gc_status(cust_cfg, prefix) # vi: ts=4 expandtab config_file.py 0000644 00000006255 15030055134 0007366 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. import configparser import logging from cloudinit.sources.helpers.vmware.imc.config_source import ConfigSource logger = logging.getLogger(__name__) class ConfigFile(ConfigSource, dict): """ConfigFile module to load the content from a specified source.""" def __init__(self, filename): self._loadConfigFile(filename) def _insertKey(self, key, val): """ Inserts a Key Value pair. Keyword arguments: key -- The key to insert val -- The value to insert for the key """ key = key.strip() val = val.strip() if key.startswith("-") or "|-" in key: canLog = False else: canLog = True # "sensitive" settings shall not be logged if canLog: logger.debug("ADDED KEY-VAL :: '%s' = '%s'", key, val) else: logger.debug("ADDED KEY-VAL :: '%s' = '*****************'", key) self[key] = val def _loadConfigFile(self, filename): """ Parses properties from the specified config file. Any previously available properties will be removed. Sensitive data will not be logged in case the key starts from '-'. Keyword arguments: filename - The full path to the config file. """ logger.info("Parsing the config file %s.", filename) config = configparser.ConfigParser() config.optionxform = str config.read(filename) self.clear() for category in config.sections(): logger.debug("FOUND CATEGORY = '%s'", category) for (key, value) in config.items(category): self._insertKey(category + "|" + key, value) def should_keep_current_value(self, key): """ Determines whether a value for a property must be kept. If the propery is missing, it is treated as it should be not changed by the engine. Keyword arguments: key -- The key to search for. """ # helps to distinguish from "empty" value which is used to indicate # "removal" return key not in self def should_remove_current_value(self, key): """ Determines whether a value for the property must be removed. If the specified key is empty, it is treated as it should be removed by the engine. Return true if the value can be removed, false otherwise. Keyword arguments: key -- The key to search for. """ # helps to distinguish from "missing" value which is used to indicate # "keeping unchanged" if key in self: return not bool(self[key]) else: return False def get_count_with_prefix(self, prefix): """ Return the total count of keys that start with the specified prefix. Keyword arguments: prefix -- prefix of the key """ return len([key for key in self if key.startswith(prefix)]) # vi: ts=4 expandtab config_namespace.py 0000644 00000000576 15030055134 0010403 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. from cloudinit.sources.helpers.vmware.imc.config_source import ConfigSource class ConfigNamespace(ConfigSource): """Specifies the Config Namespace.""" # vi: ts=4 expandtab config.py 0000644 00000011167 15030055134 0006365 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. from cloudinit.sources.helpers.vmware.imc.nic import Nic class Config: """ Stores the Contents specified in the Customization Specification file. """ CUSTOM_SCRIPT = "CUSTOM-SCRIPT|SCRIPT-NAME" DNS = "DNS|NAMESERVER|" DOMAINNAME = "NETWORK|DOMAINNAME" HOSTNAME = "NETWORK|HOSTNAME" MARKERID = "MISC|MARKER-ID" PASS = "PASSWORD|-PASS" RESETPASS = "PASSWORD|RESET" SUFFIX = "DNS|SUFFIX|" TIMEZONE = "DATETIME|TIMEZONE" UTC = "DATETIME|UTC" POST_GC_STATUS = "MISC|POST-GC-STATUS" DEFAULT_RUN_POST_SCRIPT = "MISC|DEFAULT-RUN-POST-CUST-SCRIPT" CLOUDINIT_META_DATA = "CLOUDINIT|METADATA" CLOUDINIT_USER_DATA = "CLOUDINIT|USERDATA" CLOUDINIT_INSTANCE_ID = "CLOUDINIT|INSTANCE-ID" def __init__(self, configFile): self._configFile = configFile @property def host_name(self): """Return the hostname.""" return self._configFile.get(Config.HOSTNAME, None) @property def domain_name(self): """Return the domain name.""" return self._configFile.get(Config.DOMAINNAME, None) @property def timezone(self): """Return the timezone.""" return self._configFile.get(Config.TIMEZONE, None) @property def utc(self): """Retrieves whether to set time to UTC or Local.""" return self._configFile.get(Config.UTC, None) @property def admin_password(self): """Return the root password to be set.""" return self._configFile.get(Config.PASS, None) @property def name_servers(self): """Return the list of DNS servers.""" res = [] cnt = self._configFile.get_count_with_prefix(Config.DNS) for i in range(1, cnt + 1): key = Config.DNS + str(i) res.append(self._configFile[key]) return res @property def dns_suffixes(self): """Return the list of DNS Suffixes.""" res = [] cnt = self._configFile.get_count_with_prefix(Config.SUFFIX) for i in range(1, cnt + 1): key = Config.SUFFIX + str(i) res.append(self._configFile[key]) return res @property def nics(self): """Return the list of associated NICs.""" res = [] nics = self._configFile["NIC-CONFIG|NICS"] for nic in nics.split(","): res.append(Nic(nic, self._configFile)) return res @property def reset_password(self): """Retreives if the root password needs to be reset.""" resetPass = self._configFile.get(Config.RESETPASS, "no") resetPass = resetPass.lower() if resetPass not in ("yes", "no"): raise ValueError("ResetPassword value should be yes/no") return resetPass == "yes" @property def marker_id(self): """Returns marker id.""" return self._configFile.get(Config.MARKERID, None) @property def custom_script_name(self): """Return the name of custom (pre/post) script.""" return self._configFile.get(Config.CUSTOM_SCRIPT, None) @property def post_gc_status(self): """Return whether to post guestinfo.gc.status VMX property.""" postGcStatus = self._configFile.get(Config.POST_GC_STATUS, "no") postGcStatus = postGcStatus.lower() if postGcStatus not in ("yes", "no"): raise ValueError("PostGcStatus value should be yes/no") return postGcStatus == "yes" @property def default_run_post_script(self): """ Return enable-custom-scripts default value if enable-custom-scripts is absent in VM Tools configuration """ defaultRunPostScript = self._configFile.get( Config.DEFAULT_RUN_POST_SCRIPT, "no" ) defaultRunPostScript = defaultRunPostScript.lower() if defaultRunPostScript not in ("yes", "no"): raise ValueError("defaultRunPostScript value should be yes/no") return defaultRunPostScript == "yes" @property def meta_data_name(self): """Return the name of cloud-init meta data.""" return self._configFile.get(Config.CLOUDINIT_META_DATA, None) @property def user_data_name(self): """Return the name of cloud-init user data.""" return self._configFile.get(Config.CLOUDINIT_USER_DATA, None) @property def instance_id(self): """Return instance id""" return self._configFile.get(Config.CLOUDINIT_INSTANCE_ID, None) # vi: ts=4 expandtab ipv4_mode.py 0000644 00000002140 15030055134 0006775 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class Ipv4ModeEnum: """ The IPv4 configuration mode which directly represents the user's goal. This mode effectively acts as a contract of the in-guest customization engine. It must be set based on what the user has requested and should not be changed by those layers. It's up to the in-guest engine to interpret and materialize the user's request. """ # The legacy mode which only allows dhcp/static based on whether IPv4 # addresses list is empty or not IPV4_MODE_BACKWARDS_COMPATIBLE = "BACKWARDS_COMPATIBLE" # IPv4 must use static address. Reserved for future use IPV4_MODE_STATIC = "STATIC" # IPv4 must use DHCPv4. Reserved for future use IPV4_MODE_DHCP = "DHCP" # IPv4 must be disabled IPV4_MODE_DISABLED = "DISABLED" # IPv4 settings should be left untouched. Reserved for future use IPV4_MODE_AS_IS = "AS_IS" # vi: ts=4 expandtab config_passwd.py 0000644 00000004573 15030055134 0007751 0 ustar 00 # Copyright (C) 2016 Canonical Ltd. # Copyright (C) 2016 VMware INC. # # Author: Maitreyee Saikia <msaikia@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. import logging import os from cloudinit import subp, util LOG = logging.getLogger(__name__) class PasswordConfigurator: """ Class for changing configurations related to passwords in a VM. Includes setting and expiring passwords. """ def configure(self, passwd, resetPasswd, distro): """ Main method to perform all functionalities based on configuration file inputs. @param passwd: encoded admin password. @param resetPasswd: boolean to determine if password needs to be reset. @return cfg: dict to be used by cloud-init set_passwd code. """ LOG.info("Starting password configuration") if passwd: passwd = util.b64d(passwd) allRootUsers = [] for line in open("/etc/passwd", "r"): if line.split(":")[2] == "0": allRootUsers.append(line.split(":")[0]) # read shadow file and check for each user, if its uid0 or root. uidUsersList = [] for line in open("/etc/shadow", "r"): user = line.split(":")[0] if user in allRootUsers: uidUsersList.append(user) if passwd: LOG.info("Setting admin password") distro.set_passwd("root", passwd) if resetPasswd: self.reset_password(uidUsersList) LOG.info("Configure Password completed!") def reset_password(self, uidUserList): """ Method to reset password. Use passwd --expire command. Use chage if not succeeded using passwd command. Log failure message otherwise. @param: list of users for which to expire password. """ LOG.info("Expiring password.") for user in uidUserList: try: subp.subp(["passwd", "--expire", user]) except subp.ProcessExecutionError as e: if os.path.exists("/usr/bin/chage"): subp.subp(["chage", "-d", "0", user]) else: LOG.warning( "Failed to expire password for %s with error: %s", user, e, ) # vi: ts=4 expandtab config_source.py 0000644 00000000453 15030055134 0007741 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2015 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class ConfigSource: """Specifies a source for the Config Content.""" # vi: ts=4 expandtab guestcust_event.py 0000644 00000000744 15030055134 0010346 0 ustar 00 # Copyright (C) 2016 Canonical Ltd. # Copyright (C) 2016 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class GuestCustEventEnum: """Specifies different types of Guest Customization Events""" GUESTCUST_EVENT_CUSTOMIZE_FAILED = 100 GUESTCUST_EVENT_NETWORK_SETUP_FAILED = 101 GUESTCUST_EVENT_ENABLE_NICS = 103 GUESTCUST_EVENT_QUERY_NICS = 104 # vi: ts=4 expandtab guestcust_error.py 0000644 00000000662 15030055134 0010355 0 ustar 00 # Copyright (C) 2016 Canonical Ltd. # Copyright (C) 2016 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class GuestCustErrorEnum: """Specifies different errors of Guest Customization engine""" GUESTCUST_ERROR_SUCCESS = 0 GUESTCUST_ERROR_SCRIPT_DISABLED = 6 GUESTCUST_ERROR_WRONG_META_FORMAT = 9 # vi: ts=4 expandtab config_nic.py 0000644 00000021200 15030055134 0007203 0 ustar 00 # Copyright (C) 2015 Canonical Ltd. # Copyright (C) 2016 VMware INC. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. import logging import os import re from cloudinit import subp, util from cloudinit.net.network_state import ipv4_mask_to_net_prefix logger = logging.getLogger(__name__) def gen_subnet(ip, netmask): """ Return the subnet for a given ip address and a netmask @return (str): the subnet @param ip: ip address @param netmask: netmask """ ip_array = ip.split(".") mask_array = netmask.split(".") result = [] for index in list(range(4)): result.append(int(ip_array[index]) & int(mask_array[index])) return ".".join([str(x) for x in result]) class NicConfigurator: def __init__(self, nics, use_system_devices=True): """ Initialize the Nic Configurator @param nics (list) an array of nics to configure @param use_system_devices (Bool) Get the MAC names from the system if this is True. If False, then mac names will be retrieved from the specified nics. """ self.nics = nics self.mac2Name = {} self.ipv4PrimaryGateway = None self.ipv6PrimaryGateway = None if use_system_devices: self.find_devices() else: for nic in self.nics: self.mac2Name[nic.mac.lower()] = nic.name self._primaryNic = self.get_primary_nic() def get_primary_nic(self): """ Retrieve the primary nic if it exists @return (NicBase): the primary nic if exists, None otherwise """ primary_nics = [nic for nic in self.nics if nic.primary] if not primary_nics: return None elif len(primary_nics) > 1: raise Exception( "There can only be one primary nic", [nic.mac for nic in primary_nics], ) else: return primary_nics[0] def find_devices(self): """ Create the mac2Name dictionary The mac address(es) are in the lower case """ cmd = ["ip", "addr", "show"] output, _err = subp.subp(cmd) sections = re.split(r"\n\d+: ", "\n" + output)[1:] macPat = r"link/ether (([0-9A-Fa-f]{2}[:]){5}([0-9A-Fa-f]{2}))" for section in sections: match = re.search(macPat, section) if not match: # Only keep info about nics continue mac = match.group(1).lower() name = section.split(":", 1)[0] self.mac2Name[mac] = name def gen_one_nic(self, nic): """ Return the config list needed to configure a nic @return (list): the subnets and routes list to configure the nic @param nic (NicBase): the nic to configure """ mac = nic.mac.lower() name = self.mac2Name.get(mac) if not name: raise ValueError("No known device has MACADDR: %s" % nic.mac) nics_cfg_list = [] cfg = {"type": "physical", "name": name, "mac_address": mac} subnet_list = [] route_list = [] # Customize IPv4 (subnets, routes) = self.gen_ipv4(name, nic) subnet_list.extend(subnets) route_list.extend(routes) # Customize IPv6 (subnets, routes) = self.gen_ipv6(name, nic) subnet_list.extend(subnets) route_list.extend(routes) cfg.update({"subnets": subnet_list}) nics_cfg_list.append(cfg) if route_list: nics_cfg_list.extend(route_list) return nics_cfg_list def gen_ipv4(self, name, nic): """ Return the set of subnets and routes needed to configure the IPv4 settings of a nic @return (set): the set of subnet and routes to configure the gateways @param name (str): subnet and route list for the nic @param nic (NicBase): the nic to configure """ subnet = {} route_list = [] if nic.onboot: subnet.update({"control": "auto"}) bootproto = nic.bootProto.lower() if nic.ipv4_mode.lower() == "disabled": bootproto = "manual" if bootproto != "static": subnet.update({"type": "dhcp"}) return ([subnet], route_list) else: subnet.update({"type": "static"}) # Static Ipv4 addrs = nic.staticIpv4 if not addrs: return ([subnet], route_list) v4 = addrs[0] if v4.ip: subnet.update({"address": v4.ip}) if v4.netmask: subnet.update({"netmask": v4.netmask}) # Add the primary gateway if nic.primary and v4.gateways: self.ipv4PrimaryGateway = v4.gateways[0] subnet.update({"gateway": self.ipv4PrimaryGateway}) return ([subnet], route_list) # Add routes if there is no primary nic if not self._primaryNic and v4.gateways: subnet.update( {"routes": self.gen_ipv4_route(nic, v4.gateways, v4.netmask)} ) return ([subnet], route_list) def gen_ipv4_route(self, nic, gateways, netmask): """ Return the routes list needed to configure additional Ipv4 route @return (list): the route list to configure the gateways @param nic (NicBase): the nic to configure @param gateways (str list): the list of gateways """ route_list = [] cidr = ipv4_mask_to_net_prefix(netmask) for gateway in gateways: destination = "%s/%d" % (gen_subnet(gateway, netmask), cidr) route_list.append( { "destination": destination, "type": "route", "gateway": gateway, "metric": 10000, } ) return route_list def gen_ipv6(self, name, nic): """ Return the set of subnets and routes needed to configure the gateways for a nic @return (set): the set of subnets and routes to configure the gateways @param name (str): name of the nic @param nic (NicBase): the nic to configure """ if not nic.staticIpv6: return ([], []) subnet_list = [] # Static Ipv6 addrs = nic.staticIpv6 for addr in addrs: subnet = { "type": "static6", "address": addr.ip, "netmask": addr.netmask, } subnet_list.append(subnet) # TODO: Add the primary gateway route_list = [] # TODO: Add routes if there is no primary nic # if not self._primaryNic: # route_list.extend(self._genIpv6Route(name, nic, addrs)) return (subnet_list, route_list) def _genIpv6Route(self, name, nic, addrs): route_list = [] for addr in addrs: route_list.append( {"type": "route", "gateway": addr.gateway, "metric": 10000} ) return route_list def generate(self, configure=False, osfamily=None): """Return the config elements that are needed to configure the nics""" if configure: logger.info("Configuring the interfaces file") self.configure(osfamily) nics_cfg_list = [] for nic in self.nics: nics_cfg_list.extend(self.gen_one_nic(nic)) return nics_cfg_list def clear_dhcp(self): logger.info("Clearing DHCP leases") # Ignore the return code 1. subp.subp(["pkill", "dhclient"], rcs=[0, 1]) subp.subp(["rm", "-f", "/var/lib/dhcp/*"]) def configure(self, osfamily=None): """ Configure the /etc/network/interfaces Make a back up of the original """ if not osfamily or osfamily != "debian": logger.info("Debian OS not detected. Skipping the configure step") return containingDir = "/etc/network" interfaceFile = os.path.join(containingDir, "interfaces") originalFile = os.path.join( containingDir, "interfaces.before_vmware_customization" ) if not os.path.exists(originalFile) and os.path.exists(interfaceFile): os.rename(interfaceFile, originalFile) lines = [ "# DO NOT EDIT THIS FILE BY HAND --" " AUTOMATICALLY GENERATED BY cloud-init", "source /etc/network/interfaces.d/*", "source-directory /etc/network/interfaces.d", ] util.write_file(interfaceFile, content="\n".join(lines)) self.clear_dhcp() # vi: ts=4 expandtab __init__.py 0000644 00000000000 15030055134 0006637 0 ustar 00 guestcust_state.py 0000644 00000000575 15030055134 0010347 0 ustar 00 # Copyright (C) 2016 Canonical Ltd. # Copyright (C) 2016 VMware Inc. # # Author: Sankar Tanguturi <stanguturi@vmware.com> # # This file is part of cloud-init. See LICENSE file for license information. class GuestCustStateEnum: """Specifies different states of Guest Customization engine""" GUESTCUST_STATE_RUNNING = 4 GUESTCUST_STATE_DONE = 5 # vi: ts=4 expandtab
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings