Merge pull request #297 from supertokens/dashboard-search

feat: search apis for dashboard

Author: nkshah2

supertokens_python/framework/django/django_request.py

@@ -14,7 +14,7 @@
 from __future__ import annotations
 
 import json
-from typing import TYPE_CHECKING, Any, Union
+from typing import TYPE_CHECKING, Any, Dict, Union
 from urllib.parse import parse_qsl
 
 from supertokens_python.framework.request import BaseRequest
@@ -35,6 +35,9 @@ def get_query_param(
     ) -> Union[str, None]:
         return self.request.GET.get(key, default)
 
+    def get_query_params(self) -> Dict[str, Any]:
+        return self.request.GET.dict()
+
     async def json(self) -> Union[Any, None]:
         try:
             body = json.loads(self.request.body)

supertokens_python/framework/fastapi/fastapi_request.py

@@ -13,7 +13,7 @@
 # under the License.
 from __future__ import annotations
 
-from typing import TYPE_CHECKING, Any, Union
+from typing import TYPE_CHECKING, Any, Dict, Union
 from urllib.parse import parse_qsl
 
 from supertokens_python.framework.request import BaseRequest
@@ -35,6 +35,9 @@ def get_query_param(
     ) -> Union[str, None]:
         return self.request.query_params.get(key, default)
 
+    def get_query_params(self) -> Dict[str, Any]:
+        return dict(self.request.query_params.items())  # type: ignore
+
     async def json(self) -> Union[Any, None]:
         try:
             return await self.request.json()

supertokens_python/framework/flask/flask_request.py

@@ -31,6 +31,9 @@ def __init__(self, req: Request):
     def get_query_param(self, key: str, default: Union[str, None] = None):
         return self.request.args.get(key, default)
 
+    def get_query_params(self) -> Dict[str, Any]:
+        return self.request.args.to_dict()
+
     async def json(self) -> Union[Any, None]:
         try:
             return self.request.get_json()

supertokens_python/framework/request.py

@@ -31,6 +31,10 @@ def get_query_param(
     ) -> Union[str, None]:
         pass
 
+    @abstractmethod
+    def get_query_params(self) -> Dict[str, Any]:
+        pass
+
     @abstractmethod
     async def json(self) -> Union[Any, None]:
         pass

supertokens_python/recipe/dashboard/api/__init__.py

@@ -13,6 +13,7 @@
 # under the License.
 from .api_key_protector import api_key_protector
 from .dashboard import handle_dashboard_api
+from .search.getTags import handle_get_tags
 from .signin import handle_emailpassword_signin_api
 from .signout import handle_emailpassword_signout_api
 from .userdetails.user_delete import handle_user_delete
@@ -49,4 +50,5 @@
     "handle_email_verify_token_post",
     "handle_emailpassword_signin_api",
     "handle_emailpassword_signout_api",
+    "handle_get_tags",
 ]

supertokens_python/recipe/dashboard/api/implementation.py

@@ -20,6 +20,8 @@
 from supertokens_python import Supertokens
 from supertokens_python.normalised_url_domain import NormalisedURLDomain
 from supertokens_python.normalised_url_path import NormalisedURLPath
+from supertokens_python.querier import Querier
+from supertokens_python.utils import is_version_gte
 
 from ..constants import DASHBOARD_API
 from ..interfaces import APIInterface
@@ -54,6 +56,14 @@ async def dashboard_get(
                 NormalisedURLPath(DASHBOARD_API)
             ).get_as_string_dangerous()
 
