Merge pull request #67 from ryanmac/refactor-long-python-files

refactor: Break down long Python files into modular components

Author: ryanmac

.conductor/conductor_setup/config/__init__.py

@@ -0,0 +1,8 @@
+"""
+Configuration management sub-modules
+"""
+
+from .express_configs import EXPRESS_CONFIGS, get_express_config
+from .interactive import InteractiveConfigurator
+
+__all__ = ["EXPRESS_CONFIGS", "get_express_config", "InteractiveConfigurator"]

.conductor/conductor_setup/config/express_configs.py

@@ -0,0 +1,206 @@
+"""
+Express configuration presets for common project types
+"""
+
+from typing import Dict, Any, Optional
+
+# Express configurations for common project types
+EXPRESS_CONFIGS = {
+    "react-typescript": {
+        "patterns": ["react", "typescript", "tsx", "jsx"],
+        "roles": {"default": "dev", "specialized": ["frontend", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["npm test", "npm run build"],
+        "suggested_tasks": [
+            {
+                "title": "Set up component testing with React Testing Library",
+                "labels": ["conductor:task", "testing", "frontend"],
+            },
+            {
+                "title": "Add Storybook for component development",
+                "labels": ["conductor:task", "enhancement", "frontend"],
+            },
+            {
+                "title": "Configure ESLint and Prettier",
+                "labels": ["conductor:task", "code-quality", "dev-experience"],
+            },
+        ],
+    },
+    "python-fastapi": {
+        "patterns": ["fastapi", "python", "uvicorn", "pydantic"],
+        "roles": {"default": "dev", "specialized": ["backend", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["pytest", "black --check ."],
+        "suggested_tasks": [
+            {
+                "title": "Add API documentation with OpenAPI",
+                "labels": ["conductor:task", "documentation", "backend"],
+            },
+            {
+                "title": "Set up database migrations with Alembic",
+                "labels": ["conductor:task", "database", "backend"],
+            },
+            {
+                "title": "Add integration tests for endpoints",
+                "labels": ["conductor:task", "testing", "backend"],
+            },
+        ],
+    },
+    "nextjs-fullstack": {
+        "patterns": ["next", "react", "vercel"],
+        "roles": {
+            "default": "dev",
+            "specialized": ["frontend", "backend", "code-reviewer"],
+        },
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["npm test", "npm run build", "npm run lint"],
+        "suggested_tasks": [
+            {
+                "title": "Set up authentication with NextAuth.js",
+                "labels": ["conductor:task", "auth", "fullstack"],
+            },
+            {
+                "title": "Configure Prisma for database access",
+                "labels": ["conductor:task", "database", "backend"],
+            },
+            {
+                "title": "Add E2E tests with Playwright",
+                "labels": ["conductor:task", "testing", "e2e"],
+            },
+        ],
+    },
+    "vue-javascript": {
+        "patterns": ["vue", "nuxt", "vite"],
+        "roles": {"default": "dev", "specialized": ["frontend", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["npm test", "npm run build"],
+        "suggested_tasks": [
+            {
+                "title": "Set up Pinia for state management",
+                "labels": ["conductor:task", "state-management", "frontend"],
+            },
+            {
+                "title": "Add component testing with Vitest",
+                "labels": ["conductor:task", "testing", "frontend"],
+            },
+            {
+                "title": "Configure Vue Router for navigation",
+                "labels": ["conductor:task", "routing", "frontend"],
+            },
+        ],
+    },
+    "python-django": {
+        "patterns": ["django", "python", "wsgi"],
+        "roles": {"default": "dev", "specialized": ["backend", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["python manage.py test", "black --check ."],
+        "suggested_tasks": [
+            {
+                "title": "Set up Django REST framework",
+                "labels": ["conductor:task", "api", "backend"],
+            },
+            {
+                "title": "Configure Celery for async tasks",
+                "labels": ["conductor:task", "async", "backend"],
+            },
+            {
+                "title": "Add Django Debug Toolbar",
+                "labels": ["conductor:task", "dev-experience", "backend"],
+            },
+        ],
+    },
+    "go-microservices": {
+        "patterns": ["go", "gin", "fiber", "echo"],
+        "roles": {"default": "dev", "specialized": ["backend", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["go test ./...", "go build"],
+        "suggested_tasks": [
+            {
+                "title": "Set up structured logging with zerolog",
+                "labels": ["conductor:task", "observability", "backend"],
+            },
+            {
+                "title": "Add OpenTelemetry instrumentation",
+                "labels": ["conductor:task", "observability", "backend"],
+            },
+            {
+                "title": "Create Dockerfile and docker-compose",
+                "labels": ["conductor:task", "devops", "containers"],
+            },
+        ],
+    },
+    "rust-cli": {
+        "patterns": ["rust", "cargo", "clap"],
+        "roles": {"default": "dev", "specialized": ["backend", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["cargo test", "cargo build --release"],
+        "suggested_tasks": [
+            {
+                "title": "Add comprehensive CLI tests",
+                "labels": ["conductor:task", "testing", "cli"],
+            },
+            {
+                "title": "Set up GitHub release workflow",
+                "labels": ["conductor:task", "ci-cd", "devops"],
+            },
+            {
+                "title": "Add shell completion generation",
+                "labels": ["conductor:task", "enhancement", "cli"],
+            },
+        ],
+    },
+    "mobile-react-native": {
+        "patterns": ["react-native", "expo", "ios", "android"],
+        "roles": {"default": "dev", "specialized": ["mobile", "code-reviewer"]},
+        "github_integration": {"issue_to_task": True, "pr_reviews": True},
+        "build_validation": ["npm test", "npm run lint"],
+        "suggested_tasks": [
+            {
+                "title": "Set up Detox for E2E testing",
+                "labels": ["conductor:task", "testing", "mobile"],
+            },
+            {
+                "title": "Configure push notifications",
+                "labels": ["conductor:task", "feature", "mobile"],
+            },
+            {
+                "title": "Add crash reporting with Sentry",
+                "labels": ["conductor:task", "monitoring", "mobile"],
+            },
+        ],
+    },
+}
+
+
+def get_express_config(stack_info: Dict[str, Any]) -> Optional[Dict[str, Any]]:
+    """Match detected stack to express config"""
+    # Use the primary stack from summary if available
+    if stack_info.get("summary", {}).get("primary_stack"):
+        stack_name = stack_info["summary"]["primary_stack"]
+        if stack_name in EXPRESS_CONFIGS:
+            return EXPRESS_CONFIGS[stack_name]
+
+    # Otherwise try pattern matching
+    detected_items = set()
+    detected_items.update(stack_info.get("frameworks", []))
+    detected_items.update(stack_info.get("summary", {}).get("languages", []))
+    detected_items.update(stack_info.get("summary", {}).get("tools", []))
+
+    # Add items from modern tools
+    modern = stack_info.get("modern_tools", {})
+    if modern.get("framework"):
+        detected_items.add(modern["framework"])
+    if modern.get("build_tool"):
+        detected_items.add(modern["build_tool"])
+
+    # Find best match
+    best_match = None
+    best_score = 0
+
+    for stack_name, config in EXPRESS_CONFIGS.items():
+        score = len(detected_items.intersection(config["patterns"]))
+        if score > best_score:
+            best_match = stack_name
+            best_score = score
+
+    return EXPRESS_CONFIGS.get(best_match) if best_match and best_score > 0 else None

.conductor/conductor_setup/config/interactive.py

@@ -0,0 +1,151 @@
+"""
+Interactive configuration gathering
+"""
+
+from pathlib import Path
+from typing import Dict, Any, List, Optional
+
+
+class InteractiveConfigurator:
+    """Handles interactive configuration prompts"""
+
+    def __init__(self, project_root: Path, debug: bool = False):
+        self.project_root = project_root
+        self.debug = debug
+        self.config = {}
+
+    def configure(self, detected_stack: List[Dict[str, Any]]) -> Dict[str, Any]:
+        """Run interactive configuration"""
+        print("\n" + "=" * 60)
+        print("🎼 Code Conductor Interactive Setup")
+        print("=" * 60)
+
+        # Basic configuration
+        self.config["project_name"] = self._safe_input(
+            "\n📝 Project name", default=self.project_root.name
+        )
+
+        # Documentation
+        self.config["docs_directory"] = self._get_docs_directory()
+
+        # Agent roles
+        self._configure_roles(detected_stack)
+
+        # Task management
+        self._configure_task_management()
+
+        # Concurrent agents
+        self._configure_concurrent_agents()
+
+        return self.config
+
+    def _safe_input(self, prompt: str, default: Optional[str] = None) -> str:
+        """Get user input with a default value"""
+        if default:
+            prompt = f"{prompt} [{default}]"
+        prompt += ": "
+
+        value = input(prompt).strip()
+        if not value and default:
+            return default
+        return value
+
+    def _get_docs_directory(self) -> str:
+        """Ask for documentation directory"""
+        docs_default = self._find_docs_directory()
+        docs_prompt = "\n📚 Documentation directory"
+        if docs_default:
+            return self._safe_input(docs_prompt, default=docs_default)
+        else:
+            docs_dir = self._safe_input(docs_prompt + " (or 'none')", default="docs")
+            return docs_dir if docs_dir.lower() != "none" else ""
+
+    def _find_docs_directory(self) -> str:
+        """Auto-detect documentation directory"""
+        common_docs_dirs = ["docs", "documentation", "doc", "README.md"]
+        for doc_dir in common_docs_dirs:
+            if (self.project_root / doc_dir).exists():
+                return doc_dir
+        return ""
+
+    def _configure_roles(self, detected_stack: List[Dict[str, Any]]):
+        """Configure agent roles based on detected stack"""
+        print("\n🤖 Agent Roles Configuration")
+        print("-" * 40)
+
+        # Suggest roles based on detected stack
+        suggested_roles = ["dev", "code-reviewer"]  # Always include these
+        stack_flat = []
+        for item in detected_stack:
+            if isinstance(item, dict):
+                stack_flat.extend(item.values())
+            else:
+                stack_flat.append(item)
+
+        # Add specialized roles based on detection
+        if any("react" in str(tech).lower() for tech in stack_flat):
+            suggested_roles.append("frontend")
+        if any(
+            tech in str(stack_flat).lower()
+            for tech in ["django", "flask", "fastapi", "express"]
+        ):
+            suggested_roles.append("backend")
+        if any("mobile" in str(tech).lower() for tech in stack_flat):
+            suggested_roles.append("mobile")
+
+        print(f"Suggested roles: {', '.join(suggested_roles)}")
+        custom_roles = self._safe_input(
+            "Additional roles (comma-separated) or Enter to accept", default=""
+        )
+
+        if custom_roles:
+            additional = [r.strip() for r in custom_roles.split(",") if r.strip()]
+            suggested_roles.extend(additional)
+
+        # Remove duplicates while preserving order
+        seen = set()
+        unique_roles = []
+        for role in suggested_roles:
+            if role not in seen:
+                seen.add(role)
+                unique_roles.append(role)
+
+        self.config["roles"] = {
+            "default": "dev",
+            "specialized": [r for r in unique_roles if r != "dev"],
+        }
+
+    def _configure_task_management(self):
+        """Configure task management preferences"""
+        print("\n📋 Task Management")
+        print("-" * 40)
+        print("How should tasks be managed?")
+        print("1. GitHub Issues (recommended)")
+        print("2. Local task files only")
+
+        choice = self._safe_input("Choice [1]", default="1")
+        if choice == "2":
+            self.config["github_integration"] = {
+                "issue_to_task": False,
+                "pr_reviews": False,
+            }
+            self.config["task_management"] = "local"
+        else:
+            self.config["github_integration"] = {
+                "issue_to_task": True,
+                "pr_reviews": True,
+            }
+            self.config["task_management"] = "github-issues"
+
+    def _configure_concurrent_agents(self):
+        """Configure concurrent agent limits"""
+        default_agents = "5"
+        agent_count = self._safe_input(
+            "\n🔀 Maximum concurrent agents", default=default_agents
+        )
+
+        try:
+            self.config["max_concurrent_agents"] = int(agent_count)
+        except ValueError:
+            print(f"Invalid number, using default: {default_agents}")
+            self.config["max_concurrent_agents"] = int(default_agents)