[Feature] Add SSL Certificate Context And Setting For Async/Sync HTTP Requests

openbb_platform/core/openbb_core/api/rest_api.py

@@ -85,6 +85,16 @@ async def lifespan(_: FastAPI):
 
 
 if __name__ == "__main__":
+    # pylint: disable=import-outside-toplevel
     import uvicorn
 
-    uvicorn.run("openbb_core.api.rest_api:app", reload=True)
+    Env()
+    uvicorn_kwargs = system.python_settings.model_dump().get("uvicorn", {})
+    uvicorn_reload = uvicorn_kwargs.pop("reload", None)
+
+    if uvicorn_reload is None or uvicorn_reload:
+        uvicorn_kwargs["reload"] = True
+
+    uvicorn_app = uvicorn_kwargs.pop("app", None) or "openbb_core.api.rest_api:app"
+
+    uvicorn.run(uvicorn_app, **uvicorn_kwargs)

openbb_platform/core/openbb_core/app/logs/handlers/posthog_handler.py

@@ -94,7 +94,8 @@ def log_to_dict(self, log_info: str) -> dict:
     def send(self, record: logging.LogRecord):
         """Send log record to Posthog."""
         # pylint: disable=import-outside-toplevel
-        import re
+        import re  # noqa
+        from openbb_core.provider.utils.helpers import get_certificates, restore_certs
 
         level_name = logging.getLevelName(record.levelno)
         log_line = FormatterWithExceptions.filter_log_line(text=record.getMessage())
@@ -116,8 +117,10 @@ def send(self, record: logging.LogRecord):
         if event_name not in [e.value for e in self.AllowedEvents]:
             return
 
+        old_verify = get_certificates()
         self.identify()
         posthog.capture(self.distinct_id(), event_name, properties=log_extra)
+        restore_certs(old_verify)
 
     def extract_log_extra(self, record: logging.LogRecord) -> Dict[str, Any]:
         """Extract log extra from record."""

openbb_platform/core/openbb_core/app/model/python_settings.py

@@ -2,12 +2,14 @@
 
 from typing import List, Optional
 
-from pydantic import BaseModel, Field, PositiveInt
+from pydantic import BaseModel, ConfigDict, Field, PositiveInt
 
 
 class PythonSettings(BaseModel):
     """Settings model for Python interface configuration."""
 
+    model_config = ConfigDict(extra="allow")
+
     docstring_sections: List[str] = Field(
         default_factory=lambda: ["description", "parameters", "returns", "examples"],
         description="Sections to include in autogenerated docstrings.",

openbb_platform/core/openbb_core/app/service/hub_service.py

@@ -39,9 +39,14 @@ def __init__(
         base_url: Optional[str] = None,
     ):
         """Initialize Hub service."""
+        # pylint: disable=import-outside-toplevel
+        from openbb_core.provider.utils.helpers import get_certificates, restore_certs
+
         self._base_url = base_url or Env().HUB_BACKEND
         self._session = session
         self._hub_user_settings: Optional[HubUserSettings] = None
+        self._get_certificates = get_certificates
+        self._restore_certs = restore_certs
 
     @property
     def base_url(self) -> str:
@@ -70,10 +75,13 @@ def connect(
 
     def disconnect(self) -> bool:
         """Disconnect from Hub."""
+        old_verify = self._get_certificates()
         if self._session:
             result = self._post_logout(self._session)
             self._session = None
+            self._restore_certs(old_verify)
             return result
+        self._restore_certs(old_verify)
         raise OpenBBError(
             "No session found. Login or provide a 'HubSession' on initialization."
         )
@@ -112,6 +120,8 @@ def _get_session_from_email_password(self, email: str, password: str) -> HubSess
         if not password:
             raise OpenBBError("Password not found.")
 
+        old_verify = self._get_certificates()
+
         response = post(
             url=self._base_url + "/login",
             json={
@@ -122,6 +132,8 @@ def _get_session_from_email_password(self, email: str, password: str) -> HubSess
             timeout=self.TIMEOUT,
         )
 
+        self._restore_certs(old_verify)
+
         if response.status_code == 200:
             session = response.json()
             hub_session = HubSession(
@@ -143,6 +155,7 @@ def _get_session_from_platform_token(self, token: str) -> HubSession:
             raise OpenBBError("Platform personal access token not found.")
 
         self._check_token_expiration(token)
+        old_verify = self._get_certificates()
 
         response = post(
             url=self._base_url + "/sdk/login",
@@ -152,6 +165,8 @@ def _get_session_from_platform_token(self, token: str) -> HubSession:
             timeout=self.TIMEOUT,
         )
 
+        self._restore_certs(old_verify)
+
         if response.status_code == 200:
             session = response.json()
             hub_session = HubSession(
@@ -172,6 +187,7 @@ def _post_logout(self, session: HubSession) -> bool:
         access_token = session.access_token.get_secret_value()
         token_type = session.token_type
         authorization = f"{token_type.title()} {access_token}"
+        old_verify = self._get_certificates()
 
         response = get(
             url=self._base_url + "/logout",
@@ -180,6 +196,8 @@ def _post_logout(self, session: HubSession) -> bool:
             timeout=self.TIMEOUT,
         )
 
+        self._restore_certs(old_verify)
+
         if response.status_code == 200:
             result = response.json()
             return result.get("success", False)
@@ -193,12 +211,15 @@ def _get_user_settings(self, session: HubSession) -> HubUserSettings:
         access_token = session.access_token.get_secret_value()
         token_type = session.token_type
         authorization = f"{token_type.title()} {access_token}"
+        old_verify = self._get_certificates()
 
         response = get(
             url=self._base_url + "/terminal/user",
             headers={"Authorization": authorization},
             timeout=self.TIMEOUT,
         )
+        self._restore_certs(old_verify)
+
         if response.status_code == 200:
             user_settings = response.json()
             filtered = {k: v for k, v in user_settings.items() if v is not None}
@@ -214,6 +235,7 @@ def _put_user_settings(
         access_token = session.access_token.get_secret_value()
         token_type = session.token_type
         authorization = f"{token_type.title()} {access_token}"
+        old_verify = self._get_certificates()
 
         response = put(
             url=self._base_url + "/user",
@@ -222,6 +244,8 @@ def _put_user_settings(
             timeout=self.TIMEOUT,
         )
 
+        self._restore_certs(old_verify)
+
         if response.status_code == 200:
             return True
         status_code = response.status_code