Skip to content
This repository was archived by the owner on Aug 19, 2025. It is now read-only.

Redis Backend Password support #14

Closed
k1dav wants to merge 4 commits into from
Closed

Redis Backend Password support #14

Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
b6e59a5
feat(redis_backend): add password auth
k1dav May 25, 2020
e54b529
fix(redis_backend): add args name
k1dav May 25, 2020
082b429
test(test_broadcast.py): redis with password test
k1dav May 26, 2020
719625c
test(broadcast.py): remove unnecessary test
k1dav May 26, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions broadcaster/_backends/redis.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -10,10 +10,11 @@ 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)
self._pub_conn = await asyncio_redis.Connection.create(self._host, self._port, password=self._password)
self._sub_conn = await asyncio_redis.Connection.create(self._host, self._port, password=self._password)
self._subscriber = await self._sub_conn.start_subscribe()

async def disconnect(self) -> None:
Expand Down