X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=conf_files.py;h=7fb28cb95a7d77e14ae540a8847bc1bbad5a1941;hb=54c53b53e5deefc2525888212dbed5bb0f8b0a3b;hp=fcc3b7df4672ee653d6fd52bbae7f064faca150c;hpb=1b4f53e648b13f7629970787b6ec03387e2d966a;p=nodemanager.git diff --git a/conf_files.py b/conf_files.py old mode 100644 new mode 100755 index fcc3b7d..7fb28cb --- a/conf_files.py +++ b/conf_files.py @@ -1,3 +1,5 @@ +#!/usr/bin/env python3 + """configuration files""" import grp @@ -7,12 +9,11 @@ try: from hashlib import sha1 as sha except ImportError: from sha import sha -import string import curlwrapper import logger import tools -import xmlrpclib +import xmlrpc.client from config import Config # right after net @@ -41,16 +42,16 @@ class conf_files: if not cf_rec['enabled']: return dest = cf_rec['dest'] err_cmd = cf_rec['error_cmd'] - mode = string.atoi(cf_rec['file_permissions'], base=8) + mode = int(cf_rec['file_permissions'], base=8) try: uid = pwd.getpwnam(cf_rec['file_owner'])[2] except: - logger.log('conf_files: cannot find user %s -- %s not updated'%(cf_rec['file_owner'],dest)) + logger.log('conf_files: cannot find user %s -- %s not updated'%(cf_rec['file_owner'], dest)) return try: gid = grp.getgrnam(cf_rec['file_group'])[2] except: - logger.log('conf_files: cannot find group %s -- %s not updated'%(cf_rec['file_group'],dest)) + logger.log('conf_files: cannot find group %s -- %s not updated'%(cf_rec['file_group'], dest)) return url = 'https://%s/%s' % (self.config.PLC_BOOT_HOST, cf_rec['source']) # set node_id at the end of the request - hacky @@ -63,7 +64,7 @@ class conf_files: try: logger.verbose("conf_files: retrieving URL=%s"%url) contents = curlwrapper.retrieve(url, self.config.cacert) - except xmlrpclib.ProtocolError,e: + except xmlrpc.client.ProtocolError as e: logger.log('conf_files: failed to retrieve %s from %s, skipping' % (dest, url)) return if not cf_rec['always_update'] and sha(contents).digest() == self.checksum(dest): @@ -74,16 +75,16 @@ class conf_files: logger.log('conf_files: installing file %s from %s' % (dest, url)) try: os.makedirs(os.path.dirname(dest)) except OSError: pass - tools.write_file(dest, lambda f: f.write(contents), mode=mode, uidgid=(uid,gid)) + tools.write_file(dest, lambda f: f.write(contents), mode=mode, uidgid=(uid, gid)) if self.system(cf_rec['postinstall_cmd']): self.system(err_cmd) def run_once(self, data): - if data.has_key("conf_files"): + if "conf_files" in data: for f in data['conf_files']: try: self.update_conf_file(f) except: logger.log_exc("conf_files: failed to update conf_file") else: - logger.log_missing_data("conf_files.run_once",'conf_files') + logger.log_missing_data("conf_files.run_once", 'conf_files') def start(): pass