they're taking the hobbits to isengard

app.py

@@ -7,6 +7,7 @@ from pathlib import Path
 import tempfile
 import socket
 import json
+import time
 
 mpv_pidfile = Path(tempfile.gettempdir()).joinpath("laas_mpv.pidfile")
 mpv_socket = Path(tempfile.gettempdir()).joinpath("mpvsocket")
@@ -75,6 +76,33 @@ def is_playing():
     return running
 
 
+def mpv_socket_open() -> socket.socket | None:
+    if is_playing():
+        sock = socket.socket(socket.AF_UNIX)
+        while True:
+            try:
+                sock.connect(str(mpv_socket).encode())
+                break
+            except (ConnectionRefusedError, FileNotFoundError):
+                pass
+
+        return sock
+
+    return None
+
+
+def mpv_socket_command(
+    sock: socket.socket, command: dict[str, Any]
+) -> Mapping[str, Any]:
+    sock.send((json.dumps(command) + "\n").encode())
+
+    reply = b""
+    while (data := sock.recv(1)) != b"\n":
+        reply += data
+
+    return json.loads(reply.decode())
+
+
 def sizeof_fmt(num, suffix="B"):
     for unit in ("", "Ki", "Mi", "Gi", "Ti", "Pi", "Ei", "Zi"):
         if abs(num) < 1024.0:
@@ -149,15 +177,8 @@ def api_status():
 def api_nowplaying():
     response: dict[str, Any] = {"status": "stopped"}
 
-    if is_playing():
-        sock = socket.socket(socket.AF_UNIX)
-        while True:
-            try:
-                sock.connect(str(mpv_socket).encode())
-                break
-            except (ConnectionRefusedError, FileNotFoundError):
-                pass
-
+    sock = mpv_socket_open()
+    if sock is not None:
         response["status"] = "playing"
 
         for prop in [
@@ -173,14 +194,7 @@ def api_nowplaying():
             else:
                 key = prop
 
-            command = {"command": ["get_property", prop]}
-            sock.send((json.dumps(command) + "\n").encode())
-
-            reply = b""
-            while (data := sock.recv(1)) != b"\n":
-                reply += data
-
-            reply_json: Mapping[str, Any] = json.loads(reply.decode())
+            reply_json = mpv_socket_command(sock, {"command": ["get_property", prop]})
             response[key] = reply_json["data"] if "data" in reply_json else "Unknown"
 
         sock.close()
@@ -188,6 +202,25 @@ def api_nowplaying():
     return jsonify(response)
 
 
+@app.route("/api/isengard", methods=["POST"])
+def api_isengard():
+    if not is_playing():
+        playback_start()
+
+    sock = mpv_socket_open()
+    if sock is not None:
+        mpv_socket_command(
+            sock, {"command": ["loadfile", str(music_path.joinpath("isengard.mp3"))]}
+        )
+        sock.close()
+
+        time.sleep(0.1)
+        if is_playing():
+            return jsonify("ok")
+
+    return jsonify("Could not take the hobbits to Isengard"), 500
+
+
 signal.signal(signal.SIGTERM, sigh)
 signal.signal(signal.SIGINT, sigh)
 cleanup_unclean()