tom/cdist
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

also use path in emulator

Browse source 
Signed-off-by: Nico Schottelius <nico@kr.ethz.ch>
This commit is contained in:
Nico Schottelius 2011-10-07 16:44:53 +02:00
parent 03226dc5aa
commit e8c9b10227
1 changed files with 15 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
lib/cdist/emulator.py
View file

@ -30,9 +30,9 @@ log = logging.getLogger(__name__)
def run(argv): def run(argv):
"""Emulate type commands (i.e. __file and co)""" """Emulate type commands (i.e. __file and co)"""
cdist_type = os.path.basename(argv[0]) cdist_type = os.path.basename(argv[0])
type_path = os.path.join(os.environ['__cdist_type_base_path'], cdist_type) type_path = os.path.join(os.environ['__cdist_type_base_path'], cdist_type)
param_dir = os.path.join(type_path, "parameter") param_path = os.path.join(type_path, "parameter")
global_dir = os.environ['__global'] global_path = os.environ['__global']
object_source = os.environ['__cdist_manifest'] object_source = os.environ['__cdist_manifest']
if '__debug' in os.environ: if '__debug' in os.environ:
@ -42,10 +42,10 @@ def run(argv):
parser = argparse.ArgumentParser(add_help=False) parser = argparse.ArgumentParser(add_help=False)
for parameter in cdist.file_to_list(os.path.join(param_dir, "optional")): for parameter in cdist.file_to_list(os.path.join(param_path, "optional")):
argument = "--" + parameter argument = "--" + parameter
parser.add_argument(argument, action='store', required=False) parser.add_argument(argument, action='store', required=False)
for parameter in cdist.file_to_list(os.path.join(param_dir, "required")): for parameter in cdist.file_to_list(os.path.join(param_path, "required")):
argument = "--" + parameter argument = "--" + parameter
parser.add_argument(argument, action='store', required=True) parser.add_argument(argument, action='store', required=True)
@ -74,15 +74,15 @@ def run(argv):
# FIXME: verify object id # FIXME: verify object id
log.debug(args) log.debug(args)
object_dir = os.path.join(global_dir, "object", cdist_type, object_path = os.path.join(global_path, "object", cdist_type,
object_id, cdist.DOT_CDIST) object_id, cdist.DOT_CDIST)
log.debug("Object output dir = " + object_dir) log.debug("Object output dir = " + object_path)
param_out_dir = os.path.join(object_dir, "parameter") param_out_dir = os.path.join(object_path, "parameter")
object_source_file = os.path.join(object_dir, "source") object_source_file = os.path.join(object_path, "source")
if os.path.exists(param_out_dir): if os.path.exists(object_path):
object_exists = True object_exists = True
old_object_source_fd = open(object_source_file, "r") old_object_source_fd = open(object_source_file, "r")
old_object_source = old_object_source_fd.readlines() old_object_source = old_object_source_fd.readlines()
@ -91,7 +91,9 @@ def run(argv):
else: else:
object_exists = False object_exists = False
try: try:
os.makedirs(param_out_dir, exist_ok=True) os.makedirs(object_path, exist_ok=False)
log.debug("Object param dir = " + param_out_dir)
os.makedirs(param_out_dir, exist_ok=False)
except OSError as error: except OSError as error:
raise cdist.Error(param_out_dir + ": " + error.args[1]) raise cdist.Error(param_out_dir + ": " + error.args[1])
@ -131,12 +133,12 @@ def run(argv):
if "require" in os.environ: if "require" in os.environ:
requirements = os.environ['__require'] requirements = os.environ['__require']
log.debug(object_id + ":Writing requirements: " + requirements) log.debug(object_id + ":Writing requirements: " + requirements)
require_fd = open(os.path.join(object_dir, "require"), "a") require_fd = open(os.path.join(object_path, "require"), "a")
require_fd.write(requirements.replace(" ","\n")) require_fd.write(requirements.replace(" ","\n"))
require_fd.close() require_fd.close()
# Record / Append source # Record / Append source
source_fd = open(os.path.join(object_dir, "source"), "a") source_fd = open(os.path.join(object_path, "source"), "a")
source_fd.writelines(object_source) source_fd.writelines(object_source)
source_fd.close() source_fd.close()