From 6134b02c4a50203808bf1f6263de7c3bc11efef1 Mon Sep 17 00:00:00 2001 From: Untone Date: Sun, 26 Nov 2023 15:13:55 +0300 Subject: [PATCH] redis-fix --- services/auth.py | 6 +++--- services/rediscache.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/services/auth.py b/services/auth.py index e3a956a..3381183 100644 --- a/services/auth.py +++ b/services/auth.py @@ -8,12 +8,12 @@ async def check_auth(req): headers = {"Authorization": token, "Content-Type": "application/json"} # "Bearer " + removed print(f"[services.auth] checking auth token: {token}") - query_name = "getSession" if "v2." in AUTH_URL else "session" - query_type = "mutation" if "v2." in AUTH_URL else "query" + query_name = "session" + query_type = "query" operation = "GetUserId" gql = { - "query": query_type + " " + operation + " { " + query_name + " { user { id } } " + " }", + "query": query_type + " " + operation + " { " + query_name + " { user { id } } }", "operationName": operation, "variables": None, } diff --git a/services/rediscache.py b/services/rediscache.py index e5bff34..69cc8b7 100644 --- a/services/rediscache.py +++ b/services/rediscache.py @@ -59,7 +59,7 @@ class RedisCache: async def listen(self, channel): pubsub = self._client.pubsub() - pubsub.subscribe(channel) + await pubsub.subscribe(channel) while True: message = pubsub.get_message()