From 1276d199e37328f22712af46c27db65ceedcb5d3 Mon Sep 17 00:00:00 2001 From: Chris Lovering Date: Tue, 16 Jul 2024 19:03:49 +0100 Subject: Use redis for the discord member cache over mongo --- backend/routes/auth/authorize.py | 2 +- backend/routes/discord.py | 4 ++-- backend/routes/forms/submit.py | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) (limited to 'backend/routes') diff --git a/backend/routes/auth/authorize.py b/backend/routes/auth/authorize.py index bc80a7d..8fe7e85 100644 --- a/backend/routes/auth/authorize.py +++ b/backend/routes/auth/authorize.py @@ -44,7 +44,7 @@ async def process_token( return AUTH_FAILURE user_id = user_details["id"] - member = await get_member(request.state.db, user_id, force_refresh=True) + member = await get_member(user_id, force_refresh=True) max_age = datetime.timedelta(seconds=int(bearer_token["expires_in"])) token_expiry = interaction_start + max_age diff --git a/backend/routes/discord.py b/backend/routes/discord.py index 53b8af3..196d902 100644 --- a/backend/routes/discord.py +++ b/backend/routes/discord.py @@ -60,7 +60,7 @@ class MemberRoute(route.Route): async def delete(self, request: Request) -> JSONResponse: """Force a resync of the cache for the given user.""" body = await request.json() - member = await discord.get_member(request.state.db, body["user_id"], force_refresh=True) + member = await discord.get_member(body["user_id"], force_refresh=True) if member: return JSONResponse(member.dict()) @@ -75,7 +75,7 @@ class MemberRoute(route.Route): async def get(self, request: Request) -> JSONResponse: """Get a user's roles on the configured server.""" body = await request.json() - member = await discord.get_member(request.state.db, body["user_id"]) + member = await discord.get_member(body["user_id"]) if not member: return NOT_FOUND_EXCEPTION diff --git a/backend/routes/forms/submit.py b/backend/routes/forms/submit.py index 5ba77e5..01c32cc 100644 --- a/backend/routes/forms/submit.py +++ b/backend/routes/forms/submit.py @@ -85,7 +85,7 @@ class SubmitForm(Route): try: if hasattr(request.user, User.refresh_data.__name__): old = request.user.token - await request.user.refresh_data(request.state.db) + await request.user.refresh_data() if old != request.user.token: try: -- cgit v1.2.3