show streamer version

kvmd/server.py

@@ -1,8 +1,6 @@
 import os
 import signal
 import asyncio
-import platform
-import functools
 import json
 import time
 
@@ -33,17 +31,6 @@ from .logging import get_logger
 __version__ = "0.78"
 
 
-@functools.lru_cache()
-def _get_system_info() -> Dict[str, Dict[str, str]]:
-    return {
-        "version": {
-            "platform": platform.platform(),
-            "python": platform.python_version(),
-            "kvmd": __version__,
-        },
-    }
-
-
 # =====
 def _system_task(method: Callable) -> Callable:
     async def wrap(self: "Server") -> None:
@@ -170,7 +157,13 @@ class Server:  # pylint: disable=too-many-instance-attributes
     # ===== INFO
 
     async def __info_handler(self, _: aiohttp.web.Request) -> aiohttp.web.Response:
-        return _json(_get_system_info())
+        return _json({
+            "version": {
+                "kvmd": __version__,
+                "streamer": await self.__streamer.get_version(),
+            },
+            "streamer": self.__streamer.get_app(),
+        })
 
     # ===== WEBSOCKET
 

kvmd/streamer.py

@@ -1,3 +1,4 @@
+import os
 import asyncio
 import asyncio.subprocess
 
@@ -64,6 +65,18 @@ class Streamer:  # pylint: disable=too-many-instance-attributes
             "quality": self.__quality,
         }
 
+    def get_app(self) -> str:
+        return os.path.basename(self.__cmd[0])
+
+    async def get_version(self) -> str:
+        proc = await asyncio.create_subprocess_exec(
+            *[self.__cmd[0], "--version"],
+            stdout=asyncio.subprocess.PIPE,
+            stderr=asyncio.subprocess.DEVNULL,
+        )
+        (stdout, _) = await proc.communicate()
+        return stdout.decode(errors="ignore").strip()
+
     async def cleanup(self) -> None:
         if self.is_running():
             await self.stop()