forge/ovh-dns-updater
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

can require IP version(s)

Browse source
This commit is contained in:
pj 2021-02-28 11:17:54 +01:00
parent b012a6b7dd
commit dab404ecb6
1 changed files with 64 additions and 54 deletions
Download patch file Download diff file Expand all files Collapse all files

118
ovh-dns-updater.py
View file

@ -24,11 +24,16 @@ can be provided in variety of ways:
-or in a ovh.conf file -or in a ovh.conf file
in which cases we can call with no argument (the ovh module gets the credentials on its own): in which cases we can call with no argument (the ovh module gets the credentials on its own):
''' '''
client = ovh.Client() client = ovh.Client()
# Should missing IP address being considered as error (Depend on the ISP, internet box settings...)?
# In case a required IP cannot be obtained, the script will send an email and stop without updating anything.
# If, for any reason, IPv4 or IPv6 address cannot be obtained and if it is not protected by this list, the corresponding records will be deleted for all hosts.
ip_versions_required = [4] # MUST not be empty. Can be [4],[6] or [4,6]
default_ttl = 600 # seconds default_ttl = 600 # seconds
# ttl = how long will a DNS server cache the value before checking it at the Registrar. Longer value yields faster name resolution most of the time, but less frequent updates # ttl = how long will a DNS server cache the value before checking it at the Registrar. Longer value yields faster name resolution most of the time, but less frequent updates
records_changed = 0
# list of hosts (=subdomain.domain.tld) to update, each a dictionnary with at least "domain" and "subdomain" defined # list of hosts (=subdomain.domain.tld) to update, each a dictionnary with at least "domain" and "subdomain" defined
hosts = [ hosts = [
{ {
@ -56,7 +61,7 @@ def send_email(msg, sender = 'no_reply@mydomain.com', receiver = 'admin@mydomain
try : try :
smtpObj = smtplib.SMTP('localhost') smtpObj = smtplib.SMTP('localhost')
smtpObj.sendmail(sender, receiver, smtpObj.sendmail(sender, receiver,
"From: {}\nTo: {}\nSubject: DNS Update problem\n\n{}\n".format(sender, receiver, msg) "From: {}\nTo: {}\nSubject: DNS update problem\n\nThe ovh-dns-updater.py script reports:\n{}\n".format(sender, receiver, msg)
) )
except smtplib.SMTPException: except smtplib.SMTPException:
print( timestamp()," : Error unable to send email") print( timestamp()," : Error unable to send email")
@ -67,8 +72,22 @@ def get_current_ip(v = 4):
r = requests.get(url, timeout=5.0) r = requests.get(url, timeout=5.0)
except requests.exceptions.RequestException as e: except requests.exceptions.RequestException as e:
#print("failed getting ipv{} address because {} occurred".format(v, str(e))) #print("failed getting ipv{} address because {} occurred".format(v, str(e)))
if v in ip_versions_required :
message = "{} : Cannot get required IPv{} because {} occurred. Failing".format(timestamp(), v, e)
print(message)
send_email (message)
quit()
else :
return False
if r.status_code == requests.codes.ok
return r.text
elif v in ip_versions_required :
message = "{} : Cannot get required IPv{} : requests.get returned status_code {}. Failing".format(timestamp(), v, r.status_code)
print(message)
send_email (message)
quit()
else :
return False return False
return r.text if r.status_code == requests.codes.ok else False
def timestamp() : def timestamp() :
return time.asctime( time.localtime(time.time()) ) return time.asctime( time.localtime(time.time()) )
@ -145,62 +164,53 @@ def delete_record(domain, subdomain, typ):
records_changed += 1 records_changed += 1
#reload saved values
try:
with open(current_ip_file, 'r') as f:
old_time, old_ipv4, old_ipv6 = json.load(f)
except IOError:
#print("No old ips recorded")
pass
current_ipv4 = get_current_ip(4) current_ipv4 = get_current_ip(4)
current_ipv6 = get_current_ip(6) current_ipv6 = get_current_ip(6)
#print('current ips: {} ; {}'.format(current_ipv4, current_ipv6)) #print('current ips: {} ; {}'.format(current_ipv4, current_ipv6))
if current_ipv4 or current_ipv6 : #we could get at least one address #reload saved values & compare
try : try:
with open(current_ip_file, 'r') as f:
old_time, old_ipv4, old_ipv6 = json.load(f)
need_update = (old_ipv4 != current_ipv4) or (old_ipv6 != current_ipv6) or ((old_time - time.time()) > 3600.0 * checkDNS_interval_hrs) need_update = (old_ipv4 != current_ipv4) or (old_ipv6 != current_ipv6) or ((old_time - time.time()) > 3600.0 * checkDNS_interval_hrs)
except : #old values do not exist, we must check the records except IOError:
#print("No old ips recorded")
need_update = True need_update = True
if need_update : if need_update :
try : records_changed = 0
for host in hosts : try :
domain = host["domain"] for host in hosts :
subdomain = host ["subdomain"] domain = host["domain"]
if ('ipv4' not in host) or (host['ipv4'] != False) : subdomain = host ["subdomain"]
if current_ipv4 : if ('ipv4' not in host) or (host['ipv4'] != False) :
ttl = default_ttl if ('ttl' not in host) else host['ttl'] if current_ipv4 :
update_record(domain, subdomain, current_ipv4, _ttl = ttl) ttl = default_ttl if ('ttl' not in host) else host['ttl']
else : update_record(domain, subdomain, current_ipv4, _ttl = ttl)
delete_record(domain, subdomain, 'A') else :
else : delete_record(domain, subdomain, 'A')
#print("Not touching A record for {}.{}, as instructed".format(subdomain, domain)) else :
pass #print("Not touching A record for {}.{}, as instructed".format(subdomain, domain))
if ('ipv6' not in host) or (host['ipv6'] != False) : pass
if current_ipv6 : if ('ipv6' not in host) or (host['ipv6'] != False) :
ttl = default_ttl if ('ttl' not in host) else host['ttl'] if current_ipv6 :
update_record(domain, subdomain, current_ipv6, _ttl = ttl) ttl = default_ttl if ('ttl' not in host) else host['ttl']
else : update_record(domain, subdomain, current_ipv6, _ttl = ttl)
delete_record(domain, subdomain, 'AAAA') else :
else : delete_record(domain, subdomain, 'AAAA')
#print("Not touching AAAA record for {}.{}, as instructed".format(subdomain, domain)) else :
pass #print("Not touching AAAA record for {}.{}, as instructed".format(subdomain, domain))
#all hosts records have been updated without errors, log change and save current addresses pass
print("{} : new addresses {} ; {} -- {} records updates".format(timestamp(), current_ipv4, current_ipv6, records_changed)) #all hosts records have been updated without errors, log change and save current addresses
with open(current_ip_file, 'w') as f: print("{} : new addresses {} ; {} -- {} records updates".format(timestamp(), current_ipv4, current_ipv6, records_changed))
json.dump([time.time(), current_ipv4, current_ipv6],f) with open(current_ip_file, 'w') as f:
except Exception as e: #some error occured (API down, keys expired...?), json.dump([time.time(), current_ipv4, current_ipv6],f)
msg = "{} : ### error {} while updating records!! {} records updated with new addresses {} ; {}".format(timestamp(), str(e), records_changed, current_ipv4, current_ipv6) except Exception as e: #some error occured (API down, keys expired...?),
print(msg) msg = "{} : ### error {} while updating records!! {} records updated with new addresses {} ; {}".format(timestamp(), str(e), records_changed, current_ipv4, current_ipv6)
send_email(msg) print(msg)
# not saving new addresses, so that update is attempted again. send_email(msg)
else : # not saving new addresses, so that update is attempted again.
#print("nothing to do!")
pass
else : else :
msg = "{} : cannot get IPs. Network down? ipify.org down?".format(timestamp()) #print("nothing to do!")
print(msg) pass
send_email(msg)