feat: Session multitenancy changes

Author: KShivendu

supertokens_python/recipe/emailpassword/api/implementation.py

@@ -182,6 +182,7 @@ async def sign_in_post(
             user.user_id,
             access_token_payload={},
             session_data_in_database={},
+            tenant_id=tenant_id,
             user_context=user_context,
         )
         return SignInPostOkResult(user, session)
@@ -222,6 +223,7 @@ async def sign_up_post(
             user.user_id,
             access_token_payload={},
             session_data_in_database={},
+            tenant_id=tenant_id,
             user_context=user_context,
         )
         return SignUpPostOkResult(user, session)

supertokens_python/recipe/emailverification/recipe.py

@@ -412,7 +412,7 @@ async def generate_email_verify_token_post(
         email_info = await EmailVerificationRecipe.get_instance().get_email_for_user_id(
             user_id, user_context
         )
-        tenant_id = session.get_access_token_payload()["tid"]
+        tenant_id = session.get_tenant_id()
 
         if isinstance(email_info, EmailDoesNotExistError):
             log_debug_message(

supertokens_python/recipe/passwordless/api/implementation.py

@@ -303,6 +303,7 @@ async def consume_code_post(
             user.user_id,
             {},
             {},
+            tenant_id,
             user_context=user_context,
         )
 

supertokens_python/recipe/session/access_token.py

@@ -24,6 +24,8 @@
 from .exceptions import raise_try_refresh_token_exception
 from .jwt import ParsedJWTInfo
 
+from supertokens_python.recipe.multitenancy.constants import DEFAULT_TENANT_ID
+
 
 def sanitize_string(s: Any) -> Union[str, None]:
     if s == "":
@@ -102,6 +104,10 @@ def get_info_from_access_token(
             payload.get("parentRefreshTokenHash1")
         )
         anti_csrf_token = sanitize_string(payload.get("antiCsrfToken"))
+        tenant_id = DEFAULT_TENANT_ID
+
+        if jwt_info.version >= 4:
+            tenant_id = sanitize_string(payload.get("tId"))
 
         if anti_csrf_token is None and do_anti_csrf_check:
             raise Exception("Access token does not contain the anti-csrf token")
@@ -120,6 +126,7 @@ def get_info_from_access_token(
             "antiCsrfToken": anti_csrf_token,
             "expiryTime": expiry_time,
             "timeCreated": time_created,
+            "tenantId": tenant_id,
         }
     except Exception as e:
         log_debug_message(
@@ -145,6 +152,11 @@ def validate_access_token_structure(payload: Dict[str, Any], version: int) -> No
             raise Exception(
                 "Access token does not contain all the information. Maybe the structure has changed?"
             )
+
+        if version >= 4:
+            if not isinstance(payload.get("tId"), str):
+                raise Exception("Access token does not contain all the information. Maybe the structure has changed?")
+
     elif (
         not isinstance(payload.get("sessionHandle"), str)
         or payload.get("userData") is None

supertokens_python/recipe/session/asyncio/__init__.py

@@ -43,6 +43,8 @@
 )
 from ..utils import get_required_claim_validators
 
+from supertokens_python.recipe.multitenancy.constants import DEFAULT_TENANT_ID
+
 _T = TypeVar("_T")
 
 
@@ -51,6 +53,7 @@ async def create_new_session(
     user_id: str,
     access_token_payload: Union[Dict[str, Any], None] = None,
     session_data_in_database: Union[Dict[str, Any], None] = None,
+    tenant_id: Optional[str] = None,
     user_context: Union[None, Dict[str, Any]] = None,
 ) -> SessionContainer:
     if user_context is None:
@@ -73,6 +76,7 @@ async def create_new_session(
         config,
         app_info,
         session_data_in_database,
+        tenant_id or DEFAULT_TENANT_ID,
     )
 
 
@@ -81,6 +85,7 @@ async def create_new_session_without_request_response(
     access_token_payload: Union[Dict[str, Any], None] = None,
     session_data_in_database: Union[Dict[str, Any], None] = None,
     disable_anti_csrf: bool = False,
+    tenant_id: Optional[str] = None,
     user_context: Union[None, Dict[str, Any]] = None,
 ) -> SessionContainer:
     if user_context is None:
@@ -102,7 +107,6 @@ async def create_new_session_without_request_response(
     final_access_token_payload = {**access_token_payload, "iss": issuer}
 
     for claim in claims_added_by_other_recipes:
-        # TODO: Pass tenant id
         update = await claim.build(user_id, "pass-tenant-id", user_context)
         final_access_token_payload = {**final_access_token_payload, **update}
 
@@ -111,6 +115,7 @@ async def create_new_session_without_request_response(
         final_access_token_payload,
         session_data_in_database,
         disable_anti_csrf,
+        tenant_id or DEFAULT_TENANT_ID,
         user_context=user_context,
     )
 
@@ -421,22 +426,23 @@ async def revoke_session(
 
 
 async def revoke_all_sessions_for_user(
-    user_id: str, user_context: Union[None, Dict[str, Any]] = None
+    user_id: str, tenant_id: Optional[str], user_context: Union[None, Dict[str, Any]] = None
 ) -> List[str]:
     if user_context is None:
         user_context = {}
     return await SessionRecipe.get_instance().recipe_implementation.revoke_all_sessions_for_user(
-        user_id, user_context
+        user_id, tenant_id or DEFAULT_TENANT_ID,
+        tenant_id is None, user_context
     )
 
 
 async def get_all_session_handles_for_user(
-    user_id: str, user_context: Union[None, Dict[str, Any]] = None
+    user_id: str, tenant_id: Optional[str], user_context: Union[None, Dict[str, Any]] = None
 ) -> List[str]:
     if user_context is None:
         user_context = {}
     return await SessionRecipe.get_instance().recipe_implementation.get_all_session_handles_for_user(
-        user_id, user_context
+        user_id, tenant_id or DEFAULT_TENANT_ID, tenant_id is None, user_context
     )
 
 

supertokens_python/recipe/session/interfaces.py

@@ -41,10 +41,11 @@
 
 
 class SessionObj:
-    def __init__(self, handle: str, user_id: str, user_data_in_jwt: Dict[str, Any]):
+    def __init__(self, handle: str, user_id: str, user_data_in_jwt: Dict[str, Any], tenant_id: str):
         self.handle = handle
         self.user_id = user_id
         self.user_data_in_jwt = user_data_in_jwt
+        self.tenant_id = tenant_id
 
 
 class AccessTokenObj:
@@ -69,15 +70,15 @@ def __init__(
         expiry: int,
         custom_claims_in_access_token_payload: Dict[str, Any],
         time_created: int,
+        tenant_id: str,
     ):
-        self.session_handle: str = session_handle
-        self.user_id: str = user_id
-        self.session_data_in_database: Dict[str, Any] = session_data_in_database
-        self.expiry: int = expiry
-        self.custom_claims_in_access_token_payload: Dict[
-            str, Any
-        ] = custom_claims_in_access_token_payload
-        self.time_created: int = time_created
+        self.session_handle = session_handle
+        self.user_id = user_id
+        self.session_data_in_database = session_data_in_database
+        self.expiry = expiry
+        self.custom_claims_in_access_token_payload = custom_claims_in_access_token_payload
+        self.time_created = time_created
+        self.tenant_id = tenant_id
 
 
 class ReqResInfo:
@@ -137,6 +138,7 @@ async def create_new_session(
         access_token_payload: Optional[Dict[str, Any]],
         session_data_in_database: Optional[Dict[str, Any]],
         disable_anti_csrf: Optional[bool],
+        tenant_id: str,
         user_context: Dict[str, Any],
     ) -> SessionContainer:
         pass
@@ -206,13 +208,13 @@ async def revoke_session(
 
     @abstractmethod
     async def revoke_all_sessions_for_user(
-        self, user_id: str, user_context: Dict[str, Any]
+        self, user_id: str, tenant_id: str, revoke_across_all_tenants: Optional[bool], user_context: Dict[str, Any]
     ) -> List[str]:
         pass
 
     @abstractmethod
     async def get_all_session_handles_for_user(
-        self, user_id: str, user_context: Dict[str, Any]
+        self, user_id: str, tenant_id: str, fetch_across_all_tenants: Optional[bool], user_context: Dict[str, Any]
     ) -> List[str]:
         pass
 
@@ -383,6 +385,7 @@ def __init__(
         user_data_in_access_token: Optional[Dict[str, Any]],
         req_res_info: Optional[ReqResInfo],
         access_token_updated: bool,
+        tenant_id: str,
     ):
         self.recipe_implementation = recipe_implementation
         self.config = config
@@ -395,6 +398,7 @@ def __init__(
         self.user_data_in_access_token = user_data_in_access_token
         self.req_res_info: Optional[ReqResInfo] = req_res_info
         self.access_token_updated = access_token_updated
+        self.tenant_id = tenant_id
 
         self.response_mutators: List[ResponseMutator] = []
 
@@ -436,6 +440,10 @@ async def merge_into_access_token_payload(
     def get_user_id(self, user_context: Optional[Dict[str, Any]] = None) -> str:
         pass
 
+    @abstractmethod
+    def get_tenant_id(self, user_context: Optional[Dict[str, Any]] = None) -> str:
+        pass
+
     @abstractmethod
     def get_access_token_payload(
         self, user_context: Optional[Dict[str, Any]] = None

supertokens_python/recipe/session/recipe.py

@@ -183,7 +183,7 @@ def get_apis_handled(self) -> List[APIHandled]:
     async def handle_api_request(
         self,
         request_id: str,
-        tenant_id: Optional[str],
+        tenant_id: str,
         request: BaseRequest,
         path: NormalisedURLPath,
         method: str,

supertokens_python/recipe/session/recipe_implementation.py

@@ -64,6 +64,7 @@ async def create_new_session(
         access_token_payload: Optional[Dict[str, Any]],
         session_data_in_database: Optional[Dict[str, Any]],
         disable_anti_csrf: Optional[bool],
+        tenant_id: str,
         user_context: Dict[str, Any],
     ) -> SessionContainer:
         log_debug_message("createNewSession: Started")
@@ -74,6 +75,7 @@ async def create_new_session(
             disable_anti_csrf is True,
             access_token_payload,
             session_data_in_database,
+            tenant_id
         )
         log_debug_message("createNewSession: Finished")
 
@@ -95,6 +97,7 @@ async def create_new_session(
             payload,
             None,
             True,
+            tenant_id
         )
 
         return new_session
@@ -262,6 +265,7 @@ async def get_session(
             payload,
             None,
             access_token_updated,
+            response.session.tenant_id,
         )
 
         return session
@@ -312,6 +316,7 @@ async def refresh_session(
             user_data_in_access_token=payload,
             req_res_info=None,
             access_token_updated=True,
+            tenant_id=payload["tId"],
         )
 
         return session
@@ -322,14 +327,14 @@ async def revoke_session(
         return await session_functions.revoke_session(self, session_handle)
 
     async def revoke_all_sessions_for_user(
-        self, user_id: str, user_context: Dict[str, Any]
+        self, user_id: str, tenant_id: Optional[str], revoke_across_all_tenants: Optional[bool], user_context: Dict[str, Any]
     ) -> List[str]:
-        return await session_functions.revoke_all_sessions_for_user(self, user_id)
+        return await session_functions.revoke_all_sessions_for_user(self, user_id, tenant_id, revoke_across_all_tenants)
 
     async def get_all_session_handles_for_user(
-        self, user_id: str, user_context: Dict[str, Any]
+        self, user_id: str, tenant_id: Optional[str], fetch_across_all_tenants: Optional[bool], user_context: Dict[str, Any]
     ) -> List[str]:
-        return await session_functions.get_all_session_handles_for_user(self, user_id)
+        return await session_functions.get_all_session_handles_for_user(self, user_id, tenant_id, fetch_across_all_tenants)
 
     async def revoke_multiple_sessions(
         self, session_handles: List[str], user_context: Dict[str, Any]
@@ -383,9 +388,8 @@ async def fetch_and_set_claim(
         if session_info is None:
             return False
 
-        # TODO: Pass tenant id
         access_token_payload_update = await claim.build(
-            session_info.user_id, "pass-tenant-id", user_context
+            session_info.user_id, session_info.tenant_id, user_context
         )
         return await self.merge_into_access_token_payload(
             session_handle, access_token_payload_update, user_context
@@ -463,5 +467,6 @@ async def regenerate_access_token(
             response["session"]["handle"],
             response["session"]["userId"],
             response["session"]["userDataInJWT"],
+            response["session"]["tenantId"]
         )
         return RegenerateAccessTokenOkResult(session, access_token_obj)

supertokens_python/recipe/session/session_class.py

@@ -11,7 +11,7 @@
 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
 # License for the specific language governing permissions and limitations
 # under the License.
-from typing import Any, Dict, List, TypeVar, Union
+from typing import Any, Dict, List, Optional, TypeVar, Union
 
 from supertokens_python.recipe.session.exceptions import (
     raise_invalid_claims_exception,
@@ -133,6 +133,9 @@ async def update_session_data_in_database(
     def get_user_id(self, user_context: Union[Dict[str, Any], None] = None) -> str:
         return self.user_id
 
+    def get_tenant_id(self, user_context: Union[Dict[str, Any], None] = None) -> str:
+        return self.tenant_id
+
     def get_access_token_payload(
         self, user_context: Union[Dict[str, Any], None] = None
     ) -> Dict[str, Any]: