branding; test fixes

Author: aw-was-here

nowplaying/vendor/stagelinq/__init__.py

@@ -1,6 +1,6 @@
-"""StageLinq Protocol Implementation for Python
+"""StagelinQ Protocol Implementation for Python
 
-This library implements Denon's StageLinq protocol, allowing Python applications
+This library implements Denon's StagelinQ protocol, allowing Python applications
 to communicate with DJ equipment like Denon Prime series devices.
 
 This implementation uses modern async/await patterns for all I/O operations.
@@ -12,7 +12,7 @@
 from .discovery import Device, DeviceState, DiscoveryConfig, discover_stagelinq_devices
 from .file_transfer import FileInfo, FileTransferConnection
 from .listener import (
-    StageLinqListener,
+    StagelinQListener,
     create_analytics_server,
     create_file_server,
     create_full_server,
@@ -45,7 +45,7 @@
     "FileTransferConnection",
     "FileInfo",
     "DeckValueNames",
-    "StageLinqListener",
+    "StagelinQListener",
     "create_analytics_server",
     "create_file_server",
     "create_full_server",

nowplaying/vendor/stagelinq/device.py

@@ -1,4 +1,4 @@
-"""StageLinq device connection implementation."""
+"""StagelinQ device connection implementation."""
 
 from __future__ import annotations
 
@@ -26,13 +26,13 @@
     Token,
     format_interval,
 )
-from .protocol import StageLinqConnection
+from .protocol import StagelinQConnection
 
 logger = logging.getLogger(__name__)
 
 
 class DeviceRegistry:
-    """Collection of discovered StageLinq devices."""
+    """Collection of discovered StagelinQ devices."""
 
     def __init__(self) -> None:
         self._devices: list[Device] = []
@@ -96,7 +96,7 @@ def __iter__(self):
 
 @dataclass
 class Service:
-    """Represents a StageLinq service."""
+    """Represents a StagelinQ service."""
 
     name: str
     port: int
@@ -116,7 +116,7 @@ class StateCategory(Enum):
 
 
 class StateValueType(Enum):
-    """StageLinq StateMap value types based on protocol documentation."""
+    """StagelinQ StateMap value types based on protocol documentation."""
 
     VALUE_FLOAT = 0  # Float value (type 0)
     STATE_BOOL = 1  # Boolean state (type 1)
@@ -221,12 +221,12 @@ def __str__(self) -> str:
 
 
 class DeviceConnection:
-    """Pythonic async connection to a StageLinq device."""
+    """Pythonic async connection to a StagelinQ device."""
 
     def __init__(self, device: Device, token: Token) -> None:
         self.device = device
         self.token = token
-        self._connection: StageLinqConnection | None = None
+        self._connection: StagelinQConnection | None = None
         self._services: list[Service] | None = None
 
     async def __aenter__(self) -> DeviceConnection:
@@ -249,7 +249,7 @@ async def connect(self) -> None:
             return
 
         try:
-            self._connection = StageLinqConnection(self.device.ip, self.device.port)
+            self._connection = StagelinQConnection(self.device.ip, self.device.port)
             await self._connection.connect()
             logger.info("Connected to device %s", self.device)
         except Exception as e:
