feat(api): add GitHub PR integration for pull request management

.env.example

@@ -88,3 +88,16 @@ AUTH_SECRET=CHANGE-ME-IN-PRODUCTION
 # Enable authentication requirement (default: false for migration)
 # Set to true in production to enforce authentication
 # AUTH_REQUIRED=false
+
+# ============================================================================
+# GitHub Integration (Optional - for PR creation)
+# ============================================================================
+
+# GitHub Personal Access Token with repo scope
+# Get yours at: https://github.com/settings/tokens
+# Required for: creating PRs, merging PRs, GitHub integration
+# GITHUB_TOKEN=ghp_...
+
+# Target repository in format "owner/repo"
+# Example: frankbria/codeframe
+# GITHUB_REPO=owner/repo

codeframe/core/config.py

@@ -115,6 +115,10 @@ class GlobalConfig(BaseSettings):
     default_provider: str = "claude"
     default_model: str = "claude-sonnet-4"
 
+    # GitHub Integration (Sprint 11 - PR Management)
+    github_token: Optional[str] = Field(None, alias="GITHUB_TOKEN")
+    github_repo: Optional[str] = Field(None, alias="GITHUB_REPO")  # Format: "owner/repo"
+
     model_config = SettingsConfigDict(
         env_file=".env", env_file_encoding="utf-8", case_sensitive=False, extra="ignore"
     )

codeframe/git/github_integration.py

