fix(oauth): redis compatibility

This commit is contained in:
Harry 2025-08-08 16:55:43 +08:00
parent 6f7352a7db
commit 7b98d2ea48

View File

@ -47,7 +47,9 @@ class OAuthProxyService(BasePluginClient):
if not context_id: if not context_id:
raise ValueError("context_id is required") raise ValueError("context_id is required")
# get data from redis # get data from redis
data = redis_client.getdel(f"{OAuthProxyService.__KEY_PREFIX__}{context_id}") key = f"{OAuthProxyService.__KEY_PREFIX__}{context_id}"
data = redis_client.get(key)
if not data: if not data:
raise ValueError("context_id is invalid") raise ValueError("context_id is invalid")
redis_client.delete(key)
return json.loads(data) return json.loads(data)