Add gandi dns api and first test.

plugins/dns_api/__init__.py

@@ -1,5 +1,7 @@
 import logging
 from .main import ItemProvider
 from .views import Handler
+from .providers.gandi import *
+
 
 logging.info('dns_api.__init__.py: dns_api loaded')

plugins/dns_api/providers/gandi.py

@@ -0,0 +1,40 @@
+import requests
+import json
+
+from jadi import component
+from aj.plugins.dns_api.api import ApiDnsManager
+from aj.plugins.dns_api.record import Record
+import aj
+
+@component(ApiDnsManager)
+class GandiApiDnsProvider(ApiDnsManager):
+    id = 'gandi'
+    name = 'Gandi DNS API'
+
+    def __init__(self, context):
+        apikey = aj.config.data.get('dns_apikey', '') # TODO : wrong config entry for this
+        self.baseUrl = 'https://api.gandi.net/v5/livedns/domains'
+        self.headers = {"Authorization": f"Apikey {apikey}"}
+
+    def _req(self, method, apiurl="", data=None):
+        if method not in ["get", "put", "post", "delete"]:
+            return
+
+        func = getattr(requests, method)
+        if data is None:
+            resp = func(f"{self.baseUrl}{apiurl}", headers=self.headers)
+        else:
+            resp = func(f"{self.baseUrl}{apiurl}", data=data, headers=self.headers)
+
+        return resp
+
+    def get_domains(self):
+        domains = json.loads(self._req("get").content)
+        return [domain['fqdn'] for domain in domains]
+
+    def get_records(self, domain):
+        resp = self._req('get', apiurl=f"/{domain.fqdn}/records")
+        records = json.loads(resp.content)
+
+        for record in sorted(records, key=lambda d: d['rrset_name']):
+            domain.records.append(Record(domain.fqdn, record))

plugins/dns_api/resources/js/controllers/index.controller.es

@@ -1,5 +1,7 @@
 angular.module('ajenti.dns_api').controller('DnsAPIIndexController', function($scope, $http, pageTitle, gettext, notify) {
     pageTitle.set(gettext('DNS API'));
 
+    $http.get('/api/dns_api');
+
 });
 

plugins/dns_api/views.py

@@ -3,13 +3,17 @@
 from aj.api.http import get, HttpPlugin
 from aj.auth import authorize
 from aj.api.endpoint import endpoint, EndpointError
+from aj.plugins.dns_api.manager import DomainManager
 
 @component(HttpPlugin)
 class Handler(HttpPlugin):
     def __init__(self, context):
         self.context = context
+        self.mgr = DomainManager(self.context)
+
 
     @get(r'/api/dns_api')
     @endpoint(api=True)
     def handle_api_example_dns_api(self, http_context):
-        pass
+        self.mgr.load()
+        print(self.mgr.domains)