fix

.envrc

@@ -3,9 +3,11 @@
 # It enters you into the poetry venv, removing the need for `poetry run`.
 
 if command -v nix >/dev/null; then
-    use nix -p poetry
+    use flake
 fi
 
+export GRZEGORZ_IS_DEBUG=1 # mpv does not start in fullscreen
+
 # Instead of using the flake, we use poetry to manage a development venv
 # We only use poetry2nix for deployment
 
@@ -18,4 +20,9 @@ PATH_add "$VIRTUAL_ENV/bin"
 
 if ! command -v sanic >/dev/null; then
     poetry install
+    # patchelf the venv on nixos
+    if ! test -s /lib64/ld-linux-x86-64.so.2 || { uname -a | grep -qi nixos; }; then
+        #nix run github:GuillaumeDesforges/fix-python -- --venv "$VIRTUAL_ENV" #--libs .nix/libs.nix
+        fix-python --venv "$VIRTUAL_ENV" #--libs .nix/libs.nix
+    fi
 fi

.gitignore

@@ -4,3 +4,4 @@ config.py
 *.socket
 result
 result-*
+.direnv

grzegorz/api.py

@@ -47,7 +47,7 @@ PLAYLIST_DATA_CACHE = PlaylistDataCache(auto_fetch_data=True)
 @openapi.exclude(True)
 @response_text
 async def root(request: Request):
-    return "Hello friend, I hope you're having a lovely day"
+    return "Hello friend, I hope you're having a lovely day\n"
 
 @bp.post("/load")
 @openapi.summary("Add item to playlist")

grzegorz/mpv.py

@@ -9,6 +9,7 @@ from pathlib import Path
 
 from . import nyasync
 
+IS_DEBUG = os.environ.get("GRZEGORZ_IS_DEBUG", "0") != "0"
 
 class MPV:
     # TODO: move this to /tmp or /var/run ?
@@ -27,7 +28,7 @@ class MPV:
             f'--input-ipc-server={str(cls._ipc_endpoint)}',
             '--idle',
             '--force-window',
-            '--fullscreen',
+            *(('--fullscreen',) if not IS_DEBUG else ()),
             '--no-terminal',
             '--load-unsafe-playlists',
             '--keep-open', # Keep last frame of video on end of video

grzegorz/nyasync.py

@@ -60,11 +60,11 @@ class UnixConnection:
 
     @classmethod
     async def from_path(cls, path):
-        endpoints = await asyncio.open_unix_connection(path)
+        endpoints = await asyncio.open_unix_connection(path, limit=2**24) # default is 2**16
         return cls(*endpoints)
 
     def __aiter__(self):
-        return self.reader.__aiter__()
+        return self.reader.__aiter__() # readline
 
     def write(self, data):
         self.writer.write(data)