#!/usr/bin/env python3
import json
import os
import signal
import subprocess
import time
from http.server import BaseHTTPRequestHandler, ThreadingHTTPServer
from pathlib import Path
BASE_DIR = Path(__file__).resolve().parent
PID_FILE = BASE_DIR / "run" / "opendartboard.pid"
LOG_FILE = BASE_DIR / "run" / "opendartboard.log"
HOST = "0.0.0.0"
PORT = 8090
def process_running(pid: int) -> bool:
try:
os.kill(pid, 0)
return True
except OSError:
return False
def status_payload() -> dict:
pid = None
running = False
if PID_FILE.exists():
try:
pid = int(PID_FILE.read_text().strip())
running = process_running(pid)
except (ValueError, OSError):
pid = None
running = False
return {
"ok": True,
"running": running,
"pid": pid if running else None,
}
def tail_log(lines: int = 25) -> str:
if not LOG_FILE.exists():
return ""
try:
raw = LOG_FILE.read_bytes()[-12000:]
except OSError:
return ""
text = raw.replace(b"\x00", b"").decode("utf-8", errors="replace")
return "\n".join(text.splitlines()[-lines:])
def run_script(script_name: str, settle_seconds: float = 0) -> dict:
script = BASE_DIR / script_name
try:
result = subprocess.run(
[str(script)],
cwd=str(BASE_DIR),
text=True,
capture_output=True,
timeout=25,
check=False,
)
except Exception as exc:
return {
"ok": False,
"code": 1,
"output": str(exc),
**status_payload(),
}
output = "\n".join(part for part in [result.stdout.strip(), result.stderr.strip()] if part)
deadline = time.time() + settle_seconds
if result.returncode == 0 and script_name.startswith("start"):
while time.time() < deadline:
time.sleep(0.5)
payload = status_payload()
ok = result.returncode == 0
if script_name.startswith("start") and ok and not payload["running"]:
log_tail = tail_log()
if log_tail:
output = "\n\nSenaste logg:\n" + log_tail if not output else output + "\n\nSenaste logg:\n" + log_tail
ok = False
return {
"ok": ok,
"code": result.returncode,
"output": output,
**payload,
}
def control_page() -> str:
return """
OpenDartboard kontroll
"""
class Handler(BaseHTTPRequestHandler):
def log_message(self, fmt, *args):
return
def send_json(self, payload: dict, status: int = 200):
data = json.dumps(payload).encode("utf-8")
self.send_response(status)
self.send_header("Content-Type", "application/json; charset=utf-8")
self.send_header("Cache-Control", "no-store")
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.send_header("Content-Length", str(len(data)))
self.end_headers()
self.wfile.write(data)
def send_html(self, body: str, status: int = 200):
data = body.encode("utf-8")
self.send_response(status)
self.send_header("Content-Type", "text/html; charset=utf-8")
self.send_header("Cache-Control", "no-store")
self.send_header("Content-Length", str(len(data)))
self.end_headers()
self.wfile.write(data)
def do_OPTIONS(self):
self.send_response(204)
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 do_GET(self):
if self.path.startswith("/status"):
self.send_json(status_payload())
return
if self.path == "/" or self.path.startswith("/?"):
self.send_html(control_page())
return
self.send_json({"ok": False, "error": "Unknown endpoint"}, 404)
def do_POST(self):
if self.path.startswith("/start"):
self.send_json(run_script("start-dartmachine.sh", settle_seconds=6))
return
if self.path.startswith("/stop"):
self.send_json(run_script("stop-dartmachine.sh"))
return
if self.path.startswith("/status"):
self.send_json(status_payload())
return
self.send_json({"ok": False, "error": "Unknown endpoint"}, 404)
if __name__ == "__main__":
(BASE_DIR / "run").mkdir(exist_ok=True)
ThreadingHTTPServer((HOST, PORT), Handler).serve_forever()