[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] [ascension] 29/45: added warnings to logging if records fai
|
From: |
gnunet |
|
Subject: |
[GNUnet-SVN] [ascension] 29/45: added warnings to logging if records failed to be added |
|
Date: |
Fri, 25 Jan 2019 10:02:29 +0100 |
This is an automated email from the git hooks/post-receive script.
rexxnor pushed a commit to branch master
in repository ascension.
commit 8d952a71d8e466f39e541df97be90186f77a2704
Author: rexxnor <address@hidden>
AuthorDate: Thu Oct 25 15:36:11 2018 +0200
added warnings to logging if records failed to be added
---
gnsmigrator/gnsmigrator.py | 148 ++++++++++++++++++++++++++-------------------
1 file changed, 86 insertions(+), 62 deletions(-)
diff --git a/gnsmigrator/gnsmigrator.py b/gnsmigrator/gnsmigrator.py
index 450f87d..d8bd7e7 100644
--- a/gnsmigrator/gnsmigrator.py
+++ b/gnsmigrator/gnsmigrator.py
@@ -25,6 +25,7 @@ from ctypes import c_uint64
from ctypes import c_void_p
from enum import Enum
from dataclasses import dataclass
+import logging
import queue
import re
import sys
@@ -34,7 +35,6 @@ import dns.query
import dns.resolver
import dns.zone
import docopt
-import logging
# GLOBALS
GNUNET_ZONE_CREATION_COMMAND = 'gnunet-identity'
@@ -115,12 +115,12 @@ class GNSMigrator():
pkey_line.stdout.close()
# Create identity in GNUnet
try:
- ret = sp.run([GNUNET_ZONE_CREATION_COMMAND,
- '-C', domainpart],
- stdout=sp.DEVNULL,
- stderr=sp.DEVNULL)
+ sp.run([GNUNET_ZONE_CREATION_COMMAND,
+ '-C', domainpart],
+ stdout=sp.DEVNULL,
+ stderr=sp.DEVNULL)
except sp.CalledProcessError:
- logging.info("Zone %s already exists!" % domainpart)
+ logging.info("Zone %s already exists!", domainpart)
pkey_lookup = sp.Popen([GNUNET_ZONE_CREATION_COMMAND,
'-d'],
stdout=sp.PIPE)
@@ -142,12 +142,17 @@ class GNSMigrator():
reverse_parsing[counter - 1])])
if "No results." in result.decode():
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', reverse_parsing[counter - 1],
- '-a', '-n', domainpart,
- '-t', 'PKEY',
- '-V', pkey_zone,
- '-e', 'never'])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', reverse_parsing[counter - 1],
+ '-a', '-n', domainpart,
+ '-t', 'PKEY',
+ '-V', pkey_zone,
+ '-e', 'never'])
+ if ret.returncode != 0:
+ logging.warning("failed to add record %s", domainpart)
+ logging.warning("failed to add %s record %s",
+ "PKEY", domainpart)
+
counter += 1
@staticmethod
@@ -158,12 +163,15 @@ class GNSMigrator():
if not GNSMigrator.check_if_record_exists_in_zone(record, zonename):
dnsname, ttl, rdata = record
rtype_str = str(dns.rdatatype.to_text(rdata.rdtype))
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', str(dnsname),
- '-t', rtype_str,
- '-V', str(rdata),
- '-e', '%ds' % ttl])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', str(dnsname),
+ '-t', rtype_str,
+ '-V', str(rdata),
+ '-e', '%ds' % ttl])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s",
+ rtype_str, str(dnsname))
@staticmethod
def add_srv_record_to_gns(record, zonename):
@@ -182,12 +190,15 @@ class GNSMigrator():
'-V', str(value),
'-e', '%ds' % ttl])
print(debug)
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', dnsname_str,
- '-t', rtype_str,
- '-V', str(value),
- '-e', '%ds' % ttl])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', dnsname_str,
+ '-t', rtype_str,
+ '-V', str(value),
+ '-e', '%ds' % ttl])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s",
+ rtype_str, dnsname_str)
@staticmethod
def add_a_aaaa_record_to_gns(record, zonename, domain):
@@ -197,18 +208,24 @@ class GNSMigrator():
if not GNSMigrator.check_if_record_exists_in_zone(record, zonename):
dnsname, ttl, rdata = record
rtype_str = str(dns.rdatatype.to_text(rdata.rdtype))
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', str(dnsname),
- '-t', rtype_str,
- '-V', str(rdata),
- '-e', '%ds' % ttl])
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', str(dnsname),
- '-t', 'LEHO',
- '-V', '%s.%s' % (str(dnsname), domain),
- '-e', '%ds' % ttl])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', str(dnsname),
+ '-t', rtype_str,
+ '-V', str(rdata),
+ '-e', '%ds' % ttl])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s",
+ rtype_str, str(dnsname))
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', str(dnsname),
+ '-t', 'LEHO',
+ '-V', '%s.%s' % (str(dnsname), domain),
+ '-e', '%ds' % ttl])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s",
+ "LEHO", str(dnsname))
@staticmethod
def add_soa_record_to_gns(record, zonename, domain):
@@ -224,16 +241,18 @@ class GNSMigrator():
authns = authns[:-1]
if owner[-1] == '.':
owner = owner[:-1]
- sp.call([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', '@',
- '-t', 'SOA',
- '-V', "rname=%s.%s mname=%s.%s %d,%d,%d,%d,%d"
- % (authns, domain, owner, domain,
- int(serial), int(refresh), int(retry),
- int(expiry), int(irefresh)
- ),
- '-e', '%ds' % ttl])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', '@',
+ '-t', 'SOA',
+ '-V', "rname=%s.%s mname=%s.%s %d,%d,%d,%d,%d"
+ % (authns, domain, owner, domain,
+ int(serial), int(refresh), int(retry),
+ int(expiry), int(irefresh)
+ ),
+ '-e', '%ds' % ttl])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s", "SOA", "@")
@staticmethod
def add_ns_record_to_gns(record, zonename, domain):
@@ -270,13 +289,16 @@ class GNSMigrator():
'-u', '%s.%s' % (str(dnsname), zonename)],
stdout=sp.PIPE)
if 'Got'.encode() not in ret.stdout:
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', str(dnsname),
- '-t', 'GNS2DNS',
- '-V', 'address@hidden' %
- (str(dnsname), domain, dnsresolver),
- '-e', '%ds' % ttl])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', str(dnsname),
+ '-t', 'GNS2DNS',
+ '-V', 'address@hidden' %
+ (str(dnsname), domain, dnsresolver),
+ '-e', '%ds' % ttl])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s",
+ "GNS2DNS", str(dnsname))
@staticmethod
def add_mx_record_to_gns(record, zonename):
@@ -287,12 +309,15 @@ class GNSMigrator():
if not GNSMigrator.check_if_record_exists_in_zone(record, zonename):
rdatalist = str(rdata).split(' ')
value = '%s,%s' % (rdatalist[0], rdatalist[1])
- sp.run([GNUNET_NAMESTORE_COMMAND,
- '-z', zonename,
- '-a', '-n', str(dnsname),
- '-t', dns.rdatatype.to_text(rdata.rdtype),
- '-V', value,
- '-e', '%ds' % int(ttl)])
+ ret = sp.run([GNUNET_NAMESTORE_COMMAND,
+ '-z', zonename,
+ '-a', '-n', str(dnsname),
+ '-t', dns.rdatatype.to_text(rdata.rdtype),
+ '-V', value,
+ '-e', '%ds' % int(ttl)])
+ if ret.returncode != 0:
+ logging.warning("failed to add %s record %s",
+ "GNS2DNS", str(dnsname))
@staticmethod
def check_if_record_exists_in_zone(record, zonename):
@@ -306,7 +331,7 @@ class GNSMigrator():
'-u', '%s.%s' %
(dnsname, zonename)]
)
- if 'Got '.encode() in ret:
+ if 'Got ' in ret.decode():
return True
return False
@@ -484,8 +509,7 @@ class GNSMigrator():
elif rtype_str in ['TXT', 'CNAME']:
GNSMigrator.add_gen_record_to_gns(record, zonename)
else:
- logging.warning("Record type %s is not yet supported",
rtype_str)
-
+ logging.warning("Unsupported record type: %s", rtype_str)
def main():
"""
--
To stop receiving notification emails like this one, please contact
address@hidden
- [GNUnet-SVN] [ascension] 02/45: Added LICENSE, (continued)
- [GNUnet-SVN] [ascension] 02/45: Added LICENSE, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 30/45: updated gnsmigrator and removed c rebuilds, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 08/45: added GNS2DNS support and rudimentary Unittests (incomplete), gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 45/45: renamed files, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 36/45: some experimental fixes, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 34/45: updated gnsmigrator for multiline, added multiline tests, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 35/45: unify all records under label, added SUPPORTED_RECORDS global, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 40/45: improvements, better case separation, more logging, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 39/45: added daemonization, bumped version, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 31/45: added testing for gnunet -K option and more, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 29/45: added warnings to logging if records failed to be added,
gnunet <=
- [GNUnet-SVN] [ascension] 37/45: updated README, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 41/45: added logic for subzones with zone cut, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 32/45: testing and added logging of executed commands to debug, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 38/45: renamed project to ascension, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 18/45: refactored adding of records, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 24/45: fixed zone serialisation, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 33/45: added needed return statement; add glue records first, then NS, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 21/45: fixed serial fetching and added serialization of zone, gnunet, 2019/01/25
- [GNUnet-SVN] [ascension] 42/45: added dnscurve detection and log it, fix ttl bug with hierarchy, gnunet, 2019/01/25