[codex] Route runtime errors to main bot

.github/workflows/execution-report-heartbeat.yml

@@ -54,10 +54,7 @@ jobs:
       RUNTIME_HEARTBEAT_REJECT_STATUSES: ${{ vars.RUNTIME_HEARTBEAT_REJECT_STATUSES }}
       CLOUD_RUN_SERVICE: ${{ vars.CLOUD_RUN_SERVICE }}
       GLOBAL_TELEGRAM_CHAT_ID: ${{ vars.GLOBAL_TELEGRAM_CHAT_ID }}
-      CRISIS_ALERT_TELEGRAM_CHAT_IDS: ${{ vars.CRISIS_ALERT_TELEGRAM_CHAT_IDS }}
-      CRISIS_ALERT_TELEGRAM_API_BASE_URL: ${{ vars.CRISIS_ALERT_TELEGRAM_API_BASE_URL }}
       TELEGRAM_TOKEN: ${{ secrets.TELEGRAM_TOKEN }}
-      CRISIS_ALERT_TELEGRAM_BOT_TOKEN: ${{ secrets.CRISIS_ALERT_TELEGRAM_BOT_TOKEN }}
     steps:
       - name: Checkout repository
         uses: actions/checkout@v6

.github/workflows/runtime-guard.yml

@@ -59,10 +59,7 @@ jobs:
       RUNTIME_GUARD_SCHEDULER_JOB_PATTERN: ${{ vars.RUNTIME_GUARD_SCHEDULER_JOB_PATTERN || vars.CLOUD_RUN_SERVICE }}
       CLOUD_RUN_SERVICE: ${{ vars.CLOUD_RUN_SERVICE }}
       GLOBAL_TELEGRAM_CHAT_ID: ${{ vars.GLOBAL_TELEGRAM_CHAT_ID }}
-      CRISIS_ALERT_TELEGRAM_CHAT_IDS: ${{ vars.CRISIS_ALERT_TELEGRAM_CHAT_IDS }}
-      CRISIS_ALERT_TELEGRAM_API_BASE_URL: ${{ vars.CRISIS_ALERT_TELEGRAM_API_BASE_URL }}
       TELEGRAM_TOKEN: ${{ secrets.TELEGRAM_TOKEN }}
-      CRISIS_ALERT_TELEGRAM_BOT_TOKEN: ${{ secrets.CRISIS_ALERT_TELEGRAM_BOT_TOKEN }}
     steps:
       - name: Checkout repository
         uses: actions/checkout@v6

main.py

@@ -313,10 +313,6 @@ def _runtime_error_notification_targets() -> tuple[tuple[str, str], ...]:
     targets: list[tuple[str, str]] = []
     if TG_TOKEN and TG_CHAT_ID:
         targets.append((TG_TOKEN, TG_CHAT_ID))
-    crisis_token = os.getenv("CRISIS_ALERT_TELEGRAM_BOT_TOKEN")
-    for chat_id in _split_env_list(os.getenv("CRISIS_ALERT_TELEGRAM_CHAT_IDS")):
-        if crisis_token and chat_id:
-            targets.append((crisis_token, chat_id))
 
     seen: set[tuple[str, str]] = set()
     unique_targets: list[tuple[str, str]] = []

requirements.txt

@@ -1,6 +1,6 @@
 flask
 gunicorn
-quant-platform-kit @ git+https://github.com/QuantStrategyLab/QuantPlatformKit.git@v0.7.37
+quant-platform-kit @ git+https://github.com/QuantStrategyLab/QuantPlatformKit.git@3b6a0a9bedde72773e188041e0dc48516b38aadc
 us-equity-strategies @ git+https://github.com/QuantStrategyLab/UsEquityStrategies.git@v0.7.52
 hk-equity-strategies @ git+https://github.com/QuantStrategyLab/HkEquityStrategies.git@v0.4.3
 pandas

runtime_config_support.py

@@ -69,36 +69,36 @@ class PlatformRuntimeSettings:
     strategy_config_path: str | None = None
     strategy_config_source: str | None = None
     strategy_plugin_mounts_json: str | None = None
