RuhNetConsulting
/
octodns
mirror of https://github.com/octodns/octodns
1
0
Fork 0
Code Issues 0 Projects 0 Releases 52 Wiki Activity
Browse Source

Implement Zone.add_record lenient across our providers

pull/243/head
Ross McFarland 8 years ago
parent
1103b4c383
commit
cee7677ae4
No known key found for this signature in database GPG Key ID: 61C10C4FC8FE4A89
14 changed files with 18 additions and 18 deletions
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +1
    -1
      octodns/provider/azuredns.py
  2. +1
    -1
      octodns/provider/cloudflare.py
  3. +1
    -1
      octodns/provider/digitalocean.py
  4. +1
    -1
      octodns/provider/dnsimple.py
  5. +1
    -1
      octodns/provider/dnsmadeeasy.py
  6. +4
    -4
      octodns/provider/dyn.py
  7. +1
    -1
      octodns/provider/googlecloud.py
  8. +1
    -1
      octodns/provider/ns1.py
  9. +1
    -1
      octodns/provider/ovh.py
  10. +1
    -1
      octodns/provider/powerdns.py
  11. +1
    -1
      octodns/provider/rackspace.py
  12. +1
    -1
      octodns/provider/route53.py
  13. +1
    -1
      octodns/provider/yaml.py
  14. +2
    -2
      octodns/source/tinydns.py

+ 1
- 1
octodns/provider/azuredns.py View File

@ -345,7 +345,7 @@ class AzureProvider(BaseProvider):
data['type'] = typ data['type'] = typ
data['ttl'] = azrecord.ttl data['ttl'] = azrecord.ttl
record = Record.new(zone, record_name, data, source=self) record = Record.new(zone, record_name, data, source=self)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/cloudflare.py View File

@ -253,7 +253,7 @@ class CloudflareProvider(BaseProvider):
self.log.info('CDN rewrite %s already in zone', name) self.log.info('CDN rewrite %s already in zone', name)
continue continue
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/digitalocean.py View File