+            is_search_enabled: bool = False
+            querier = Querier.get_instance(options.recipe_id)
+            cdiVersion = await querier.get_api_version()
+            if not cdiVersion:
+                return ""
+            if is_version_gte(cdiVersion, "2.20"):
+                is_search_enabled = True
+
             return Template(
                 dedent(
                     """
@@ -65,6 +75,7 @@ async def dashboard_get(
                             window.dashboardAppPath = "${dashboardPath}"
                             window.connectionURI = "${connectionURI}"
                             window.authMode = "${authMode}"
+                            window.isSearchEnabled = "${isSearchEnabled}"
                         </script>
                         <script defer src="${bundleDomain}/static/js/bundle.js"></script></head>
                         <link href="${bundleDomain}/static/css/main.css" rel="stylesheet" type="text/css">
@@ -82,6 +93,7 @@ async def dashboard_get(
                 dashboardPath=dashboard_path,
                 connectionURI=connection_uri,
                 authMode=auth_mode,
+                isSearchEnabled=is_search_enabled,
             )
 
         self.dashboard_get = dashboard_get

supertokens_python/recipe/dashboard/api/search/__init__.py

@@ -0,0 +1,30 @@
+# Copyright (c) 2021, VRAI Labs and/or its affiliates. All rights reserved.
+#
+# This software is licensed under the Apache License, Version 2.0 (the
+# "License") as published by the Apache Software Foundation.
+#
+# You may not use this file except in compliance with the License. You may
+# obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# 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 __future__ import annotations
+
+from typing import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from supertokens_python.recipe.dashboard.interfaces import APIInterface, APIOptions
+
+from supertokens_python.normalised_url_path import NormalisedURLPath
+from supertokens_python.querier import Querier
+from supertokens_python.recipe.dashboard.interfaces import SearchTagsOK
+
+
+async def handle_get_tags(_: APIInterface, __: APIOptions) -> SearchTagsOK:
+    response = await Querier.get_instance().send_get_request(
+        NormalisedURLPath("/user/search/tags")
+    )
+    return SearchTagsOK(tags=response["tags"])

supertokens_python/recipe/dashboard/api/search/getTags.py

@@ -55,6 +55,7 @@ async def handle_users_get_api(
         time_joined_order=time_joined_order,  # type: ignore
         pagination_token=pagination_token,
         include_recipe_ids=None,
+        query=api_options.request.get_query_params(),
     )
 
     # user metadata bulk fetch with batches:

supertokens_python/recipe/dashboard/api/users_get.py

@@ -10,3 +10,4 @@
 USER_EMAIL_VERIFY_TOKEN_API = "/api/user/email/verify/token"
 EMAIL_PASSWORD_SIGN_IN = "/api/signin"
 EMAIL_PASSSWORD_SIGNOUT = "/api/signout"
+SEARCH_TAGS_API = "/api/search/tags"

supertokens_python/recipe/dashboard/constants.py

@@ -293,3 +293,14 @@ class SignOutOK(APIResponse):
 
     def to_json(self):
         return {"status": self.status}
+
+
+class SearchTagsOK(APIResponse):
+    status: str = "OK"
+    tags: List[str]
+
+    def __init__(self, tags: List[str]) -> None:
+        self.tags = tags
+
+    def to_json(self):
+        return {"status": self.status, "tags": self.tags}

supertokens_python/recipe/dashboard/interfaces.py

@@ -25,6 +25,7 @@
     handle_email_verify_token_post,
     handle_emailpassword_signin_api,
     handle_emailpassword_signout_api,
+    handle_get_tags,
     handle_metadata_get,
     handle_metadata_put,
     handle_sessions_get,
@@ -56,6 +57,7 @@
     DASHBOARD_API,
     EMAIL_PASSSWORD_SIGNOUT,
     EMAIL_PASSWORD_SIGN_IN,
+    SEARCH_TAGS_API,
     USER_API,
     USER_EMAIL_VERIFY_API,
     USER_EMAIL_VERIFY_TOKEN_API,
@@ -181,6 +183,8 @@ async def handle_api_request(
             api_function = handle_email_verify_token_post
         elif request_id == EMAIL_PASSSWORD_SIGNOUT:
             api_function = handle_emailpassword_signout_api
+        elif request_id == SEARCH_TAGS_API:
+            api_function = handle_get_tags
 
         if api_function is not None:
             return await api_key_protector(

supertokens_python/recipe/dashboard/recipe.py

@@ -51,6 +51,7 @@
     DASHBOARD_API,
     EMAIL_PASSSWORD_SIGNOUT,
     EMAIL_PASSWORD_SIGN_IN,
+    SEARCH_TAGS_API,
     USER_API,
     USER_EMAIL_VERIFY_API,
     USER_EMAIL_VERIFY_TOKEN_API,
@@ -237,6 +238,8 @@ def get_api_if_matched(path: NormalisedURLPath, method: str) -> Optional[str]:
         return EMAIL_PASSWORD_SIGN_IN
     if path_str.endswith(EMAIL_PASSSWORD_SIGNOUT) and method == "post":
         return EMAIL_PASSSWORD_SIGNOUT
+    if path_str.endswith(SEARCH_TAGS_API) and method == "get":
+        return SEARCH_TAGS_API
 
     return None
 

supertokens_python/recipe/dashboard/utils.py

@@ -49,10 +49,10 @@
 from .utils import (
     execute_async,
     get_rid_from_header,
+    get_top_level_domain_for_same_site_resolution,
     is_version_gte,
     normalise_http_method,
     send_non_200_response_with_message,
-    get_top_level_domain_for_same_site_resolution,
 )
 
 if TYPE_CHECKING:
@@ -328,6 +328,7 @@ async def get_users(  # pylint: disable=no-self-use
         limit: Union[int, None],
         pagination_token: Union[str, None],
         include_recipe_ids: Union[None, List[str]],
+        query: Union[Dict[str, str], None] = None,
     ) -> UsersResponse:
         querier = Querier.get_instance(None)
         params = {"timeJoinedOrder": time_joined_order}
@@ -341,6 +342,9 @@ async def get_users(  # pylint: disable=no-self-use
             include_recipe_ids_str = ",".join(include_recipe_ids)
             params = {"includeRecipeIds": include_recipe_ids_str, **params}
 
+        if query is not None:
+            params = {**params, **query}
+
         response = await querier.send_get_request(NormalisedURLPath(USERS), params)
         next_pagination_token = None
         if "nextPaginationToken" in response: