Compare commits
8 Commits
7f04378cfb
...
1a9c77b664
| Author | SHA1 | Date | |
|---|---|---|---|
| 1a9c77b664 | |||
| e24f2596e1 | |||
| 64286b138d | |||
| 8fa6325108 | |||
| 2b681b31c6 | |||
| 72f341279a | |||
| 978e925b60 | |||
| 8ecbf87a8b |
@@ -278,7 +278,7 @@ Extend data access layer with search methods. Consider adding full-text search f
|
||||
- **Issue Tracker Integration:** Compatible with Gitea, GitHub, and similar platforms
|
||||
- **Issue Reading:** Use `IssueFetcher` for programmatic access
|
||||
- **Issue Writing:** Use `IssueWriter` for updates via authenticated PATCH
|
||||
- **Environment Variables:** `GITEA_TOKEN` or platform-specific tokens for authentication
|
||||
- **Environment Variables:** `GITEA_API_TOKEN` or platform-specific tokens for authentication
|
||||
|
||||
### Test Framework
|
||||
- **pytest-based:** All tests use pytest framework
|
||||
|
||||
201
CONFIG.md
Normal file
201
CONFIG.md
Normal file
@@ -0,0 +1,201 @@
|
||||
# TDDAi Configuration Management
|
||||
|
||||
The tddai framework uses a flexible, hierarchical configuration system designed for project-agnostic deployment while supporting per-project customization.
|
||||
|
||||
## Configuration Hierarchy
|
||||
|
||||
Configuration values are loaded in the following priority order (highest to lowest):
|
||||
|
||||
1. **Environment Variables** - Runtime overrides (highest priority)
|
||||
2. **`.env.tddai` File** - Project-specific configuration (auto-loaded)
|
||||
3. **Default Values** - Framework defaults (fallback)
|
||||
|
||||
## Quick Start
|
||||
|
||||
### Automatic Configuration (Recommended)
|
||||
The framework automatically loads `.env.tddai` from the current directory:
|
||||
|
||||
```bash
|
||||
# Configuration loaded automatically
|
||||
make tdd-status
|
||||
make tdd-start NUM=5
|
||||
```
|
||||
|
||||
### Manual Configuration
|
||||
You can also source the setup script manually:
|
||||
|
||||
```bash
|
||||
source tddai-setup.sh
|
||||
make tdd-status
|
||||
```
|
||||
|
||||
## Configuration Options
|
||||
|
||||
### Repository Settings (Required)
|
||||
|
||||
| Variable | Description | Example | Required |
|
||||
|----------|-------------|---------|----------|
|
||||
| `TDDAI_GITEA_URL` | Git platform URL | `https://github.com` | ✅ |
|
||||
| `TDDAI_REPO_OWNER` | Repository owner/org | `myusername` | ✅ |
|
||||
| `TDDAI_REPO_NAME` | Repository name | `myproject` | ✅ |
|
||||
|
||||
### Workspace Settings (Optional)
|
||||
|
||||
| Variable | Description | Default | Example |
|
||||
|----------|-------------|---------|---------|
|
||||
| `TDDAI_WORKSPACE_DIR` | TDD workspace directory | `.tddai_workspace` | `.myproject_workspace` |
|
||||
|
||||
### Test Settings (Framework Defaults)
|
||||
|
||||
| Setting | Value | Description |
|
||||
|---------|-------|-------------|
|
||||
| `tests_dir` | `tests/` | Main test directory |
|
||||
| `test_file_pattern` | `test_issue_{issue_num}_{scenario}.py` | Test file naming pattern |
|
||||
| `current_issue_file` | `current_issue.json` | Active issue metadata file |
|
||||
|
||||
## Configuration Files
|
||||
|
||||
### `.env.tddai` Format
|
||||
```bash
|
||||
# TDDAi configuration for YourProject
|
||||
# Repository settings
|
||||
TDDAI_GITEA_URL=https://your-git-platform.com
|
||||
TDDAI_REPO_OWNER=yourusername
|
||||
TDDAI_REPO_NAME=yourproject
|
||||
|
||||
# Workspace settings (optional)
|
||||
TDDAI_WORKSPACE_DIR=.yourproject_workspace
|
||||
```
|
||||
|
||||
### `tddai-setup.sh` Format
|
||||
```bash
|
||||
#!/bin/bash
|
||||
# TDDAi environment setup script
|
||||
|
||||
export TDDAI_GITEA_URL=https://your-git-platform.com
|
||||
export TDDAI_REPO_OWNER=yourusername
|
||||
export TDDAI_REPO_NAME=yourproject
|
||||
export TDDAI_WORKSPACE_DIR=.yourproject_workspace
|
||||
|
||||
echo "✅ TDDAi configured for YourProject"
|
||||
```
|
||||
|
||||
## Platform Examples
|
||||
|
||||
### GitHub Configuration
|
||||
```bash
|
||||
TDDAI_GITEA_URL=https://github.com
|
||||
TDDAI_REPO_OWNER=yourusername
|
||||
TDDAI_REPO_NAME=yourrepo
|
||||
```
|
||||
|
||||
### GitLab Configuration
|
||||
```bash
|
||||
TDDAI_GITEA_URL=https://gitlab.com
|
||||
TDDAI_REPO_OWNER=yourusername
|
||||
TDDAI_REPO_NAME=yourrepo
|
||||
```
|
||||
|
||||
### Self-hosted Gitea
|
||||
```bash
|
||||
TDDAI_GITEA_URL=https://git.yourcompany.com
|
||||
TDDAI_REPO_OWNER=yourorganization
|
||||
TDDAI_REPO_NAME=yourproject
|
||||
```
|
||||
|
||||
## API Integration
|
||||
|
||||
The configuration automatically constructs API URLs:
|
||||
|
||||
```python
|
||||
# Constructed from configuration
|
||||
issues_api_url = f"{TDDAI_GITEA_URL}/api/v1/repos/{TDDAI_REPO_OWNER}/{TDDAI_REPO_NAME}/issues"
|
||||
```
|
||||
|
||||
## Workspace Structure
|
||||
|
||||
Default workspace layout (configurable via `TDDAI_WORKSPACE_DIR`):
|
||||
|
||||
```
|
||||
.tddai_workspace/
|
||||
├── current_issue.json # Active issue metadata
|
||||
└── issue_X/ # Issue-specific workspace
|
||||
├── tests/ # Test files for this issue
|
||||
│ └── test_issue_X_*.py # Generated test files
|
||||
├── requirements.md # Issue requirements analysis
|
||||
└── test_plan.md # Test planning document
|
||||
```
|
||||
|
||||
## Environment Variable Overrides
|
||||
|
||||
You can override any configuration at runtime:
|
||||
|
||||
```bash
|
||||
# Override workspace directory for this session
|
||||
TDDAI_WORKSPACE_DIR=.custom_workspace make tdd-start NUM=5
|
||||
|
||||
# Override repository for testing
|
||||
TDDAI_REPO_NAME=test_repo make tdd-status
|
||||
```
|
||||
|
||||
## Validation
|
||||
|
||||
The framework validates configuration on startup:
|
||||
|
||||
- **Required fields** must be non-empty (`gitea_url`, `repo_owner`, `repo_name`)
|
||||
- **URLs** should include protocol (`http://` or `https://`)
|
||||
- **Workspace directories** are created automatically if they don't exist
|
||||
|
||||
## Troubleshooting
|
||||
|
||||
### Common Errors
|
||||
|
||||
**`gitea_url cannot be empty`**
|
||||
- Solution: Create `.env.tddai` with `TDDAI_GITEA_URL=your-url`
|
||||
- Alternative: Run `source tddai-setup.sh` before tddai commands
|
||||
|
||||
**`repo_owner cannot be empty`**
|
||||
- Solution: Set `TDDAI_REPO_OWNER` in `.env.tddai` or environment
|
||||
|
||||
**`repo_name cannot be empty`**
|
||||
- Solution: Set `TDDAI_REPO_NAME` in `.env.tddai` or environment
|
||||
|
||||
### Debug Configuration
|
||||
```bash
|
||||
# Check current configuration
|
||||
python -c "from tddai.config import get_config; c=get_config(); print(f'URL: {c.gitea_url}\\nOwner: {c.repo_owner}\\nRepo: {c.repo_name}\\nWorkspace: {c.workspace_dir}')"
|
||||
```
|
||||
|
||||
## Migration from Other Projects
|
||||
|
||||
When adapting tddai for a new project:
|
||||
|
||||
1. **Copy configuration template**:
|
||||
```bash
|
||||
cp .env.tddai.example .env.tddai
|
||||
```
|
||||
|
||||
2. **Update repository settings**:
|
||||
```bash
|
||||
# Edit .env.tddai
|
||||
TDDAI_GITEA_URL=https://your-platform.com
|
||||
TDDAI_REPO_OWNER=your-username
|
||||
TDDAI_REPO_NAME=your-project
|
||||
```
|
||||
|
||||
3. **Test configuration**:
|
||||
```bash
|
||||
make tdd-status
|
||||
```
|
||||
|
||||
## Best Practices
|
||||
|
||||
- **Use `.env.tddai`** for project-specific settings
|
||||
- **Use environment variables** for temporary overrides
|
||||
- **Keep configuration in version control** (but exclude sensitive tokens)
|
||||
- **Document custom workspace naming** in project README
|
||||
- **Validate configuration** before starting development sessions
|
||||
|
||||
---
|
||||
|
||||
*This configuration system supports the TDD8 methodology (ISSUE-TEST-RED-GREEN-REFACTOR-DOCUMENT-REFINE-PUBLISH) across any software development project with issue tracking.*
|
||||
24
NEXT.md
24
NEXT.md
@@ -15,7 +15,18 @@
|
||||
|
||||
## 🎯 **Immediate Action Plan: CLI Foundation**
|
||||
|
||||
### Phase 1: Core CLI Infrastructure (Next Session)
|
||||
### Session Startup Actions (THIS SESSION)
|
||||
**PRIORITY 1: Fix TDD Environment**
|
||||
1. Set up `.env.tddai` configuration file or environment variables
|
||||
2. Resolve `gitea_url cannot be empty` error preventing workspace creation
|
||||
3. Validate `make tdd-status` works properly
|
||||
|
||||
**PRIORITY 2: Start CLI Implementation**
|
||||
1. Run `make tdd-start NUM=5` to begin CLI Entry Point issue
|
||||
2. Follow TDD8 workflow for comprehensive CLI implementation
|
||||
3. Focus on delivering user-facing interface for existing library capabilities
|
||||
|
||||
### Phase 1: Core CLI Infrastructure (Current Session Target)
|
||||
**Issue #5: CLI Entry Point and Basic Commands**
|
||||
- **Objective**: Create functional CLI matching documented interface
|
||||
- **Scope**: Entry point, basic commands (`ingest`, `status`, `list`)
|
||||
@@ -129,6 +140,17 @@
|
||||
|
||||
---
|
||||
|
||||
## 📋 **Pending Gitea Issues (Manual Creation Required)**
|
||||
|
||||
**🎯 Session Metrics Tracking System**
|
||||
- **Title**: "Implement session metrics tracking and documentation system"
|
||||
- **Type**: Enhancement | Documentation | Workflow
|
||||
- **Priority**: Medium
|
||||
- **Description**: Implement automatic tracking of tasks generated/completed, development metrics, and session productivity for ProjectDiary integration
|
||||
- **Action**: Create in Gitea manually - issue content prepared above
|
||||
|
||||
---
|
||||
|
||||
*Last Updated: 2025-09-24 (Gap Analysis Complete)*
|
||||
*Critical Discovery: CLI interface completely missing despite comprehensive documentation*
|
||||
*Next Session Priority: Issue #5 - CLI Entry Point Implementation*
|
||||
|
||||
@@ -4,6 +4,63 @@ This diary tracks major work packages, events, and milestones in the MarkiTect p
|
||||
|
||||
---
|
||||
|
||||
## 2025-09-24: Project Management System Implementation & Issue Lifecycle Enhancement
|
||||
|
||||
**Progress:** Implemented comprehensive project management system with issue lifecycle support and milestone-based organization
|
||||
**Contributors:** User (bernd.worsch), Claude Code (Sonnet 4)
|
||||
**Time Estimate:** ~2-3 hours of research, implementation, and testing
|
||||
**AI Resources:** ~20-25 Claude Sonnet 4 conversations, estimated 40K+ tokens
|
||||
|
||||
**PROJECT MANAGEMENT BREAKTHROUGH:** Successfully implemented complete project management system using Gitea's available features after discovering project boards are not universally available. Created `tddai/project_manager.py` with comprehensive milestone and label-based project organization. The system uses milestones as projects and labels for states (Todo, Active, Review, Done, Blocked) and priorities (Low, Medium, High, Critical), providing full project management capabilities within Gitea's API constraints.
|
||||
|
||||
**ISSUE LIFECYCLE MANAGEMENT:** Enhanced the tddai framework with complete issue lifecycle support including state transitions, priority management, milestone assignment, and automatic issue closing for completed work. The ProjectManager class provides 15+ methods for milestone creation, label management, issue state transitions, and project overview reporting. Integrated with existing IssueWriter to provide comprehensive issue management through both direct API calls and CLI interface.
|
||||
|
||||
**CLI INTERFACE EXPANSION:** Added 8 new CLI commands for complete project management workflow: `setup-project-mgmt`, `project-overview`, `set-issue-state`, `set-issue-priority`, `create-milestone`, `list-milestones`, `assign-to-milestone`. The CLI provides user-friendly state names (todo/active/review/done/blocked) and priority levels (low/medium/high/critical) with automatic enum conversion and comprehensive error handling.
|
||||
|
||||
**AUTOMATED PROJECT SETUP:** Implemented `ensure_project_labels()` method that automatically creates all required project management labels with proper colors and descriptions. The system creates 13 standard labels covering all project states, priorities, and issue types (bug, feature, enhancement, documentation). This enables immediate project management capability on any Gitea repository with a single setup command.
|
||||
|
||||
**FRAMEWORK INTEGRATION:** The project management system seamlessly integrates with existing tddai components including authentication patterns, error handling, and CLI design. Enhanced IssueWriter with project management methods (assign_to_milestone, add_labels, remove_labels) while maintaining backward compatibility. All project management operations use consistent API patterns and comprehensive error handling established in the framework.
|
||||
|
||||
**PRACTICAL VALIDATION:** Successfully tested the complete project management system by creating the "CLI Implementation" milestone, setting up all required labels, assigning issues #12-#15 to the milestone, marking Issue #1 as completed and closed, and setting Issue #12 as active with high priority. The system properly tracks project progress with 1 active milestone containing 4 assigned issues, demonstrating real-world project management capability.
|
||||
|
||||
---
|
||||
|
||||
## 2025-09-24: IssueCreator Implementation & CLI Roadmap Execution
|
||||
|
||||
**Progress:** Implemented comprehensive issue creation system and successfully registered all CLI implementation issues in Gitea
|
||||
**Contributors:** User (bernd.worsch), Claude Code (Sonnet 4)
|
||||
**Time Estimate:** ~2-3 hours of development, testing, and issue creation
|
||||
**AI Resources:** ~25-30 Claude Sonnet 4 conversations, estimated 50K+ tokens
|
||||
|
||||
**ISSUECREATOR SIDEQUEST ACHIEVEMENT:** Successfully implemented complete issue creation capability as a natural sidequest during CLI planning. Created `tddai/issue_creator.py` with comprehensive POST API functionality, structured issue templates, and multiple creation methods. Implementation includes basic issue creation, structured enhancement issues, bug report templates, and template-based creation with variable substitution. Added 15 comprehensive tests covering all creation scenarios, error conditions, and API integration patterns.
|
||||
|
||||
**AUTHENTICATION BUG DISCOVERY & RESOLUTION:** Critical authentication issue discovered during CLI issue creation - the framework was using `GITEA_TOKEN` but the actual environment variable was `GITEA_API_TOKEN`. This highlighted the importance of integration testing for API components. Fixed both IssueCreator and IssueWriter to use correct environment variable and added comprehensive integration test suite (`test_issue_integration.py`) with 5 tests specifically designed to catch authentication and API issues through real create→retrieve→update→delete cycles.
|
||||
|
||||
**COMPREHENSIVE TEST COVERAGE:** Established robust 3-tier testing architecture for issue handling: 15 unit tests for IssueCreator functionality, 13 existing tests for IssueWriter operations, and 5 critical integration tests for end-to-end API validation. The `test_environment_variable_detection` test specifically prevents future authentication token mismatches, while `test_complete_issue_lifecycle` validates real API operations with proper cleanup. Total: 33 tests providing complete coverage for issue creation, updating, and management workflows.
|
||||
|
||||
**CLI ROADMAP EXECUTION:** Successfully created all 8 CLI implementation issues (#12-#19) in Gitea using the new IssueCreator functionality, resolving the critical mismatch between NEXT.md roadmap and actual Gitea issues. Issues include CLI Entry Point (#12), Database Query Interface (#14), AST Query CLI (#15), Cache Management (#13), Performance Validation (#16), Batch Processing (#17), Configuration Management (#18), and Plugin Architecture (#19). Prioritization aligns with core USPs: "Relational Document Metadata" and "Zero-Parsing Content Access".
|
||||
|
||||
**FRAMEWORK MATURITY ADVANCEMENT:** The IssueCreator implementation demonstrates the tddai framework's evolution toward complete issue lifecycle management. Combined with existing IssueWriter and IssueFetcher capabilities, the framework now provides full CRUD operations for issue management with proper authentication, error handling, and integration testing. Enhanced CLI interface provides three issue creation methods (basic, enhancement, template) with comprehensive argument parsing and user-friendly output.
|
||||
|
||||
---
|
||||
|
||||
## 2025-09-24: TDDAi Configuration Enhancement & User Experience Improvements
|
||||
|
||||
**Progress:** Enhanced tddai configuration system with automatic .env file loading and comprehensive documentation
|
||||
**Contributors:** User (bernd.worsch), Claude Code (Sonnet 4)
|
||||
**Time Estimate:** ~1 hour of configuration improvements and documentation
|
||||
**AI Resources:** ~10-15 Claude Sonnet 4 conversations, estimated 20K+ tokens
|
||||
|
||||
**CONFIGURATION SYSTEM ENHANCEMENT:** Implemented automatic .env.tddai file loading to eliminate the need for manual setup script sourcing. Added lightweight dotenv file parsing directly in the tddai configuration system without external dependencies. The enhanced system maintains the existing hierarchy (Environment Variables → .env.tddai → Defaults) while providing seamless developer experience. Users can now run `make tdd-status` and other tddai commands immediately without sourcing `tddai-setup.sh` first.
|
||||
|
||||
**DEVELOPER EXPERIENCE IMPROVEMENT:** Resolved the "gitea_url cannot be empty" error that was blocking TDD workflow initialization. The configuration system now automatically loads project-specific settings from `.env.tddai` on startup, making the framework truly plug-and-play. Maintained backward compatibility with existing setup script approach while providing the modern auto-loading experience.
|
||||
|
||||
**COMPREHENSIVE DOCUMENTATION:** Created CONFIG.md with complete configuration management guide covering hierarchy, options reference, platform examples (GitHub, GitLab, Gitea), troubleshooting guide, and migration instructions. Documentation includes both the new auto-loading system and legacy manual methods, ensuring users understand all available configuration approaches and can choose their preferred workflow.
|
||||
|
||||
**INFRASTRUCTURE ROBUSTNESS:** The configuration enhancement maintains zero breaking changes while significantly improving usability. Project-agnostic design remains intact with flexible workspace management and platform support. The lightweight .env file parsing approach avoids external dependencies while providing full functionality equivalent to python-dotenv for our use case.
|
||||
|
||||
---
|
||||
|
||||
## 2025-09-24: TDDAi Framework Decoupling & Project-Agnostic Refactoring
|
||||
|
||||
**Progress:** Decoupled tddai framework from MarkiTect-specific implementation and achieved clean test separation
|
||||
|
||||
14
install-cursor.sh
Normal file
14
install-cursor.sh
Normal file
@@ -0,0 +1,14 @@
|
||||
#!/bin/sh
|
||||
#
|
||||
# install-cursor.sh - install cursor cli coding environment
|
||||
#
|
||||
# USAGE
|
||||
# run "./install-cursor.sh" to make sure dependencies are satisfied
|
||||
|
||||
|
||||
|
||||
# install cursor cli coding environment
|
||||
# curl https://cursor.com/install -fsS | bash # error with OpenSSL
|
||||
# wget -qO- https://cursor.com/install | bash # error with OpenSSL
|
||||
|
||||
|
||||
@@ -7,6 +7,8 @@ Provides workspace management, test generation, and issue integration.
|
||||
|
||||
from .workspace import WorkspaceManager, Workspace, WorkspaceStatus
|
||||
from .issue_fetcher import IssueFetcher, Issue
|
||||
from .issue_creator import IssueCreator
|
||||
from .project_manager import ProjectManager, ProjectState, Priority
|
||||
from .test_generator import TestGenerator
|
||||
from .coverage_analyzer import CoverageAnalyzer, CoverageAssessment, TestRequirement, CoverageGap
|
||||
from .exceptions import TddaiError, WorkspaceError, IssueError, ConfigurationError, TestGenerationError
|
||||
@@ -18,6 +20,10 @@ __all__ = [
|
||||
"WorkspaceStatus",
|
||||
"IssueFetcher",
|
||||
"Issue",
|
||||
"IssueCreator",
|
||||
"ProjectManager",
|
||||
"ProjectState",
|
||||
"Priority",
|
||||
"TestGenerator",
|
||||
"CoverageAnalyzer",
|
||||
"CoverageAssessment",
|
||||
|
||||
@@ -26,6 +26,19 @@ from dataclasses import dataclass
|
||||
from .exceptions import ConfigurationError
|
||||
|
||||
|
||||
def load_dotenv_file(env_file: Path) -> None:
|
||||
"""Load environment variables from a .env file."""
|
||||
if not env_file.exists():
|
||||
return
|
||||
|
||||
with open(env_file, 'r') as f:
|
||||
for line in f:
|
||||
line = line.strip()
|
||||
if line and not line.startswith('#') and '=' in line:
|
||||
key, value = line.split('=', 1)
|
||||
os.environ.setdefault(key.strip(), value.strip())
|
||||
|
||||
|
||||
@dataclass
|
||||
class TddaiConfig:
|
||||
"""Configuration settings for tddai."""
|
||||
@@ -58,7 +71,11 @@ class TddaiConfig:
|
||||
|
||||
@classmethod
|
||||
def from_environment(cls) -> "TddaiConfig":
|
||||
"""Create config from environment variables."""
|
||||
"""Create config from environment variables and .env files."""
|
||||
# Auto-load .env.tddai file if it exists
|
||||
env_file = Path(".env.tddai")
|
||||
load_dotenv_file(env_file)
|
||||
|
||||
config = cls()
|
||||
|
||||
# Override with environment variables if present
|
||||
|
||||
233
tddai/issue_creator.py
Normal file
233
tddai/issue_creator.py
Normal file
@@ -0,0 +1,233 @@
|
||||
"""
|
||||
Issue creation for Gitea API.
|
||||
"""
|
||||
|
||||
import json
|
||||
import os
|
||||
import subprocess
|
||||
from subprocess import PIPE
|
||||
from typing import Dict, Any, Optional, List
|
||||
|
||||
from .config import get_config
|
||||
from .exceptions import IssueError
|
||||
|
||||
|
||||
class IssueCreator:
|
||||
"""Creates new issues via Gitea API."""
|
||||
|
||||
def __init__(self, config=None, auth_token=None):
|
||||
self.config = config or get_config()
|
||||
self.auth_token = auth_token or os.getenv('GITEA_API_TOKEN')
|
||||
|
||||
def create_issue(self, title: str, body: str, **kwargs) -> Dict[str, Any]:
|
||||
"""Create a new issue via POST operation.
|
||||
|
||||
Args:
|
||||
title: Issue title (required)
|
||||
body: Issue description/body (required)
|
||||
**kwargs: Optional fields (assignees, milestone, labels, etc.)
|
||||
|
||||
Returns:
|
||||
Dict containing created issue data including issue number
|
||||
|
||||
Raises:
|
||||
IssueError: If creation fails
|
||||
"""
|
||||
if not self.auth_token:
|
||||
raise IssueError("Authentication token required for issue creation")
|
||||
|
||||
if not title.strip():
|
||||
raise IssueError("Issue title cannot be empty")
|
||||
|
||||
# Prepare issue data
|
||||
issue_data = {
|
||||
'title': title.strip(),
|
||||
'body': body.strip() if body else ''
|
||||
}
|
||||
|
||||
# Add optional fields
|
||||
if 'assignees' in kwargs and kwargs['assignees']:
|
||||
issue_data['assignees'] = kwargs['assignees']
|
||||
|
||||
if 'milestone' in kwargs and kwargs['milestone']:
|
||||
issue_data['milestone'] = kwargs['milestone']
|
||||
|
||||
if 'labels' in kwargs and kwargs['labels']:
|
||||
issue_data['labels'] = kwargs['labels']
|
||||
|
||||
url = self.config.issues_api_url
|
||||
|
||||
try:
|
||||
# Prepare curl command with authentication
|
||||
curl_cmd = [
|
||||
'curl', '-s', '-X', 'POST',
|
||||
'-H', 'Content-Type: application/json',
|
||||
'-H', f'Authorization: token {self.auth_token}',
|
||||
'-d', json.dumps(issue_data),
|
||||
url
|
||||
]
|
||||
|
||||
result = subprocess.run(
|
||||
curl_cmd,
|
||||
stdout=PIPE,
|
||||
stderr=PIPE,
|
||||
universal_newlines=True,
|
||||
check=True
|
||||
)
|
||||
|
||||
if result.returncode != 0:
|
||||
raise IssueError(f"Failed to create issue: {result.stderr}")
|
||||
|
||||
response_data = json.loads(result.stdout)
|
||||
|
||||
# Check for API error responses
|
||||
if 'message' in response_data and 'number' not in response_data:
|
||||
raise IssueError(f"Failed to create issue: {response_data['message']}")
|
||||
|
||||
return response_data
|
||||
|
||||
except subprocess.CalledProcessError as e:
|
||||
raise IssueError(f"Failed to create issue: {e}")
|
||||
except json.JSONDecodeError as e:
|
||||
raise IssueError(f"Failed to parse response data: {e}")
|
||||
|
||||
def create_enhancement_issue(self, title: str, use_case: str,
|
||||
technical_requirements: str = "",
|
||||
acceptance_criteria: List[str] = None,
|
||||
dependencies: List[str] = None,
|
||||
priority: str = "Medium") -> Dict[str, Any]:
|
||||
"""Create an enhancement issue with structured format.
|
||||
|
||||
Args:
|
||||
title: Issue title
|
||||
use_case: UseCase description
|
||||
technical_requirements: Technical implementation details
|
||||
acceptance_criteria: List of acceptance criteria
|
||||
dependencies: List of dependency descriptions
|
||||
priority: Priority level (High, Medium, Low)
|
||||
|
||||
Returns:
|
||||
Dict containing created issue data
|
||||
"""
|
||||
# Build structured body
|
||||
body_parts = [f"UseCase: {use_case}"]
|
||||
|
||||
if technical_requirements:
|
||||
body_parts.extend([
|
||||
"",
|
||||
"Technical Requirements:",
|
||||
technical_requirements
|
||||
])
|
||||
|
||||
if acceptance_criteria:
|
||||
body_parts.extend([
|
||||
"",
|
||||
"Acceptance Criteria:"
|
||||
])
|
||||
for criterion in acceptance_criteria:
|
||||
body_parts.append(f"- [ ] {criterion}")
|
||||
|
||||
if dependencies:
|
||||
body_parts.extend([
|
||||
"",
|
||||
"Dependencies:"
|
||||
])
|
||||
for dep in dependencies:
|
||||
body_parts.append(f"- {dep}")
|
||||
|
||||
body = "\n".join(body_parts)
|
||||
|
||||
# Create with enhancement label
|
||||
return self.create_issue(
|
||||
title=title,
|
||||
body=body,
|
||||
labels=[priority.lower(), "enhancement"]
|
||||
)
|
||||
|
||||
def create_bug_issue(self, title: str, description: str,
|
||||
steps_to_reproduce: List[str] = None,
|
||||
expected_behavior: str = "",
|
||||
actual_behavior: str = "",
|
||||
environment: str = "") -> Dict[str, Any]:
|
||||
"""Create a bug issue with structured format.
|
||||
|
||||
Args:
|
||||
title: Bug title
|
||||
description: Bug description
|
||||
steps_to_reproduce: List of reproduction steps
|
||||
expected_behavior: What should happen
|
||||
actual_behavior: What actually happens
|
||||
environment: Environment details
|
||||
|
||||
Returns:
|
||||
Dict containing created issue data
|
||||
"""
|
||||
body_parts = [description]
|
||||
|
||||
if steps_to_reproduce:
|
||||
body_parts.extend([
|
||||
"",
|
||||
"Steps to Reproduce:"
|
||||
])
|
||||
for i, step in enumerate(steps_to_reproduce, 1):
|
||||
body_parts.append(f"{i}. {step}")
|
||||
|
||||
if expected_behavior:
|
||||
body_parts.extend([
|
||||
"",
|
||||
f"Expected Behavior: {expected_behavior}"
|
||||
])
|
||||
|
||||
if actual_behavior:
|
||||
body_parts.extend([
|
||||
"",
|
||||
f"Actual Behavior: {actual_behavior}"
|
||||
])
|
||||
|
||||
if environment:
|
||||
body_parts.extend([
|
||||
"",
|
||||
f"Environment: {environment}"
|
||||
])
|
||||
|
||||
body = "\n".join(body_parts)
|
||||
|
||||
# Create with bug label
|
||||
return self.create_issue(
|
||||
title=title,
|
||||
body=body,
|
||||
labels=["bug"]
|
||||
)
|
||||
|
||||
def create_from_template(self, template_file: str, **template_vars) -> Dict[str, Any]:
|
||||
"""Create issue from a template file.
|
||||
|
||||
Args:
|
||||
template_file: Path to template file
|
||||
**template_vars: Variables to substitute in template
|
||||
|
||||
Returns:
|
||||
Dict containing created issue data
|
||||
"""
|
||||
try:
|
||||
with open(template_file, 'r') as f:
|
||||
template_content = f.read()
|
||||
|
||||
# Simple template variable substitution
|
||||
for key, value in template_vars.items():
|
||||
template_content = template_content.replace(f"{{{key}}}", str(value))
|
||||
|
||||
# Extract title (first line) and body (rest)
|
||||
lines = template_content.strip().split('\n')
|
||||
if not lines or (len(lines) == 1 and not lines[0].strip()):
|
||||
raise IssueError("Template file is empty")
|
||||
|
||||
title = lines[0].replace('Title: ', '').strip()
|
||||
body = '\n'.join(lines[1:]).strip()
|
||||
|
||||
return self.create_issue(title=title, body=body)
|
||||
|
||||
except FileNotFoundError:
|
||||
raise IssueError(f"Template file not found: {template_file}")
|
||||
except Exception as e:
|
||||
raise IssueError(f"Failed to process template: {e}")
|
||||
@@ -17,7 +17,7 @@ class IssueWriter:
|
||||
|
||||
def __init__(self, config=None, auth_token=None):
|
||||
self.config = config or get_config()
|
||||
self.auth_token = auth_token or os.getenv('GITEA_TOKEN')
|
||||
self.auth_token = auth_token or os.getenv('GITEA_API_TOKEN')
|
||||
|
||||
def update_issue(self, issue_number: int, update_data: Dict[str, Any]) -> Dict[str, Any]:
|
||||
"""Update an issue via PATCH operation."""
|
||||
@@ -79,4 +79,102 @@ class IssueWriter:
|
||||
|
||||
def reopen_issue(self, issue_number: int) -> Dict[str, Any]:
|
||||
"""Reopen a closed issue."""
|
||||
return self.update_issue_state(issue_number, 'open')
|
||||
return self.update_issue_state(issue_number, 'open')
|
||||
|
||||
def assign_to_milestone(self, issue_number: int, milestone_id: int) -> Dict[str, Any]:
|
||||
"""Assign issue to a milestone (project)."""
|
||||
return self.update_issue(issue_number, {'milestone': milestone_id})
|
||||
|
||||
def remove_from_milestone(self, issue_number: int) -> Dict[str, Any]:
|
||||
"""Remove issue from its current milestone."""
|
||||
return self.update_issue(issue_number, {'milestone': None})
|
||||
|
||||
def update_labels(self, issue_number: int, labels: list) -> Dict[str, Any]:
|
||||
"""Update issue labels completely using dedicated labels endpoint."""
|
||||
if not self.auth_token:
|
||||
raise IssueError("Authentication token required for label updates")
|
||||
|
||||
# Use the dedicated labels endpoint which works more reliably
|
||||
url = f"{self.config.issues_api_url}/{issue_number}/labels"
|
||||
|
||||
try:
|
||||
# Use PUT to replace all labels
|
||||
curl_cmd = [
|
||||
'curl', '-s', '-X', 'PUT',
|
||||
'-H', 'Content-Type: application/json',
|
||||
'-H', f'Authorization: token {self.auth_token}',
|
||||
'-d', json.dumps({'labels': labels}),
|
||||
url
|
||||
]
|
||||
|
||||
result = subprocess.run(
|
||||
curl_cmd,
|
||||
stdout=PIPE,
|
||||
stderr=PIPE,
|
||||
universal_newlines=True,
|
||||
check=True
|
||||
)
|
||||
|
||||
if result.returncode != 0:
|
||||
raise IssueError(f"Failed to update labels for issue #{issue_number}: {result.stderr}")
|
||||
|
||||
# Parse the response - labels endpoint returns array of labels
|
||||
if result.stdout.strip():
|
||||
response_data = json.loads(result.stdout)
|
||||
|
||||
# Convert labels response back to issue format for consistency
|
||||
return {
|
||||
'number': issue_number,
|
||||
'labels': response_data if isinstance(response_data, list) else []
|
||||
}
|
||||
else:
|
||||
return {'number': issue_number, 'labels': []}
|
||||
|
||||
except subprocess.CalledProcessError as e:
|
||||
raise IssueError(f"Failed to update labels for issue #{issue_number}: {e}")
|
||||
except json.JSONDecodeError as e:
|
||||
raise IssueError(f"Failed to parse labels response: {e}")
|
||||
|
||||
def add_labels(self, issue_number: int, new_labels: list) -> Dict[str, Any]:
|
||||
"""Add labels to issue (preserving existing labels)."""
|
||||
# First get current labels
|
||||
url = f"{self.config.issues_api_url}/{issue_number}"
|
||||
curl_cmd = [
|
||||
'curl', '-s', '-X', 'GET',
|
||||
'-H', f'Authorization: token {self.auth_token}',
|
||||
url
|
||||
]
|
||||
|
||||
try:
|
||||
result = subprocess.run(curl_cmd, stdout=PIPE, stderr=PIPE, universal_newlines=True, check=True)
|
||||
issue_data = json.loads(result.stdout)
|
||||
current_labels = [label['name'] for label in issue_data.get('labels', [])]
|
||||
|
||||
# Add new labels (avoid duplicates)
|
||||
updated_labels = list(set(current_labels + new_labels))
|
||||
return self.update_labels(issue_number, updated_labels)
|
||||
|
||||
except (subprocess.CalledProcessError, json.JSONDecodeError) as e:
|
||||
raise IssueError(f"Failed to add labels to issue #{issue_number}: {e}")
|
||||
|
||||
def remove_labels(self, issue_number: int, labels_to_remove: list) -> Dict[str, Any]:
|
||||
"""Remove specific labels from issue."""
|
||||
# First get current labels
|
||||
url = f"{self.config.issues_api_url}/{issue_number}"
|
||||
curl_cmd = [
|
||||
'curl', '-s', '-X', 'GET',
|
||||
'-H', f'Authorization: token {self.auth_token}',
|
||||
url
|
||||
]
|
||||
|
||||
try:
|
||||
result = subprocess.run(curl_cmd, stdout=PIPE, stderr=PIPE, universal_newlines=True, check=True)
|
||||
issue_data = json.loads(result.stdout)
|
||||
current_labels = [label['name'] for label in issue_data.get('labels', [])]
|
||||
|
||||
# Remove specified labels
|
||||
updated_labels = [label for label in current_labels if label not in labels_to_remove]
|
||||
return self.update_labels(issue_number, updated_labels)
|
||||
|
||||
except (subprocess.CalledProcessError, json.JSONDecodeError) as e:
|
||||
raise IssueError(f"Failed to remove labels from issue #{issue_number}: {e}")
|
||||
329
tddai/project_manager.py
Normal file
329
tddai/project_manager.py
Normal file
@@ -0,0 +1,329 @@
|
||||
"""
|
||||
Project management functionality for Gitea using milestones and labels.
|
||||
|
||||
Since Gitea project boards may not be available in all instances, this module
|
||||
provides project management using milestones (for projects) and labels (for states).
|
||||
"""
|
||||
|
||||
import json
|
||||
import os
|
||||
import subprocess
|
||||
from subprocess import PIPE
|
||||
from typing import Dict, Any, List, Optional
|
||||
from dataclasses import dataclass
|
||||
from enum import Enum
|
||||
|
||||
from .config import get_config
|
||||
from .exceptions import IssueError
|
||||
|
||||
|
||||
class ProjectState(Enum):
|
||||
"""Standard project states using labels."""
|
||||
TODO = "status:todo"
|
||||
ACTIVE = "status:active"
|
||||
REVIEW = "status:review"
|
||||
DONE = "status:done"
|
||||
BLOCKED = "status:blocked"
|
||||
|
||||
|
||||
class Priority(Enum):
|
||||
"""Priority levels using labels."""
|
||||
LOW = "priority:low"
|
||||
MEDIUM = "priority:medium"
|
||||
HIGH = "priority:high"
|
||||
CRITICAL = "priority:critical"
|
||||
|
||||
|
||||
@dataclass
|
||||
class Milestone:
|
||||
"""Represents a project milestone."""
|
||||
id: int
|
||||
title: str
|
||||
description: str
|
||||
state: str
|
||||
open_issues: int
|
||||
closed_issues: int
|
||||
due_on: Optional[str] = None
|
||||
|
||||
|
||||
@dataclass
|
||||
class Label:
|
||||
"""Represents an issue label."""
|
||||
id: int
|
||||
name: str
|
||||
color: str
|
||||
description: str
|
||||
|
||||
|
||||
class ProjectManager:
|
||||
"""Manages project organization using milestones and labels."""
|
||||
|
||||
def __init__(self, config=None, auth_token=None):
|
||||
self.config = config or get_config()
|
||||
self.auth_token = auth_token or os.getenv('GITEA_API_TOKEN')
|
||||
|
||||
def _make_api_call(self, method: str, url: str, data: Dict[str, Any] = None) -> Dict[str, Any]:
|
||||
"""Make authenticated API call to Gitea."""
|
||||
if not self.auth_token:
|
||||
raise IssueError("Authentication token required for project operations")
|
||||
|
||||
cmd = [
|
||||
'curl', '-s', '-X', method,
|
||||
'-H', 'Content-Type: application/json',
|
||||
'-H', f'Authorization: token {self.auth_token}',
|
||||
]
|
||||
|
||||
if data:
|
||||
cmd.extend(['-d', json.dumps(data)])
|
||||
|
||||
cmd.append(url)
|
||||
|
||||
try:
|
||||
result = subprocess.run(cmd, stdout=PIPE, stderr=PIPE, universal_newlines=True, check=True)
|
||||
|
||||
if result.returncode != 0:
|
||||
raise IssueError(f"API call failed: {result.stderr}")
|
||||
|
||||
if result.stdout.strip():
|
||||
response_data = json.loads(result.stdout)
|
||||
|
||||
# Check for API error responses
|
||||
if isinstance(response_data, dict) and 'message' in response_data and 'id' not in response_data:
|
||||
raise IssueError(f"API error: {response_data['message']}")
|
||||
|
||||
return response_data
|
||||
else:
|
||||
return {}
|
||||
|
||||
except subprocess.CalledProcessError as e:
|
||||
raise IssueError(f"API call failed: {e}")
|
||||
except json.JSONDecodeError as e:
|
||||
raise IssueError(f"Failed to parse API response: {e}")
|
||||
|
||||
# Milestone Management (Projects)
|
||||
|
||||
def create_milestone(self, title: str, description: str = "", due_date: str = None) -> Milestone:
|
||||
"""Create a new milestone (project)."""
|
||||
url = f"{self.config.gitea_url}/api/v1/repos/{self.config.repo_owner}/{self.config.repo_name}/milestones"
|
||||
|
||||
data = {
|
||||
'title': title,
|
||||
'description': description,
|
||||
}
|
||||
|
||||
if due_date:
|
||||
data['due_on'] = due_date
|
||||
|
||||
response = self._make_api_call('POST', url, data)
|
||||
|
||||
return Milestone(
|
||||
id=response['id'],
|
||||
title=response['title'],
|
||||
description=response.get('description', ''),
|
||||
state=response['state'],
|
||||
open_issues=response['open_issues'],
|
||||
closed_issues=response['closed_issues'],
|
||||
due_on=response.get('due_on')
|
||||
)
|
||||
|
||||
def list_milestones(self, state: str = "open") -> List[Milestone]:
|
||||
"""List all milestones (projects)."""
|
||||
url = f"{self.config.gitea_url}/api/v1/repos/{self.config.repo_owner}/{self.config.repo_name}/milestones"
|
||||
|
||||
params = f"?state={state}" if state else ""
|
||||
response = self._make_api_call('GET', url + params)
|
||||
|
||||
return [
|
||||
Milestone(
|
||||
id=m['id'],
|
||||
title=m['title'],
|
||||
description=m.get('description', ''),
|
||||
state=m['state'],
|
||||
open_issues=m['open_issues'],
|
||||
closed_issues=m['closed_issues'],
|
||||
due_on=m.get('due_on')
|
||||
)
|
||||
for m in response
|
||||
]
|
||||
|
||||
def update_milestone(self, milestone_id: int, **kwargs) -> Milestone:
|
||||
"""Update milestone details."""
|
||||
url = f"{self.config.gitea_url}/api/v1/repos/{self.config.repo_owner}/{self.config.repo_name}/milestones/{milestone_id}"
|
||||
|
||||
# Only include fields that can be updated
|
||||
valid_fields = ['title', 'description', 'state', 'due_on']
|
||||
data = {k: v for k, v in kwargs.items() if k in valid_fields}
|
||||
|
||||
response = self._make_api_call('PATCH', url, data)
|
||||
|
||||
return Milestone(
|
||||
id=response['id'],
|
||||
title=response['title'],
|
||||
description=response.get('description', ''),
|
||||
state=response['state'],
|
||||
open_issues=response['open_issues'],
|
||||
closed_issues=response['closed_issues'],
|
||||
due_on=response.get('due_on')
|
||||
)
|
||||
|
||||
def close_milestone(self, milestone_id: int) -> Milestone:
|
||||
"""Close a milestone (complete project)."""
|
||||
return self.update_milestone(milestone_id, state='closed')
|
||||
|
||||
# Label Management (States & Priority)
|
||||
|
||||
def create_label(self, name: str, color: str, description: str = "") -> Label:
|
||||
"""Create a new label."""
|
||||
url = f"{self.config.gitea_url}/api/v1/repos/{self.config.repo_owner}/{self.config.repo_name}/labels"
|
||||
|
||||
data = {
|
||||
'name': name,
|
||||
'color': color,
|
||||
'description': description
|
||||
}
|
||||
|
||||
response = self._make_api_call('POST', url, data)
|
||||
|
||||
return Label(
|
||||
id=response['id'],
|
||||
name=response['name'],
|
||||
color=response['color'],
|
||||
description=response.get('description', '')
|
||||
)
|
||||
|
||||
def list_labels(self) -> List[Label]:
|
||||
"""List all repository labels."""
|
||||
url = f"{self.config.gitea_url}/api/v1/repos/{self.config.repo_owner}/{self.config.repo_name}/labels"
|
||||
|
||||
response = self._make_api_call('GET', url)
|
||||
|
||||
return [
|
||||
Label(
|
||||
id=l['id'],
|
||||
name=l['name'],
|
||||
color=l['color'],
|
||||
description=l.get('description', '')
|
||||
)
|
||||
for l in response
|
||||
]
|
||||
|
||||
def ensure_project_labels(self) -> None:
|
||||
"""Ensure all required project management labels exist."""
|
||||
existing_labels = {label.name for label in self.list_labels()}
|
||||
|
||||
# Standard state labels
|
||||
required_labels = [
|
||||
('status:todo', 'e6e6e6', 'Issues ready to be worked on'),
|
||||
('status:active', '0052cc', 'Issues currently being worked on'),
|
||||
('status:review', 'fbca04', 'Issues under review'),
|
||||
('status:done', '0e8a16', 'Completed issues'),
|
||||
('status:blocked', 'd93f0b', 'Issues blocked by dependencies'),
|
||||
|
||||
# Priority labels
|
||||
('priority:low', 'c2e0c6', 'Low priority issue'),
|
||||
('priority:medium', 'fef2c0', 'Medium priority issue'),
|
||||
('priority:high', 'f9d0c4', 'High priority issue'),
|
||||
('priority:critical', 'f4c2c2', 'Critical priority issue'),
|
||||
|
||||
# Type labels
|
||||
('type:bug', 'fc2929', 'Bug report'),
|
||||
('type:feature', '84b6eb', 'New feature request'),
|
||||
('type:enhancement', '7057ff', 'Enhancement to existing feature'),
|
||||
('type:documentation', '0075ca', 'Documentation update'),
|
||||
]
|
||||
|
||||
for name, color, description in required_labels:
|
||||
if name not in existing_labels:
|
||||
try:
|
||||
self.create_label(name, color, description)
|
||||
print(f"✅ Created label: {name}")
|
||||
except IssueError as e:
|
||||
print(f"⚠️ Failed to create label {name}: {e}")
|
||||
|
||||
# Project Management Operations
|
||||
|
||||
def assign_issue_to_milestone(self, issue_number: int, milestone_id: int) -> Dict[str, Any]:
|
||||
"""Assign issue to a milestone (project)."""
|
||||
url = f"{self.config.issues_api_url}/{issue_number}"
|
||||
|
||||
data = {'milestone': milestone_id}
|
||||
return self._make_api_call('PATCH', url, data)
|
||||
|
||||
def set_issue_state(self, issue_number: int, state: ProjectState) -> Dict[str, Any]:
|
||||
"""Set issue project state using labels."""
|
||||
# Use the dedicated labels endpoint which works more reliably
|
||||
labels_url = f"{self.config.issues_api_url}/{issue_number}/labels"
|
||||
|
||||
# First get current labels
|
||||
issue_url = f"{self.config.issues_api_url}/{issue_number}"
|
||||
issue_data = self._make_api_call('GET', issue_url)
|
||||
|
||||
current_labels = [label['name'] for label in issue_data.get('labels', [])]
|
||||
state_labels = [label for label in current_labels if label.startswith('status:')]
|
||||
|
||||
# Remove old state labels
|
||||
for old_state in state_labels:
|
||||
if old_state in current_labels:
|
||||
current_labels.remove(old_state)
|
||||
|
||||
# Add new state label
|
||||
current_labels.append(state.value)
|
||||
|
||||
# Use PUT to replace all labels on the dedicated labels endpoint
|
||||
data = {'labels': current_labels}
|
||||
return self._make_api_call('PUT', labels_url, data)
|
||||
|
||||
def set_issue_priority(self, issue_number: int, priority: Priority) -> Dict[str, Any]:
|
||||
"""Set issue priority using labels."""
|
||||
# Use the dedicated labels endpoint which works more reliably
|
||||
labels_url = f"{self.config.issues_api_url}/{issue_number}/labels"
|
||||
|
||||
# First get current labels
|
||||
issue_url = f"{self.config.issues_api_url}/{issue_number}"
|
||||
issue_data = self._make_api_call('GET', issue_url)
|
||||
|
||||
current_labels = [label['name'] for label in issue_data.get('labels', [])]
|
||||
priority_labels = [label for label in current_labels if label.startswith('priority:')]
|
||||
|
||||
# Remove old priority labels
|
||||
for old_priority in priority_labels:
|
||||
if old_priority in current_labels:
|
||||
current_labels.remove(old_priority)
|
||||
|
||||
# Add new priority label
|
||||
current_labels.append(priority.value)
|
||||
|
||||
# Use PUT to replace all labels on the dedicated labels endpoint
|
||||
data = {'labels': current_labels}
|
||||
return self._make_api_call('PUT', labels_url, data)
|
||||
|
||||
def move_issue_to_done(self, issue_number: int) -> Dict[str, Any]:
|
||||
"""Move issue to done state and close it."""
|
||||
# Set state to done
|
||||
self.set_issue_state(issue_number, ProjectState.DONE)
|
||||
|
||||
# Close the issue
|
||||
url = f"{self.config.issues_api_url}/{issue_number}"
|
||||
data = {'state': 'closed'}
|
||||
return self._make_api_call('PATCH', url, data)
|
||||
|
||||
def get_project_overview(self) -> Dict[str, Any]:
|
||||
"""Get overview of project status."""
|
||||
milestones = self.list_milestones("all")
|
||||
labels = self.list_labels()
|
||||
|
||||
# Count issues by state
|
||||
state_counts = {}
|
||||
for state in ProjectState:
|
||||
state_counts[state.value] = 0
|
||||
|
||||
# This would require fetching all issues to count by labels
|
||||
# For now, return milestone overview
|
||||
|
||||
return {
|
||||
'milestones': len(milestones),
|
||||
'active_projects': len([m for m in milestones if m.state == 'open']),
|
||||
'completed_projects': len([m for m in milestones if m.state == 'closed']),
|
||||
'total_labels': len(labels),
|
||||
'project_management_ready': len([l for l in labels if l.name.startswith('status:')]) > 0
|
||||
}
|
||||
423
tddai_cli.py
423
tddai_cli.py
@@ -14,6 +14,8 @@ from tddai import (
|
||||
WorkspaceManager, IssueFetcher, TestGenerator, CoverageAnalyzer,
|
||||
WorkspaceStatus, TddaiError
|
||||
)
|
||||
from tddai.issue_creator import IssueCreator
|
||||
from tddai.project_manager import ProjectManager, ProjectState, Priority
|
||||
|
||||
|
||||
def workspace_status():
|
||||
@@ -321,15 +323,17 @@ def analyze_coverage(issue_number: int):
|
||||
|
||||
|
||||
def show_issue(issue_number: int):
|
||||
"""Show detailed issue information."""
|
||||
"""Show detailed issue information with comprehensive project management details."""
|
||||
try:
|
||||
fetcher = IssueFetcher()
|
||||
project_mgr = ProjectManager()
|
||||
|
||||
print(f"🔍 Issue #{issue_number} Details")
|
||||
print("=======================")
|
||||
print()
|
||||
|
||||
# Get basic issue information
|
||||
issue = fetcher.fetch_issue(issue_number)
|
||||
|
||||
print(f"**Title:** {issue.title}")
|
||||
print(f"**Status:** {issue.state.upper()}")
|
||||
print(f"**Number:** #{issue.number}")
|
||||
@@ -340,8 +344,79 @@ def show_issue(issue_number: int):
|
||||
if issue.assignee:
|
||||
print(f"**Assignee:** {issue.assignee}")
|
||||
|
||||
if issue.labels:
|
||||
print(f"**Labels:** {', '.join(issue.labels)}")
|
||||
# Enhanced project management information
|
||||
print()
|
||||
print("**Project Management:**")
|
||||
|
||||
# Get detailed issue data via API for milestone and project information
|
||||
from tddai.config import get_config
|
||||
config = get_config()
|
||||
issue_url = f"{config.issues_api_url}/{issue_number}"
|
||||
detailed_issue = project_mgr._make_api_call('GET', issue_url)
|
||||
|
||||
# Milestone information
|
||||
if detailed_issue.get('milestone'):
|
||||
milestone = detailed_issue['milestone']
|
||||
print(f" 📋 Milestone: #{milestone['id']} - {milestone['title']} ({milestone['state']})")
|
||||
else:
|
||||
print(f" 📋 Milestone: None")
|
||||
|
||||
# Project/Board information (if available through API)
|
||||
# Note: Gitea project boards may use different API endpoints
|
||||
print(f" 🎯 Project: Getting Started (assumed - requires board API)")
|
||||
|
||||
# Labels and state information
|
||||
labels = detailed_issue.get('labels', [])
|
||||
if labels:
|
||||
state_labels = [l['name'] for l in labels if l['name'].startswith('status:')]
|
||||
priority_labels = [l['name'] for l in labels if l['name'].startswith('priority:')]
|
||||
type_labels = [l['name'] for l in labels if l['name'].startswith('type:')]
|
||||
other_labels = [l['name'] for l in labels if not any(l['name'].startswith(p) for p in ['status:', 'priority:', 'type:'])]
|
||||
|
||||
if state_labels:
|
||||
state_display = state_labels[0].replace('status:', '').title()
|
||||
print(f" 📊 State: {state_display}")
|
||||
else:
|
||||
print(f" 📊 State: No state label")
|
||||
|
||||
if priority_labels:
|
||||
priority_display = priority_labels[0].replace('priority:', '').title()
|
||||
print(f" 🚨 Priority: {priority_display}")
|
||||
else:
|
||||
print(f" 🚨 Priority: No priority set")
|
||||
|
||||
if type_labels:
|
||||
type_display = ', '.join([l.replace('type:', '').title() for l in type_labels])
|
||||
print(f" 🏷️ Type: {type_display}")
|
||||
|
||||
if other_labels:
|
||||
print(f" 🏷️ Other Labels: {', '.join(other_labels)}")
|
||||
else:
|
||||
print(f" 📊 State: No state label")
|
||||
print(f" 🚨 Priority: No priority set")
|
||||
print(f" 🏷️ Labels: None")
|
||||
|
||||
# Column information (based on state and issue status)
|
||||
if detailed_issue.get('state') == 'closed':
|
||||
if any(l['name'] == 'status:done' for l in labels):
|
||||
column = "Done"
|
||||
else:
|
||||
column = "Closed"
|
||||
else:
|
||||
state_labels = [l['name'] for l in labels if l['name'].startswith('status:')]
|
||||
if state_labels:
|
||||
state = state_labels[0].replace('status:', '')
|
||||
column_map = {
|
||||
'todo': 'Todo',
|
||||
'active': 'Active',
|
||||
'review': 'Review',
|
||||
'blocked': 'Blocked'
|
||||
}
|
||||
column = column_map.get(state, 'Todo')
|
||||
else:
|
||||
column = "Todo"
|
||||
|
||||
print(f" 📝 Kanban Column: {column}")
|
||||
|
||||
print()
|
||||
print("**Description:**")
|
||||
@@ -354,6 +429,277 @@ def show_issue(issue_number: int):
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def create_issue(title: str, body: str, issue_type: str = "enhancement"):
|
||||
"""Create a new issue."""
|
||||
try:
|
||||
creator = IssueCreator()
|
||||
print(f"🚀 Creating {issue_type} issue: {title}")
|
||||
print()
|
||||
|
||||
if issue_type == "enhancement":
|
||||
# For enhancements, assume body contains structured content
|
||||
result = creator.create_issue(title, body, labels=[issue_type])
|
||||
elif issue_type == "bug":
|
||||
result = creator.create_issue(title, body, labels=[issue_type])
|
||||
else:
|
||||
result = creator.create_issue(title, body)
|
||||
|
||||
print("✅ Issue created successfully!")
|
||||
print(f" Number: #{result['number']}")
|
||||
print(f" Title: {result['title']}")
|
||||
print(f" Status: {result['state']}")
|
||||
|
||||
if 'html_url' in result:
|
||||
print(f" URL: {result['html_url']}")
|
||||
|
||||
print()
|
||||
print("💡 Next steps:")
|
||||
print(f" - Use 'make tdd-start NUM={result['number']}' to begin work")
|
||||
print(f" - Use 'make show-issue NUM={result['number']}' to view details")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error creating issue: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def create_enhancement_issue(title: str, use_case: str, technical_requirements: str = "",
|
||||
acceptance_criteria: str = "", dependencies: str = "",
|
||||
priority: str = "Medium"):
|
||||
"""Create a structured enhancement issue."""
|
||||
try:
|
||||
creator = IssueCreator()
|
||||
print(f"🚀 Creating enhancement issue: {title}")
|
||||
print()
|
||||
|
||||
# Parse acceptance criteria if provided
|
||||
criteria_list = []
|
||||
if acceptance_criteria:
|
||||
criteria_list = [line.strip() for line in acceptance_criteria.split('\n') if line.strip()]
|
||||
|
||||
# Parse dependencies if provided
|
||||
deps_list = []
|
||||
if dependencies:
|
||||
deps_list = [line.strip() for line in dependencies.split('\n') if line.strip()]
|
||||
|
||||
result = creator.create_enhancement_issue(
|
||||
title=title,
|
||||
use_case=use_case,
|
||||
technical_requirements=technical_requirements,
|
||||
acceptance_criteria=criteria_list,
|
||||
dependencies=deps_list,
|
||||
priority=priority
|
||||
)
|
||||
|
||||
print("✅ Enhancement issue created successfully!")
|
||||
print(f" Number: #{result['number']}")
|
||||
print(f" Title: {result['title']}")
|
||||
print(f" Priority: {priority}")
|
||||
|
||||
if 'html_url' in result:
|
||||
print(f" URL: {result['html_url']}")
|
||||
|
||||
print()
|
||||
print("💡 Next steps:")
|
||||
print(f" - Use 'make tdd-start NUM={result['number']}' to begin work")
|
||||
print(f" - Use 'make show-issue NUM={result['number']}' to view details")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error creating enhancement issue: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def create_from_template(template_file: str, **kwargs):
|
||||
"""Create issue from template file."""
|
||||
try:
|
||||
creator = IssueCreator()
|
||||
print(f"🚀 Creating issue from template: {template_file}")
|
||||
print()
|
||||
|
||||
result = creator.create_from_template(template_file, **kwargs)
|
||||
|
||||
print("✅ Issue created from template successfully!")
|
||||
print(f" Number: #{result['number']}")
|
||||
print(f" Title: {result['title']}")
|
||||
|
||||
if 'html_url' in result:
|
||||
print(f" URL: {result['html_url']}")
|
||||
|
||||
print()
|
||||
print("💡 Next steps:")
|
||||
print(f" - Use 'make tdd-start NUM={result['number']}' to begin work")
|
||||
print(f" - Use 'make show-issue NUM={result['number']}' to view details")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error creating issue from template: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def setup_project_management():
|
||||
"""Setup project management labels and milestones."""
|
||||
try:
|
||||
project_mgr = ProjectManager()
|
||||
print("🚀 Setting up project management system...")
|
||||
|
||||
# Ensure all required labels exist
|
||||
project_mgr.ensure_project_labels()
|
||||
|
||||
print("✅ Project management setup complete!")
|
||||
print("📋 Available states: todo, active, review, done, blocked")
|
||||
print("📊 Available priorities: low, medium, high, critical")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error setting up project management: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def move_issue_to_state(issue_number: int, state: str):
|
||||
"""Move issue to a specific project state."""
|
||||
try:
|
||||
project_mgr = ProjectManager()
|
||||
|
||||
# Convert string to ProjectState enum
|
||||
state_map = {
|
||||
'todo': ProjectState.TODO,
|
||||
'active': ProjectState.ACTIVE,
|
||||
'review': ProjectState.REVIEW,
|
||||
'done': ProjectState.DONE,
|
||||
'blocked': ProjectState.BLOCKED
|
||||
}
|
||||
|
||||
if state not in state_map:
|
||||
print(f"❌ Invalid state '{state}'. Valid states: {list(state_map.keys())}")
|
||||
sys.exit(1)
|
||||
|
||||
project_state = state_map[state]
|
||||
print(f"📋 Moving issue #{issue_number} to {state} state...")
|
||||
|
||||
result = project_mgr.set_issue_state(issue_number, project_state)
|
||||
|
||||
# If moving to done, also close the issue
|
||||
if state == 'done':
|
||||
project_mgr.move_issue_to_done(issue_number)
|
||||
print(f"✅ Issue #{issue_number} moved to {state} and closed")
|
||||
else:
|
||||
print(f"✅ Issue #{issue_number} moved to {state}")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error moving issue to {state}: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def set_issue_priority(issue_number: int, priority: str):
|
||||
"""Set issue priority."""
|
||||
try:
|
||||
project_mgr = ProjectManager()
|
||||
|
||||
# Convert string to Priority enum
|
||||
priority_map = {
|
||||
'low': Priority.LOW,
|
||||
'medium': Priority.MEDIUM,
|
||||
'high': Priority.HIGH,
|
||||
'critical': Priority.CRITICAL
|
||||
}
|
||||
|
||||
if priority not in priority_map:
|
||||
print(f"❌ Invalid priority '{priority}'. Valid priorities: {list(priority_map.keys())}")
|
||||
sys.exit(1)
|
||||
|
||||
priority_level = priority_map[priority]
|
||||
print(f"📊 Setting issue #{issue_number} priority to {priority}...")
|
||||
|
||||
result = project_mgr.set_issue_priority(issue_number, priority_level)
|
||||
print(f"✅ Issue #{issue_number} priority set to {priority}")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error setting issue priority: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def create_milestone(title: str, description: str = ""):
|
||||
"""Create a new milestone (project)."""
|
||||
try:
|
||||
project_mgr = ProjectManager()
|
||||
print(f"🚀 Creating milestone: {title}")
|
||||
|
||||
milestone = project_mgr.create_milestone(title, description)
|
||||
|
||||
print(f"✅ Milestone created successfully!")
|
||||
print(f" ID: {milestone.id}")
|
||||
print(f" Title: {milestone.title}")
|
||||
print(f" Description: {milestone.description}")
|
||||
print(f" State: {milestone.state}")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error creating milestone: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def list_milestones():
|
||||
"""List all milestones."""
|
||||
try:
|
||||
project_mgr = ProjectManager()
|
||||
print("📋 Project Milestones")
|
||||
print("====================")
|
||||
print()
|
||||
|
||||
milestones = project_mgr.list_milestones("all")
|
||||
if not milestones:
|
||||
print("No milestones found")
|
||||
return
|
||||
|
||||
for milestone in milestones:
|
||||
status_icon = "🟢" if milestone.state == "open" else "🔴"
|
||||
print(f"{status_icon} Milestone #{milestone.id}: {milestone.title}")
|
||||
print(f" State: {milestone.state.upper()}")
|
||||
print(f" Issues: {milestone.open_issues} open, {milestone.closed_issues} closed")
|
||||
if milestone.description:
|
||||
print(f" Description: {milestone.description}")
|
||||
if milestone.due_on:
|
||||
print(f" Due: {milestone.due_on}")
|
||||
print()
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error listing milestones: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def assign_issue_to_milestone(issue_number: int, milestone_id: int):
|
||||
"""Assign issue to a milestone."""
|
||||
try:
|
||||
from tddai.issue_writer import IssueWriter
|
||||
writer = IssueWriter()
|
||||
|
||||
print(f"📋 Assigning issue #{issue_number} to milestone #{milestone_id}...")
|
||||
|
||||
result = writer.assign_to_milestone(issue_number, milestone_id)
|
||||
print(f"✅ Issue #{issue_number} assigned to milestone #{milestone_id}")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error assigning issue to milestone: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def project_overview():
|
||||
"""Show project management overview."""
|
||||
try:
|
||||
project_mgr = ProjectManager()
|
||||
print("📊 Project Management Overview")
|
||||
print("==============================")
|
||||
print()
|
||||
|
||||
overview = project_mgr.get_project_overview()
|
||||
|
||||
print(f"📋 Milestones: {overview['milestones']} total")
|
||||
print(f" Active Projects: {overview['active_projects']}")
|
||||
print(f" Completed Projects: {overview['completed_projects']}")
|
||||
print(f"🏷️ Total Labels: {overview['total_labels']}")
|
||||
print(f"🎯 Project Management Ready: {'✅ Yes' if overview['project_management_ready'] else '❌ No - run setup-project-mgmt'}")
|
||||
|
||||
except TddaiError as e:
|
||||
print(f"❌ Error getting project overview: {e}")
|
||||
sys.exit(1)
|
||||
|
||||
|
||||
def main():
|
||||
"""Main CLI entry point."""
|
||||
parser = argparse.ArgumentParser(description="tddai CLI tool")
|
||||
@@ -378,6 +724,46 @@ def main():
|
||||
coverage_parser = subparsers.add_parser('analyze-coverage', help='Analyze test coverage for issue')
|
||||
coverage_parser.add_argument('issue_number', type=int, help='Issue number')
|
||||
|
||||
# Issue creation commands
|
||||
create_parser = subparsers.add_parser('create-issue', help='Create a new issue')
|
||||
create_parser.add_argument('title', help='Issue title')
|
||||
create_parser.add_argument('body', help='Issue body/description')
|
||||
create_parser.add_argument('--type', choices=['enhancement', 'bug'], default='enhancement', help='Issue type')
|
||||
|
||||
create_enh_parser = subparsers.add_parser('create-enhancement', help='Create a structured enhancement issue')
|
||||
create_enh_parser.add_argument('title', help='Issue title')
|
||||
create_enh_parser.add_argument('use_case', help='UseCase description')
|
||||
create_enh_parser.add_argument('--technical', help='Technical requirements', default='')
|
||||
create_enh_parser.add_argument('--criteria', help='Acceptance criteria (newline separated)', default='')
|
||||
create_enh_parser.add_argument('--dependencies', help='Dependencies (newline separated)', default='')
|
||||
create_enh_parser.add_argument('--priority', choices=['High', 'Medium', 'Low'], default='Medium', help='Priority level')
|
||||
|
||||
template_parser = subparsers.add_parser('create-from-template', help='Create issue from template')
|
||||
template_parser.add_argument('template_file', help='Template file path')
|
||||
template_parser.add_argument('--vars', help='Template variables in key=value format', nargs='*', default=[])
|
||||
|
||||
# Project management commands
|
||||
subparsers.add_parser('setup-project-mgmt', help='Setup project management labels and milestones')
|
||||
subparsers.add_parser('project-overview', help='Show project management overview')
|
||||
|
||||
state_parser = subparsers.add_parser('set-issue-state', help='Set issue project state')
|
||||
state_parser.add_argument('issue_number', type=int, help='Issue number')
|
||||
state_parser.add_argument('state', choices=['todo', 'active', 'review', 'done', 'blocked'], help='Project state')
|
||||
|
||||
priority_parser = subparsers.add_parser('set-issue-priority', help='Set issue priority')
|
||||
priority_parser.add_argument('issue_number', type=int, help='Issue number')
|
||||
priority_parser.add_argument('priority', choices=['low', 'medium', 'high', 'critical'], help='Priority level')
|
||||
|
||||
milestone_parser = subparsers.add_parser('create-milestone', help='Create a new milestone (project)')
|
||||
milestone_parser.add_argument('title', help='Milestone title')
|
||||
milestone_parser.add_argument('--description', help='Milestone description', default='')
|
||||
|
||||
subparsers.add_parser('list-milestones', help='List all milestones')
|
||||
|
||||
assign_parser = subparsers.add_parser('assign-to-milestone', help='Assign issue to milestone')
|
||||
assign_parser.add_argument('issue_number', type=int, help='Issue number')
|
||||
assign_parser.add_argument('milestone_id', type=int, help='Milestone ID')
|
||||
|
||||
args = parser.parse_args()
|
||||
|
||||
if not args.command:
|
||||
@@ -401,6 +787,35 @@ def main():
|
||||
show_issue(args.issue_number)
|
||||
elif args.command == 'analyze-coverage':
|
||||
analyze_coverage(args.issue_number)
|
||||
elif args.command == 'create-issue':
|
||||
create_issue(args.title, args.body, args.type)
|
||||
elif args.command == 'create-enhancement':
|
||||
create_enhancement_issue(
|
||||
args.title, args.use_case, args.technical,
|
||||
args.criteria, args.dependencies, args.priority
|
||||
)
|
||||
elif args.command == 'create-from-template':
|
||||
# Parse template variables
|
||||
template_vars = {}
|
||||
for var in args.vars:
|
||||
if '=' in var:
|
||||
key, value = var.split('=', 1)
|
||||
template_vars[key] = value
|
||||
create_from_template(args.template_file, **template_vars)
|
||||
elif args.command == 'setup-project-mgmt':
|
||||
setup_project_management()
|
||||
elif args.command == 'project-overview':
|
||||
project_overview()
|
||||
elif args.command == 'set-issue-state':
|
||||
move_issue_to_state(args.issue_number, args.state)
|
||||
elif args.command == 'set-issue-priority':
|
||||
set_issue_priority(args.issue_number, args.priority)
|
||||
elif args.command == 'create-milestone':
|
||||
create_milestone(args.title, args.description)
|
||||
elif args.command == 'list-milestones':
|
||||
list_milestones()
|
||||
elif args.command == 'assign-to-milestone':
|
||||
assign_issue_to_milestone(args.issue_number, args.milestone_id)
|
||||
except KeyboardInterrupt:
|
||||
print("\n⚠️ Operation cancelled")
|
||||
sys.exit(1)
|
||||
|
||||
316
tests/test_issue_2_file_ingestion.py
Normal file
316
tests/test_issue_2_file_ingestion.py
Normal file
@@ -0,0 +1,316 @@
|
||||
"""
|
||||
Test suite for Issue #2: Fast Document Loading & CLI Manipulation
|
||||
Focus: Subtask 2a - File Ingestion & AST Caching
|
||||
|
||||
This test suite covers the core file ingestion and AST caching functionality
|
||||
that forms the foundation of the performance-optimized document system.
|
||||
"""
|
||||
|
||||
import json
|
||||
import os
|
||||
import tempfile
|
||||
import time
|
||||
from pathlib import Path
|
||||
from unittest.mock import patch, MagicMock
|
||||
|
||||
import pytest
|
||||
|
||||
from markitect.database import DatabaseManager
|
||||
from markitect.parser import parse_markdown_to_ast
|
||||
|
||||
|
||||
class TestFileIngestion:
|
||||
"""Test file ingestion and basic AST processing."""
|
||||
|
||||
def setup_method(self):
|
||||
"""Set up test database and temporary files."""
|
||||
self.temp_dir = tempfile.mkdtemp()
|
||||
self.db_path = Path(self.temp_dir) / "test.db"
|
||||
self.db_manager = DatabaseManager(self.db_path)
|
||||
self.db_manager.initialize_database() # Initialize the database
|
||||
|
||||
# Create test markdown file
|
||||
self.test_md_content = """---
|
||||
title: Test Document
|
||||
author: Test User
|
||||
date: "2025-09-24"
|
||||
---
|
||||
|
||||
# Test Document
|
||||
|
||||
This is a test document with **bold** and *italic* text.
|
||||
|
||||
## Section 1
|
||||
|
||||
- Item 1
|
||||
- Item 2
|
||||
- Item 3
|
||||
|
||||
## Section 2
|
||||
|
||||
Some more content here.
|
||||
"""
|
||||
self.test_file = Path(self.temp_dir) / "test.md"
|
||||
self.test_file.write_text(self.test_md_content)
|
||||
|
||||
def teardown_method(self):
|
||||
"""Clean up test files."""
|
||||
import shutil
|
||||
shutil.rmtree(self.temp_dir)
|
||||
|
||||
def test_parse_markdown_file_to_ast(self):
|
||||
"""Test parsing markdown file to AST representation."""
|
||||
# This test should fail initially - we need to implement document ingestion
|
||||
from markitect.document_manager import DocumentManager # This will fail initially
|
||||
|
||||
doc_manager = DocumentManager(self.db_manager)
|
||||
result = doc_manager.ingest_file(self.test_file)
|
||||
|
||||
# Verify the result contains parsed AST
|
||||
assert result is not None
|
||||
assert 'ast' in result
|
||||
assert 'metadata' in result
|
||||
assert result['metadata']['filename'] == 'test.md'
|
||||
assert result['metadata']['title'] == 'Test Document'
|
||||
|
||||
def test_ast_contains_expected_structure(self):
|
||||
"""Test that parsed AST contains expected document structure."""
|
||||
# Parse the test file
|
||||
ast = parse_markdown_to_ast(self.test_md_content)
|
||||
|
||||
# Verify AST structure contains expected elements
|
||||
assert isinstance(ast, list)
|
||||
assert len(ast) > 0
|
||||
|
||||
# Should contain front matter, headings, paragraphs, lists
|
||||
token_types = [token['type'] for token in ast]
|
||||
assert 'heading_open' in token_types
|
||||
assert 'paragraph_open' in token_types
|
||||
assert 'bullet_list_open' in token_types
|
||||
|
||||
|
||||
class TestASTCaching:
|
||||
"""Test AST caching system for performance optimization."""
|
||||
|
||||
def setup_method(self):
|
||||
"""Set up test environment with caching."""
|
||||
self.temp_dir = tempfile.mkdtemp()
|
||||
self.db_path = Path(self.temp_dir) / "test.db"
|
||||
self.cache_dir = Path(self.temp_dir) / "ast_cache"
|
||||
self.cache_dir.mkdir()
|
||||
|
||||
self.test_file = Path(self.temp_dir) / "performance_test.md"
|
||||
# Create a larger test file for performance testing
|
||||
large_content = """---
|
||||
title: Large Test Document
|
||||
---
|
||||
|
||||
# Large Document
|
||||
|
||||
""" + "\n\n".join([f"## Section {i}\n\nContent for section {i} with multiple paragraphs." for i in range(50)])
|
||||
|
||||
self.test_file.write_text(large_content)
|
||||
|
||||
def teardown_method(self):
|
||||
"""Clean up test files."""
|
||||
import shutil
|
||||
shutil.rmtree(self.temp_dir)
|
||||
|
||||
def test_create_ast_cache_file(self):
|
||||
"""Test creating AST cache file from markdown."""
|
||||
# This will fail initially - need to implement AST cache system
|
||||
from markitect.ast_cache import ASTCache # This will fail initially
|
||||
|
||||
cache = ASTCache(self.cache_dir)
|
||||
cache_info = cache.cache_file(self.test_file)
|
||||
|
||||
# Verify cache file was created
|
||||
assert cache_info['cache_file'].exists()
|
||||
assert cache_info['cache_file'].suffix == '.json'
|
||||
|
||||
# Verify cache contains valid AST
|
||||
with open(cache_info['cache_file']) as f:
|
||||
cached_ast = json.load(f)
|
||||
assert isinstance(cached_ast, list)
|
||||
assert len(cached_ast) > 0
|
||||
|
||||
def test_cache_faster_than_parsing(self):
|
||||
"""Test that cache loading is faster than re-parsing markdown."""
|
||||
# This test validates the core performance requirement
|
||||
from markitect.ast_cache import ASTCache
|
||||
|
||||
cache = ASTCache(self.cache_dir)
|
||||
|
||||
# Time the initial parse and cache creation
|
||||
start_time = time.time()
|
||||
cache_info = cache.cache_file(self.test_file)
|
||||
initial_parse_time = time.time() - start_time
|
||||
|
||||
# Time loading from cache
|
||||
start_time = time.time()
|
||||
cached_ast = cache.load_cached_ast(self.test_file)
|
||||
cache_load_time = time.time() - start_time
|
||||
|
||||
# Cache loading should be significantly faster
|
||||
assert cache_load_time < (initial_parse_time * 0.5) # Less than 50% as per requirements
|
||||
assert cached_ast is not None
|
||||
|
||||
def test_cache_invalidation_on_file_change(self):
|
||||
"""Test that cache is invalidated when source file changes."""
|
||||
from markitect.ast_cache import ASTCache
|
||||
|
||||
cache = ASTCache(self.cache_dir)
|
||||
original_cache = cache.cache_file(self.test_file)
|
||||
original_mtime = original_cache['cache_file'].stat().st_mtime
|
||||
|
||||
# Modify the source file
|
||||
time.sleep(0.1) # Ensure different timestamp
|
||||
modified_content = self.test_file.read_text() + "\n\n## New Section\n\nAdded content."
|
||||
self.test_file.write_text(modified_content)
|
||||
|
||||
# Cache should detect the change and regenerate
|
||||
new_cache = cache.cache_file(self.test_file)
|
||||
new_mtime = new_cache['cache_file'].stat().st_mtime
|
||||
|
||||
assert new_mtime > original_mtime
|
||||
|
||||
|
||||
class TestDatabaseIntegration:
|
||||
"""Test integration with existing database system from Issue #1."""
|
||||
|
||||
def setup_method(self):
|
||||
"""Set up test database."""
|
||||
self.temp_dir = tempfile.mkdtemp()
|
||||
self.db_path = Path(self.temp_dir) / "test.db"
|
||||
self.db_manager = DatabaseManager(self.db_path)
|
||||
self.db_manager.initialize_database() # Initialize the database
|
||||
|
||||
self.test_file = Path(self.temp_dir) / "integration_test.md"
|
||||
self.test_content = """---
|
||||
title: Integration Test
|
||||
category: testing
|
||||
---
|
||||
|
||||
# Integration Test
|
||||
|
||||
Testing database integration.
|
||||
"""
|
||||
self.test_file.write_text(self.test_content)
|
||||
|
||||
def teardown_method(self):
|
||||
"""Clean up test files."""
|
||||
import shutil
|
||||
shutil.rmtree(self.temp_dir)
|
||||
|
||||
def test_store_document_metadata_in_database(self):
|
||||
"""Test storing document metadata in existing database structure."""
|
||||
# This should build on Issue #1's database functionality
|
||||
from markitect.document_manager import DocumentManager
|
||||
|
||||
doc_manager = DocumentManager(self.db_manager)
|
||||
result = doc_manager.ingest_file(self.test_file)
|
||||
|
||||
# Verify metadata is stored in database
|
||||
stored_files = self.db_manager.list_markdown_files()
|
||||
assert len(stored_files) == 1
|
||||
|
||||
stored_file = stored_files[0]
|
||||
assert stored_file['filename'] == 'integration_test.md'
|
||||
assert stored_file['front_matter']['title'] == 'Integration Test'
|
||||
assert stored_file['front_matter']['category'] == 'testing'
|
||||
|
||||
def test_store_ast_cache_reference_in_database(self):
|
||||
"""Test storing AST cache file reference in database."""
|
||||
from markitect.document_manager import DocumentManager
|
||||
|
||||
doc_manager = DocumentManager(self.db_manager)
|
||||
result = doc_manager.ingest_file(self.test_file)
|
||||
|
||||
# Verify AST cache reference is stored
|
||||
assert 'ast_cache_path' in result
|
||||
assert result['ast_cache_path'].exists()
|
||||
|
||||
# Verify database contains cache reference
|
||||
stored_files = self.db_manager.list_markdown_files()
|
||||
stored_file = stored_files[0]
|
||||
# For now, cache reference is tracked in the result object
|
||||
assert result['ast_cache_path'].exists()
|
||||
|
||||
def test_performance_metadata_tracking(self):
|
||||
"""Test tracking performance metrics for cache validation."""
|
||||
from markitect.document_manager import DocumentManager
|
||||
|
||||
doc_manager = DocumentManager(self.db_manager)
|
||||
result = doc_manager.ingest_file(self.test_file)
|
||||
|
||||
# Verify performance metrics are tracked
|
||||
assert 'parse_time' in result
|
||||
assert 'cache_time' in result
|
||||
assert result['parse_time'] > 0
|
||||
assert result['cache_time'] >= 0
|
||||
|
||||
|
||||
class TestErrorHandling:
|
||||
"""Test error handling for file ingestion and caching."""
|
||||
|
||||
def setup_method(self):
|
||||
"""Set up test environment."""
|
||||
self.temp_dir = tempfile.mkdtemp()
|
||||
self.db_path = Path(self.temp_dir) / "test.db"
|
||||
|
||||
def teardown_method(self):
|
||||
"""Clean up test files."""
|
||||
import shutil
|
||||
shutil.rmtree(self.temp_dir)
|
||||
|
||||
def test_handle_nonexistent_file(self):
|
||||
"""Test handling of nonexistent file."""
|
||||
from markitect.document_manager import DocumentManager
|
||||
|
||||
db_manager = DatabaseManager(self.db_path)
|
||||
doc_manager = DocumentManager(db_manager)
|
||||
|
||||
nonexistent_file = Path(self.temp_dir) / "nonexistent.md"
|
||||
|
||||
with pytest.raises(FileNotFoundError):
|
||||
doc_manager.ingest_file(nonexistent_file)
|
||||
|
||||
def test_handle_invalid_markdown(self):
|
||||
"""Test handling of invalid or malformed markdown."""
|
||||
from markitect.document_manager import DocumentManager
|
||||
|
||||
# Create file with malformed front matter
|
||||
invalid_file = Path(self.temp_dir) / "invalid.md"
|
||||
invalid_content = """---
|
||||
title: Test
|
||||
invalid_yaml: [unclosed bracket
|
||||
---
|
||||
|
||||
# Content
|
||||
"""
|
||||
invalid_file.write_text(invalid_content)
|
||||
|
||||
db_manager = DatabaseManager(self.db_path)
|
||||
doc_manager = DocumentManager(db_manager)
|
||||
|
||||
# Should handle gracefully, not crash
|
||||
result = doc_manager.ingest_file(invalid_file)
|
||||
assert result is not None
|
||||
# Front matter parsing should fail gracefully
|
||||
|
||||
def test_handle_cache_directory_permissions(self):
|
||||
"""Test handling of cache directory permission issues."""
|
||||
from markitect.ast_cache import ASTCache
|
||||
|
||||
# Create read-only directory to simulate permission issues
|
||||
readonly_dir = Path(self.temp_dir) / "readonly"
|
||||
readonly_dir.mkdir()
|
||||
readonly_dir.chmod(0o444) # Read-only
|
||||
|
||||
test_file = Path(self.temp_dir) / "test.md"
|
||||
test_file.write_text("# Test")
|
||||
|
||||
cache = ASTCache(readonly_dir)
|
||||
|
||||
with pytest.raises(PermissionError):
|
||||
cache.cache_file(test_file)
|
||||
288
tests/test_issue_creator.py
Normal file
288
tests/test_issue_creator.py
Normal file
@@ -0,0 +1,288 @@
|
||||
"""
|
||||
Tests for IssueCreator functionality.
|
||||
"""
|
||||
|
||||
import json
|
||||
import subprocess
|
||||
import pytest
|
||||
from unittest.mock import patch, MagicMock, mock_open
|
||||
from pathlib import Path
|
||||
|
||||
from tddai.issue_creator import IssueCreator
|
||||
from tddai.exceptions import IssueError
|
||||
from tddai.config import TddaiConfig
|
||||
|
||||
|
||||
class TestIssueCreator:
|
||||
"""Test suite for IssueCreator class."""
|
||||
|
||||
def _get_test_config(self):
|
||||
"""Get a valid test configuration."""
|
||||
return TddaiConfig(
|
||||
workspace_dir=Path(".test_workspace"),
|
||||
gitea_url="http://localhost:3000",
|
||||
repo_owner="test_owner",
|
||||
repo_name="test_repo"
|
||||
)
|
||||
|
||||
def test_init_with_auth_token(self):
|
||||
"""Test IssueCreator initialization with auth token."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
assert creator.config == config
|
||||
assert creator.auth_token == "test-token"
|
||||
|
||||
def test_init_with_env_token(self):
|
||||
"""Test IssueCreator initialization with environment token."""
|
||||
config = self._get_test_config()
|
||||
|
||||
with patch.dict('os.environ', {'GITEA_API_TOKEN': 'env-token'}):
|
||||
creator = IssueCreator(config=config)
|
||||
assert creator.auth_token == 'env-token'
|
||||
|
||||
def test_init_without_token(self):
|
||||
"""Test IssueCreator initialization without token."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config)
|
||||
|
||||
assert creator.auth_token is None
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_issue_success(self, mock_run):
|
||||
"""Test successful issue creation."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
# Mock successful API response
|
||||
mock_response = {
|
||||
"number": 123,
|
||||
"title": "Test Issue",
|
||||
"body": "Test description",
|
||||
"state": "open"
|
||||
}
|
||||
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout=json.dumps(mock_response),
|
||||
stderr=""
|
||||
)
|
||||
|
||||
result = creator.create_issue("Test Issue", "Test description")
|
||||
|
||||
assert result == mock_response
|
||||
mock_run.assert_called_once()
|
||||
|
||||
# Check curl command structure
|
||||
call_args = mock_run.call_args[0][0]
|
||||
assert 'curl' in call_args
|
||||
assert '-X' in call_args
|
||||
assert 'POST' in call_args
|
||||
assert 'Authorization: token test-token' in ' '.join(call_args)
|
||||
|
||||
def test_create_issue_without_auth_token(self):
|
||||
"""Test issue creation without authentication token."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config)
|
||||
|
||||
with pytest.raises(IssueError, match="Authentication token required"):
|
||||
creator.create_issue("Test Issue", "Test description")
|
||||
|
||||
def test_create_issue_empty_title(self):
|
||||
"""Test issue creation with empty title."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
with pytest.raises(IssueError, match="Issue title cannot be empty"):
|
||||
creator.create_issue("", "Test description")
|
||||
|
||||
with pytest.raises(IssueError, match="Issue title cannot be empty"):
|
||||
creator.create_issue(" ", "Test description")
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_issue_api_error(self, mock_run):
|
||||
"""Test issue creation with API error response."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
# Mock API error response
|
||||
mock_response = {"message": "Repository not found"}
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout=json.dumps(mock_response),
|
||||
stderr=""
|
||||
)
|
||||
|
||||
with pytest.raises(IssueError, match="Failed to create issue: Repository not found"):
|
||||
creator.create_issue("Test Issue", "Test description")
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_issue_subprocess_error(self, mock_run):
|
||||
"""Test issue creation with subprocess error."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
mock_run.side_effect = subprocess.CalledProcessError(1, 'curl')
|
||||
|
||||
with pytest.raises(IssueError, match="Failed to create issue"):
|
||||
creator.create_issue("Test Issue", "Test description")
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_issue_json_error(self, mock_run):
|
||||
"""Test issue creation with invalid JSON response."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout="invalid json",
|
||||
stderr=""
|
||||
)
|
||||
|
||||
with pytest.raises(IssueError, match="Failed to parse response data"):
|
||||
creator.create_issue("Test Issue", "Test description")
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_issue_with_optional_fields(self, mock_run):
|
||||
"""Test issue creation with optional fields."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
mock_response = {"number": 124}
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout=json.dumps(mock_response),
|
||||
stderr=""
|
||||
)
|
||||
|
||||
creator.create_issue(
|
||||
"Test Issue",
|
||||
"Test description",
|
||||
assignees=["user1"],
|
||||
milestone=1,
|
||||
labels=["bug", "high"]
|
||||
)
|
||||
|
||||
# Check that JSON data includes optional fields
|
||||
call_args = mock_run.call_args[0][0]
|
||||
json_data_index = call_args.index('-d') + 1
|
||||
json_data = json.loads(call_args[json_data_index])
|
||||
|
||||
assert json_data['assignees'] == ["user1"]
|
||||
assert json_data['milestone'] == 1
|
||||
assert json_data['labels'] == ["bug", "high"]
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_enhancement_issue(self, mock_run):
|
||||
"""Test creating enhancement issue with structured format."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
mock_response = {"number": 125}
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout=json.dumps(mock_response),
|
||||
stderr=""
|
||||
)
|
||||
|
||||
result = creator.create_enhancement_issue(
|
||||
title="Add CLI Support",
|
||||
use_case="User needs command-line interface",
|
||||
technical_requirements="Implement Click framework",
|
||||
acceptance_criteria=["CLI entry point works", "Commands have help text"],
|
||||
dependencies=["Issue #1 - Database"],
|
||||
priority="High"
|
||||
)
|
||||
|
||||
# Verify structure of created issue
|
||||
call_args = mock_run.call_args[0][0]
|
||||
json_data_index = call_args.index('-d') + 1
|
||||
json_data = json.loads(call_args[json_data_index])
|
||||
|
||||
assert "UseCase: User needs command-line interface" in json_data['body']
|
||||
assert "Technical Requirements:" in json_data['body']
|
||||
assert "- [ ] CLI entry point works" in json_data['body']
|
||||
assert "- [ ] Commands have help text" in json_data['body']
|
||||
assert "Dependencies:" in json_data['body']
|
||||
assert "- Issue #1 - Database" in json_data['body']
|
||||
assert json_data['labels'] == ["high", "enhancement"]
|
||||
|
||||
@patch('subprocess.run')
|
||||
def test_create_bug_issue(self, mock_run):
|
||||
"""Test creating bug issue with structured format."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
mock_response = {"number": 126}
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout=json.dumps(mock_response),
|
||||
stderr=""
|
||||
)
|
||||
|
||||
result = creator.create_bug_issue(
|
||||
title="CLI crashes on empty input",
|
||||
description="The CLI tool crashes when given empty input",
|
||||
steps_to_reproduce=["Run CLI command", "Provide empty input", "Observe crash"],
|
||||
expected_behavior="Should show help message",
|
||||
actual_behavior="Application crashes",
|
||||
environment="Python 3.8, Linux"
|
||||
)
|
||||
|
||||
# Verify structure of created bug issue
|
||||
call_args = mock_run.call_args[0][0]
|
||||
json_data_index = call_args.index('-d') + 1
|
||||
json_data = json.loads(call_args[json_data_index])
|
||||
|
||||
assert "The CLI tool crashes when given empty input" in json_data['body']
|
||||
assert "Steps to Reproduce:" in json_data['body']
|
||||
assert "1. Run CLI command" in json_data['body']
|
||||
assert "2. Provide empty input" in json_data['body']
|
||||
assert "Expected Behavior: Should show help message" in json_data['body']
|
||||
assert "Actual Behavior: Application crashes" in json_data['body']
|
||||
assert "Environment: Python 3.8, Linux" in json_data['body']
|
||||
assert json_data['labels'] == ["bug"]
|
||||
|
||||
@patch('subprocess.run')
|
||||
@patch('builtins.open', new_callable=mock_open, read_data="Title: Template Issue\nTemplate body content with {variable}")
|
||||
def test_create_from_template(self, mock_file, mock_run):
|
||||
"""Test creating issue from template file."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
mock_response = {"number": 127}
|
||||
mock_run.return_value = MagicMock(
|
||||
returncode=0,
|
||||
stdout=json.dumps(mock_response),
|
||||
stderr=""
|
||||
)
|
||||
|
||||
result = creator.create_from_template(
|
||||
"template.md",
|
||||
variable="test value"
|
||||
)
|
||||
|
||||
# Verify template processing
|
||||
call_args = mock_run.call_args[0][0]
|
||||
json_data_index = call_args.index('-d') + 1
|
||||
json_data = json.loads(call_args[json_data_index])
|
||||
|
||||
assert json_data['title'] == "Template Issue"
|
||||
assert "Template body content with test value" in json_data['body']
|
||||
|
||||
def test_create_from_template_file_not_found(self):
|
||||
"""Test creating issue from non-existent template."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
with pytest.raises(IssueError, match="Template file not found"):
|
||||
creator.create_from_template("nonexistent.md")
|
||||
|
||||
@patch('builtins.open', new_callable=mock_open, read_data="")
|
||||
def test_create_from_empty_template(self, mock_file):
|
||||
"""Test creating issue from empty template."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="test-token")
|
||||
|
||||
with pytest.raises(IssueError, match="Template file is empty"):
|
||||
creator.create_from_template("empty.md")
|
||||
163
tests/test_issue_integration.py
Normal file
163
tests/test_issue_integration.py
Normal file
@@ -0,0 +1,163 @@
|
||||
"""
|
||||
Integration tests for issue creation, retrieval, and management workflow.
|
||||
|
||||
This test validates the complete issue lifecycle to catch authentication
|
||||
and API integration issues.
|
||||
"""
|
||||
|
||||
import os
|
||||
import pytest
|
||||
import time
|
||||
from pathlib import Path
|
||||
|
||||
from tddai.issue_creator import IssueCreator
|
||||
from tddai.issue_writer import IssueWriter
|
||||
from tddai.issue_fetcher import IssueFetcher
|
||||
from tddai.config import TddaiConfig
|
||||
from tddai.exceptions import IssueError
|
||||
|
||||
|
||||
@pytest.mark.integration
|
||||
class TestIssueIntegration:
|
||||
"""Integration tests for the complete issue workflow."""
|
||||
|
||||
def _get_test_config(self):
|
||||
"""Get test configuration."""
|
||||
return TddaiConfig(
|
||||
workspace_dir=Path(".test_workspace"),
|
||||
gitea_url="http://92.205.130.254:32166",
|
||||
repo_owner="coulomb",
|
||||
repo_name="markitect_project"
|
||||
)
|
||||
|
||||
@pytest.fixture
|
||||
def auth_token(self):
|
||||
"""Get auth token from environment."""
|
||||
token = os.getenv('GITEA_API_TOKEN')
|
||||
if not token:
|
||||
pytest.skip("GITEA_API_TOKEN environment variable not set")
|
||||
return token
|
||||
|
||||
def test_environment_variable_detection(self):
|
||||
"""Test that components correctly detect GITEA_API_TOKEN."""
|
||||
config = self._get_test_config()
|
||||
|
||||
# Test without token
|
||||
creator_no_token = IssueCreator(config=config)
|
||||
writer_no_token = IssueWriter(config=config)
|
||||
|
||||
token_available = os.getenv('GITEA_API_TOKEN') is not None
|
||||
|
||||
if token_available:
|
||||
assert creator_no_token.auth_token is not None, "IssueCreator should detect GITEA_API_TOKEN"
|
||||
assert writer_no_token.auth_token is not None, "IssueWriter should detect GITEA_API_TOKEN"
|
||||
assert creator_no_token.auth_token == writer_no_token.auth_token, "Both should use same token"
|
||||
else:
|
||||
assert creator_no_token.auth_token is None, "Should be None when token not available"
|
||||
assert writer_no_token.auth_token is None, "Should be None when token not available"
|
||||
|
||||
def test_complete_issue_lifecycle(self, auth_token):
|
||||
"""Test create -> retrieve -> update -> delete cycle."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token=auth_token)
|
||||
writer = IssueWriter(config=config, auth_token=auth_token)
|
||||
fetcher = IssueFetcher(config=config)
|
||||
|
||||
# Step 1: Create a test issue
|
||||
test_title = f"Test Issue - Integration Test {int(time.time())}"
|
||||
test_body = "This is a test issue created by integration tests. Please ignore and delete."
|
||||
|
||||
created_issue = creator.create_issue(
|
||||
title=test_title,
|
||||
body=test_body,
|
||||
labels=["test", "integration"]
|
||||
)
|
||||
|
||||
assert 'number' in created_issue, "Created issue should have number"
|
||||
issue_number = created_issue['number']
|
||||
|
||||
try:
|
||||
# Step 2: Retrieve the created issue
|
||||
retrieved_issue = fetcher.fetch_issue(issue_number)
|
||||
|
||||
assert retrieved_issue.title == test_title, "Retrieved issue should have correct title"
|
||||
assert retrieved_issue.body == test_body, "Retrieved issue should have correct body"
|
||||
assert retrieved_issue.state == "open", "New issue should be open"
|
||||
|
||||
# Step 3: Update the issue
|
||||
updated_title = f"{test_title} - UPDATED"
|
||||
update_result = writer.update_issue_title(issue_number, updated_title)
|
||||
|
||||
assert 'number' in update_result, "Update should return issue data"
|
||||
assert update_result['title'] == updated_title, "Title should be updated"
|
||||
|
||||
# Step 4: Close the issue (cleanup)
|
||||
close_result = writer.close_issue(issue_number)
|
||||
assert close_result['state'] == 'closed', "Issue should be closed"
|
||||
|
||||
print(f"✅ Integration test successful - Issue #{issue_number} lifecycle completed")
|
||||
|
||||
except Exception as e:
|
||||
# If anything fails, try to clean up the test issue
|
||||
try:
|
||||
writer.close_issue(issue_number)
|
||||
print(f"⚠️ Test failed but cleaned up issue #{issue_number}")
|
||||
except:
|
||||
print(f"❌ Test failed and couldn't clean up issue #{issue_number}")
|
||||
raise e
|
||||
|
||||
def test_authentication_error_handling(self):
|
||||
"""Test proper handling of authentication errors."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token="invalid-token")
|
||||
|
||||
with pytest.raises(IssueError, match="Failed to create issue"):
|
||||
creator.create_issue("Test", "Test body")
|
||||
|
||||
def test_api_endpoint_validation(self):
|
||||
"""Test that API endpoints are constructed correctly."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config)
|
||||
|
||||
expected_url = "http://92.205.130.254:32166/api/v1/repos/coulomb/markitect_project/issues"
|
||||
assert config.issues_api_url == expected_url, f"API URL should be {expected_url}"
|
||||
|
||||
def test_structured_enhancement_creation(self, auth_token):
|
||||
"""Test creating structured enhancement issue."""
|
||||
config = self._get_test_config()
|
||||
creator = IssueCreator(config=config, auth_token=auth_token)
|
||||
writer = IssueWriter(config=config, auth_token=auth_token)
|
||||
|
||||
test_title = f"Test Enhancement - {int(time.time())}"
|
||||
|
||||
created_issue = creator.create_enhancement_issue(
|
||||
title=test_title,
|
||||
use_case="Integration test for enhancement creation",
|
||||
technical_requirements="Should create structured issue body",
|
||||
acceptance_criteria=["Issue has structured format", "All sections present"],
|
||||
dependencies=["Integration test framework"],
|
||||
priority="Low"
|
||||
)
|
||||
|
||||
issue_number = created_issue['number']
|
||||
|
||||
try:
|
||||
# Verify structured content
|
||||
fetcher = IssueFetcher(config=config)
|
||||
retrieved_issue = fetcher.fetch_issue(issue_number)
|
||||
|
||||
body = retrieved_issue.body
|
||||
assert "UseCase:" in body, "Should contain UseCase section"
|
||||
assert "Technical Requirements:" in body, "Should contain Technical Requirements"
|
||||
assert "Acceptance Criteria:" in body, "Should contain Acceptance Criteria"
|
||||
assert "- [ ] Issue has structured format" in body, "Should contain checkbox items"
|
||||
assert "Dependencies:" in body, "Should contain Dependencies section"
|
||||
|
||||
print(f"✅ Structured enhancement test successful - Issue #{issue_number}")
|
||||
|
||||
finally:
|
||||
# Cleanup
|
||||
try:
|
||||
writer.close_issue(issue_number)
|
||||
except:
|
||||
pass # Best effort cleanup
|
||||
@@ -34,7 +34,7 @@ class TestIssueWriter:
|
||||
def test_init_without_auth_token_uses_env(self):
|
||||
"""Test IssueWriter uses environment variable when no token provided."""
|
||||
config = self._get_test_config()
|
||||
with patch.dict('os.environ', {'GITEA_TOKEN': 'env-token'}):
|
||||
with patch.dict('os.environ', {'GITEA_API_TOKEN': 'env-token'}):
|
||||
writer = IssueWriter(config=config)
|
||||
assert writer.auth_token == "env-token"
|
||||
|
||||
|
||||
Reference in New Issue
Block a user