-    crisis_alert_channels: tuple[str, ...] = ()
-    crisis_alert_email_recipients: tuple[str, ...] = ()
-    crisis_alert_email_sender_email: str | None = None
-    crisis_alert_email_sender_password: str | None = None
-    crisis_alert_email_smtp_host: str | None = None
-    crisis_alert_email_smtp_port: str | None = None
-    crisis_alert_email_smtp_security: str | None = None
-    crisis_alert_sms_recipients: tuple[str, ...] = ()
-    crisis_alert_sms_provider: str | None = None
-    crisis_alert_sms_account_id: str | None = None
-    crisis_alert_sms_auth_token: str | None = None
-    crisis_alert_sms_sender: str | None = None
-    crisis_alert_sms_messaging_service_id: str | None = None
-    crisis_alert_sms_api_base_url: str | None = None
-    crisis_alert_sms_body_max_chars: str | None = None
-    crisis_alert_push_recipients: tuple[str, ...] = ()
-    crisis_alert_push_provider: str | None = None
-    crisis_alert_push_app_token: str | None = None
-    crisis_alert_push_access_token: str | None = None
-    crisis_alert_push_api_base_url: str | None = None
-    crisis_alert_push_device: str | None = None
-    crisis_alert_push_priority: str | None = None
-    crisis_alert_push_tags: str | None = None
-    crisis_alert_push_body_max_chars: str | None = None
-    crisis_alert_telegram_chat_ids: tuple[str, ...] = ()
-    crisis_alert_telegram_bot_token: str | None = None
-    crisis_alert_telegram_api_base_url: str | None = None
-    crisis_alert_telegram_parse_mode: str | None = None
-    crisis_alert_telegram_disable_web_page_preview: str | None = None
-    crisis_alert_telegram_body_max_chars: str | None = None
+    strategy_plugin_alert_channels: tuple[str, ...] = ()
+    strategy_plugin_alert_email_recipients: tuple[str, ...] = ()
+    strategy_plugin_alert_email_sender_email: str | None = None
+    strategy_plugin_alert_email_sender_password: str | None = None
+    strategy_plugin_alert_email_smtp_host: str | None = None
+    strategy_plugin_alert_email_smtp_port: str | None = None
+    strategy_plugin_alert_email_smtp_security: str | None = None
+    strategy_plugin_alert_sms_recipients: tuple[str, ...] = ()
+    strategy_plugin_alert_sms_provider: str | None = None
+    strategy_plugin_alert_sms_account_id: str | None = None
+    strategy_plugin_alert_sms_auth_token: str | None = None
+    strategy_plugin_alert_sms_sender: str | None = None
+    strategy_plugin_alert_sms_messaging_service_id: str | None = None
+    strategy_plugin_alert_sms_api_base_url: str | None = None
+    strategy_plugin_alert_sms_body_max_chars: str | None = None
+    strategy_plugin_alert_push_recipients: tuple[str, ...] = ()
+    strategy_plugin_alert_push_provider: str | None = None
+    strategy_plugin_alert_push_app_token: str | None = None
+    strategy_plugin_alert_push_access_token: str | None = None
+    strategy_plugin_alert_push_api_base_url: str | None = None
+    strategy_plugin_alert_push_device: str | None = None
+    strategy_plugin_alert_push_priority: str | None = None
+    strategy_plugin_alert_push_tags: str | None = None
+    strategy_plugin_alert_push_body_max_chars: str | None = None
+    strategy_plugin_alert_telegram_chat_ids: tuple[str, ...] = ()
+    strategy_plugin_alert_telegram_bot_token: str | None = None
+    strategy_plugin_alert_telegram_api_base_url: str | None = None
+    strategy_plugin_alert_telegram_parse_mode: str | None = None
+    strategy_plugin_alert_telegram_disable_web_page_preview: str | None = None
+    strategy_plugin_alert_telegram_body_max_chars: str | None = None
     runtime_target: RuntimeTarget | None = None
 
 
