Phase 7: Implement SlippageAnalyst and Performance schemas for GitOps

Author: darestack

src/agents/performance.py

@@ -0,0 +1,48 @@
+from src.llm.factory import LLMFactory
+from src.schemas.performance import SlippageAnalysis, SlippageStatus
+from src.core.logging import logger
+
+
+class SlippageAnalyst:
+    """
+    The Specialized Intelligence Layer for GitOps Accountability.
+    Analyzes 'Promise-vs-Reality' (Commit/PR) ratios.
+    """
+
+    def __init__(self, provider_name: str = None):
+        self.llm = LLMFactory.get_provider(provider_name)
+
+    async def analyze_performance_gap(
+        self, promised_tasks: list[str], actual_work_done: str
+    ) -> SlippageAnalysis:
+        """
+        Calculates the slippage between what was committed in Git/Chat and what was delivered.
+        """
+        logger.info(
+            "slippage_analysis_started",
+            tasks_count=len(promised_tasks),
+        )
+
+        prompt = f"""
+        Execute a high-stakes performance audit.
+        
+        PROMISED TASKS:
+        {promised_tasks}
+        
+        ACTUAL WORK DONE (Evidence):
+        {actual_work_done}
+        
+        Analyze if the developer is 'slipping' or creating 'shadow debt' (promising refactors but only doing hotfixes).
+        """
+
+        analysis: SlippageAnalysis = await self.llm.generate(
+            prompt=prompt, response_model=SlippageAnalysis
+        )
+
+        logger.info(
+            "slippage_analysis_complete",
+            status=analysis.status,
+            ratio=analysis.fulfillment_ratio,
+        )
+
+        return analysis

src/schemas/performance.py

@@ -0,0 +1,31 @@
+from pydantic import BaseModel, Field
+from enum import Enum
+
+
+class SlippageStatus(str, Enum):
+    ON_TRACK = "on_track"
+    SLIPPING = "slipping"
+    BROKEN = "broken"
+    SHADOW_DEBT = "shadow_debt"
+
+
+class SlippageAnalysis(BaseModel):
+    status: SlippageStatus
+    fulfillment_ratio: float = Field(..., ge=0, le=1)
+    detected_gap: str = Field(..., description="Description of promised vs reality.")
+    risk_to_system_stability: float = Field(..., ge=0, le=1)
+    intervention_required: bool
+
+
+class GitCommitPromise(BaseModel):
+    commit_hash: str
+    author_email: str
+    message: str
+    extracted_tasks: list[str]
+    deadline_hint: Optional[str] = None
+
+
+class GitInbound(BaseModel):
+    repository: str
+    branch: str
+    commits: list[GitCommitPromise]