Source code for libcloud.dns.drivers.buddyns

# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements.  See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License.  You may obtain a copy of the License at
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# See the License for the specific language governing permissions and
# limitations under the License.
BuddyNS DNS Driver

    import simplejson as json
except ImportError:
    import json

from libcloud.dns.types import Provider, ZoneDoesNotExistError,\
from libcloud.dns.base import DNSDriver, Zone
from libcloud.common.buddyns import BuddyNSConnection, BuddyNSResponse,\

__all__ = [

class BuddyNSDNSResponse(BuddyNSResponse):

class BuddyNSDNSConnection(BuddyNSConnection):
    responseCls = BuddyNSDNSResponse

[docs]class BuddyNSDNSDriver(DNSDriver): name = 'BuddyNS DNS' website = '' type = Provider.BUDDYNS connectionCls = BuddyNSDNSConnection
[docs] def list_zones(self): action = '/api/v2/zone/' response = self.connection.request(action=action, method='GET') zones = self._to_zones(items=response.parse_body()) return zones
[docs] def get_zone(self, zone_id): """ :param zone_id: Zone domain name (e.g. :return: :class:`Zone` """ action = '/api/v2/zone/%s' % zone_id try: response = self.connection.request(action=action, method='GET') except BuddyNSException as e: if e.message == 'Not found': raise ZoneDoesNotExistError(value=e.message, driver=self, zone_id=zone_id) else: raise e zone = self._to_zone(response.parse_body()) return zone
[docs] def create_zone(self, domain, type='master', ttl=None, extra=None): """ :param domain: Zone domain name (e.g. :type domain: ``str`` :param type: Zone type (This is not really used. See API docs for extra parameters) :type type: ``str`` :param ttl: TTL for new records (This is used through the extra param) :type ttl: ``int`` :param extra: Extra attributes that are specific to the driver such as ttl. :type extra: ``dict`` :rtype: :class:`Zone` Do not forget to pass the master in extra, extra = {'master':''} for example. """ action = '/api/v2/zone/' data = {'name': domain} if extra is not None: data.update(extra) post_data = json.dumps(data) try: response = self.connection.request(action=action, method='POST', data=post_data) except BuddyNSException as e: if e.message == 'Invalid zone submitted for addition.': raise ZoneAlreadyExistsError(value=e.message, driver=self, zone_id=domain) else: raise e zone = self._to_zone(response.parse_body()) return zone
[docs] def delete_zone(self, zone): """ :param zone: Zone to be deleted. :type zone: :class:`Zone` :return: Boolean """ action = '/api/v2/zone/%s' % zone.domain try: self.connection.request(action=action, method='DELETE') except BuddyNSException as e: if e.message == 'Not found': raise ZoneDoesNotExistError(value=e.message, driver=self, else: raise e return True
def _to_zone(self, item): common_keys = ['name', ] extra = {} for key in item: if key not in common_keys: extra[key] = item.get(key) zone = Zone(domain=item['name'], id=item['name'], type=None, extra=extra, ttl=None, driver=self) return zone def _to_zones(self, items): zones = [] for item in items: zones.append(self._to_zone(item)) return zones