@@ -255,57 +255,57 @@ def load_platform_runtime_settings(
             os.getenv("LONGBRIDGE_STRATEGY_PLUGIN_MOUNTS_JSON")
             or os.getenv("STRATEGY_PLUGIN_MOUNTS_JSON")
         ),
-        crisis_alert_channels=_split_env_list(os.getenv("CRISIS_ALERT_CHANNELS")),
-        crisis_alert_email_recipients=_split_env_list(os.getenv("CRISIS_ALERT_EMAIL_RECIPIENTS")),
-        crisis_alert_email_sender_email=_first_non_empty(os.getenv("CRISIS_ALERT_EMAIL_SENDER_EMAIL")),
-        crisis_alert_email_sender_password=_first_non_empty(
-            os.getenv("CRISIS_ALERT_EMAIL_SENDER_PASSWORD")
+        strategy_plugin_alert_channels=_split_env_list(os.getenv("STRATEGY_PLUGIN_ALERT_CHANNELS")),
+        strategy_plugin_alert_email_recipients=_split_env_list(os.getenv("STRATEGY_PLUGIN_ALERT_EMAIL_RECIPIENTS")),
+        strategy_plugin_alert_email_sender_email=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_EMAIL_SENDER_EMAIL")),
+        strategy_plugin_alert_email_sender_password=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_EMAIL_SENDER_PASSWORD")
         ),
-        crisis_alert_email_smtp_host=_first_non_empty(os.getenv("CRISIS_ALERT_EMAIL_SMTP_HOST")),
-        crisis_alert_email_smtp_port=_first_non_empty(os.getenv("CRISIS_ALERT_EMAIL_SMTP_PORT")),
-        crisis_alert_email_smtp_security=_first_non_empty(
-            os.getenv("CRISIS_ALERT_EMAIL_SMTP_SECURITY")
+        strategy_plugin_alert_email_smtp_host=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_EMAIL_SMTP_HOST")),
+        strategy_plugin_alert_email_smtp_port=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_EMAIL_SMTP_PORT")),
+        strategy_plugin_alert_email_smtp_security=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_EMAIL_SMTP_SECURITY")
         ),
-        crisis_alert_sms_recipients=_split_env_list(os.getenv("CRISIS_ALERT_SMS_RECIPIENTS")),
-        crisis_alert_sms_provider=_first_non_empty(os.getenv("CRISIS_ALERT_SMS_PROVIDER")),
-        crisis_alert_sms_account_id=_first_non_empty(os.getenv("CRISIS_ALERT_SMS_ACCOUNT_ID")),
-        crisis_alert_sms_auth_token=_first_non_empty(os.getenv("CRISIS_ALERT_SMS_AUTH_TOKEN")),
-        crisis_alert_sms_sender=_first_non_empty(os.getenv("CRISIS_ALERT_SMS_SENDER")),
-        crisis_alert_sms_messaging_service_id=_first_non_empty(
-            os.getenv("CRISIS_ALERT_SMS_MESSAGING_SERVICE_ID")
+        strategy_plugin_alert_sms_recipients=_split_env_list(os.getenv("STRATEGY_PLUGIN_ALERT_SMS_RECIPIENTS")),
+        strategy_plugin_alert_sms_provider=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_SMS_PROVIDER")),
+        strategy_plugin_alert_sms_account_id=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_SMS_ACCOUNT_ID")),
+        strategy_plugin_alert_sms_auth_token=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_SMS_AUTH_TOKEN")),
+        strategy_plugin_alert_sms_sender=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_SMS_SENDER")),
+        strategy_plugin_alert_sms_messaging_service_id=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_SMS_MESSAGING_SERVICE_ID")
         ),
-        crisis_alert_sms_api_base_url=_first_non_empty(os.getenv("CRISIS_ALERT_SMS_API_BASE_URL")),
-        crisis_alert_sms_body_max_chars=_first_non_empty(
-            os.getenv("CRISIS_ALERT_SMS_BODY_MAX_CHARS")
+        strategy_plugin_alert_sms_api_base_url=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_SMS_API_BASE_URL")),
+        strategy_plugin_alert_sms_body_max_chars=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_SMS_BODY_MAX_CHARS")
         ),
