CAIP-79 add simple caching for skd flag

Author: broHeryk

symphony/bdk/core/auth/auth_session.py

@@ -36,7 +36,10 @@ async def refresh(self):
         """
         logger.debug("Authenticate")
         self._session_token = await self._authenticator.retrieve_session_token()
-        self._key_manager_token = await self._authenticator.retrieve_key_manager_token()
+        if await self.skd_enabled:
+            self._key_manager_token = ""
+            return
+        self.key_manager_token = await self._authenticator.retrieve_key_manager_token()
 
     @property
     async def session_token(self):

symphony/bdk/core/service/version/agent_version_service.py

@@ -1,6 +1,8 @@
 import re
+from datetime import datetime, timezone
 
 from symphony.bdk.core.auth.auth_session import AuthSession
+from symphony.bdk.core.auth.jwt_helper import generate_expiration_time
 from symphony.bdk.core.config.model.bdk_retry_config import BdkRetryConfig
 from symphony.bdk.core.retry import retry
 from symphony.bdk.gen.agent_api.signals_api import SignalsApi
@@ -19,12 +21,29 @@ class AgentVersionService:
     def __init__(self, signals_api: SignalsApi, retry_config: BdkRetryConfig):
         self._signals_api = signals_api
         self._retry_config = retry_config
+        self._is_skd_supported = None
+        self._expire_at = -1
 
-    @retry
     async def is_skd_supported(self) -> bool:
-        """
+        """ AgentVersionService stores cached version  flag.
+        Caching interval is the same as in to session token caching.
+        Once cache is expired it calls agent info api to update version.
+
         :return: boolean flag if skd supported for agent
         """
+        if (
+            self._is_skd_supported is not None
+            and self._expire_at
+            > datetime.now(timezone.utc).timestamp()
+        ):
+            return self._is_skd_supported
+        self._expire_at = generate_expiration_time()
+        self._is_skd_supported = await self._get_agent_skd_support()
+        return self._is_skd_supported
+
+
+    @retry
+    async def _get_agent_skd_support(self) -> bool:
         try:
             agent_info = await self._signals_api.v1_info_get()
             if not agent_info or not agent_info.version: