Merge pull request #373 from supertokens/feat/multitenancy-claims

feat: Add multitenancy claim

Author: rishabhpoddar

supertokens_python/recipe/emailverification/recipe.py

@@ -312,7 +312,9 @@ class EmailVerificationClaimClass(BooleanClaim):
     def __init__(self):
         default_max_age_in_sec = 300
 
-        async def fetch_value(user_id: str, user_context: Dict[str, Any]) -> bool:
+        async def fetch_value(
+            user_id: str, _tenant_id: str, user_context: Dict[str, Any]
+        ) -> bool:
             recipe = EmailVerificationRecipe.get_instance()
             email_info = await recipe.get_email_for_user_id(user_id, user_context)
 

supertokens_python/recipe/multitenancy/interfaces.py

@@ -336,6 +336,5 @@ async def login_methods_get(
 
 
 TypeGetAllowedDomainsForTenantId = Callable[
-    [Union[str, None], Dict[str, Any]],
-    Awaitable[List[str]],
+    [Optional[str], Dict[str, Any]], Awaitable[Optional[List[str]]]
 ]

supertokens_python/recipe/multitenancy/recipe.py

@@ -100,6 +100,9 @@ def __init__(
         )
 
         self.static_third_party_providers: List[ProviderInput] = []
+        self.get_allowed_domains_for_tenant_id = (
+            self.config.get_allowed_domains_for_tenant_id
+        )
 
     def is_error_from_this_recipe_based_on_instance(self, err: Exception) -> bool:
         return isinstance(err, (TenantDoesNotExistError, RecipeDisabledForTenantError))
@@ -259,41 +262,43 @@ async def login_methods_get(
 
 class AllowedDomainsClaimClass(PrimitiveArrayClaim[List[str]]):
     def __init__(self):
-        async def fetch_value(_user_id: str, user_context: Dict[str, Any]) -> List[str]:
+        default_max_age_in_sec = 60 * 60
+
+        async def fetch_value(
+            _: str, tenant_id: str, user_context: Dict[str, Any]
+        ) -> Optional[List[str]]:
             recipe = MultitenancyRecipe.get_instance()
-            tenant_id = (
-                None  # TODO fetch value will be passed with tenant_id as well later
-            )
 
-            if recipe.config.get_allowed_domains_for_tenant_id is None:
-                return (
-                    []
-                )  # User did not provide a function to get allowed domains, but is using a validator. So we don't allow any domains by default
+            if recipe.get_allowed_domains_for_tenant_id is None:
+                # User did not provide a function to get allowed domains, but is using a validator. So we don't allow any domains by default
+                return None
 
-            domains_res = await recipe.config.get_allowed_domains_for_tenant_id(
+            return await recipe.get_allowed_domains_for_tenant_id(
                 tenant_id, user_context
             )
-            return domains_res
 
-        super().__init__(
-            key="st-tenant-domains",
-            fetch_value=fetch_value,
-            default_max_age_in_sec=3600,
-        )
+        super().__init__("st-t-dmns", fetch_value, default_max_age_in_sec)
 
     def get_value_from_payload(
-        self, payload: JSONObject, user_context: Union[Dict[str, Any], None] = None
-    ) -> Union[List[str], None]:
-        if self.key not in payload:
+        self, payload: JSONObject, user_context: Optional[Dict[str, Any]] = None
+    ) -> Optional[List[str]]:
+        _ = user_context
+
+        res = payload.get(self.key, {}).get("v")
+        if res is None:
             return []
-        return super().get_value_from_payload(payload, user_context)
+        return res
 
     def get_last_refetch_time(
-        self, payload: JSONObject, user_context: Union[Dict[str, Any], None] = None
-    ) -> Union[int, None]:
-        if self.key not in payload:
+        self, payload: JSONObject, user_context: Optional[Dict[str, Any]] = None
+    ) -> Optional[int]:
+        _ = user_context
+
+        res = payload.get(self.key, {}).get("t")
+        if res is None:
             return get_timestamp_ms()
-        return super().get_last_refetch_time(payload, user_context)
+
+        return res
 
 
 AllowedDomainsClaim = AllowedDomainsClaimClass()

supertokens_python/recipe/session/asyncio/__init__.py

@@ -102,7 +102,8 @@ 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:
-        update = await claim.build(user_id, user_context)
+        # TODO: Pass tenant id
+        update = await claim.build(user_id, "pass-tenant-id", user_context)
         final_access_token_payload = {**final_access_token_payload, **update}
 
     return await SessionRecipe.get_instance().recipe_implementation.create_new_session(

supertokens_python/recipe/session/claim_base_classes/boolean_claim.py

@@ -31,7 +31,7 @@ def __init__(
         self,
         key: str,
         fetch_value: Callable[
-            [str, Dict[str, Any]],
+            [str, str, Dict[str, Any]],
             MaybeAwaitable[Optional[bool]],
         ],
         default_max_age_in_sec: Optional[int] = None,

supertokens_python/recipe/session/claim_base_classes/primitive_array_claim.py

@@ -267,7 +267,7 @@ def __init__(
         self,
         key: str,
         fetch_value: Callable[
-            [str, Dict[str, Any]],
+            [str, str, Dict[str, Any]],
             MaybeAwaitable[Optional[PrimitiveList]],
         ],
         default_max_age_in_sec: Optional[int] = None,

supertokens_python/recipe/session/claim_base_classes/primitive_claim.py

@@ -132,7 +132,7 @@ def __init__(
         self,
         key: str,
         fetch_value: Callable[
-            [str, Dict[str, Any]],
+            [str, str, Dict[str, Any]],
             MaybeAwaitable[Optional[Primitive]],
         ],
         default_max_age_in_sec: Optional[int] = None,

supertokens_python/recipe/session/interfaces.py

@@ -585,7 +585,7 @@ def __init__(
         self,
         key: str,
         fetch_value: Callable[
-            [str, Dict[str, Any]],
+            [str, str, Dict[str, Any]],
             MaybeAwaitable[Optional[_T]],
         ],
     ) -> None:
@@ -628,11 +628,12 @@ def get_value_from_payload(
         """Gets the value of the claim stored in the payload"""
 
     async def build(
-        self, user_id: str, user_context: Optional[Dict[str, Any]] = None
+        self, user_id: str, tenant_id: str, user_context: Optional[Dict[str, Any]] = None
     ) -> JSONObject:
         if user_context is None:
             user_context = {}
-        value = await resolve(self.fetch_value(user_id, user_context))
+
+        value = await resolve(self.fetch_value(user_id, tenant_id, user_context))
 
         if value is None:
             return {}

supertokens_python/recipe/session/recipe_implementation.py

@@ -48,6 +48,7 @@
 
 from .interfaces import SessionContainer
 from supertokens_python.querier import Querier
+from supertokens_python.recipe.multitenancy.constants import DEFAULT_TENANT_ID
 
 
 class RecipeImplementation(RecipeInterface):  # pylint: disable=too-many-public-methods
@@ -120,7 +121,11 @@ async def validate_claims(
                     "update_claims_in_payload_if_needed refetching for %s", validator.id
                 )
                 value = await resolve(
-                    validator.claim.fetch_value(user_id, user_context)
+                    validator.claim.fetch_value(
+                        user_id,
+                        access_token_payload.get("tId", DEFAULT_TENANT_ID),
+                        user_context,
+                    )
                 )
                 log_debug_message(
                     "update_claims_in_payload_if_needed %s refetch result %s",
@@ -378,8 +383,9 @@ 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, user_context
+            session_info.user_id, "pass-tenant-id", user_context
         )
         return await self.merge_into_access_token_payload(
             session_handle, access_token_payload_update, user_context

supertokens_python/recipe/session/session_class.py

@@ -220,7 +220,8 @@ async def fetch_and_set_claim(
         if user_context is None:
             user_context = {}
 
-        update = await claim.build(self.get_user_id(), user_context)
+        # TODO: Pass tenant id
+        update = await claim.build(self.get_user_id(), "pass-tenant-id", user_context)
         return await self.merge_into_access_token_payload(update, user_context)
 
     async def set_claim_value(