@@ -283,7 +283,7 @@ async def discover_services(
 
         # Implement proper service discovery protocol
         # Connect to main port and request services
-        main_conn = StageLinqConnection(self.device.ip, self.device.port)
+        main_conn = StagelinQConnection(self.device.ip, self.device.port)
         services = []
 
         try:
@@ -405,15 +405,15 @@ def __init__(self, host: str, port: int, token: Token) -> None:
         self.host = host
         self.port = port
         self.token = token
-        self._connection: StageLinqConnection | None = None
+        self._connection: StagelinQConnection | None = None
         self._subscriptions: set[str] = set()
 
     async def connect(self) -> None:
         """Connect to StateMap service."""
         if self._connection:
             return
 
-        self._connection = StageLinqConnection(self.host, self.port)
+        self._connection = StagelinQConnection(self.host, self.port)
         await self._connection.connect()
 
         # Send service announcement message (required by protocol)
@@ -532,15 +532,15 @@ def __init__(self, host: str, port: int, token: Token) -> None:
         self.host = host
         self.port = port
         self.token = token
-        self._connection: StageLinqConnection | None = None
+        self._connection: StagelinQConnection | None = None
         self._streaming = False
 
     async def connect(self) -> None:
         """Connect to BeatInfo service."""
         if self._connection:
             return
 
-        self._connection = StageLinqConnection(self.host, self.port)
+        self._connection = StagelinQConnection(self.host, self.port)
         await self._connection.connect()
         logger.info("Connected to BeatInfo at %s:%s", self.host, self.port)
 

nowplaying/vendor/stagelinq/discovery.py

@@ -1,4 +1,4 @@
-"""StageLinq device discovery implementation."""
+"""StagelinQ device discovery implementation."""
 
 from __future__ import annotations
 
@@ -13,7 +13,7 @@
 import netifaces
 
 from .messages import DISCOVERER_EXIT, DISCOVERER_HOWDY, DiscoveryMessage, Token
-from .protocol import StageLinqProtocol
+from .protocol import StagelinQProtocol
 
 logger = logging.getLogger(__name__)
 
@@ -27,7 +27,7 @@ class DeviceState(Enum):
 
 @dataclass
 class Device:
-    """Represents a StageLinq device."""
+    """Represents a StagelinQ device."""
 
     ip: str
     name: str
@@ -90,7 +90,7 @@ def from_discovery_message(
 class DiscoveryConfig:
     """Configuration for device discovery."""
 
-    name: str = "Python StageLinq"
+    name: str = "Python StagelinQ"
     software_name: str = "python-stagelinq"
     software_version: str = "0.1.0"
     token: Token | None = None
@@ -104,25 +104,25 @@ def __post_init__(self) -> None:
             self.token = Token()
 
 
-class StageLinqError(Exception):
-    """Base exception for StageLinq errors."""
+class StagelinQError(Exception):
+    """Base exception for StagelinQ errors."""
 
 
-class DiscoveryError(StageLinqError):
+class DiscoveryError(StagelinQError):
     """Exception raised during device discovery."""
 
 
-class StageLinqDiscovery:
-    """Async StageLinq device discovery."""
+class StagelinQDiscovery:
+    """Async StagelinQ device discovery."""
 
     def __init__(self, config: DiscoveryConfig | None = None) -> None:
         self.config = config or DiscoveryConfig()
         self._transport: asyncio.DatagramTransport | None = None
-        self._protocol: StageLinqProtocol | None = None
+        self._protocol: StagelinQProtocol | None = None
         self._announce_task: asyncio.Task | None = None
         self._discovered_devices: dict[str, Device] = {}
 
-    async def __aenter__(self) -> StageLinqDiscovery:
+    async def __aenter__(self) -> StagelinQDiscovery:
         """Async context manager entry."""
         await self.start()
         return self
@@ -143,12 +143,12 @@ async def start(self) -> None:
 
         loop = asyncio.get_event_loop()
         self._transport, self._protocol = await loop.create_datagram_endpoint(
-            lambda: StageLinqProtocol(self._on_message_received),
+            lambda: StagelinQProtocol(self._on_message_received),
             local_addr=("0.0.0.0", self.config.port),
             reuse_port=True,
         )
 
-        logger.info("Started StageLinq discovery on port %s", self.config.port)
+        logger.info("Started StagelinQ discovery on port %s", self.config.port)
 
     async def stop(self) -> None:
         """Stop discovery service."""
@@ -162,7 +162,7 @@ async def stop(self) -> None:
             self._transport.close()
             self._transport = None
 
-        logger.info("Stopped StageLinq discovery")
+        logger.info("Stopped StagelinQ discovery")
 
     async def start_announcing(self) -> None:
         """Start periodic announcements."""
@@ -298,9 +298,9 @@ def discovered_devices(self) -> dict[str, Device]:
 @contextlib.asynccontextmanager
 async def discover_stagelinq_devices(
     config: DiscoveryConfig | None = None,
-) -> AsyncIterator[StageLinqDiscovery]:
-    """Context manager for StageLinq device discovery."""
-    discovery = StageLinqDiscovery(config)
+) -> AsyncIterator[StagelinQDiscovery]:
+    """Context manager for StagelinQ device discovery."""
+    discovery = StagelinQDiscovery(config)
     try:
         await discovery.start()
         yield discovery

nowplaying/vendor/stagelinq/file_transfer.py

@@ -1,4 +1,4 @@
-"""StageLinq file transfer implementation.
+"""StagelinQ file transfer implementation.
 
 Based on the FileTransfer protocol analysis from:
 https://github.com/icedream/go-stagelinq/issues/8
@@ -89,7 +89,7 @@
 from typing import BinaryIO
 
 from .messages import Message, Token, serializer
-from .protocol import StageLinqConnection
+from .protocol import StagelinQConnection
 
 logger = logging.getLogger(__name__)
 
@@ -118,7 +118,7 @@
 
 @dataclass
 class FileInfo:
-    """Information about a file on the StageLinq device."""
+    """Information about a file on the StagelinQ device."""
 
     path: str
     name: str
@@ -134,7 +134,7 @@ def __str__(self) -> str:
 
 @dataclass
 class FileSource:
-    """Information about a file source on the StageLinq device."""
+    """Information about a file source on the StagelinQ device."""
 
     name: str
     database_path: str
@@ -588,7 +588,7 @@ def __init__(self, host: str, port: int, token: Token) -> None:
         self.host = host
         self.port = port
         self.token = token
-        self._connection: StageLinqConnection | None = None
+        self._connection: StagelinQConnection | None = None
         self._sources: list[FileSource] = []
         self._next_request_id = 1
         self._directory_cache: dict[str, list[FileInfo]] = {}  # path -> files
@@ -620,7 +620,7 @@ async def connect(self) -> None:
             return
 
         try:
-            self._connection = StageLinqConnection(self.host, self.port)
+            self._connection = StagelinQConnection(self.host, self.port)
             await self._connection.connect()
             logger.info("Connected to FileTransfer at %s:%s", self.host, self.port)
         except Exception as e: