CCCHH/dooris
1
1
Fork 0
Code Issues 1 Pull requests 1 Releases Packages 1 Activity Actions

api: implement caching for lock discovery

Browse source
This commit is contained in:
lilly 2026-05-09 21:30:53 +02:00
commit 5658228ce2
Signed by: lilly
SSH key fingerprint: SHA256:y9T5GFw2A20WVklhetIxG1+kcg/Ce0shnQmbu1LQ37g
1 changed files with 8 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

18
api/src/dooris_api/app.py
View file

@ -117,16 +117,14 @@ async def login_callback(req: Request, resp: Response, oidc_client: deps.OpenidC
@app.get("/api/locks/", tags=["locks"], responses={status.HTTP_401_UNAUTHORIZED: {"model": models.HttpProblemDetail}})
async def list_locks(ccujack: deps.CCUJackClient) -> List[models.Lock]:
locks = await ccujack.find_locks()
# TODO: Properly associate parameters with their values
# values = await asyncio.gather(*[
# ccujack.query_param_value(f"{i_lock.address}/{i_channel.index}/{i_param.id}/~pv")
# for i_lock, lock_channels in locks
# for i_channel, channel_params in lock_channels
# for i_param in channel_params
# ])
async def list_locks(ccujack: deps.CCUJackClient, cache: deps.Cache) -> List[models.Lock]:
# discover locks from ccujack
CACHE_KEY = "ccu-find-locks"
if CACHE_KEY in cache:
locks = cache[CACHE_KEY]
else:
locks = await ccujack.find_locks()
cache[CACHE_KEY] = locks
# assemble result objects
result = []