From: kaliko <kaliko@azylum.org>
Date: Mon, 4 Mar 2024 15:31:27 +0000 (+0100)
Subject: Add unix socket (closes #1)
X-Git-Url: http://git.kaliko.me/?a=commitdiff_plain;h=4f5df6d2baf74ac2b2ee9a8500125a420f5c3293;hp=67af350e8543fa42463a7926e4c5987fd182c271;p=python-musicpdaio.git

Add unix socket (closes #1)
---

diff --git a/mpdaio/connection.py b/mpdaio/connection.py
index 5da292c..c47cd7e 100644
--- a/mpdaio/connection.py
+++ b/mpdaio/connection.py
@@ -61,12 +61,18 @@ class ConnectionPool(base):
                     if not conn.in_use:
                         await conn.close()
                         break
-
-            log.debug('about to connect %s', host)
-            reader, writer = await asyncio.wait_for(
-                    asyncio.open_connection(server, port),
-                    timeout
-                    )
+            if server[0] in ['/', '@']:
+                log.debug('about to connect unix socket %s', server)
+                reader, writer = await asyncio.wait_for(
+                        asyncio.open_unix_connection(path=server),
+                        timeout
+                        )
+            else:
+                log.debug('about to connect tcp socket %s:%s', *host)
+                reader, writer = await asyncio.wait_for(
+                        asyncio.open_connection(server, port),
+                        timeout
+                        )
             #log.debug('Connected to %s:%s', host[0], host[1])
             connection = Connection(self, host, reader, writer)
             await connection._hello()