Class Handler

server/manage_api.py:309–475

class Handler(BaseHTTPRequestHandler):
    server_version = "ServerStatusManageAPI/1.0"

    def log_message(self, fmt, *args):
        print("%s - %s" % (self.address_string(), fmt % args), flush=True)

    def end_headers(self):
        self.send_header("Cache-Control", "no-store")
        if CORS_ORIGIN:
            self.send_header("Access-Control-Allow-Origin", CORS_ORIGIN)
            self.send_header("Access-Control-Allow-Headers", "Authorization, Content-Type, X-Admin-Token")
            self.send_header("Access-Control-Allow-Methods", "GET, POST, PUT, DELETE, OPTIONS")
        super().end_headers()

    def send_json(self, status, payload):
        data = json.dumps(payload, ensure_ascii=False).encode("utf-8")
        self.send_response(status)
        self.send_header("Content-Type", "application/json; charset=utf-8")
        self.send_header("Content-Length", str(len(data)))
        self.end_headers()
        self.wfile.write(data)

    def send_error_json(self, err):
        payload = {"ok": False, "error": err.message}
        if err.details is not None:
            payload["details"] = err.details
        self.send_json(err.status, payload)

    def route(self):
        parsed = urlparse(self.path)
        path = parsed.path.rstrip("/") or "/"
        method = self.command.upper()
        if method == "OPTIONS":
            self.send_response(204)
            self.end_headers()
            return
        try:
            if path == "/api/health" and method == "GET":
                pid = get_sergate_pid()
                self.send_json(200, {
                    "ok": True,
                    "enabled": bool(ADMIN_TOKEN),
                    "sergate": {"running": bool(pid), "pid": pid},
                    "configPath": CONFIG_PATH,
                })
                return
            if path == "/api/schema" and method == "GET":
                self.send_json(200, {"ok": True, "schema": api_schema()})
                return
            self.require_auth()
            if path == "/api/config":
                if method == "GET":
                    self.send_json(200, {"ok": True, "config": load_config()})
                    return
                if method == "PUT":
                    config = read_body(self)
                    config, pid = write_and_reload(config)
                    self.send_json(200, {"ok": True, "reloaded": True, "pid": pid, "config": config})