@@ -0,0 +1,329 @@
+"""GitHub API Integration for CodeFRAME.
+
+Handles GitHub API operations for Pull Request management.
+Part of Sprint 11 - GitHub PR Integration.
+"""
+
+from dataclasses import dataclass
+from datetime import datetime
+from typing import Any, Dict, List, Optional
+import logging
+
+import httpx
+
+logger = logging.getLogger(__name__)
+
+
+class GitHubAPIError(Exception):
+    """Exception raised when GitHub API returns an error."""
+
+    def __init__(
+        self,
+        status_code: int,
+        message: str,
+        details: Optional[Dict[str, Any]] = None,
+    ):
+        self.status_code = status_code
+        self.message = message
+        self.details = details
+        super().__init__(f"GitHub API Error ({status_code}): {message}")
+
+
+@dataclass
+class PRDetails:
+    """Pull Request details from GitHub API."""
+
+    number: int
+    url: str
+    state: str
+    title: str
+    body: Optional[str]
+    created_at: datetime
+    merged_at: Optional[datetime]
+    head_branch: str
+    base_branch: str
+
+
+@dataclass
+class MergeResult:
+    """Result of a PR merge operation."""
+
+    sha: Optional[str]
+    merged: bool
+    message: str
+
+
+class GitHubIntegration:
+    """GitHub API client for PR operations.
+
+    Provides methods for creating, listing, merging, and closing
+    pull requests via the GitHub REST API.
+    """
+
+    BASE_URL = "https://api.github.com"
+
+    def __init__(self, token: str, repo: str):
+        """Initialize GitHub integration.
+
+        Args:
+            token: GitHub Personal Access Token with repo scope
+            repo: Repository in format "owner/repo"
+
+        Raises:
+            ValueError: If repo format is invalid
+        """
+        parts = repo.split("/", 1)
+        if len(parts) != 2 or not parts[0].strip() or not parts[1].strip():
+            raise ValueError(
+                f"Invalid repo format: '{repo}'. Expected 'owner/repo'"
+            )
+
+        self.token = token
+        self.repo = repo
+        self.owner, self.repo_name = parts[0].strip(), parts[1].strip()
+
+        self._client = httpx.AsyncClient(
+            headers={
+                "Authorization": f"Bearer {token}",
+                "Accept": "application/vnd.github.v3+json",
+                "X-GitHub-Api-Version": "2022-11-28",
+            },
+            timeout=30.0,
+        )
+
+    async def _make_request(
+        self,
+        method: str,
+        endpoint: str,
+        json_data: Optional[Dict[str, Any]] = None,
+    ) -> Any:
+        """Make an authenticated request to GitHub API.
+
+        Args:
+            method: HTTP method (GET, POST, PATCH, PUT, DELETE)
+            endpoint: API endpoint path
+            json_data: Optional JSON body data
+
+        Returns:
+            Parsed JSON response
+
+        Raises:
+            GitHubAPIError: If API returns an error status
+        """
+        url = f"{self.BASE_URL}{endpoint}"
+
+        try:
+            response = await self._client.request(
+                method=method,
+                url=url,
+                json=json_data,
+            )
+
+            if response.status_code >= 400:
+                try:
+                    error_data = response.json()
+                    message = error_data.get("message", response.text)
+                    details = error_data.get("errors")
+                except Exception:
+                    message = response.text
+                    details = None
+
+                raise GitHubAPIError(
+                    status_code=response.status_code,
+                    message=message,
+                    details={"errors": details} if details else None,
+                )
+
+            # Handle empty responses (204 No Content)
+            if response.status_code == 204:
+                return None
+
+            return response.json()
+
+        except httpx.TimeoutException as e:
+            logger.error(f"GitHub API timeout: {e}")
+            raise GitHubAPIError(
+                status_code=408,
+                message="Request timed out",
+            )
+        except httpx.RequestError as e:
+            logger.error(f"GitHub API request error: {e}")
+            raise GitHubAPIError(
+                status_code=500,
+                message=f"Request failed: {str(e)}",
+            )
+
+    def _parse_pr_response(self, data: Dict[str, Any]) -> PRDetails:
+        """Parse GitHub PR response into PRDetails object.
+
+        Args:
+            data: Raw GitHub API response
+
+        Returns:
+            Parsed PRDetails object
+        """
+        created_at = datetime.fromisoformat(
+            data["created_at"].replace("Z", "+00:00")
+        )
+        merged_at = None
+        if data.get("merged_at"):
+            merged_at = datetime.fromisoformat(
+                data["merged_at"].replace("Z", "+00:00")
+            )
+
+        return PRDetails(
+            number=data["number"],
+            url=data["html_url"],
+            state=data["state"],
+            title=data["title"],
+            body=data.get("body"),
+            created_at=created_at,
+            merged_at=merged_at,
+            head_branch=data["head"]["ref"],
+            base_branch=data["base"]["ref"],
+        )
+
+    async def create_pull_request(
+        self,
+        branch: str,
+        title: str,
+        body: str,
+        base: str = "main",
+    ) -> PRDetails:
+        """Create a new pull request.
+
+        Args:
+            branch: Head branch with changes
+            title: PR title
+            body: PR description
+            base: Base branch to merge into (default: main)
+
+        Returns:
+            PRDetails with the created PR info
+
+        Raises:
+            GitHubAPIError: If PR creation fails
+        """
+        endpoint = f"/repos/{self.owner}/{self.repo_name}/pulls"
+
+        data = await self._make_request(
+            method="POST",
+            endpoint=endpoint,
+            json_data={
+                "title": title,
+                "body": body,
+                "head": branch,
+                "base": base,
+            },
+        )
+
+        logger.info(f"Created PR #{data['number']}: {title}")
+        return self._parse_pr_response(data)
+
+    async def get_pull_request(self, pr_number: int) -> PRDetails:
+        """Get pull request details.
+
+        Args:
+            pr_number: PR number
+
+        Returns:
+            PRDetails with the PR info
+
+        Raises:
+            GitHubAPIError: If PR not found or API error
+        """
+        endpoint = f"/repos/{self.owner}/{self.repo_name}/pulls/{pr_number}"
+
+        data = await self._make_request(
+            method="GET",
+            endpoint=endpoint,
+        )
+
+        return self._parse_pr_response(data)
+
+    async def list_pull_requests(
+        self,
+        state: str = "open",
+    ) -> List[PRDetails]:
+        """List pull requests for the repository.
+
+        Args:
+            state: Filter by state (open, closed, all)
+
+        Returns:
+            List of PRDetails
+
+        Raises:
+            GitHubAPIError: If API error occurs
+        """
+        endpoint = f"/repos/{self.owner}/{self.repo_name}/pulls"
+
+        data = await self._make_request(
+            method="GET",
+            endpoint=f"{endpoint}?state={state}",
+        )
+
+        return [self._parse_pr_response(pr) for pr in data]
+
+    async def merge_pull_request(
+        self,
+        pr_number: int,
+        method: str = "squash",
+    ) -> MergeResult:
+        """Merge a pull request.
+
+        Args:
+            pr_number: PR number to merge
+            method: Merge method (merge, squash, rebase)
+
+        Returns:
+            MergeResult with merge outcome
+
+        Raises:
+            GitHubAPIError: If merge fails
+        """
+        endpoint = f"/repos/{self.owner}/{self.repo_name}/pulls/{pr_number}/merge"
+
+        data = await self._make_request(
+            method="PUT",
+            endpoint=endpoint,
+            json_data={
+                "merge_method": method,
+            },
+        )
+
+        logger.info(f"Merged PR #{pr_number} with method '{method}'")
+        return MergeResult(
+            sha=data.get("sha"),
+            merged=data.get("merged", False),
+            message=data.get("message", ""),
+        )
+
+    async def close_pull_request(self, pr_number: int) -> bool:
+        """Close a pull request without merging.
+
+        Args:
+            pr_number: PR number to close
+
+        Returns:
+            True if successfully closed
+
+        Raises:
+            GitHubAPIError: If close fails
+        """
+        endpoint = f"/repos/{self.owner}/{self.repo_name}/pulls/{pr_number}"
+
+        data = await self._make_request(
+            method="PATCH",
+            endpoint=endpoint,
+            json_data={
+                "state": "closed",
+            },
+        )
+
+        logger.info(f"Closed PR #{pr_number}")
+        return data.get("state") == "closed"
+
+    async def close(self) -> None:
+        """Close the HTTP client."""
+        await self._client.aclose()

