From 406f22bce11fcae702754540c28d00aa02432305 Mon Sep 17 00:00:00 2001 From: Birdie Kingston Date: Tue, 20 Feb 2024 13:57:35 +1100 Subject: [PATCH] Add username authentication support for redis --- broadcaster/_backends/redis.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/broadcaster/_backends/redis.py b/broadcaster/_backends/redis.py index 2c4aeba..72b4b14 100644 --- a/broadcaster/_backends/redis.py +++ b/broadcaster/_backends/redis.py @@ -13,9 +13,10 @@ def __init__(self, url: str): self._host = parsed_url.hostname or "localhost" self._port = parsed_url.port or 6379 self._password = parsed_url.password or None + self._username = parsed_url.username or None async def connect(self) -> None: - kwargs = {"host": self._host, "port": self._port, "password": self._password} + kwargs = {"host": self._host, "port": self._port, "password": self._password, "username": self._username} self._pub_conn = await asyncio_redis.Connection.create(**kwargs) self._sub_conn = await asyncio_redis.Connection.create(**kwargs) self._subscriber = await self._sub_conn.start_subscribe()