Support systemd-journal-gatewayd using a TCP socket (#5576)

home-assistant · Jan 27, 2025 · 8ff9c08 · 8ff9c08
1 parent 1b0aa30
commit 8ff9c08
Showing 1 changed file with 11 additions and 5 deletions.
diff --git a/supervisor/host/logs.py b/supervisor/host/logs.py
@@ -6,6 +6,7 @@
 from contextlib import asynccontextmanager
 import json
 import logging
+import os
 from pathlib import Path
 
 from aiohttp import ClientError, ClientSession, ClientTimeout
@@ -53,7 +54,9 @@ def __init__(self, coresys: CoreSys):
 
     @property
     def available(self) -> bool:
-        """Return True if Unix socket to systemd-journal-gatwayd is available."""
+        """Check if systemd-journal-gatwayd is available."""
+        if os.environ.get("SUPERVISOR_SYSTEMD_JOURNAL_GATEWAYD_URL"):
+            return True
         return SYSTEMD_JOURNAL_GATEWAYD_SOCKET.is_socket()
 
     @property
@@ -162,14 +165,17 @@ async def journald_logs(
             )
 
         try:
-            async with ClientSession(
-                connector=UnixConnector(path=str(SYSTEMD_JOURNAL_GATEWAYD_SOCKET))
-            ) as session:
+            if base_url := os.environ.get("SUPERVISOR_SYSTEMD_JOURNAL_GATEWAYD_URL"):
+                connector = None
+            else:
+                base_url = "http://localhost/"
+                connector = UnixConnector(path=str(SYSTEMD_JOURNAL_GATEWAYD_SOCKET))
+            async with ClientSession(base_url=base_url, connector=connector) as session:
                 headers = {ACCEPT: accept}
                 if range_header:
                     headers[RANGE] = range_header
                 async with session.get(
-                    f"http://localhost{path}",
+                    f"{path}",
                     headers=headers,
                     params=params or {},
                     timeout=timeout,