feat: layers information is send to output
This commit is contained in:
parent
67876d77a4
commit
5548144d2d
1 changed files with 26 additions and 18 deletions
|
|
@ -62,8 +62,8 @@ def _main(arguments, do_not_print):
|
||||||
for version in versions:
|
for version in versions:
|
||||||
print(version)
|
print(version)
|
||||||
exit()
|
exit()
|
||||||
metaconfig, config, err_warn = load_user_datas(rougailconfig)
|
layer_datas, metaconfig, config, err_warn = load_user_datas(rougailconfig)
|
||||||
output = get_output(rougailconfig, metaconfig, config, err_warn)
|
output = get_output(rougailconfig, metaconfig, config, err_warn, layer_datas)
|
||||||
if do_not_print:
|
if do_not_print:
|
||||||
return output.run()
|
return output.run()
|
||||||
ret = output.print()
|
ret = output.print()
|
||||||
|
|
@ -158,6 +158,7 @@ def manage_warnings(warnings):
|
||||||
|
|
||||||
|
|
||||||
def load_user_datas(rougailconfig):
|
def load_user_datas(rougailconfig):
|
||||||
|
layer_datas = {}
|
||||||
if not rougailconfig["cli.load_config"]:
|
if not rougailconfig["cli.load_config"]:
|
||||||
return None, {"errors": [], "warnings": []}
|
return None, {"errors": [], "warnings": []}
|
||||||
try:
|
try:
|
||||||
|
|
@ -188,9 +189,13 @@ def load_user_datas(rougailconfig):
|
||||||
for idx, layer in enumerate(layers):
|
for idx, layer in enumerate(layers):
|
||||||
if idx:
|
if idx:
|
||||||
subconfig = subconfig.config("_".join(layer))
|
subconfig = subconfig.config("_".join(layer))
|
||||||
|
layer_name = subconfig.path()
|
||||||
subconfig.owner.set(subconfig.path())
|
subconfig.owner.set(subconfig.path())
|
||||||
|
else:
|
||||||
|
layer_name = None
|
||||||
# data user
|
# data user
|
||||||
user_datas = []
|
user_datas = []
|
||||||
|
layer_datas[layer_name] = {}
|
||||||
for user_data_name in layer:
|
for user_data_name in layer:
|
||||||
path = (
|
path = (
|
||||||
Path(__file__).parent.parent
|
Path(__file__).parent.parent
|
||||||
|
|
@ -204,34 +209,36 @@ def load_user_datas(rougailconfig):
|
||||||
module = load_modules("rougail.user_data_" + user_data_name, str(path))
|
module = load_modules("rougail.user_data_" + user_data_name, str(path))
|
||||||
rougail_user_datas = module.RougailUserData
|
rougail_user_datas = module.RougailUserData
|
||||||
if hasattr(rougail_user_datas, 'interactive_user_datas') and rougail_user_datas.interactive_user_datas:
|
if hasattr(rougail_user_datas, 'interactive_user_datas') and rougail_user_datas.interactive_user_datas:
|
||||||
interactive_user_datas[user_data_name] = rougail_user_datas
|
interactive_user_datas.setdefault(layer_name, {})[user_data_name] = rougail_user_datas
|
||||||
continue
|
continue
|
||||||
elif interactive_user_datas:
|
elif interactive_user_datas:
|
||||||
raise Exception(_(f'interactive user datas "{0}" is loader before uninteractive user datas "{1}"').format(list(interactive_user_datas), user_data_name))
|
raise Exception(_(f'interactive user datas "{0}" is loader before uninteractive user datas "{1}"').format(list(interactive_user_datas), user_data_name))
|
||||||
user_datas.extend(
|
for user_data in rougail_user_datas(
|
||||||
rougail_user_datas(
|
|
||||||
subconfig,
|
subconfig,
|
||||||
rougailconfig=rougailconfig,
|
rougailconfig=rougailconfig,
|
||||||
).run()
|
).run():
|
||||||
)
|
layer_datas[layer_name].setdefault(user_data_name, []).append(user_data["source"])
|
||||||
|
user_datas.append(user_data)
|
||||||
if user_datas:
|
if user_datas:
|
||||||
new_err_warn = UserDatas(subconfig).user_datas(user_datas, invalid_user_datas_error=invalid_user_datas_error, unknown_user_datas_error=unknown_user_datas_error)
|
new_err_warn = UserDatas(subconfig).user_datas(user_datas, invalid_user_datas_error=invalid_user_datas_error, unknown_user_datas_error=unknown_user_datas_error)
|
||||||
for level, datas in new_err_warn.items():
|
for level, datas in new_err_warn.items():
|
||||||
if datas:
|
if datas:
|
||||||
err_warn[level].updates(datas)
|
err_warn[level].extend(datas)
|
||||||
for layer, rougail_user_datas in interactive_user_datas.items():
|
for layer_name, interactive_user_data in interactive_user_datas.items():
|
||||||
if has_layers and len(layers) > 1:
|
for layer, rougail_user_datas in interactive_user_data.items():
|
||||||
subconfig = subconfig.config("_".join(layer))
|
if has_layers and len(layers) > 1:
|
||||||
subconfig.owner.set(subconfig.path())
|
subconfig = subconfig.config("_".join(layer))
|
||||||
rougail_user_datas(
|
subconfig.owner.set(subconfig.path())
|
||||||
subconfig,
|
for user_data in rougail_user_datas(
|
||||||
rougailconfig=rougailconfig,
|
subconfig,
|
||||||
).run()
|
rougailconfig=rougailconfig,
|
||||||
|
).run():
|
||||||
|
layer_datas[layer_name].setdefault(user_data_name, []).append(user_data["source"])
|
||||||
|
|
||||||
return metaconfig, subconfig, err_warn
|
return layer_datas, metaconfig, subconfig, err_warn
|
||||||
|
|
||||||
|
|
||||||
def get_output(rougailconfig, metaconfig, config, err_warn):
|
def get_output(rougailconfig, metaconfig, config, err_warn, layer_datas):
|
||||||
# output
|
# output
|
||||||
if config and (not rougailconfig["cli.load_config"] or not rougailconfig["cli.read_write"]):
|
if config and (not rougailconfig["cli.load_config"] or not rougailconfig["cli.read_write"]):
|
||||||
config.property.read_only()
|
config.property.read_only()
|
||||||
|
|
@ -249,6 +256,7 @@ def get_output(rougailconfig, metaconfig, config, err_warn):
|
||||||
user_data_warnings=err_warn["warnings"],
|
user_data_warnings=err_warn["warnings"],
|
||||||
config_owner_is_path=True,
|
config_owner_is_path=True,
|
||||||
metaconfig=metaconfig,
|
metaconfig=metaconfig,
|
||||||
|
layer_datas=layer_datas,
|
||||||
)
|
)
|
||||||
return output
|
return output
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue