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

openbb_platform/core/openbb_core/api/rest_api.py

@@ -85,6 +85,17 @@ async def lifespan(_: FastAPI):
 
 
 if __name__ == "__main__":
+    # pylint: disable=import-outside-toplevel
     import uvicorn
 
-    uvicorn.run("openbb_core.api.rest_api:app", reload=True)
+    # This initializes the OpenBB environment variables so they can be read before uvicorn is run.
+    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", "openbb_core.api.rest_api:app")
+
+    uvicorn.run(uvicorn_app, **uvicorn_kwargs)

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

@@ -26,12 +26,17 @@ class AllowedEvents(Enum):
 
     def __init__(self, settings: LoggingSettings):
         """Initialize Posthog Handler."""
+        # pylint: disable=import-outside-toplevel
+        from openbb_core.provider.utils.helpers import get_requests_session
 
         super().__init__()
         self._settings = settings
         self.logged_in = False
         posthog.api_key = "phc_6FXLqu4uW9yxfyN8DpPdgzCdlYXOmIWdMGh6GnBgJLX"  # pragma: allowlist secret  # noqa
         posthog.host = "https://app.posthog.com"  # noqa
+        posthog.request._session = (  # pylint: disable=protected-access
+            get_requests_session()
+        )
 
     @property
     def settings(self) -> LoggingSettings:

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

@@ -2,19 +2,70 @@
 
 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.",
     )
     docstring_max_length: Optional[PositiveInt] = Field(
         default=None, description="Maximum length of autogenerated docstrings."
     )
+    http: Optional[dict] = Field(
+        default_factory=dict,
+        description="HTTP settings covers all requests made by the internal, utility, functions."
+        + " The configuration applies to both the requests and aiohttp libraries."
+        + "\n    "
+        + """Available settings:
+            - cafile: str - Path to a CA certificate file.
+            - certfile: str - Path to a client certificate file.
+            - keyfile: str - Path to a client key file.
+            - password: str - Password for the client key file.  # aiohttp only
+            - verify_ssl: bool - Verify SSL certificates.
+            - fingerprint: str - SSL fingerprint.  # aiohttp only
+            - proxy: str - Proxy URL.
+            - proxy_auth: str | list - Proxy authentication.  # aiohttp only
+            - proxy_headers: dict - Proxy headers.  # aiohttp only
+            - timeout: int - Request timeout.
+            - auth: str | list - Basic authentication.
+            - headers: dict - Request headers.
+            - cookies: dict - Dictionary of session cookies.
+
+        Any additional keys supplied will be ignored unless explicitly implemented via custom code.
+
+        The settings are passed into the `requests.Session` object and the `aiohttp.ClientSession` object by:
+            - `openbb_core.provider.utils.helpers.make_request` - Sync
+            - `openbb_core.provider.utils.helpers.amake_request` - Async
+            - `openbb_core.provider.utils.helpers.amake_requests` - Async (multiple requests)
+            - Inserted to use with YFinance & Finviz library implementations.
+
+        Return a session object with the settings applied by:
+            - `openbb_core.provider.utils.helpers.get_requests_session`
+            - `openbb_core.provider.utils.helpers.get_async_requests_session`
+        """,
+    )
+    uvicorn: Optional[dict] = Field(
+        default_factory=dict,
+        description="Uvicorn settings, covers all the launch of FastAPI when using the following entry points:"
+        + "\n    "
+        + """
+            - Running the FastAPI as a Python module script.
+              - python -m openbb_core.api.rest_api
+            - Running the `openbb-api` command.
+                - openbb-api
+
+        All settings are passed directly to `uvicorn.run`, and can be found in the Uvicorn documentation.
+            - https://www.uvicorn.org/settings/
+
+        Keyword arguments supplied to the command line will take priority over the settings in this configuration.
+        """,
+    )
 
     def __repr__(self) -> str:
         """Return a string representation of the model."""

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

@@ -13,7 +13,6 @@
 from openbb_core.app.model.profile import Profile
 from openbb_core.app.model.user_settings import UserSettings
 from openbb_core.env import Env
-from requests import get, post, put
 
 
 class HubService:
@@ -39,9 +38,13 @@ def __init__(
         base_url: Optional[str] = None,
     ):
         """Initialize Hub service."""
+        # pylint: disable=import-outside-toplevel
+        from openbb_core.provider.utils.helpers import get_requests_session
+
         self._base_url = base_url or Env().HUB_BACKEND
         self._session = session
         self._hub_user_settings: Optional[HubUserSettings] = None
+        self._request_session = get_requests_session()
 
     @property
     def base_url(self) -> str:
@@ -112,7 +115,7 @@ def _get_session_from_email_password(self, email: str, password: str) -> HubSess
         if not password:
             raise OpenBBError("Password not found.")
 
-        response = post(
+        response = self._request_session.post(
             url=self._base_url + "/login",
             json={
                 "email": email,
@@ -144,7 +147,7 @@ def _get_session_from_platform_token(self, token: str) -> HubSession:
 
         self._check_token_expiration(token)
 
-        response = post(
+        response = self._request_session.post(
             url=self._base_url + "/sdk/login",
             json={
                 "token": token,
@@ -173,7 +176,7 @@ def _post_logout(self, session: HubSession) -> bool:
         token_type = session.token_type
         authorization = f"{token_type.title()} {access_token}"
 
-        response = get(
+        response = self._request_session.get(
             url=self._base_url + "/logout",
             headers={"Authorization": authorization},
             json={"token": access_token},
@@ -193,12 +196,12 @@ 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}"
-
-        response = get(
+        response = self._request_session.get(
             url=self._base_url + "/terminal/user",
             headers={"Authorization": authorization},
             timeout=self.TIMEOUT,
         )
+
         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,14 +217,12 @@ def _put_user_settings(
         access_token = session.access_token.get_secret_value()
         token_type = session.token_type
         authorization = f"{token_type.title()} {access_token}"
-
-        response = put(
+        response = self._request_session.put(
             url=self._base_url + "/user",
             headers={"Authorization": authorization},
             json=settings.model_dump(exclude_defaults=True),
             timeout=self.TIMEOUT,
         )
-
         if response.status_code == 200:
             return True
         status_code = response.status_code

openbb_platform/core/openbb_core/provider/utils/errors.py

@@ -36,4 +36,4 @@ def __init__(
                 msg = msg.replace("<provider name>", provider_name)
             message = msg
         self.message = message
-        super().__init__(self.message)
+        super().__init__(str(self.message))