Handle integrity errors in DNS aggregator

2019-12-19 10:45:06 -05:00 · 2019-12-19 10:45:06 -05:00 · 0841ddf8b0
parent 98764f1edd
commit 0841ddf8b0
1 changed files with 9 additions and 5 deletions
--- a/node-daemon/pvcd/DNSAggregatorInstance.py
+++ b/node-daemon/pvcd/DNSAggregatorInstance.py
@ -484,11 +484,15 @@ class AXFRDaemonInstance(object):
                            r_data = record[4]
                            if self.config['debug']:
                                print('Add record: {}'.format(name))
+                            try:
                                sql_curs.execute(
                                    "INSERT INTO records (domain_id, name, ttl, type, prio, content) VALUES (%s, %s, %s, %s, %s, %s)",
                                    (domain_id, r_name, r_ttl, r_type, 0, r_data)
                                )
                                changed = True
+                            except psycopg2.IntegrityError as e:
+                                if self.config['debug']:
+                                    print('Failed to add record due to {}: {}'.format(e, name))

                    if changed:
                        # Increase SOA serial