refactor(integrations): use env constants in remaining from_env loaders

Point Postgres, MySQL, Better Stack, SigNoz, and Sentry env reads at the shared config.constants names so catalog discovery and runtime loaders cannot drift.

Author: VaibhavUpreti

config/constants/__init__.py

@@ -304,6 +304,7 @@
     SENTRY_MAX_BREADCRUMBS,
     SENTRY_ORGANIZATION_SLUG_ENV,
     SENTRY_PROJECT_SLUG_ENV,
+    SENTRY_STATS_PERIOD_ENV,
     SENTRY_TRACES_SAMPLE_RATE,
 )
 from config.constants.sentry_mcp import (
@@ -613,6 +614,7 @@
     "SENTRY_MCP_URL_ENV",
     "SENTRY_ORGANIZATION_SLUG_ENV",
     "SENTRY_PROJECT_SLUG_ENV",
+    "SENTRY_STATS_PERIOD_ENV",
     "SENTRY_TRACES_SAMPLE_RATE",
     "SERVICENOW_INSTANCE_URL_ENV",
     "SERVICENOW_PASSWORD_ENV",

config/constants/sentry.py

@@ -26,4 +26,5 @@
 SENTRY_ORGANIZATION_SLUG_ENV: Final[str] = "SENTRY_ORG_SLUG"
 SENTRY_AUTH_TOKEN_ENV: Final[str] = "SENTRY_AUTH_TOKEN"
 SENTRY_PROJECT_SLUG_ENV: Final[str] = "SENTRY_PROJECT_SLUG"
+SENTRY_STATS_PERIOD_ENV: Final[str] = "SENTRY_STATS_PERIOD"
 DEFAULT_SENTRY_BASE_URL: Final[str] = "https://sentry.io"

integrations/betterstack/__init__.py

@@ -28,6 +28,12 @@
 import httpx
 from pydantic import Field, field_validator
 
+from config.constants.betterstack import (
+    BETTERSTACK_PASSWORD_ENV,
+    BETTERSTACK_QUERY_ENDPOINT_ENV,
+    BETTERSTACK_SOURCES_ENV,
+    BETTERSTACK_USERNAME_ENV,
+)
 from config.strict_config import StrictConfigModel
 from core.tool_framework.utils.tool_availability import tool_unavailable
 from integrations._validation_helpers import report_classify_failure, report_validation_failure
@@ -104,16 +110,16 @@ def betterstack_config_from_env() -> BetterStackConfig | None:
     surfaced to the planner via :func:`betterstack_extract_params`; it is
     not required for availability.
     """
-    endpoint = os.getenv("BETTERSTACK_QUERY_ENDPOINT", "").strip()
-    username = os.getenv("BETTERSTACK_USERNAME", "").strip()
+    endpoint = os.getenv(BETTERSTACK_QUERY_ENDPOINT_ENV, "").strip()
+    username = os.getenv(BETTERSTACK_USERNAME_ENV, "").strip()
     if not endpoint or not username:
         return None
     return build_betterstack_config(
         {
             "query_endpoint": endpoint,
             "username": username,
-            "password": os.getenv("BETTERSTACK_PASSWORD", ""),
-            "sources": os.getenv("BETTERSTACK_SOURCES", ""),
+            "password": os.getenv(BETTERSTACK_PASSWORD_ENV, ""),
+            "sources": os.getenv(BETTERSTACK_SOURCES_ENV, ""),
         }
     )
 

integrations/mysql/__init__.py

@@ -14,6 +14,14 @@
 
 from pydantic import Field, field_validator
 
+from config.constants.mysql import (
+    MYSQL_DATABASE_ENV,
+    MYSQL_HOST_ENV,
+    MYSQL_PASSWORD_ENV,
+    MYSQL_PORT_ENV,
+    MYSQL_SSL_MODE_ENV,
+    MYSQL_USERNAME_ENV,
+)
 from integrations._relational import (
     RelationalConfigBase,
     env_int,
@@ -80,18 +88,18 @@ def build_mysql_config(raw: dict[str, Any] | None) -> MySQLConfig:
 
 def mysql_config_from_env() -> MySQLConfig | None:
     """Load a MySQL config from environment variables."""
-    host = env_str("MYSQL_HOST")
-    database = env_str("MYSQL_DATABASE")
+    host = env_str(MYSQL_HOST_ENV)
+    database = env_str(MYSQL_DATABASE_ENV)
     if not host or not database:
         return None
     return build_mysql_config(
         {
             "host": host,
-            "port": env_int("MYSQL_PORT", DEFAULT_MYSQL_PORT),
+            "port": env_int(MYSQL_PORT_ENV, DEFAULT_MYSQL_PORT),
             "database": database,
-            "username": env_str("MYSQL_USERNAME", DEFAULT_MYSQL_USER),
-            "password": os.getenv("MYSQL_PASSWORD", ""),
-            "ssl_mode": env_str("MYSQL_SSL_MODE", DEFAULT_MYSQL_SSL_MODE),
+            "username": env_str(MYSQL_USERNAME_ENV, DEFAULT_MYSQL_USER),
+            "password": os.getenv(MYSQL_PASSWORD_ENV, ""),
+            "ssl_mode": env_str(MYSQL_SSL_MODE_ENV, DEFAULT_MYSQL_SSL_MODE),
         }
     )
 

integrations/postgresql/__init__.py

@@ -14,6 +14,14 @@
 
 from pydantic import Field, field_validator
 
+from config.constants.postgresql import (
+    POSTGRESQL_DATABASE_ENV,
+    POSTGRESQL_HOST_ENV,
+    POSTGRESQL_PASSWORD_ENV,
+    POSTGRESQL_PORT_ENV,
+    POSTGRESQL_SSL_MODE_ENV,
+    POSTGRESQL_USERNAME_ENV,
+)
 from core.tool_framework.utils.tool_availability import tool_unavailable
 from integrations._relational import (
     RelationalConfigBase,
@@ -77,18 +85,18 @@ def build_postgresql_config(raw: dict[str, Any] | None) -> PostgreSQLConfig:
 
 def postgresql_config_from_env() -> PostgreSQLConfig | None:
     """Load a PostgreSQL config from env vars."""
-    host = env_str("POSTGRESQL_HOST")
-    database = env_str("POSTGRESQL_DATABASE")
+    host = env_str(POSTGRESQL_HOST_ENV)
+    database = env_str(POSTGRESQL_DATABASE_ENV)
     if not host or not database:
         return None
     return build_postgresql_config(
         {
             "host": host,
-            "port": env_int("POSTGRESQL_PORT", DEFAULT_POSTGRESQL_PORT),
+            "port": env_int(POSTGRESQL_PORT_ENV, DEFAULT_POSTGRESQL_PORT),
             "database": database,
-            "username": env_str("POSTGRESQL_USERNAME", DEFAULT_POSTGRESQL_USER),
-            "password": os.getenv("POSTGRESQL_PASSWORD", ""),
-            "ssl_mode": env_str("POSTGRESQL_SSL_MODE", DEFAULT_POSTGRESQL_SSL_MODE),
+            "username": env_str(POSTGRESQL_USERNAME_ENV, DEFAULT_POSTGRESQL_USER),
+            "password": os.getenv(POSTGRESQL_PASSWORD_ENV, ""),
+            "ssl_mode": env_str(POSTGRESQL_SSL_MODE_ENV, DEFAULT_POSTGRESQL_SSL_MODE),
         }
     )
 

integrations/sentry/__init__.py

@@ -18,6 +18,7 @@
     SENTRY_BASE_URL_ENV,
     SENTRY_ORGANIZATION_SLUG_ENV,
     SENTRY_PROJECT_SLUG_ENV,
+    SENTRY_STATS_PERIOD_ENV,
 )
 from config.llm_credentials import resolve_env_credential
 from config.strict_config import StrictConfigModel
@@ -42,7 +43,7 @@
 
 def _resolve_stats_period(explicit: str | None = None) -> str:
     """Resolve the issues lookback window, overridable via ``SENTRY_STATS_PERIOD``."""
-    period = (explicit or os.getenv("SENTRY_STATS_PERIOD", "") or "").strip()
+    period = (explicit or os.getenv(SENTRY_STATS_PERIOD_ENV, "") or "").strip()
     return period or DEFAULT_SENTRY_STATS_PERIOD
 
 

integrations/signoz/__init__.py

@@ -14,6 +14,7 @@
 import httpx
 from pydantic import Field
 
+from config.constants.signoz import SIGNOZ_API_KEY_ENV, SIGNOZ_URL_ENV
 from config.strict_config import StrictConfigModel
 from integrations._validation_helpers import report_classify_failure, report_validation_failure
 
@@ -52,8 +53,8 @@ def build_signoz_config(raw: dict[str, Any] | None) -> SigNozConfig:
 
 def signoz_config_from_env() -> SigNozConfig | None:
     """Load a SigNoz config from env vars."""
-    url = os.getenv("SIGNOZ_URL", "").strip()
-    api_key = os.getenv("SIGNOZ_API_KEY", "").strip()
+    url = os.getenv(SIGNOZ_URL_ENV, "").strip()
+    api_key = os.getenv(SIGNOZ_API_KEY_ENV, "").strip()
 
     if not (url and api_key):
         return None