@ -230,7 +230,7 @@ class DigitalOceanProvider(BaseProvider):
data_for = getattr(self, '_data_for_{}'.format(_type)) data_for = getattr(self, '_data_for_{}'.format(_type))
record = Record.new(zone, name, data_for(_type, records), record = Record.new(zone, name, data_for(_type, records),
source=self, lenient=lenient) source=self, lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
exists = zone.name in self._zone_records exists = zone.name in self._zone_records
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',


+ 1
- 1
octodns/provider/dnsimple.py View File

@ -270,7 +270,7 @@ class DnsimpleProvider(BaseProvider):
data_for = getattr(self, '_data_for_{}'.format(_type)) data_for = getattr(self, '_data_for_{}'.format(_type))
record = Record.new(zone, name, data_for(_type, records), record = Record.new(zone, name, data_for(_type, records),
source=self, lenient=lenient) source=self, lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
exists = zone.name in self._zone_records exists = zone.name in self._zone_records
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',


+ 1
- 1
octodns/provider/dnsmadeeasy.py View File

@ -263,7 +263,7 @@ class DnsMadeEasyProvider(BaseProvider):
data_for = getattr(self, '_data_for_{}'.format(_type)) data_for = getattr(self, '_data_for_{}'.format(_type))
record = Record.new(zone, name, data_for(_type, records), record = Record.new(zone, name, data_for(_type, records),
source=self, lenient=lenient) source=self, lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
exists = zone.name in self._zone_records exists = zone.name in self._zone_records
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',


+ 4
- 4
octodns/provider/dyn.py View File

@ -399,7 +399,7 @@ class DynProvider(BaseProvider):
return self._traffic_directors return self._traffic_directors
def _populate_traffic_directors(self, zone):
def _populate_traffic_directors(self, zone, lenient):
self.log.debug('_populate_traffic_directors: zone=%s', zone.name) self.log.debug('_populate_traffic_directors: zone=%s', zone.name)
td_records = set() td_records = set()
for fqdn, types in self.traffic_directors.items(): for fqdn, types in self.traffic_directors.items():
@ -444,7 +444,7 @@ class DynProvider(BaseProvider):
name = zone.hostname_from_fqdn(fqdn) name = zone.hostname_from_fqdn(fqdn)
record = Record.new(zone, name, data, source=self) record = Record.new(zone, name, data, source=self)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
td_records.add(record) td_records.add(record)
return td_records return td_records
@ -460,7 +460,7 @@ class DynProvider(BaseProvider):
td_records = set() td_records = set()
if self.traffic_directors_enabled: if self.traffic_directors_enabled:
td_records = self._populate_traffic_directors(zone)
td_records = self._populate_traffic_directors(zone, lenient)
exists = True exists = True
dyn_zone = _CachingDynZone.get(zone.name[:-1]) dyn_zone = _CachingDynZone.get(zone.name[:-1])
@ -483,7 +483,7 @@ class DynProvider(BaseProvider):
record = Record.new(zone, name, data, source=self, record = Record.new(zone, name, data, source=self,
lenient=lenient) lenient=lenient)
if record not in td_records: if record not in td_records:
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/googlecloud.py View File

@ -230,7 +230,7 @@ class GoogleCloudProvider(BaseProvider):
self.log.debug('populate: adding record {} records: {!s}' self.log.debug('populate: adding record {} records: {!s}'
.format(record_name, data)) .format(record_name, data))
record = Record.new(zone, record_name, data, source=self) record = Record.new(zone, record_name, data, source=self)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/ns1.py View File

@ -211,7 +211,7 @@ class Ns1Provider(BaseProvider):
record = Record.new(zone, name, data_for(_type, record), record = Record.new(zone, name, data_for(_type, record),
source=self, lenient=lenient) source=self, lenient=lenient)
zone_hash[(_type, name)] = record zone_hash[(_type, name)] = record
[zone.add_record(r) for r in zone_hash.values()]
[zone.add_record(r, lenient=lenient) for r in zone_hash.values()]
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)
return exists return exists


+ 1
- 1
octodns/provider/ovh.py View File

@ -82,7 +82,7 @@ class OvhProvider(BaseProvider):
data_for = getattr(self, '_data_for_{}'.format(_type)) data_for = getattr(self, '_data_for_{}'.format(_type))
record = Record.new(zone, name, data_for(_type, records), record = Record.new(zone, name, data_for(_type, records),
source=self, lenient=lenient) source=self, lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/powerdns.py View File

@ -199,7 +199,7 @@ class PowerDnsBaseProvider(BaseProvider):
record_name = zone.hostname_from_fqdn(rrset['name']) record_name = zone.hostname_from_fqdn(rrset['name'])
record = Record.new(zone, record_name, data_for(rrset), record = Record.new(zone, record_name, data_for(rrset),
source=self, lenient=lenient) source=self, lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/rackspace.py View File

@ -215,7 +215,7 @@ class RackspaceProvider(BaseProvider):
record = Record.new(zone, record_name, record = Record.new(zone, record_name,
data_for(record_set), data_for(record_set),
source=self) source=self)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=True', self.log.info('populate: found %s records, exists=True',
len(zone.records) - before) len(zone.records) - before)


+ 1
- 1
octodns/provider/route53.py View File

@ -489,7 +489,7 @@ class Route53Provider(BaseProvider):
data = data[0] data = data[0]
record = Record.new(zone, name, data, source=self, record = Record.new(zone, name, data, source=self,
lenient=lenient) lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=%s', self.log.info('populate: found %s records, exists=%s',
len(zone.records) - before, exists) len(zone.records) - before, exists)


+ 1
- 1
octodns/provider/yaml.py View File

@ -67,7 +67,7 @@ class YamlProvider(BaseProvider):
d['ttl'] = self.default_ttl d['ttl'] = self.default_ttl
record = Record.new(zone, name, d, source=self, record = Record.new(zone, name, d, source=self,
lenient=lenient) lenient=lenient)
zone.add_record(record)
zone.add_record(record, lenient=lenient)
self.log.info('populate: found %s records, exists=False', self.log.info('populate: found %s records, exists=False',
len(zone.records) - before) len(zone.records) - before)


+ 2
- 2
octodns/source/tinydns.py View File

@ -134,7 +134,7 @@ class TinyDnsBaseSource(BaseSource):
record = Record.new(zone, name, data, source=self, record = Record.new(zone, name, data, source=self,
lenient=lenient) lenient=lenient)
try: try:
zone.add_record(record)
zone.add_record(record, lenient=lenient)
except SubzoneRecordException: except SubzoneRecordException:
self.log.debug('_populate_normal: skipping subzone ' self.log.debug('_populate_normal: skipping subzone '
'record=%s', record) 'record=%s', record)
@ -175,7 +175,7 @@ class TinyDnsBaseSource(BaseSource):
'value': value 'value': value
}, source=self, lenient=lenient) }, source=self, lenient=lenient)
try: try:
zone.add_record(record)
zone.add_record(record, lenient=lenient)
except DuplicateRecordException: except DuplicateRecordException:
self.log.warn('Duplicate PTR record for {}, ' self.log.warn('Duplicate PTR record for {}, '
'skipping'.format(addr)) 'skipping'.format(addr))


Write Preview
Loading…
Cancel
Save