m3taversal
05d74d5e32
Imports 67 files from VPS (/opt/teleo-eval/) into repo as the single source of truth. Previously only 8 of 67 files existed in repo — the rest were deployed directly to VPS via SCP, causing massive drift. Includes: - pipeline/lib/: 33 Python modules (daemon core, extraction, evaluation, merge, cascade, cross-domain, costs, attribution, etc.) - pipeline/: main daemon (teleo-pipeline.py), reweave.py, batch-extract-50.sh - diagnostics/: 19 files (4-page dashboard, alerting, daily digest, review queue, tier1 metrics) - agent-state/: bootstrap, lib-state, cascade inbox processor, schema - systemd/: service unit files for reference - deploy.sh: rsync-based deploy with --dry-run, syntax checks, dirty-tree gate - research-session.sh: updated with Step 8.5 digest + cascade inbox processing No new code written — all files are exact copies from VPS as of 2026-04-06. From this point forward: edit in repo, commit, then deploy.sh. Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
64 lines
1.9 KiB
Python
64 lines
1.9 KiB
Python
"""Route handlers for /api/review-queue endpoint.
|
|
|
|
Import into app.py and register routes in create_app().
|
|
"""
|
|
|
|
import logging
|
|
|
|
from aiohttp import web
|
|
from review_queue import fetch_review_queue
|
|
|
|
logger = logging.getLogger("argus.review_queue")
|
|
|
|
|
|
async def handle_review_queue(request):
|
|
"""GET /api/review-queue — PR review pipeline view.
|
|
|
|
Query params:
|
|
status: filter by status (broken, needs-review, approved-awaiting-merge, changes-requested)
|
|
author: filter by agent/author name
|
|
domain: filter by domain
|
|
|
|
Returns JSON with queue items sorted by display priority:
|
|
broken (flagged) > needs-review (by age) > approved-awaiting-merge
|
|
"""
|
|
token = request.app.get("_forgejo_token")
|
|
|
|
try:
|
|
queue = await fetch_review_queue(forgejo_token=token)
|
|
except Exception as e:
|
|
logger.error("Review queue fetch failed: %s", e)
|
|
return web.json_response({"error": str(e)}, status=500)
|
|
|
|
# Apply filters
|
|
status_filter = request.query.get("status")
|
|
if status_filter:
|
|
queue = [item for item in queue if item["status"] == status_filter]
|
|
|
|
author_filter = request.query.get("author")
|
|
if author_filter:
|
|
queue = [item for item in queue if item["author"] == author_filter]
|
|
|
|
domain_filter = request.query.get("domain")
|
|
if domain_filter:
|
|
queue = [item for item in queue if item["domain"] == domain_filter]
|
|
|
|
# Summary stats
|
|
status_counts = {}
|
|
for item in queue:
|
|
status_counts[item["status"]] = status_counts.get(item["status"], 0) + 1
|
|
|
|
return web.json_response({
|
|
"queue": queue,
|
|
"total": len(queue),
|
|
"status_counts": status_counts,
|
|
})
|
|
|
|
|
|
def register_review_queue_routes(app, forgejo_token=None):
|
|
"""Register review queue routes on the app.
|
|
|
|
forgejo_token: optional Forgejo API token for authenticated requests
|
|
"""
|
|
app["_forgejo_token"] = forgejo_token
|
|
app.router.add_get("/api/review-queue", handle_review_queue)
|