feat: add Support Engineer (auto error detection and repair)

src/config/features.py

@@ -65,6 +65,10 @@ def api_server_enabled(self) -> bool:
     def scheduler_enabled(self) -> bool:
         """Check if the job scheduler is enabled."""
         return self.settings.enable_scheduler
+    @property
+    def support_engineer_enabled(self) -> bool:
+        return self.settings.enable_support_engineer
+
 
     @property
     def agentic_mode_enabled(self) -> bool:
@@ -100,6 +104,7 @@ def is_feature_enabled(self, feature_name: str) -> bool:
             "development": self.development_features_enabled,
             "api_server": self.api_server_enabled,
             "scheduler": self.scheduler_enabled,
+            "support_engineer": self.support_engineer_enabled,
             "agentic_mode": self.agentic_mode_enabled,
             "voice_messages": self.voice_messages_enabled,
             "stream_drafts": self.stream_drafts_enabled,

src/config/settings.py

@@ -299,6 +299,11 @@ class Settings(BaseSettings):
     enable_api_server: bool = Field(False, description="Enable FastAPI webhook server")
     api_server_port: int = Field(8080, description="Webhook API server port")
     enable_scheduler: bool = Field(False, description="Enable job scheduler")
+    enable_support_engineer: bool = Field(
+        False,
+        description="Enable Support Engineer (auto error detection)",
+    )
+
     github_webhook_secret: Optional[str] = Field(
         None, description="GitHub webhook HMAC secret"
     )

src/main.py

@@ -1,6 +1,7 @@
 """Main entry point for Claude Code Telegram Bot."""
 
 import argparse
+import os
 import asyncio
 import logging
 import signal
@@ -17,6 +18,7 @@
     SessionManager,
 )
 from src.claude.sdk_integration import ClaudeSDKManager
+from src.claude.cli_manager import CLIManager
 from src.config.features import FeatureFlags
 from src.config.settings import Settings
 from src.events.bus import EventBus
@@ -26,6 +28,7 @@
 from src.notifications.service import NotificationService
 from src.projects import ProjectThreadManager, load_project_registry
 from src.scheduler.scheduler import JobScheduler
+from src.scheduler.support_engineer import SupportEngineer, set_bot_and_owner
 from src.security.audit import AuditLogger, InMemoryAuditStorage
 from src.security.auth import (
     AuthenticationManager,
@@ -140,15 +143,24 @@ async def create_application(config: Settings) -> Dict[str, Any]:
     session_storage = SQLiteSessionStorage(storage.db_manager)
     session_manager = SessionManager(config, session_storage)
 
-    # Create Claude SDK manager and integration facade
-    logger.info("Using Claude Python SDK integration")
-    sdk_manager = ClaudeSDKManager(config, security_validator=security_validator)
-
-    claude_integration = ClaudeIntegration(
-        config=config,
-        sdk_manager=sdk_manager,
-        session_manager=session_manager,
-    )
+    # Create Claude manager based on integration mode
+    integration_mode = os.getenv("CLAUDE_INTEGRATION_MODE", "sdk").lower()
+    if integration_mode == "cli":
+        logger.info("Using Claude CLI subprocess integration")
+        cli_manager = CLIManager(config, security_validator=security_validator)
+        claude_integration = ClaudeIntegration(
+            config=config,
+            cli_manager=cli_manager,
+            session_manager=session_manager,
+        )
+    else:
+        logger.info("Using Claude Python SDK integration")
+        sdk_manager = ClaudeSDKManager(config, security_validator=security_validator)
+        claude_integration = ClaudeIntegration(
+            config=config,
+            sdk_manager=sdk_manager,
+            session_manager=session_manager,
+        )
 
     # --- Event bus and agentic platform components ---
     event_bus = EventBus()
@@ -316,6 +328,17 @@ def signal_handler(signum: int, frame: Any) -> None:
             await scheduler.start()
             logger.info("Job scheduler enabled")
 
+        # Support Engineer - automatic error detection and repair
+        if features.support_engineer_enabled:
+            owner_chat_id = config.allowed_users[0] if config.allowed_users else None
+            if owner_chat_id:
+                set_bot_and_owner(bot=telegram_bot, owner_chat_id=owner_chat_id)
+                support_engineer = SupportEngineer()
+                support_engineer.start()
+                logger.info("support_engineer.enabled", owner_chat_id=owner_chat_id)
+            else:
+                logger.warning("support_engineer.skipped_no_owner")
+
         # Shutdown task
         shutdown_task = asyncio.create_task(shutdown_event.wait())
         tasks.append(shutdown_task)