app/routers/pairs.py

import json
from fastapi import APIRouter, Depends, HTTPException
from app.database import get_db
from app.feature_engineering import normalize_object
from app.services import score_pair
from app.repository import list_high_risk_pairs, get_pair, get_pair_history, pairs_in_same_shell, object_pairs
router=APIRouter(prefix="/api/v1", tags=["pairs"])
@router.post("/score/pair")
def score_pair_route(payload:dict, db=Depends(get_db)): return score_pair(db, normalize_object(payload["primary"]), normalize_object(payload["secondary"]))
@router.get("/pairs/high-risk")
def high_risk(limit:int=50, db=Depends(get_db)):
    rows=list_high_risk_pairs(db, limit)
    return [{"pair_id":r.pair_id,"risk_score":r.risk_score,"anomaly_score":r.anomaly_score,"final_score":r.final_score,"risk_label":r.risk_label,"recurrence_count":r.recurrence_count,"trend_delta_24h":r.trend_delta_24h,"shell_key":r.shell_key,"top_factors":json.loads(r.top_factors_json)} for r in rows]
@router.get("/pairs/{pair_id}")
def pair_detail(pair_id:str, db=Depends(get_db)):
    row=get_pair(db, pair_id)
    if not row: raise HTTPException(status_code=404, detail="Pair not found")
    payload=json.loads(row.feature_payload_json)
    return {"pair_id":row.pair_id,"primary_object_id":row.primary_object_id,"secondary_object_id":row.secondary_object_id,"risk_score":row.risk_score,"anomaly_score":row.anomaly_score,"final_score":row.final_score,"risk_label":row.risk_label,"recurrence_count":row.recurrence_count,"trend_delta_24h":row.trend_delta_24h,"shell_key":row.shell_key,"top_factors":json.loads(row.top_factors_json),"features":payload,"analyst_summary":payload.get("analyst_summary",""),"structured_explanation":payload.get("structured_explanation",{})}
@router.get("/pairs/{pair_id}/history")
def pair_history(pair_id:str, limit:int=20, db=Depends(get_db)):
    rows=get_pair_history(db, pair_id, limit)
    return [{"history_id":r.history_id,"run_id":r.run_id,"risk_score":r.risk_score,"anomaly_score":r.anomaly_score,"final_score":r.final_score,"created_at":r.created_at} for r in rows]
@router.get("/pairs/{pair_id}/neighbors")
def pair_neighbors(pair_id:str, limit:int=20, db=Depends(get_db)):
    row=get_pair(db, pair_id)
    if not row: raise HTTPException(status_code=404, detail="Pair not found")
    shell_rows=pairs_in_same_shell(db, row.shell_key or "unknown", row.pair_id, limit)
    object_related=object_pairs(db, row.primary_object_id, limit)+object_pairs(db, row.secondary_object_id, limit)
    seen={pair_id}; related=[]
    for r in shell_rows+object_related:
        if r.pair_id in seen: continue
        seen.add(r.pair_id); related.append({"pair_id":r.pair_id,"final_score":r.final_score,"risk_label":r.risk_label,"top_factors":json.loads(r.top_factors_json)})
        if len(related)>=limit: break
    return related