fix lost of logs

Author: matusdrobuliak66

services/web/server/src/simcore_service_webserver/projects/_controller/projects_states_rest.py

@@ -28,7 +28,7 @@
 from ...notifications import project_logs
 from ...products import products_web
 from ...products.models import Product
-from ...resource_manager.user_sessions import managed_resource
+from ...resource_manager.user_sessions import PROJECT_ID_KEY, managed_resource
 from ...security.decorators import permission_required
 from ...socketio.server import get_socket_server
 from ...users import users_service
@@ -91,11 +91,17 @@ async def open_project(request: web.Request) -> web.Response:
             ),
         )
 
+        # Check if projects wallet is not in debt
         await projects_wallets_service.check_project_financial_status(
             request.app,
             project_id=path_params.project_id,
             product_name=req_ctx.product_name,
         )
+        # Check if user has access to a project wallet (Useful for simultaneous access to project by different users)
+        project_wallet = await projects_wallets_service.get_project_wallet(
+            request.app,
+            project_id=path_params.project_id,
+        )
 
         product: Product = products_web.get_current_product(request)
         app_settings = get_application_settings(request.app)
@@ -220,7 +226,17 @@ async def close_project(request: web.Request) -> web.Response:
             X_SIMCORE_USER_AGENT, UNDEFINED_DEFAULT_SIMCORE_USER_AGENT_VALUE
         ),
     )
-    await project_logs.unsubscribe(request.app, path_params.project_id)
+
+    with managed_resource(
+        req_ctx.user_id, client_session_id, request.app
+    ) as user_session:
+        all_user_sessions_with_project = await user_session.find_users_of_resource(
+            request.app, key=PROJECT_ID_KEY, value=f"{path_params.project_id}"
+        )
+        # Only unsubscribe from logs if there is no other occurrence of the open project
+        if len(all_user_sessions_with_project) == 0:
+            await project_logs.unsubscribe(request.app, path_params.project_id)
+
     return web.json_response(status=status.HTTP_204_NO_CONTENT)
 
 

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

@@ -2,7 +2,6 @@
 from collections.abc import Iterator
 from contextlib import contextmanager
 from dataclasses import dataclass
-from functools import cached_property
 from typing import Final
 
 from aiohttp import web
@@ -64,7 +63,7 @@ class UserSessionResourcesRegistry:
     def _registry(self) -> RedisResourceRegistry:
         return get_registry(self.app)
 
-    @cached_property
+    @property
     def resource_key(self) -> UserSession:
         return UserSession(
             user_id=self.user_id,
@@ -148,8 +147,11 @@ async def find_all_resources_of_user(self, key: str) -> list[str]:
             msg=f"{self.user_id=} finding all {key} from registry",
             extra=get_log_record_extra(user_id=self.user_id),
         ):
-            return await get_registry(self.app).find_resources(
-                UserSession(user_id=self.user_id, client_session_id="*"), key
+            return await self._registry.find_resources(
+                UserSession(
+                    user_id=self.user_id, client_session_id="*"
+                ),  #  <-- this one checks for all user tabs
+                key,
             )
 
     async def find(self, resource_name: str) -> list[str]:
@@ -161,7 +163,10 @@ async def find(self, resource_name: str) -> list[str]:
             extra=get_log_record_extra(user_id=self.user_id),
         )
 
-        return await self._registry.find_resources(self.resource_key, resource_name)
+        return await self._registry.find_resources(
+            self.resource_key,
+            resource_name,  # <-- when initialized with specific tab (client_session_id), checks only that tab otherwise all tabs
+        )
 
     async def add(self, key: str, value: str) -> None:
         _logger.debug(