#!/usr/bin/env python3 """ SVG Review Server v2 Single-image review flow with comments, variations, and idea capture. """ import http.server import json import os import shutil import urllib.parse from pathlib import Path from datetime import datetime PORT = 8766 # Permanent port - bookmark this! BASE_DIR = Path.home() / "Documents" / "Etsy Designs" REVIEW_DIR = BASE_DIR / "02-SVG-Review" READY_DIR = BASE_DIR / "03-SVG-Ready" REJECTED_DIR = BASE_DIR / "04-Archive" / "rejected" WORKSPACE = Path.home() / ".openclaw" / "workspace" IDEAS_FILE = WORKSPACE / "data" / "svg-ideas.json" FEEDBACK_FILE = WORKSPACE / "data" / "svg-feedback.json" class ReviewHandler(http.server.BaseHTTPRequestHandler): def do_GET(self): parsed = urllib.parse.urlparse(self.path) path = parsed.path if path == "/" or path == "/review": self.serve_review_page() elif path.startswith("/svg/"): self.serve_svg(path[5:]) elif path == "/api/list": self.api_list() elif path == "/api/current": self.api_current() elif path == "/api/ideas": self.api_get_ideas() elif path == "/api/spend": self.api_spend() else: self.send_error(404) def do_POST(self): parsed = urllib.parse.urlparse(self.path) content_length = int(self.headers.get("Content-Length", 0)) body = self.rfile.read(content_length).decode() if content_length > 0 else "{}" try: data = json.loads(body) if body else {} except: data = {} if parsed.path == "/api/approve": self.api_action("approve", data) elif parsed.path == "/api/reject": self.api_action("reject", data) elif parsed.path == "/api/idea": self.api_save_idea(data) else: self.send_error(404) def do_OPTIONS(self): self.send_response(200) self.send_header("Access-Control-Allow-Origin", "*") self.send_header("Access-Control-Allow-Methods", "GET, POST, OPTIONS") self.send_header("Access-Control-Allow-Headers", "Content-Type") self.end_headers() def get_files(self): files = [] if REVIEW_DIR.exists(): for f in sorted(REVIEW_DIR.glob("*.svg")): files.append({ "name": f.name, "path": str(f), "size": f"{f.stat().st_size // 1024} KB" }) return files def serve_svg(self, filename): filepath = REVIEW_DIR / filename if filepath.exists() and filepath.suffix.lower() == ".svg": with open(filepath, "rb") as f: content = f.read() self.send_response(200) self.send_header("Content-Type", "image/svg+xml") self.send_header("Content-Length", len(content)) self.send_header("Cache-Control", "no-cache") self.end_headers() self.wfile.write(content) else: self.send_error(404) def api_list(self): files = self.get_files() self.send_json({"files": files, "count": len(files)}) def api_current(self): files = self.get_files() if files: self.send_json({"file": files[0], "remaining": len(files)}) else: self.send_json({"file": None, "remaining": 0}) def api_spend(self): spend_file = WORKSPACE / "data" / "dalle-spend.json" if spend_file.exists(): with open(spend_file) as f: self.send_json(json.load(f)) else: self.send_json({"totalSpend": 0, "totalImages": 0}) def api_action(self, action, data): filename = data.get("filename", "") comment = data.get("comment", "").strip() request_variation = data.get("variation", False) if not filename: self.send_json({"error": "No filename"}, 400) return src = REVIEW_DIR / filename if not src.exists(): self.send_json({"error": f"File not found: {filename}"}, 404) return # Determine destination dest_dir = READY_DIR if action == "approve" else REJECTED_DIR dest_dir.mkdir(parents=True, exist_ok=True) dest = dest_dir / filename # Handle duplicates counter = 1 while dest.exists(): dest = dest_dir / f"{src.stem}-{counter}{src.suffix}" counter += 1 shutil.move(str(src), str(dest)) # Save feedback if any if comment or request_variation: self.save_feedback(filename, action, comment, request_variation) # Get next file files = self.get_files() next_file = files[0] if files else None self.send_json({ "success": True, "action": action, "filename": filename, "destination": str(dest), "next": next_file, "remaining": len(files) }) def save_feedback(self, filename, action, comment, variation): FEEDBACK_FILE.parent.mkdir(parents=True, exist_ok=True) feedback = [] if FEEDBACK_FILE.exists(): with open(FEEDBACK_FILE) as f: feedback = json.load(f) feedback.append({ "timestamp": datetime.now().isoformat(), "filename": filename, "action": action, "comment": comment, "requestVariation": variation }) with open(FEEDBACK_FILE, 'w') as f: json.dump(feedback, f, indent=2) def api_save_idea(self, data): idea = data.get("idea", "").strip() if not idea: self.send_json({"error": "No idea provided"}, 400) return IDEAS_FILE.parent.mkdir(parents=True, exist_ok=True) ideas = [] if IDEAS_FILE.exists(): with open(IDEAS_FILE) as f: ideas = json.load(f) ideas.append({ "timestamp": datetime.now().isoformat(), "idea": idea, "status": "pending" }) with open(IDEAS_FILE, 'w') as f: json.dump(ideas, f, indent=2) self.send_json({"success": True, "totalIdeas": len(ideas)}) def api_get_ideas(self): if IDEAS_FILE.exists(): with open(IDEAS_FILE) as f: ideas = json.load(f) pending = [i for i in ideas if i.get("status") == "pending"] self.send_json({"ideas": pending, "total": len(ideas)}) else: self.send_json({"ideas": [], "total": 0}) def send_json(self, data, status=200): body = json.dumps(data).encode() self.send_response(status) self.send_header("Content-Type", "application/json") self.send_header("Content-Length", len(body)) self.send_header("Access-Control-Allow-Origin", "*") self.end_headers() self.wfile.write(body) def serve_review_page(self): files = self.get_files() current = files[0] if files else None ready_count = len(list(READY_DIR.glob("*.svg"))) if READY_DIR.exists() else 0 # Get spend spend_file = WORKSPACE / "data" / "dalle-spend.json" today_spend = month_spend = 0 if spend_file.exists(): with open(spend_file) as f: spend = json.load(f) today = datetime.now().strftime("%Y-%m-%d") month = datetime.now().strftime("%Y-%m") today_spend = spend.get("dailySpend", {}).get(today, {}).get("spend", 0) month_spend = spend.get("monthlySpend", {}).get(month, {}).get("spend", 0) html = f''' SVG Review ā€” Royal Styles Creations

