File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/dns/drivers/__pycache__/rackspace.cpython-310.pyc
Back
o ;j�Z � @ s d dl Z d dlmZmZmZ d dlmZmZmZm Z d dl m Z d dl m Z mZ d dlmZ d dlmZ d dlmZ d d lmZ d d lmZ d d lmZmZ d d gZ g d�Z g d�Z G dd � d e�Z G dd � d ee�Z G dd� d�Z!G dd� dee�Z"dd� Z#dd� Z$dS )� N)�Zone�Record� DNSDriver)�Provider� RecordType�ZoneDoesNotExistError�RecordDoesNotExistError)�httplib)� get_new_obj�merge_valid_keys)�PollingConnection)� LibcloudError)�OpenStackDriverMixin)�AUTH_URL)� BaseHTTPError)�OpenStack_1_1_Response�OpenStack_1_1_Connection�RackspaceDNSResponse�RackspaceDNSConnection)�email�commentZns1)�ttlr �priority�created�updatedc @ s e Zd ZdZdd� ZdS )r z' Rackspace DNS Response class. c C s� t | j�}| jj}| �� }|tjkr0|d dkr!td| |d d��|d dkr0td| |d d��|r]d |v rEd � |d |d |d �}|S d |v r]d d� |d d D �}dd� |� }|S t d| ��)N�resource�zone� �id)�value�driver�zone_id�record)r r � record_id�code�message� {} - {} ({})�detailsZvalidationErrorsc S s g | ]}|�qS � r( )�.0�mr( r( �R/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/dns/drivers/rackspace.py� <listcomp>6 s z4RackspaceDNSResponse.parse_error.<locals>.<listcomp>�messageszValidation errors: %sz, zUnexpected status code: %s) �int�status� connection�contextZ parse_bodyr � NOT_FOUNDr r �format�joinr )�selfr/ r1 �body�err�errorsr( r( r+ � parse_error' s" z RackspaceDNSResponse.parse_errorN)�__name__� __module__� __qualname__�__doc__r9 r( r( r( r+ r " s c sP e Zd ZdZeZdZdZdZe Z dZ � fdd�Z dd � Z d d � Zd d � Z� ZS )r z) Rackspace DNS Connection class. Ng @� �2.0c s$ |� dd �| _t� j|i |�� d S �N�region)�poprA �super�__init__)r5 �args�kwargs�� __class__r( r+ rD J s z RackspaceDNSConnection.__init__c C s |j d }d| ddid�}|S )NZjobIdz /status/%sZ showDetailsT��action�params)�object)r5 �responser1 Zrequest_kwargsZjob_idrF r( r( r+ �get_poll_request_kwargsN s z.RackspaceDNSConnection.get_poll_request_kwargsc C s^ |j d }|dkr+|j d }d|v r d�|d |d |d �}n|d }t|| jd��|d kS ) Nr/ �ERROR�errorr$ r% r& r' �r Z COMPLETED)rL r3 r r )r5 rM r/ �datar% r( r( r+ � has_completedS s �z$RackspaceDNSConnection.has_completedc C sb d| j v r| jjddd d�}ntd| j ��|j}| jdkr$|�dd�}| jd kr/|�dd�}|S ) Nr? ZcloudDNSzrax:dns)�nameZ service_typerA z Auth version %s not supported�uszhttps://lon.dns.apizhttps://dns.api�uk)� _auth_versionZservice_catalog� get_endpointr �urlrA �replace)r5 ZepZ public_urlr( r( r+ rX e s � z#RackspaceDNSConnection.get_endpoint)r: r; r< r= r Z responseClsZ XML_NAMESPACEZ poll_interval�timeoutr Zauth_urlrW rD rN rS rX � __classcell__r( r( rG r+ r = s c @ s0 e Zd Zd dd�Zd dd�Zdd� Zdd � ZdS ) �RackspacePTRRecordNc C s: |rt |�nd | _|| _tj| _|| _|| _|pi | _d S �N) �strr �ipr �PTR�type�domainr �extra)r5 r r` rc r rd r( r( r+ rD | s zRackspacePTRRecord.__init__c C s | j j| ||d�S )N)r" rc rd )r �ex_update_ptr_record)r5 rc rd r( r( r+ �update� s zRackspacePTRRecord.updatec C s | j j| d�S )N)r" )r �ex_delete_ptr_record�r5 r( r( r+ �delete� s zRackspacePTRRecord.deletec C s d� | jj| j| j| jj�S )Nz'<{}: ip={}, domain={}, provider={} ...>)r3 rH r: r` rc r rT rh r( r( r+ �__repr__� s �zRackspacePTRRecord.__repr__r^ )r: r; r< rD rf ri rj r( r( r( r+ r] { s r] c s$ e Zd ZdZdZejZeZ d=� fdd� Z e j de j d e jd e jd e jd e jd e jde jdiZedd� �Zdd� Zdd� Zdd� Zdd� Zd>dd �Zd?d d �Z d@d d �Z d?d!d"�Z d#d$� Z d%d&� Z d'd(� Z!d)d*� Z"d@d+d,�Z#dAd-d.�Z$d/d0� Z%d1d2� Z&d3d4� Z'd5d6� Z(d7d8� Z)d9d:� Z*d;d<� Z+� Z,S )B�RackspaceDNSDriverz Rackspace DNSzhttp://www.rackspace.com/NTrU c sH | � � }||vrtd| ��tj| fi |�� t� j|||||d� d S )NzInvalid region: %s)�key�secret�host�portrA )� list_regions� ValueErrorr rD rC ) r5 rl rm Zsecurern ro rA rF Z valid_regionsrG r( r+ rD � s zRackspaceDNSDriver.__init__�A�AAAA�CNAME�MX�NSra �SRV�TXTc C s ddgS )NrU rV r( )�clsr( r( r+ rp � s z RackspaceDNSDriver.list_regionsc c sf � d}d} ||d�}| j jd|d�j}|d }|D ]}| �|�V qt|t|�|�r0||7 }nd S q)Nr �d T)�limit�offset�/domainsrI �domains)r0 �requestrL �_to_zone�_rackspace_result_has_more�len)r5 r| r{ rK rM Z zones_list�itemr( r( r+ � iterate_zones� s �� �z RackspaceDNSDriver.iterate_zonesc c s� � | j �d|jd�� d}d} d||d�}| j jd|j |d�j}|d }|d }|D ] }| j||d �} | V q,t|t|�|�rF||7 }nd S q) Nr �r r r rz T)Z showRecordr{ r| � /domains/%srI � recordsList�records�rR r )r0 � set_contextr r rL � _to_recordr� r� ) r5 r r| r{ rK rM Z records_listr� r� r" r( r( r+ �iterate_records� s. �� �� �z"RackspaceDNSDriver.iterate_recordsc C s6 | j �d|d�� | j jd| d�}| j|jd�}|S )Nr r� r� �rJ �rR )r0 r� r r� rL )r5 r! rM r r( r( r+ �get_zone� s zRackspaceDNSDriver.get_zonec C sH | j |d�}| j�d|d�� | jjd�||�d�j}| j||d�}|S )N)r! r" r� �/domains/{}/records/{}r� r� )r� r0 r� r r3 rL r� )r5 r! r# r rM r" r( r( r+ � get_record� s ��z RackspaceDNSDriver.get_record�masterc C s� |r|ni }d|vrt d��||d dg id�}|r ||d< d|v r(|d |d< d|gi}| jjdd |d �}| j|jd d d d �}|S )Nr z/"email" key must be present in extra dictionaryr� )rT � emailAddressr� r r r~ r} �POST�rJ �methodrR rM r r� )rq r0 � async_requestr� rL ) r5 rc rb r rd �payloadrR rM r r( r( r+ � create_zone� s � z RackspaceDNSDriver.create_zonec C s� |r|ni }|rt d| d��i }|rt|�|d< d|v r"|d |d< d|v r,|d |d< |r0|n|j}|r7|n|j}| j�d|jd�� | jjd |j d |d � tt � |j �t |d �}t |t|||d �d�}|S )NzDomain cannot be changedrQ r r r� r r r� r� �PUTr� �rK Z valid_keysrd )rb r rd ��obj�klassZ attributes)r r. rb r r0 r� r r� r �copy�deepcopyrd �VALID_ZONE_EXTRA_PARAMSr r ) r5 r rc rb r rd rR �mergedZ updated_zoner( r( r+ � update_zone s. ��z RackspaceDNSDriver.update_zonec C s� |r|ni }| j |j|d�}|| j| |d�}d|v r#t|d �|d< d|v r/t|d �|d< d|gi}| j�d|jd�� | jjd|j |d d �j}| j |d d d |d �}|S )N�rc rT �rT rb rR r r r� r r� z/domains/%s/recordsr� )rJ rR r� rM r r� ) �_to_full_record_namerc �RECORD_TYPE_MAPr. r0 r� r r� rL r� ) r5 rT r rb rR rd r� rM r" r( r( r+ � create_record" s ��z RackspaceDNSDriver.create_recordc C s� |r|ni }| j |jj|jd�}d|i}|r||d< d|v r$|d |d< d|v r.|d |d< |d ur4|n|j}|r;|n|j}| j�d|jd�� | jj d� |jj|j�d |d � t t � |j�t|d �}t|t||| |d �d �}|S )Nr� rT rR r r r" r� r� r� r� r� )rb rR r rd r� )r� r rc rT rb rR r0 r� r r� r3 r r� r� rd �VALID_RECORD_EXTRA_PARAMSr r ) r5 r" rT rb rR rd r� r� Zupdated_recordr( r( r+ � update_record8 s8 � � �z RackspaceDNSDriver.update_recordc C s. | j �d|jd�� | j jd|j dd� dS )Nr r� r� �DELETE�rJ r� T)r0 r� r r� )r5 r r( r( r+ � delete_zone_ s z RackspaceDNSDriver.delete_zonec C s6 | j �d|jd�� | j jd�|jj|j�dd� dS )Nr" r� r� r� r� T)r0 r� r r� r3 r �r5 r" r( r( r+ � delete_recordd s �z RackspaceDNSDriver.delete_recordc c s� � t |� d|jd i}|jd }| j�ddi� z*| jjd| |d�j}|d }td d |i|��}|D ] }| j||d �}|V q4W d S ty\ } z | j d krWW Y d } ~ d S � d } ~ ww )a� Return a generator to iterate over existing PTR Records. The ``device`` should be an instance of one of these: :class:`libcloud.compute.base.Node` :class:`libcloud.loadbalancer.base.LoadBalancer` And it needs to have the following ``extra`` fields set: service_name - the service catalog name for the device uri - the URI pointing to the GET endpoint for the device Those are automatically set for you if you got the device from the Rackspace driver for that service. For example: server = rs_compute.ex_get_node_details(id) ptr_iter = rs_dns.ex_list_ptr_records(server) loadbalancer = rs_lbs.get_balancer(id) ptr_iter = rs_dns.ex_list_ptr_records(loadbalancer) Note: the Rackspace DNS API docs indicate that the device 'href' is optional, but testing does not bear this out. It throws a 400 Bad Request error if you do not pass in the 'href' from the server or loadbalancer. So ``device`` is required. :param device: the device that owns the IP :rtype: ``generator`` of :class:`RackspacePTRRecord` �href�uri� service_namer Z ptr_records�/rdns/%srI r� �rel�rR �linki� Nr( ) �_check_ptr_extra_fieldsrd r0 r� r rL �dict�_to_ptr_recordr r$ ) r5 �devicerK r� rM r� r� r� r" �excr( r( r+ �ex_iterate_ptr_recordsl s. � ��� ��z)RackspaceDNSDriver.ex_iterate_ptr_recordsc C sP | j �d|d�� | j jd�||�d�j}tt|d d ��}| j||d d�S ) aK Get a specific PTR record by id. :param service_name: the service catalog name of the linked device(s) i.e. cloudLoadBalancers or cloudServersOpenStack :param record_id: the id (i.e. PTR-12345) of the PTR record :rtype: instance of :class:`RackspacePTRRecord` r" r� z /rdns/{}/{}r� r� r� r� r� )r0 r� r r3 rL �next�iterr� )r5 r� r# rM r� r( r( r+ �ex_get_ptr_record� s ��z$RackspaceDNSDriver.ex_get_ptr_recordc C s� t |� |du r i }|tj|d�}d|v r|d |d< d|gid|jd |jd d�d �}| jjd d |d �j}tt|d d ��}| j ||d d�S )a� Create a PTR record for a specific IP on a specific device. The ``device`` should be an instance of one of these: :class:`libcloud.compute.base.Node` :class:`libcloud.loadbalancer.base.LoadBalancer` And it needs to have the following ``extra`` fields set: service_name - the service catalog name for the device uri - the URI pointing to the GET endpoint for the device Those are automatically set for you if you got the device from the Rackspace driver for that service. For example: server = rs_compute.ex_get_node_details(id) rs_dns.create_ptr_record(server, ip, domain) loadbalancer = rs_lbs.get_balancer(id) rs_dns.create_ptr_record(loadbalancer, ip, domain) :param device: the device that owns the IP :param ip: the IP for which you want to set reverse DNS :param domain: the fqdn you want that IP to represent :param extra: a ``dict`` with optional extra values: ttl - the time-to-live of the PTR record :rtype: instance of :class:`RackspacePTRRecord` Nr� r r� r r� r� )�contentr� r� )r� r� z/rdnsr� r� rM r� r� ) r� r ra rd r0 r� rL r� r� r� ) r5 r� r` rc rd rR r� rM r� r( r( r+ �ex_create_ptr_record� s ��z'RackspaceDNSDriver.ex_create_ptr_recordc C s� |dur ||j kr d}|dur)t|�}|D ]}||jv r(|j| || kr(||= q|du r1|s1|S t|� |j}| �|� | j||||d�S )a Update a PTR record for a specific IP on a specific device. If you need to change the domain or ttl, use this API to update the record by deleting the old one and creating a new one. :param record: the original :class:`RackspacePTRRecord` :param domain: the fqdn you want that IP to represent :param extra: a ``dict`` with optional extra values: ttl - the time-to-live of the PTR record :rtype: instance of :class:`RackspacePTRRecord` N)rd )rc r� rd r� r` rg r� )r5 r" rc rd rl r` r( r( r+ re � s � z'RackspaceDNSDriver.ex_update_ptr_recordc C sJ t |� | j�d|jd�� | jjd|jd d|jd |jd�d� d S ) z� Delete an existing PTR Record :param record: the original :class:`RackspacePTRRecord` :rtype: ``bool`` r" r� r� r� r� r� )r� r` )rJ r� rK T)r� r0 r� r r� rd r` r� r( r( r+ rg s �z'RackspaceDNSDriver.ex_delete_ptr_recordc C sl |d }|d }d}|� dd�}i }d|v r |d |d< d|v r&|d |d< tt|�||t|�| |d �}|S ) Nr rT r� r r r� r r )r rc rb r r rd )�getr r_ r. )r5 rR r rc rb r rd r r( r( r+ r� s zRackspaceDNSDriver._to_zonec C s� |d }|d }| j |j|d�}| �|d �}|d }d|i}tD ] } | |v r-|| || < q!tt|�||||| |�dd �|d�} | S ) Nr rT r� rb rR �fqdnr )r rT rb rR r r r rd )�_to_partial_record_namerc Z_string_to_record_typer� r r_ r� ) r5 rR r r r� rT rb Z record_datard rl r" r( r( r+ r� ( s* � � z RackspaceDNSDriver._to_recordc C sb |d }|d }|d }|d |d d�}t D ] }||v r#|| ||< qtt|�||| |d�}|S )Nr rR rT r� r� )r� r� )r r` rc r rd )r� r] r_ ) r5 rR r� r r` rc rd rl r" r( r( r+ r� @ s �z!RackspaceDNSDriver._to_ptr_recordc C s |r d� ||�}|S |}|S )z� Build a FQDN from a domain and record name. :param domain: Domain name. :type domain: ``str`` :param name: Record name. :type name: ``str`` z{}.{})r3 �r5 rc rT r( r( r+ r� M s �z'RackspaceDNSDriver._to_full_record_namec C s ||krdS |� d| d�}|S )z� Remove domain portion from the record name. :param domain: Domain name. :type domain: ``str`` :param name: Full record name (fqdn). :type name: ``str`` Nz.%sr )rZ r� r( r( r+ r� ^ s z*RackspaceDNSDriver._to_partial_record_namec C s | � � }| j|d< |S r@ )Zopenstack_connection_kwargsrA )r5 rF r( r( r+ �_ex_connection_class_kwargsq s z.RackspaceDNSDriver._ex_connection_class_kwargs)NTNNrU )r� NN)NNNNr^ )NN)-r: r; r< rT Zwebsiter Z RACKSPACErb r Z connectionClsrD r rr rs rt ru rv ra rw rx r� � classmethodrp r� r� r� r� r� r� r� r� r� r� r� r� r� re rg r� r� r� r� r� r� r\ r( r( rG r+ rk � sL � ! '5 5" rk c C s4 ||k rdS | � dd�D ] }|d dkr dS q dS )NFZlinksr( r� r� T)r� )rM Z result_lengthr{ r� r( r( r+ r� w s �r� c C sF t | d�rt| jt�r| j�d�d ur| j�d�d us!td| ��d S )Nrd r� r� z\Can't create PTR Record for %s because it doesn't have a 'uri' and 'service_name' in 'extra')�hasattr� isinstancerd r� r� r )Zdevice_or_recordr( r( r+ r� � s � ����r� )%r� Zlibcloud.dns.baser r r Zlibcloud.dns.typesr r r r Zlibcloud.utils.py3r Zlibcloud.utils.miscr r Zlibcloud.common.baser Zlibcloud.common.typesr Zlibcloud.common.openstackr Zlibcloud.common.rackspacer Zlibcloud.common.exceptionsr Z"libcloud.compute.drivers.openstackr r �__all__r� r� r r r] rk r� r� r( r( r( r+ �<module> s. > g
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings