[Community] add package check key

Drakkar-Software · Jul 5, 2024 · d37ab96 · d37ab96
1 parent ec9493c
commit d37ab96
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 2 deletions.
diff --git a/octobot/community/authentication.py b/octobot/community/authentication.py
@@ -285,7 +285,10 @@ async def wait_for_private_data_fetch_if_processing(self):
         await self.wait_for_login_if_processing()
         if self.is_logged_in() and self._fetched_private_data is not None and not self._fetched_private_data.is_set():
             # ensure login details have been fetched
-            await asyncio.wait_for(self._fetched_private_data.wait(), constants.COMMUNITY_FETCH_TIMEOUT)
+            await asyncio.wait_for(
+                self._fetched_private_data.wait(),
+                supabase_backend.HTTP_RETRY_COUNT * constants.COMMUNITY_FETCH_TIMEOUT
+            )
 
     def can_authenticate(self):
         return bool(

diff --git a/octobot/community/supabase_backend/__init__.py b/octobot/community/supabase_backend/__init__.py
@@ -30,6 +30,7 @@
 from octobot.community.supabase_backend import community_supabase_client
 from octobot.community.supabase_backend.community_supabase_client import (
     CommunitySupabaseClient,
+    HTTP_RETRY_COUNT,
 )
 
 __all__ = [
@@ -38,4 +39,5 @@
     "ASyncConfigurationStorage",
     "AuthenticatedAsyncSupabaseClient",
     "CommunitySupabaseClient",
+    "HTTP_RETRY_COUNT",
 ]
diff --git a/octobot/community/supabase_backend/community_supabase_client.py b/octobot/community/supabase_backend/community_supabase_client.py
@@ -64,6 +64,10 @@ async def httpx_retrier_wrapper(*args, **kwargs):
                     # waking up, retry
                     error = "bad gateway"
                 else:
+                    if i > 0:
+                        commons_logging.get_logger(__name__).debug(
+                            f"{f.__name__}(args={args[1:]}) succeeded after {i+1} attempts"
+                        )
                     return resp
             except httpx.ReadTimeout as err:
                 error = f"{err} ({err.__class__.__name__})"

diff --git a/octobot/constants.py b/octobot/constants.py
@@ -71,7 +71,7 @@
     "COMMUNITY_EXTENSIONS_CHECK_ENDPOINT", "https://premium.octobot.cloud"
 )
 COMMUNITY_EXTENSIONS_CHECK_ENDPOINT_KEY = os.getenv(
-    "COMMUNITY_EXTENSIONS_CHECK_ENDPOINT_KEY", "TODO"
+    "COMMUNITY_EXTENSIONS_CHECK_ENDPOINT_KEY", "eyJhbGciOiJSUzI1NiIsInR5cCI6IkpXVCJ9.eyJhcHBsaWNhdGlvbl9jbGFpbSI6W3sibmFtZXNwYWNlX2lkIjoiIiwiYXBwbGljYXRpb25faWQiOiI5YTEzMTg2Mi1iMmY2LTRlOWUtYjU1OC0yOTU4MWFjYjM0ZjUifV0sInZlcnNpb24iOjIsImF1ZCI6ImZ1bmN0aW9ucyIsImp0aSI6IjJkMTM5OWQxLTRkNjMtNGVmNi1hNTI3LWNhMDQxMDdiNmUwYSIsImlhdCI6MTcyMDEyNjc1OSwiaXNzIjoiU0NBTEVXQVkiLCJuYmYiOjE3MjAxMjY3NTksInN1YiI6InRva2VuIn0.S2StO0Jey_BGotVdIYOa1hUNyF1m-BTLr-5oy24tiIXoh6nysMn_wBx0EzTDjQ_rG9yyUWbEYENjVlUzRJukiUf-5jjmIY0sgp6gYwtn6tu5Va1HyLOHpTNLYmSFcj7S-DcJXfd0uIGJcNRSAvYftnt-SVqjray0g5SfQEoB6UDSQolfECs4Avj7O0_Wtny1LHoIX_BEqlGWetODNklNNrBJuFUtSxoGfGarVGejOyvCdk10tFXpGJQr9dKPhnNSChs6N3qk4ApH5ET6JjOUENVF6x-KZ8Ed82KFU0gdGXICMVIiCUJz-b-QU88-HG6QG2-fD8dtvRUSCt_PsZPPZ_7IDWWuA-LEdNlKCyatVz0Yx3mCDusHN7Tt3ae-dJg9wpC4VCxqy8-MHOg9uf9GREkkc8Al-Nfn04tLWrl-OY_lrJ_jJ5_6N_XTwzNGmEdN3EVAeedwfyfpiuiXJMy84WQpfmJWn1zKEUrsBmx8xrTPz1pmZBB6uRKcdjUNWV2MpiAgxFxQI8Mo_zUJvagydfylcijjen8wP1ML0y8ywF8KSUmNprBv2SUwY8AXywtP5qIusnUEv-WxtoFdOU7Rgu3bCsdlktVEo2n2S-j6R9bki43gIgAmyxCveE-lwcNYoc_MahHMrjRW2uoO5deDo_yq90OJmnvnl35cLgVbkoA"
 )
 COMMUNITY_EXTENSIONS_PACKAGES_IDENTIFIER = ".cloud"
 COMMUNITY_FETCH_TIMEOUT = 30