2018-12-23 11:05:38 +01:00
|
|
|
from typing import Any, Callable, Dict, List
|
2015-02-18 01:45:39 +01:00
|
|
|
|
2018-12-23 11:05:38 +01:00
|
|
|
from .cache import element_cache
|
2015-02-18 01:45:39 +01:00
|
|
|
|
2016-02-27 20:25:06 +01:00
|
|
|
|
2018-12-23 11:05:38 +01:00
|
|
|
AllData = Dict[str, Dict[int, Dict[str, Any]]]
|
|
|
|
ProjectorElementCallable = Callable[[Dict[str, Any], AllData], Dict[str, Any]]
|
2016-02-27 20:25:06 +01:00
|
|
|
|
|
|
|
|
2018-12-23 11:05:38 +01:00
|
|
|
projector_elements: Dict[str, ProjectorElementCallable] = {}
|
2015-06-12 21:08:57 +02:00
|
|
|
|
2017-08-30 00:07:54 +02:00
|
|
|
|
2018-12-23 11:05:38 +01:00
|
|
|
def register_projector_element(name: str, element: ProjectorElementCallable) -> None:
|
2017-08-30 00:07:54 +02:00
|
|
|
"""
|
2018-12-23 11:05:38 +01:00
|
|
|
Registers a projector element.
|
2017-08-30 00:07:54 +02:00
|
|
|
|
|
|
|
Has to be called in the app.ready method.
|
|
|
|
"""
|
2018-12-23 11:05:38 +01:00
|
|
|
projector_elements[name] = element
|
2017-08-30 00:07:54 +02:00
|
|
|
|
|
|
|
|
2018-12-23 11:05:38 +01:00
|
|
|
async def get_projectot_data(
|
|
|
|
projector_ids: List[int] = None
|
|
|
|
) -> Dict[int, Dict[str, Any]]:
|
|
|
|
"""
|
|
|
|
Callculates and returns the data for one or all projectors.
|
2017-08-30 00:07:54 +02:00
|
|
|
"""
|
2018-12-23 11:05:38 +01:00
|
|
|
if projector_ids is None:
|
|
|
|
projector_ids = []
|
|
|
|
|
|
|
|
all_data = await element_cache.get_all_full_data_ordered()
|
|
|
|
projector_data: Dict[int, Dict[str, Dict[str, Any]]] = {}
|
|
|
|
|
|
|
|
for projector_id, projector in all_data.get("core/projector", {}).items():
|
|
|
|
if projector_ids and projector_id not in projector_ids:
|
|
|
|
# only render the projector in question.
|
|
|
|
continue
|
|
|
|
|
|
|
|
projector_data[projector_id] = {}
|
|
|
|
if not projector["config"]:
|
|
|
|
projector_data[projector_id] = {
|
|
|
|
"error": {"error": "Projector has no config"}
|
|
|
|
}
|
|
|
|
continue
|
|
|
|
|
|
|
|
for uuid, projector_config in projector["config"].items():
|
|
|
|
projector_element = projector_elements.get(projector_config["name"])
|
|
|
|
if projector_element is None:
|
|
|
|
projector_data[projector_id][uuid] = {
|
|
|
|
"error": "Projector element {} does not exist".format(
|
|
|
|
projector_config["name"]
|
|
|
|
)
|
|
|
|
}
|
|
|
|
else:
|
|
|
|
projector_data[projector_id][uuid] = projector_element(
|
|
|
|
projector_config, all_data
|
|
|
|
)
|
|
|
|
return projector_data
|
|
|
|
|
|
|
|
|
|
|
|
def get_config(all_data: AllData, key: str) -> Any:
|
2017-08-30 00:07:54 +02:00
|
|
|
"""
|
2018-12-23 11:05:38 +01:00
|
|
|
Returns the config value from all_data.
|
|
|
|
"""
|
|
|
|
from ..core.config import config
|
|
|
|
|
|
|
|
return all_data[config.get_collection_string()][config.get_key_to_id()[key]][
|
|
|
|
"value"
|
|
|
|
]
|