-        crisis_alert_push_recipients=_split_env_list(os.getenv("CRISIS_ALERT_PUSH_RECIPIENTS")),
-        crisis_alert_push_provider=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_PROVIDER")),
-        crisis_alert_push_app_token=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_APP_TOKEN")),
-        crisis_alert_push_access_token=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_ACCESS_TOKEN")),
-        crisis_alert_push_api_base_url=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_API_BASE_URL")),
-        crisis_alert_push_device=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_DEVICE")),
-        crisis_alert_push_priority=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_PRIORITY")),
-        crisis_alert_push_tags=_first_non_empty(os.getenv("CRISIS_ALERT_PUSH_TAGS")),
-        crisis_alert_push_body_max_chars=_first_non_empty(
-            os.getenv("CRISIS_ALERT_PUSH_BODY_MAX_CHARS")
+        strategy_plugin_alert_push_recipients=_split_env_list(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_RECIPIENTS")),
+        strategy_plugin_alert_push_provider=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_PROVIDER")),
+        strategy_plugin_alert_push_app_token=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_APP_TOKEN")),
+        strategy_plugin_alert_push_access_token=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_ACCESS_TOKEN")),
+        strategy_plugin_alert_push_api_base_url=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_API_BASE_URL")),
+        strategy_plugin_alert_push_device=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_DEVICE")),
+        strategy_plugin_alert_push_priority=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_PRIORITY")),
+        strategy_plugin_alert_push_tags=_first_non_empty(os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_TAGS")),
+        strategy_plugin_alert_push_body_max_chars=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_PUSH_BODY_MAX_CHARS")
         ),
-        crisis_alert_telegram_chat_ids=_split_env_list(
-            os.getenv("CRISIS_ALERT_TELEGRAM_CHAT_IDS")
+        strategy_plugin_alert_telegram_chat_ids=_split_env_list(
+            os.getenv("STRATEGY_PLUGIN_ALERT_TELEGRAM_CHAT_IDS")
         ),
-        crisis_alert_telegram_bot_token=_first_non_empty(
-            os.getenv("CRISIS_ALERT_TELEGRAM_BOT_TOKEN")
+        strategy_plugin_alert_telegram_bot_token=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_TELEGRAM_BOT_TOKEN")
         ),
-        crisis_alert_telegram_api_base_url=_first_non_empty(
-            os.getenv("CRISIS_ALERT_TELEGRAM_API_BASE_URL")
+        strategy_plugin_alert_telegram_api_base_url=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_TELEGRAM_API_BASE_URL")
         ),
-        crisis_alert_telegram_parse_mode=_first_non_empty(
-            os.getenv("CRISIS_ALERT_TELEGRAM_PARSE_MODE")
+        strategy_plugin_alert_telegram_parse_mode=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_TELEGRAM_PARSE_MODE")
         ),
-        crisis_alert_telegram_disable_web_page_preview=_first_non_empty(
-            os.getenv("CRISIS_ALERT_TELEGRAM_DISABLE_WEB_PAGE_PREVIEW")
+        strategy_plugin_alert_telegram_disable_web_page_preview=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_TELEGRAM_DISABLE_WEB_PAGE_PREVIEW")
         ),
-        crisis_alert_telegram_body_max_chars=_first_non_empty(
-            os.getenv("CRISIS_ALERT_TELEGRAM_BODY_MAX_CHARS")
+        strategy_plugin_alert_telegram_body_max_chars=_first_non_empty(
+            os.getenv("STRATEGY_PLUGIN_ALERT_TELEGRAM_BODY_MAX_CHARS")
         ),
         runtime_target=runtime_target,
     )

scripts/cloud_run_runtime_guard.py

@@ -168,10 +168,6 @@ def _summarize(entry: dict[str, Any]) -> str:
 
 def _send_telegram(message: str) -> bool:
     targets: list[tuple[str, str]] = []
-    crisis_token = os.environ.get("CRISIS_ALERT_TELEGRAM_BOT_TOKEN")
-    for chat_id in _split_values(os.environ.get("CRISIS_ALERT_TELEGRAM_CHAT_IDS")):
-        if crisis_token:
-            targets.append((crisis_token, chat_id))
 
     token = os.environ.get("TELEGRAM_TOKEN") or os.environ.get("TG_TOKEN")
     for chat_id in _split_values(os.environ.get("GLOBAL_TELEGRAM_CHAT_ID")):
@@ -184,7 +180,7 @@ def _send_telegram(message: str) -> bool:
         return False
 
     ok = True
-    base_url = os.environ.get("CRISIS_ALERT_TELEGRAM_API_BASE_URL") or "https://api.telegram.org"
+    base_url = "https://api.telegram.org"
     for token_value, chat_id in unique_targets:
         body = urllib.parse.urlencode({"chat_id": chat_id, "text": message}).encode()
         request = urllib.request.Request(

scripts/execution_report_heartbeat.py

@@ -289,10 +289,6 @@ def _is_accepted_report(payload: dict[str, Any]) -> tuple[bool, str]:
 
 def _send_telegram(message: str) -> bool:
     targets: list[tuple[str, str]] = []
-    crisis_token = os.environ.get("CRISIS_ALERT_TELEGRAM_BOT_TOKEN")
-    for chat_id in _split_values(os.environ.get("CRISIS_ALERT_TELEGRAM_CHAT_IDS")):
-        if crisis_token:
-            targets.append((crisis_token, chat_id))
     token = os.environ.get("TELEGRAM_TOKEN") or os.environ.get("TG_TOKEN")
     for chat_id in _split_values(os.environ.get("GLOBAL_TELEGRAM_CHAT_ID")):
         if token:
@@ -301,7 +297,7 @@ def _send_telegram(message: str) -> bool:
     if not unique_targets:
         print("No Telegram token/chat configured; unable to send heartbeat alert.", file=sys.stderr)
         return False
-    base_url = os.environ.get("CRISIS_ALERT_TELEGRAM_API_BASE_URL") or "https://api.telegram.org"
+    base_url = "https://api.telegram.org"
     ok = True
     for token_value, chat_id in unique_targets:
         body = urllib.parse.urlencode({"chat_id": chat_id, "text": message}).encode()

tests/test_request_handling.py

@@ -71,12 +71,12 @@ def run(self, *args, **kwargs):
         tg_token=None,
         tg_chat_id="shared-chat-id",
         dry_run_only=False,
-        crisis_alert_email_recipients=(),
-        crisis_alert_email_sender_email=None,
-        crisis_alert_email_sender_password=None,
-        crisis_alert_sms_recipients=(),
-        crisis_alert_sms_account_id=None,
-        crisis_alert_sms_auth_token=None,
+        strategy_plugin_alert_email_recipients=(),
+        strategy_plugin_alert_email_sender_email=None,
+        strategy_plugin_alert_email_sender_password=None,
+        strategy_plugin_alert_sms_recipients=(),
+        strategy_plugin_alert_sms_account_id=None,
+        strategy_plugin_alert_sms_auth_token=None,
         runtime_target=build_runtime_target(
             platform_id="longbridge",
             strategy_profile="soxl_soxx_trend_income",
@@ -209,8 +209,16 @@ def fake_run_strategy():
 
         module.run_strategy = fake_run_strategy
 
-        with module.app.test_request_context("/", method="POST"):
-            body, status = module.handle_trigger()
+        with patch.dict(
+            os.environ,
+            {
+                "STRATEGY_PLUGIN_ALERT_TELEGRAM_BOT_TOKEN": "plugin-token",
+                "STRATEGY_PLUGIN_ALERT_TELEGRAM_CHAT_IDS": "plugin-chat",
+            },
+            clear=False,
+        ):
+            with module.app.test_request_context("/", method="POST"):
+                body, status = module.handle_trigger()
 
         self.assertEqual(status, 200)
         self.assertEqual(body, "OK",)