X-Git-Url: http://git.ipfire.org/?p=oddments%2Fddns.git;a=blobdiff_plain;f=src%2Fddns%2Fproviders.py;h=8576c9bccae0838c991478c83b406d079adc56d3;hp=b0b3bf7ddcab65acbcc813db6c4ab833144b9682;hb=4caed6ed57ba0c86e11c81f218b10efc9bf6a301;hpb=2e5ad318df053edd0503755709350b8cccbfb6e3 diff --git a/src/ddns/providers.py b/src/ddns/providers.py index b0b3bf7..8576c9b 100644 --- a/src/ddns/providers.py +++ b/src/ddns/providers.py @@ -19,9 +19,16 @@ # # ############################################################################### +import logging + +from i18n import _ + # Import all possible exception types. from .errors import * +logger = logging.getLogger("ddns.providers") +logger.propagate = 1 + class DDNSProvider(object): INFO = { # A short string that uniquely identifies @@ -104,12 +111,41 @@ class DDNSProvider(object): """ return self.get("password") - def __call__(self): + @property + def protocols(self): + return self.INFO.get("protocols") + + def __call__(self, force=False): + if force: + logger.info(_("Updating %s forced") % self.hostname) + + # Check if we actually need to update this host. + elif self.is_uptodate(self.protocols): + logger.info(_("%s is already up to date") % self.hostname) + return + + # Execute the update. self.update() def update(self): raise NotImplementedError + def is_uptodate(self, protos): + """ + Returns True if this host is already up to date + and does not need to change the IP address on the + name server. + """ + for proto in protos: + addresses = self.core.system.resolve(self.hostname, proto) + + current_address = self.get_address(proto) + + if not current_address in addresses: + return False + + return True + def send_request(self, *args, **kwargs): """ Proxy connection to the send request @@ -159,7 +195,7 @@ class DDNSProviderDHS(DDNSProvider): return # Handle error codes. - elif response.code == "401": + elif response.code == 401: raise DDNSAuthenticationError # If we got here, some other update error happened.