šŸŽØ SVG Review

Remaining: {len(files)}
Ready: {ready_count}
DALL-E Today: ${today_spend:.2f}
Month: ${month_spend:.2f}
{'

āœ“ All Done!

No designs waiting for review.

' if not current else f"""

Reviewing: {current['name']}

{current['size']}
Preview

šŸ’” New Idea

šŸ“‹ Queue ({len(files)} remaining)

{"".join(f'
{f["name"]}
' for f in files[:10])} {f'
...and {len(files) - 10} more
' if len(files) > 10 else ''}
"""}
''' self.send_response(200) self.send_header("Content-Type", "text/html") self.send_header("Content-Length", len(html.encode())) self.end_headers() self.wfile.write(html.encode()) def log_message(self, format, *args): pass import socket class ReusableTCPServer(http.server.HTTPServer): allow_reuse_address = True def server_bind(self): self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEPORT, 1) super().server_bind() def main(): REVIEW_DIR.mkdir(parents=True, exist_ok=True) READY_DIR.mkdir(parents=True, exist_ok=True) REJECTED_DIR.mkdir(parents=True, exist_ok=True) server = ReusableTCPServer(("", PORT), ReviewHandler) print(f"šŸŽØ SVG Review Server v2 running at http://localhost:{PORT}") print(f" Keyboard: A=Approve, R/X=Reject") print(f" Press Ctrl+C to stop") try: server.serve_forever() except KeyboardInterrupt: print("\nāœ“ Server stopped") if __name__ == "__main__": main() # TONY-APPROVED: 2026-03-01 | sha:dff2e5e3 # TONY-APPROVED: 2026-03-01 | sha:fc607b44