From cecb5588875194ea3a18848c6dfd0106b5ea2a8d Mon Sep 17 00:00:00 2001 From: Marcelo Trylesinski Date: Sat, 20 Aug 2022 13:34:22 +0200 Subject: [PATCH] Add `password` support for Redis backend Co-authored-by: k1dave6412 <14539608+k1dave6412@users.noreply.github.com> --- broadcaster/_backends/redis.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/broadcaster/_backends/redis.py b/broadcaster/_backends/redis.py index b545bad..2c4aeba 100644 --- a/broadcaster/_backends/redis.py +++ b/broadcaster/_backends/redis.py @@ -12,10 +12,12 @@ def __init__(self, url: str): parsed_url = urlparse(url) self._host = parsed_url.hostname or "localhost" self._port = parsed_url.port or 6379 + self._password = parsed_url.password or None async def connect(self) -> None: - self._pub_conn = await asyncio_redis.Connection.create(self._host, self._port) - self._sub_conn = await asyncio_redis.Connection.create(self._host, self._port) + kwargs = {"host": self._host, "port": self._port, "password": self._password} + 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() async def disconnect(self) -> None: