Bopytex/bopytex/service.py

101 lines
2.1 KiB
Python
Raw Permalink Normal View History

2013-09-27 18:09:38 +00:00
#!/usr/bin/env python
# encoding: utf-8
2017-04-16 08:36:27 +00:00
"""
Producing then compiling templates
"""
2022-05-05 12:35:01 +00:00
import importlib.util
2022-07-19 13:15:06 +00:00
import os
2022-05-05 12:35:01 +00:00
from pathlib import Path
2022-07-28 07:39:51 +00:00
2022-05-05 12:35:01 +00:00
from bopytex import default_config
2022-07-28 07:39:51 +00:00
from bopytex.scheduler import Scheduler
2022-04-10 04:45:10 +00:00
def orcherstrator(
options: dict,
planner,
dispatcher,
):
2022-04-10 04:45:10 +00:00
tasks = planner(options)
2022-04-09 14:18:56 +00:00
scheduler = Scheduler(dispatcher, [options["template"]])
2022-04-09 14:18:56 +00:00
scheduler.append(tasks)
for message in scheduler.backlog():
yield message
2014-01-19 20:37:46 +00:00
2022-05-05 12:35:01 +00:00
def load_module(modulefile: str):
spec = importlib.util.spec_from_file_location("module.name", modulefile)
module = importlib.util.module_from_spec(spec)
spec.loader.exec_module(module)
return module
def clean_vars_keys(
vars: dict,
keys: list[str] = [
"__name__",
"__doc__",
"__package__",
"__loader__",
"__spec__",
"__file__",
"__cached__",
"__builtins__",
],
) -> dict:
new_dict = vars.copy()
for k in keys:
del new_dict[k]
return new_dict
2022-07-19 13:15:06 +00:00
def config_from_file(filename: str) -> dict:
if Path(filename).exists():
local_config = vars(load_module(filename))
return clean_vars_keys(local_config)
else:
return {}
def build_config(options: dict) -> dict:
"""Look for options["configfile"] to load it with default_config and options"""
config = clean_vars_keys(vars(default_config))
2022-07-19 13:15:06 +00:00
configfile = ""
2022-05-05 12:35:01 +00:00
try:
2022-07-19 13:15:06 +00:00
configfile = options["configfile"]
2022-05-05 12:35:01 +00:00
except KeyError:
2022-07-19 13:15:06 +00:00
pass
try:
configfile = os.environ["BOPYTEXCONFIG"]
except KeyError:
pass
if configfile:
local_config = config_from_file(configfile)
config.update(local_config)
2022-07-19 13:15:06 +00:00
2022-05-05 12:35:01 +00:00
config.update(options)
2022-05-05 12:35:01 +00:00
return config
def main(**options):
2022-07-19 13:15:06 +00:00
config = build_config(options)
orcherstre = orcherstrator(
2022-05-05 12:35:01 +00:00
config, planner=default_config.planner, dispatcher=default_config.dispatcher
)
for message in orcherstre:
yield message
2017-04-16 08:36:27 +00:00
2022-05-05 12:35:01 +00:00
2013-09-27 18:09:38 +00:00
# -----------------------------
# Reglages pour 'vim'
# vim:set autoindent expandtab tabstop=4 shiftwidth=4:
2017-04-16 08:36:27 +00:00
# cursor: 16 del