codeframe/persistence/database.py

@@ -34,6 +34,7 @@
     CorrectionRepository,
     ActivityRepository,
     AuditRepository,
+    PRRepository,
 )
 
 if TYPE_CHECKING:
@@ -106,6 +107,7 @@ def __init__(self, db_path: Path | str):
         self.correction_attempts: Optional[CorrectionRepository] = None
         self.activities: Optional[ActivityRepository] = None
         self.audit_logs: Optional[AuditRepository] = None
+        self.pull_requests: Optional[PRRepository] = None
 
     def initialize(self) -> None:
         """Initialize database schema and repositories."""
@@ -151,6 +153,7 @@ def _initialize_repositories(self) -> None:
         self.correction_attempts = CorrectionRepository(sync_conn=self.conn, async_conn=self._async_conn, database=self, sync_lock=self._sync_lock)
         self.activities = ActivityRepository(sync_conn=self.conn, async_conn=self._async_conn, database=self, sync_lock=self._sync_lock)
         self.audit_logs = AuditRepository(sync_conn=self.conn, async_conn=self._async_conn, database=self, sync_lock=self._sync_lock)
+        self.pull_requests = PRRepository(sync_conn=self.conn, async_conn=self._async_conn, database=self, sync_lock=self._sync_lock)
 
     # Backward compatibility properties (maintain old *_repository naming)
     @property
@@ -211,7 +214,8 @@ def _update_repository_async_connections(self) -> None:
         for repo in [self.projects, self.issues, self.tasks, self.agents, self.blockers,
                      self.memories, self.context_items, self.checkpoints, self.git_branches,
                      self.test_results, self.lint_results, self.code_reviews, self.quality_gates,
-                     self.token_usage, self.correction_attempts, self.activities, self.audit_logs]:
+                     self.token_usage, self.correction_attempts, self.activities, self.audit_logs,
+                     self.pull_requests]:
             if repo:
                 repo._async_conn = self._async_conn