4592e35732
Brain Service: - Playwright stealth crawler replacing browserless (og:image, Readability, Reddit JSON API) - AI classification with tag definitions and folder assignment - YouTube video download via yt-dlp - Karakeep migration complete (96 items) - Taxonomy management (folders with icons/colors, tags) - Discovery shuffle, sort options, search (Meilisearch + pgvector) - Item tag/folder editing, card color accents RSS Reader Service: - Custom FastAPI reader replacing Miniflux - Feed management (add/delete/refresh), category support - Full article extraction via Readability - Background content fetching for new entries - Mark all read with confirmation - Infinite scroll, retention cleanup (30/60 day) - 17 feeds migrated from Miniflux iOS App (SwiftUI): - Native iOS 17+ app with @Observable architecture - Cookie-based auth, configurable gateway URL - Dashboard with custom background photo + frosted glass widgets - Full fitness module (today/templates/goals/food library) - AI assistant chat (fitness + brain, raw JSON state management) - 120fps ProMotion support AI Assistants (Gateway): - Unified dispatcher with fitness/brain domain detection - Fitness: natural language food logging, photo analysis, multi-item splitting - Brain: save/append/update/delete notes, search & answer, undo support - Madiha user gets fitness-only (brain disabled) Firefox Extension: - One-click save to Brain from any page - Login with platform credentials - Right-click context menu (save page/link/image) - Notes field for URL saves - Signed and published on AMO Other: - Reader bookmark button routes to Brain (was Karakeep) - Fitness food library with "Add" button + add-to-meal popup - Kindle send file size check (25MB SMTP2GO limit) - Atelier UI as default (useAtelierShell=true) - Mobile upload box in nav drawer Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
69 lines
2.3 KiB
Python
69 lines
2.3 KiB
Python
"""
|
|
Platform Gateway — Proxy helper and service routing.
|
|
"""
|
|
|
|
import json
|
|
import urllib.request
|
|
import urllib.error
|
|
|
|
from database import get_db
|
|
|
|
|
|
def proxy_request(target_url, method, headers, body=None, timeout=120):
|
|
"""Proxy a request to a backend service. Returns (status, response_headers, response_body).
|
|
All internal services use plain HTTP (Docker network) — no SSL context needed.
|
|
"""
|
|
try:
|
|
req = urllib.request.Request(target_url, data=body, method=method)
|
|
for k, v in headers.items():
|
|
req.add_header(k, v)
|
|
|
|
with urllib.request.urlopen(req, timeout=timeout) as resp:
|
|
resp_body = resp.read()
|
|
resp_headers = dict(resp.headers)
|
|
return resp.status, resp_headers, resp_body
|
|
|
|
except urllib.error.HTTPError as e:
|
|
body = e.read() if e.fp else b'{}'
|
|
return e.code, dict(e.headers), body
|
|
except Exception as e:
|
|
return 502, {"Content-Type": "application/json"}, json.dumps({"error": f"Service unavailable: {e}"}).encode()
|
|
|
|
|
|
# ── Service routing ──
|
|
|
|
SERVICE_MAP = {} # populated from DB at startup
|
|
|
|
|
|
def load_service_map():
|
|
global SERVICE_MAP
|
|
conn = get_db()
|
|
rows = conn.execute("SELECT id, proxy_target FROM apps WHERE enabled = 1").fetchall()
|
|
conn.close()
|
|
SERVICE_MAP = {row["id"]: row["proxy_target"] for row in rows}
|
|
|
|
|
|
def resolve_service(path):
|
|
"""Given /api/trips/foo, return ('trips', 'http://backend:8087', '/api/foo')."""
|
|
# Path format: /api/{service_id}/...
|
|
parts = path.split("/", 4) # ['', 'api', 'trips', 'foo']
|
|
if len(parts) < 3:
|
|
return None, None, None
|
|
service_id = parts[2]
|
|
target = SERVICE_MAP.get(service_id)
|
|
if not target:
|
|
return None, None, None
|
|
remainder = "/" + "/".join(parts[3:]) if len(parts) > 3 else "/"
|
|
# Services that don't use /api prefix (Express apps, etc.)
|
|
NO_API_PREFIX_SERVICES = {"inventory", "music", "budget"}
|
|
SERVICE_PATH_PREFIX = {}
|
|
if service_id in SERVICE_PATH_PREFIX:
|
|
backend_path = f"{SERVICE_PATH_PREFIX[service_id]}{remainder}"
|
|
elif service_id in NO_API_PREFIX_SERVICES:
|
|
backend_path = remainder
|
|
elif remainder.startswith("/images/") or remainder.startswith("/documents/"):
|
|
backend_path = remainder
|
|
else:
|
|
backend_path = f"/api{remainder}"
|
|
return service_id, target, backend_path
|