🎨 Refactor resource manager keys to use CLIENT_SOCKET_REGISTRY_APPKEY for consistency

Author: pcrespov

services/web/server/src/simcore_service_webserver/resource_manager/_constants.py

@@ -14,8 +14,7 @@
 
 from ..application_setup import ModuleCategory, app_setup_func
 from ..redis import setup_redis
-from ._constants import APP_CLIENT_SOCKET_REGISTRY_KEY, APP_RESOURCE_MANAGER_TASKS_KEY
-from .registry import RedisResourceRegistry
+from .registry import CLIENT_SOCKET_REGISTRY_APPKEY, RedisResourceRegistry
 
 _logger = logging.getLogger(__name__)
 
@@ -33,9 +32,7 @@
 def setup_resource_manager(app: web.Application) -> bool:
     """Sets up resource manager subsystem in the application"""
 
-    app[APP_RESOURCE_MANAGER_TASKS_KEY] = []
-
     setup_redis(app)
-    app[APP_CLIENT_SOCKET_REGISTRY_KEY] = RedisResourceRegistry(app)
+    app[CLIENT_SOCKET_REGISTRY_APPKEY] = RedisResourceRegistry(app)
 
     return True

services/web/server/src/simcore_service_webserver/resource_manager/plugin.py

@@ -14,13 +14,13 @@
 """
 
 import logging
+from typing import Final
 
 import redis.asyncio as aioredis
 from aiohttp import web
 from servicelib.redis import handle_redis_returns_union_types
 
 from ..redis import get_redis_resources_client
-from ._constants import APP_CLIENT_SOCKET_REGISTRY_KEY
 from .models import (
     ALIVE_SUFFIX,
     RESOURCE_SUFFIX,
@@ -144,7 +144,12 @@ async def get_all_resource_keys(self) -> tuple[AliveSessions, DeadSessions]:
         return (alive_keys, dead_keys)
 
 
+CLIENT_SOCKET_REGISTRY_APPKEY: Final = web.AppKey(
+    "CLIENT_SOCKET_REGISTRY", RedisResourceRegistry
+)
+
+
 def get_registry(app: web.Application) -> RedisResourceRegistry:
-    client: RedisResourceRegistry = app[APP_CLIENT_SOCKET_REGISTRY_KEY]
+    client = app[CLIENT_SOCKET_REGISTRY_APPKEY]
     assert isinstance(client, RedisResourceRegistry)  # nosec
     return client