Backend to update dns record.

ajenti · Apr 29, 2023 · 9fe8db0 · 9fe8db0
1 parent e9eef4e
commit 9fe8db0
Show file tree

Hide file tree

Showing 3 changed files with 23 additions and 0 deletions.
diff --git a/plugins/dns_api/api.py b/plugins/dns_api/api.py
@@ -19,5 +19,8 @@ def get_records(self, domain):
     def add_record(self, fqdn, record):
         raise NotImplementedError
 
+    def update_record(self, fqdn, record):
+        raise NotImplementedError
+
     def delete_record(self, fqdn, name):
         raise NotImplementedError
diff --git a/plugins/dns_api/manager.py b/plugins/dns_api/manager.py
@@ -14,6 +14,9 @@ def get_records(self):
     def add_record(self, record):
         return self.api.add_record(self.fqdn, record)
 
+    def update_record(self, record):
+        return self.api.update_record(self.fqdn, record)
+
     def delete_record(self, name):
         return self.api.delete_record(self.fqdn, name)
 

diff --git a/plugins/dns_api/providers/gandi.py b/plugins/dns_api/providers/gandi.py
@@ -63,6 +63,23 @@ def add_record(self, fqdn, record):
         except Exception as e:
             logging.error(e)
 
+    def update_record(self, fqdn, record):
+        try:
+            data = json.dumps({'items': [{
+                'rrset_name': record.name,
+                'rrset_type': record.type,
+                'rrset_values': record.values,
+                'rrset_ttl': record.ttl
+            }]})
+            resp = self._req('put', apiurl=f"/{fqdn}/records/{record.name}", data=data)
+            messages = json.loads(resp.content)
+            if messages.get('status', '') == 'error':
+                return resp.status_code, messages['errors']
+            else:
+                return resp.status_code, messages['message']
+        except Exception as e:
+            logging.error(e)
+
     def delete_record(self, fqdn, name):
         try:
             resp = self._req('delete', apiurl=f"/{fqdn}/records/{name}")