You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@libcloud.apache.org by an...@apache.org on 2016/03/21 11:23:14 UTC
[05/17] libcloud git commit: adds dns support for ns1 provider
adds dns support for ns1 provider
Project: http://git-wip-us.apache.org/repos/asf/libcloud/repo
Commit: http://git-wip-us.apache.org/repos/asf/libcloud/commit/0f278d90
Tree: http://git-wip-us.apache.org/repos/asf/libcloud/tree/0f278d90
Diff: http://git-wip-us.apache.org/repos/asf/libcloud/diff/0f278d90
Branch: refs/heads/trunk
Commit: 0f278d9037f5c63469497c15a3ffda21503ba2ac
Parents: 8d012ca
Author: lostbird <lostbird@lostbird.(none)>
Authored: Mon Feb 22 16:15:29 2016 +0100
Committer: anthony-shaw <an...@gmail.com>
Committed: Mon Mar 21 21:20:31 2016 +1100
----------------------------------------------------------------------
libcloud/common/nsone.py | 60 ++++++++++
libcloud/dns/drivers/nsone.py | 229 +++++++++++++++++++++++++++++++++++++
libcloud/dns/types.py | 1 +
3 files changed, 290 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/libcloud/blob/0f278d90/libcloud/common/nsone.py
----------------------------------------------------------------------
diff --git a/libcloud/common/nsone.py b/libcloud/common/nsone.py
new file mode 100644
index 0000000..d1f1bbd
--- /dev/null
+++ b/libcloud/common/nsone.py
@@ -0,0 +1,60 @@
+from libcloud.common.base import ConnectionKey, JsonResponse
+
+
+__all__ = [
+ 'API_HOST',
+ 'NsOneException',
+ 'NsOneResponse',
+ 'NsOneConnection'
+]
+
+# Endpoint for nsone api
+API_HOST = 'api.nsone.net'
+
+
+class NsOneResponse(JsonResponse):
+ errors = []
+ objects = []
+
+ def __init__(self, response, connection):
+ super(NsOneResponse, self).__init__(response=response, connection=connection)
+ self.errors, self.objects = self.parse_body_and_errors()
+ if not self.success():
+ raise NsOneException(code=self.status, message=self.errors.pop()['message'])
+
+ def parse_body_and_errors(self):
+ js = super(NsOneResponse, self).parse_body()
+ if 'message' in js:
+ self.errors.append(js)
+ else:
+ self.objects.append(js)
+
+ return self.errors, self.objects
+
+ def success(self):
+ return len(self.errors) == 0
+
+
+class NsOneConnection(ConnectionKey):
+ host = API_HOST
+ responseCls = NsOneResponse
+
+ def add_default_headers(self, headers):
+ headers['Content-Type'] = 'application/json'
+ headers['X-NSONE-KEY'] = self.key
+
+ return headers
+
+
+class NsOneException(Exception):
+
+ def __init__(self, code, message):
+ self.code = code
+ self.message = message
+ self.args = (code, message)
+
+ def __str__(self):
+ return "%s %s" % (self.code, self.message)
+
+ def __repr__(self):
+ return "NsOneException %s %s" % (self.code, self.message)
http://git-wip-us.apache.org/repos/asf/libcloud/blob/0f278d90/libcloud/dns/drivers/nsone.py
----------------------------------------------------------------------
diff --git a/libcloud/dns/drivers/nsone.py b/libcloud/dns/drivers/nsone.py
new file mode 100644
index 0000000..4e54491
--- /dev/null
+++ b/libcloud/dns/drivers/nsone.py
@@ -0,0 +1,229 @@
+try:
+ import simplejson as json
+except ImportError:
+ import json
+
+from libcloud.utils.py3 import httplib
+from libcloud.dns.base import DNSDriver, Zone, Record, RecordType
+from libcloud.common.nsone import NsOneConnection, NsOneResponse, NsOneException
+from libcloud.dns.types import Provider, ZoneDoesNotExistError, ZoneAlreadyExistsError, RecordDoesNotExistError, \
+ RecordAlreadyExistsError
+
+
+__all__ = [
+ 'NsOneDNSDriver'
+]
+
+
+class NsOneDNSResponse(NsOneResponse):
+ pass
+
+
+class NsOneDNSConnection(NsOneConnection):
+ responseCls = NsOneDNSResponse
+
+
+class NsOneDNSDriver(DNSDriver):
+ name = 'NS1 DNS'
+ website = 'https://ns1.com'
+ type = Provider.NSONE
+ connectionCls = NsOneDNSConnection
+
+ RECORD_TYPE_MAP = {
+ RecordType.A: 'A',
+ RecordType.AAAA: 'AAAA',
+ RecordType.CNAME: 'CNAME',
+ RecordType.MX: 'MX',
+ RecordType.NS: 'NS',
+ RecordType.PTR: 'PTR',
+ RecordType.SOA: 'SOA',
+ RecordType.SRV: 'SRV',
+ RecordType.TXT: 'TXT'
+ }
+
+ def list_zones(self):
+ action = '/v1/zones'
+ response = self.connection.request(action=action, method='GET')
+ zones = self._to_zones(items=response.parse_body())
+
+ return zones
+
+ def get_zone(self, zone_id):
+ action = '/v1/zones/%s' % zone_id
+ try:
+ response = self.connection.request(action=action, method='GET')
+ except NsOneException, e:
+ if e.message == 'zone not found':
+ raise ZoneDoesNotExistError(value=e.message, driver=self, zone_id=zone_id)
+ else:
+ raise e
+ zone = self._to_zone(response.objects[0])
+
+ return zone
+
+ def create_zone(self, domain, type='master', ttl=None, extra=None):
+ """
+ :param domain: Zone domain name (e.g. example.com)
+ :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, nx_ttl. Read API docs for more.
+ :type extra: ``dict``
+
+ :rtype: :class:`Zone`
+ """
+ action = '/v1/zones/%s' % domain
+ raw_data = {'zone': domain}
+ if extra is not None:
+ raw_data.update(extra)
+ data = json.dumps(raw_data)
+ try:
+ response = self.connection.request(action=action, method='PUT', data=data)
+ except NsOneException, e:
+ if e.message == 'zone already exists':
+ raise ZoneAlreadyExistsError(value=e.message, driver=self, zone_id=domain)
+ else:
+ raise e
+
+ zone = self._to_zone(response.objects[0])
+
+ return zone
+
+ def delete_zone(self, zone):
+ action = '/v1/zones/%s' % zone.domain
+ zones_list = self.list_zones()
+ if not self.ex_zone_exists(zone_id=zone.id, zones_list=zones_list):
+ raise ZoneDoesNotExistError(value='', driver=self, zone_id=zone.id)
+
+ response = self.connection.request(action=action, method='DELETE')
+
+ return response.status == httplib.OK
+
+ def update_zone(self, zone, domain, type='master', ttl=None, extra=None):
+ pass
+
+ def list_records(self, zone):
+ """
+ :param zone: Zone to list records for.
+ :type zone: :class:`Zone`
+
+ :return: ``list`` of :class:`Record`
+ """
+ action = '/v1/zones/%s' % zone.domain
+ try:
+ response = self.connection.request(action=action, method='GET')
+ except NsOneException, e:
+ if e.message == 'zone not found':
+ raise ZoneDoesNotExistError(value=e.message, driver=self, zone_id=zone.id)
+ else:
+ raise e
+ records = self._to_records(items=response.parse_body()['records'], zone=zone)
+
+ return records
+
+ def get_record(self, zone_id, record_id):
+ action = '/v1/zones/%s/%s/%s' % (zone_id, zone_id, record_id)
+ try:
+ response = self.connection.request(action=action, method='GET')
+ except NsOneException, e:
+ if e.message == 'record not found':
+ raise RecordDoesNotExistError(value=e.message, driver=self, record_id=record_id)
+ else:
+ raise e
+ zone = self.get_zone(zone_id=zone_id)
+ record = self._to_record(item=response.objects[0], zone=zone)
+
+ return record
+
+ def delete_record(self, record):
+ pass
+
+ def create_record(self, name, zone, type, data, extra=None):
+ action = '/v1/zones/%s/%s/%s' % (zone.domain, zone.domain, type)
+ raw_data = {
+ "answers": [
+ {
+ "answer": [
+ 10,
+ data
+ ], }
+ ],
+ "type": type,
+ "domain": zone.domain,
+ "zone": zone
+ }
+
+ if extra is not None:
+ raw_data.update(extra)
+ data = json.dumps(raw_data)
+ try:
+ response = self.connection.request(action=action, method='PUT', data=data)
+ except NsOneException, e:
+ if e.message == 'record already exists':
+ raise RecordAlreadyExistsError(value=e.message, driver=self, record_id='')
+
+ return response
+
+ def update_record(self, record, name, type, data, extra=None):
+ pass
+
+ def ex_zone_exists(self, zone_id, zones_list):
+ """
+ Function to check if a `Zone` object exists.
+ :param zone_id: ID of the `Zone` object.
+ :type zone_id: ``str``
+
+ :param zones_list: A list containing `Zone` objects.
+ :type zones_list: ``list``.
+
+ :rtype: Returns `True` or `False`.
+ """
+ zone_ids = []
+ for zone in zones_list:
+ zone_ids.append(zone.id)
+
+ return zone_id in zone_ids
+
+ def _to_zone(self, item):
+ common_attr = ['zone', 'id', 'type']
+ extra = {}
+ for key in item:
+ if key not in common_attr:
+ extra[key] = item.get(key)
+
+ zone = Zone(domain=item['zone'], id=item['id'], type=item.get('type'), extra=extra, ttl=extra.get('ttl'),
+ driver=self)
+
+ return zone
+
+ def _to_zones(self, items):
+ zones = []
+ for item in items:
+ zones.append(self._to_zone(item))
+
+ return zones
+
+ def _to_record(self, item, zone):
+ common_attr = ['id', 'short_answers', 'domain', 'type']
+ extra = {}
+ for key in item:
+ if key not in common_attr:
+ extra[key] = item.get(key)
+ record = Record(id=item['id'], name=item['domain'], type=item['type'],
+ data=item['short_answers'], zone=zone, driver=self,
+ extra=extra)
+
+ return record
+
+ def _to_records(self, items, zone):
+ records = []
+ for item in items:
+ records.append(self._to_record(item, zone))
+
+ return records
http://git-wip-us.apache.org/repos/asf/libcloud/blob/0f278d90/libcloud/dns/types.py
----------------------------------------------------------------------
diff --git a/libcloud/dns/types.py b/libcloud/dns/types.py
index dc504e4..2edd090 100644
--- a/libcloud/dns/types.py
+++ b/libcloud/dns/types.py
@@ -48,6 +48,7 @@ class Provider(object):
DURABLEDNS = 'durabledns'
GODADDY = 'godaddy'
CLOUDFLARE = 'cloudflare'
+ NSONE = 'nsone'
# Deprecated
RACKSPACE_US = 'rackspace_us'