File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/openstack/__pycache__/neutron.cpython-310.pyc
Back
o ;j�� � @ s� d Z ddlZddlZddlmZ dZzddlmZ ddlm Z dZW n e y+ Y nw dZ z ddl Z ddlZ dZ W n e yC Y nw e�e�Zdd � Zd d � Zd d � ZG dd� de�ZdS )z Neutron class � N)� exceptionsF)� NeutronShell)�clientTc C � t S �N)� HAS_NEUTRON� r r �P/opt/saltstack/salt/lib/python3.10/site-packages/salt/utils/openstack/neutron.py� check_neutron# � r c C r r )�HAS_KEYSTONEAUTHr r r r �check_keystone' r r c C s. d}i }| � � D ] }||v r| | ||< q|S )N)�usernameZuser_id�password�token� tenant_name� tenant_id�auth_url� service_typeZ endpoint_type� region_name�verifyZ endpoint_url�timeoutZinsecureZca_certZretriesZ raise_error�session�auth)�keys)�kwargsZ variables�ret�varr r r �sanitize_neutronclient+ s �r c @ s� e Zd ZdZ d�dd�Z d�dd �Z d�d d �Zed d � �Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd2d3� Zd4d5� Z d6d7� Z d8d9� Z d:d;� Z d<d=� Z d�d>d?�Z!d@dA� Z"dBdC� Z#dDdE� Z$dFdG� Z%d�dHdI�Z&d�dJdK�Z'dLdM� Z(dNdO� Z)dPdQ� Z* d�dRdS�Z+dTdU� Z,dVdW� Z-dXdY� Z.dZd[� Z/d�d]d^�Z0d�d_d`�Z1dadb� Z2dcdd� Z3dedf� Z4d�dgdh�Z5d�didj�Z6dkdl� Z7dmdn� Z8dodp� Z9dqdr� Z:dsdt� Z;dudv� Z<dwdx� Z=d�dydz�Z>d�d{d|�Z?d}d~� Z@dd�� ZAd�d�� ZBd�d�d��ZCd�d�d��ZDd�d�� ZEd�d�� ZFd�d�� ZG � d�d�d��ZHd�d�� ZId�d�d��ZJd�d�� ZKd�d�d��ZLd�d�� ZMd�d�� ZNd�d�� ZOd�d�� ZP d�d�d��ZQd�d�� ZRd�d�� ZSd�d�� ZTd�d�� ZUd�d�� ZVd�d�� ZWd�d�� ZXd�d�� ZYd�d�� ZZd�d�� Z[d�d�� Z\d�d�� Z]d�d�� Z^ d�d�d��Z_d�d�� Z`d�d�� Zad�dÄ Zbd�dń ZcdS )�� SaltNeutronz/ Class for all neutronclient functions N�networkFc K sl t jj�dd� ts dS t|tg�r$| jd|||||||d�| �� dS | jd|||||||d�| �� dS )z, Set up neutron credentials ZArgonaG The neutron module has been deprecated and will be removed in {version}. This includes * salt.utils.openstack.neutron * salt.modules.neutron * salt.pillar.neutron Please migrate to neutronng. salt.modules.neutron -> salt.modules.neutronng salt.pillar.neutron -> salt.pillar.neutronng Please update to using the neutronng moduleN)r � project_namer r r �os_auth_pluginr )r r r r r r" r r ) �salt�utilsZversionsZ warn_untilr �allr � _new_init� _old_init) �selfr r r r r r r" Zuse_keystoneauthr r r r �__init__O s: � � � � �zSaltNeutron.__init__Tc K s� |d u ri }t j�|p d�} | �� | _|�� | _|| jd< || jd< || jd< || jd< |�d�rC| �dd�| jd< | �dd�| jd< || jd < || jd < t| j�| _| j d i | j��} t j j | | d �| _ t j d d | j i| j��| _d S )Nr r r! r �3Zuser_domain_name�defaultZproject_domain_namer r )r r r r )� keystoneauth1�loadingZget_plugin_loader�copyZ client_kwargsr �endswith�getr Zload_from_optionsr ZSessionr �Client� network_conn) r( r r! r r r r r" r r r �loader�optionsr r r r& � s( � zSaltNeutron._new_initc K st | � � | _|| jd< || jd< || jd< || jd< || jd< || jd< | | jd< t| j�| _tjdi | j��| _d S ) Nr r r r r r r r )r. r r r r1 r2 ) r( r r r r r r r" r r r r r r r' � s zSaltNeutron._old_initc C sf g }| D ]}|d |kr| S |� d�|kr |�|� q|s$t�d��t|�dkr/t�d��|d S )N�id�namezResource not found.� z Multiple resource matches found.r )r0 �appendr Z MinionError�len)� resources� name_or_idr �resourcer r r �_fetch� s � zSaltNeutron._fetchc C � | � |�}|d S �Nr5 �� _fetch_port�r( r< r r r � _find_port_id� � zSaltNeutron._find_port_idc C r> r? ��_fetch_networkrB r r r �_find_network_id� rD z SaltNeutron._find_network_idc C r> r? �� _fetch_subnetrB r r r �_find_subnet_id� rD zSaltNeutron._find_subnet_idc C r> r? �� _fetch_routerrB r r r �_find_router_id� rD zSaltNeutron._find_router_idc C r> r? ��_fetch_security_grouprB r r r �_find_security_group_id� rD z#SaltNeutron._find_security_group_idc C r> r? )�_fetch_vpnservicerB r r r �_find_vpnservice_id� rD z SaltNeutron._find_vpnservice_idc C r> r? �� _fetch_ipsec_site_connectionrB r r r � _find_ipsec_site_connection_id� rD z*SaltNeutron._find_ipsec_site_connection_idc C r> r? ��_fetch_ikepolicyrB r r r �_find_ikepolicy_id� rD z SaltNeutron._find_ikepolicy_idc C r> r? ��_fetch_ipsecpolicyrB r r r �_find_ipsecpolicy_id� rD z SaltNeutron._find_ipsecpolicy_idc C r> r? ��_fetch_firewall_rulerB r r r �_find_firewall_rule_id� rD z"SaltNeutron._find_firewall_rule_idc C � | � � d }| �||�S )NZports)� list_portsr= �r( r; r: r r r rA � � zSaltNeutron._fetch_portc C r_ )NZnetworks)� list_networksr= ra r r r rF rb zSaltNeutron._fetch_networkc C r_ )N�subnets)� list_subnetsr= ra r r r rI rb zSaltNeutron._fetch_subnetc C r_ )NZrouters)� list_routersr= ra r r r rL rb zSaltNeutron._fetch_routerc C r_ )NZsecurity_groups)�list_security_groupsr= ra r r r rO rb z!SaltNeutron._fetch_security_groupc C r_ )NZ vpnservices)�list_vpnservicesr= ra r r r rQ rb z SaltNeutron._fetch_vpnservicec C r_ )NZipsec_site_connections)�list_ipsec_site_connectionsr= ra r r r rT rb z(SaltNeutron._fetch_ipsec_site_connectionc C r_ )NZ ikepolicies)�list_ikepoliciesr= ra r r r rW rb z SaltNeutron._fetch_ikepolicyc C r_ )NZ ipsecpolicies)�list_ipsecpoliciesr= ra r r r rZ rb z SaltNeutron._fetch_ipsecpolicyc C r_ )NZfirewall_rules)�list_firewall_rulesr= ra r r r r] ! rb z SaltNeutron._fetch_firewall_rulec C r_ )NZ firewalls)�list_firewallsr= ra r r r �_fetch_firewall% rb zSaltNeutron._fetch_firewallc C s | � � S )z_ Fetches tenant info in server's context for following quota operation )�get_quotas_tenant�r( r r r ro ) s z SaltNeutron.get_quotas_tenantc C � | j �� S )z, Fetches all tenants quotas )r2 � list_quotasrp r r r rr 0 � zSaltNeutron.list_quotasc C s | j j|d�S )zB Fetches information of a certain tenant's quotas �r )r2 � show_quota)r( r r r r ru 6 s zSaltNeutron.show_quotac C sl i } |r|| d< |r|| d< |r|| d< |r|| d< |r || d< |r&|| d< |r,|| d< | j j|d| id �S ) z) Update a tenant's quota �subnet�routerr � floatingip�port�security_group�security_group_ruleZquota)r �body)r2 � update_quota) r( r rv rw r rx ry �sec_grpZ sec_grp_ruler| r r r r} < s zSaltNeutron.update_quotac C � | j j|d�}|r |S dS )z; Delete the specified tenant's quota value rt T)r2 � delete_quota)r( r r r r r r� [ s zSaltNeutron.delete_quotac C rq )zA Fetches a list of all extensions on server side )r2 �list_extensionsrp r r r r� b rs zSaltNeutron.list_extensionsc C rq )z: Fetches a list of all ports for a tenant )r2 r` rp r r r r` h rs zSaltNeutron.list_portsc C � | � |�S )z7 Fetches information of a certain port r@ )r( ry r r r � show_portn rs zSaltNeutron.show_portc C s4 | � |�}|||d�}|r||d< | jjd|id�S )z$ Creates a new port )�admin_state_upr6 � network_id� device_idry �r| )rG r2 � create_port)r( r6 r r� r� �net_idr| r r r r� t s zSaltNeutron.create_portc C s( | � |�}||d�}| jj|d|id�S )z Updates a port �r6 r� ry )ry r| )rC r2 � update_port)r( ry r6 r� �port_idr| r r r r� ~ s zSaltNeutron.update_portc C �$ | � |�}| jj|d�}|r|S dS )z, Deletes the specified port )ry T)rC r2 � delete_port)r( ry r� r r r r r� � � zSaltNeutron.delete_portc C rq �z= Fetches a list of all networks for a tenant )r2 rc rp r r r rc � rs zSaltNeutron.list_networksc C r� )z: Fetches information of a certain network rE )r( r r r r � show_network� rs zSaltNeutron.show_networkc C sd ||d�} |r || d< |r|| d< |r|| d< |r || d< |r#|| d< |r)|| d< | j jd| id �S ) z' Creates a new network r� zrouter:externalzprovider:network_typezprovider:physical_networkzprovider:segmentation_id�shared�vlan_transparentr r� )r2 �create_network) r( r6 r� Z router_extZ network_typeZphysical_networkZsegmentation_idr� r� r| r r r r� � s zSaltNeutron.create_networkc C �" | � |�}| jj|dd|iid�S )z# Updates a network r r6 )r r| )rG r2 �update_network)r( r r6 r� r r r r� � � �zSaltNeutron.update_networkc C r� )z/ Deletes the specified network )r T)rG r2 �delete_network)r( r r� r r r r r� � r� zSaltNeutron.delete_networkc C rq r� )r2 re rp r r r re � rs zSaltNeutron.list_subnetsc C r� )z9 Fetches information of a certain subnet rH )r( rv r r r � show_subnet� rs zSaltNeutron.show_subnet� c C s* | � |�}||||d�}| jjd|id�S )z& Creates a new subnet )�cidr� ip_versionr� r6 rv r� )rG r2 � create_subnet)r( r r� r6 r� r� r| r r r r� � s �zSaltNeutron.create_subnetc C r� )z" Updates a subnet rv r6 )rv r| )rJ r2 � update_subnet)r( rv r6 � subnet_idr r r r� � r� zSaltNeutron.update_subnetc C r� )z. Deletes the specified subnet )rv T)rJ r2 � delete_subnet)r( rv r� r r r r r� � r� zSaltNeutron.delete_subnetc C rq )z< Fetches a list of all routers for a tenant )r2 rf rp r r r rf � rs zSaltNeutron.list_routersc C r� )z9 Fetches information of a certain router rK �r( rw r r r � show_router� rs zSaltNeutron.show_routerc C s6 ||d�}|r| � |�}d|i|d< | jjd|id�S )z& Creates a new router r� r� �external_gateway_inforw r� )rG r2 � create_router)r( r6 � ext_networkr� r| r� r r r r� � s zSaltNeutron.create_routerc K s~ | � |�}i }d|v r%|�d�du rd|d< n| �|�d��}d|i|d< |dur-||d< |dur5||d< | jj|d|id�S ) z" Updates a router r� Nr� r� r6 r� rw �rw r| )rM r0 rG r2 � update_router)r( rw r6 r� r � router_idr| r� r r r r� s zSaltNeutron.update_routerc C r� )z- Delete the specified router �rw T)rM r2 � delete_router)r( rw r� r r r r r� r� zSaltNeutron.delete_routerc C �( | � |�}| �|�}| jj|d|id�S )zL Adds an internal network interface to the specified router r� r� )rM rJ r2 �add_interface_router�r( rw rv r� r� r r r r� # � �z SaltNeutron.add_interface_routerc C r� )zQ Removes an internal network interface from the specified router r� r� )rM rJ r2 �remove_interface_routerr� r r r r� - r� z#SaltNeutron.remove_interface_routerc C r� )zJ Adds an external network gateway to the specified router r� r� )rM rG r2 �add_gateway_router)r( rw r r� r� r r r r� 7 r� z SaltNeutron.add_gateway_routerc C s | � |�}| jj|d�S )zO Removes an external network gateway from the specified router r� )rM r2 �remove_gateway_router)r( rw r� r r r r� A s z!SaltNeutron.remove_gateway_routerc C rq )z> Fetch a list of all floatingips for a tenant )r2 �list_floatingipsrp r r r r� H rs z SaltNeutron.list_floatingipsc C � | j �|�S )z= Fetches information of a certain floatingip )r2 �show_floatingip)r( � floatingip_idr r r r� N � zSaltNeutron.show_floatingipc C s: | � |�}d|i}|r| �|�}||d< | jjd|id�S )z* Creates a new floatingip Zfloating_network_idr� rx r� )rG rC r2 �create_floatingip)r( Zfloating_networkry r� r| r� r r r r� T s z SaltNeutron.create_floatingipc C s8 |du r di i}n | � |�}dd|ii}| jj||d�S )zf Updates a floatingip, disassociates the floating ip if port is set to `None` Nrx r� )rx r| )rC r2 �update_floatingip)r( r� ry r| r� r r r r� ` s z SaltNeutron.update_floatingipc C s | j �|�}|r |S dS )z2 Deletes the specified floatingip T)r2 �delete_floatingip)r( r� r r r r r� l s z SaltNeutron.delete_floatingipc C rq )zD Fetches a list of all security groups for a tenant )r2 rg rp r r r rg s rs z SaltNeutron.list_security_groupsc C r� )zA Fetches information of a certain security group rN )r( r~ r r r �show_security_groupy rs z SaltNeutron.show_security_groupc C s d||d�i}| j j|d�S )z. Creates a new security group rz )r6 � descriptionr� )r2 �create_security_group)r( r6 �descr| r r r r� s z!SaltNeutron.create_security_groupc C sB | � |�}di i}|r||d d< |r||d d< | jj||d�S )z* Updates a security group rz r6 r� r� )rP r2 �update_security_group)r( r~ r6 r� � sec_grp_idr| r r r r� � s z!SaltNeutron.update_security_groupc C �" | � |�}| j�|�}|r|S dS )z6 Deletes the specified security group T)rP r2 �delete_security_group)r( r~ r� r r r r r� � � z!SaltNeutron.delete_security_groupc C rq )zI Fetches a list of all security group rules for a tenant )r2 �list_security_group_rulesrp r r r r� � rs z%SaltNeutron.list_security_group_rulesc C s | j �|�d S )zF Fetches information of a certain security group rule r{ )r2 �show_security_group_rule)r( �sec_grp_rule_idr r r r� � s �z$SaltNeutron.show_security_group_rule�ingressc C s0 | � |�}|||||||d�} | jjd| id�S )z3 Creates a new security group rule )Zsecurity_group_idZremote_group_id� direction�protocol�port_range_min�port_range_maxZ ethertyper{ r� )rP r2 �create_security_group_rule) r( r~ Z remote_grp_idr� r� r� r� Zetherr� r| r r r r� � s � �z&SaltNeutron.create_security_group_rulec C r )z; Deletes the specified security group rule )r{ T)r2 �delete_security_group_rule)r( r� r r r r r� � s � z&SaltNeutron.delete_security_group_rulec K s | j j|fi |��S )zL Fetches a list of all configured VPN services for a tenant )r2 rh )r( Z retrieve_allr r r r rh � s z SaltNeutron.list_vpnservicesc K s | � |�}| jj|fi |��S )z? Fetches information of a specific VPN service )rR r2 �show_vpnservice)r( � vpnservicer � vpnservice_idr r r r� � s zSaltNeutron.show_vpnservicec C s4 | � |�}| �|�}||||d�}| jjd|id�S )z+ Creates a new VPN service )r� r� r6 r� r� r� )rJ rM r2 �create_vpnservice)r( rv rw r6 r� r� r� r| r r r r� � s �z SaltNeutron.create_vpnservicec C s& | � |�}d|i}| jj|d|id�S )z' Updates a VPN service r� r� r� )rR r2 �update_vpnservice)r( r� r� r� r| r r r r� � s �z SaltNeutron.update_vpnservicec C r� )z3 Deletes the specified VPN service T)rR r2 �delete_vpnservice)r( r� r� r r r r r� � r� z SaltNeutron.delete_vpnservicec C rq )zL Fetches all configured IPsec Site Connections for a tenant )r2 ri rp r r r ri � rs z'SaltNeutron.list_ipsec_site_connectionsc C r� )zG Fetches information of a specific IPsecSiteConnection rS )r( �ipsec_site_connectionr r r �show_ipsec_site_connection� rs z&SaltNeutron.show_ipsec_site_connectionc K s� | � |�} | �|�} | �|�} || | |g| | |||d� }d| v r&| d |d< d| v r0| d |d< d| v r<d| d i|d< d| v rPd|vrHi |d< | d |d d< d | v rdd|vr\i |d< | d |d d < | jjd |id �S ) z3 Creates a new IPsecSiteConnection ) �psk�ipsecpolicy_idr� � peer_cidrs� ikepolicy_idr� � peer_address�peer_idr6 Z initiatorZmtuZ dpd_action�actionZdpdZ dpd_interval�intervalZ dpd_timeoutr r� r� )r[ rX rR r2 � create_ipsec_site_connection)r( r6 � ipsecpolicy� ikepolicyr� r� r� r� r� r� r r� r� r� r| r r r r� s< � �z(SaltNeutron.create_ipsec_site_connectionc C r� )z; Deletes the specified IPsecSiteConnection T)rU r2 � delete_ipsec_site_connection)r( r� Zipsec_site_connection_idr r r r r� 5 s � z(SaltNeutron.delete_ipsec_site_connectionc C rq )zK Fetches a list of all configured IKEPolicies for a tenant )r2 rj rp r r r rj ? rs z SaltNeutron.list_ikepoliciesc C r� )z= Fetches information of a specific IKEPolicy rV )r( r� r r r �show_ikepolicyE rs zSaltNeutron.show_ikepolicyc K � d|i}d|v r|d |d< d|v r|d |d< d|v r"|d |d< d|v r,|d |d< d|v r6|d |d< d|v rBd|d i|d< d |v rVd|vrNi |d< |d |d d < | j jd |id �S ) z) Creates a new IKEPolicy r6 Zphase1_negotiation_mode�auth_algorithm�encryption_algorithm�pfsZ ike_version�units�lifetime�valuer� r� )r2 �create_ikepolicy�r( r6 r r| r r r r� K �$ z SaltNeutron.create_ikepolicyc C r� )z1 Deletes the specified IKEPolicy T)rX r2 �delete_ikepolicy)r( r� r� r r r r r� b r� z SaltNeutron.delete_ikepolicyc C rq )zM Fetches a list of all configured IPsecPolicies for a tenant )r2 rk rp r r r rk j rs z SaltNeutron.list_ipsecpoliciesc C r� )z? Fetches information of a specific IPsecPolicy rY )r( r� r r r �show_ipsecpolicyp rs z SaltNeutron.show_ipsecpolicyc K r� ) z+ Creates a new IPsecPolicy r6 Ztransform_protocolr� Zencapsulation_moder� r� r� r� r� r� r� )r2 �create_ipsecpolicyr� r r r r� v r� z SaltNeutron.create_ipsecpolicyc C r� )z3 Deletes the specified IPsecPolicy T)r[ r2 �delete_ipsecpolicy)r( Z ipseecpolicyZipseecpolicy_idr r r r r� � r� z SaltNeutron.delete_ipsecpolicyc C rq )zN Fetches a list of all configured firewall rules for a tenant )r2 rl rp r r r rl � rs z SaltNeutron.list_firewall_rulesc C r� )zA Fetches information of a specific firewall rule r\ )r( � firewall_ruler r r �show_firewall_rule� rs z SaltNeutron.show_firewall_rulec K s� ||d�}d|v r|d |d< d|v r|d |d< d|v r#|d |d< d|v r-|d |d< d|v r7|d |d< d|v rA|d |d< d|v rK|d |d< d |v rU|d |d < | j jd |id �S ) z, Create a new firlwall rule )r� r� r r6 r� r� �source_ip_address�destination_portr� �enabledr� r� )r2 �create_firewall_rule)r( r� r� r r| r r r r� � s$ z SaltNeutron.create_firewall_rulec C r� )z5 Deletes the specified firewall rule T)r^ r2 �delete_firewall_rule)r( r� Zfirewall_rule_idr r r r r� � r� z SaltNeutron.delete_firewall_rulec C s� i } |r|| d< |r|| d< |r|| d< |r|| d< |r || d< |r&|| d< |r,|| d< | r2| | d< | r8| | d < | r>| | d < | rD| | d < | j j|d | id �S )z( Update a firewall rule r� r� r6 r� r� r� �destination_ip_address� source_portr� r� r� r� r� )r2 �update_firewall_rule)r( r� r� r� r6 r� r� r� r� r� r� r� r� r| r r r r� � s4 �z SaltNeutron.update_firewall_rulec C rq )z> Fetches a list of all firewalls for a tenant )r2 rm rp r r r rm � rs zSaltNeutron.list_firewallsc C r� )z< Fetches information of a specific firewall )rn )r( Zfirewallr r r � show_firewall� rs zSaltNeutron.show_firewallc C r� )z! List L3 agents. )r2 � list_l3_agent_hosting_routersr� r r r r� � r� z)SaltNeutron.list_l3_agent_hosting_routersc C rq )z List agents. )r2 � list_agentsrp r r r r� � rs zSaltNeutron.list_agents)NNr NF)NT)NNNNNNN)T)TNNNNNN)Nr� r )NN)Nr� NNNN) NNNNNNNNNNN)d�__name__� __module__� __qualname__�__doc__r) r& r' � staticmethodr= rC rG rJ rM rP rR rU rX r[ r^ rA rF rI rL rO rQ rT rW rZ r] rn ro rr ru r} r� r� r` r� r� r� r� rc r� r� r� r� re r� r� r� r� rf r� r� r� r� r� r� r� r� r� r� r� r� r� rg r� r� r� r� r� r� r� r� rh r� r� r� r� ri r� r� r� rj r� r� r� rk r� r� r� rl r� r� r� r� rm r� r� r� r r r r r J s �> �0 � � � � �0 �- r )r �loggingZsalt.utils.versionsr# r r Zneutronclient.shellr Zneutronclient.v2_0r � ImportErrorr Zkeystoneauth1.loadingr, Zkeystoneauth1.session� getLoggerr� �logr r r r r r r r �<module> s2 � �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings