@@ -17,15 +17,17 @@ def __init__(self, db):
1717
1818 async def get_by_token_hash (self , token_hash : str ) -> RefreshToken | None :
1919 result = await self .db .execute (
20- select (RefreshTokenModel ).where (RefreshTokenModel .token_hash == token_hash )
20+ select (RefreshTokenModel ).where (
21+ RefreshTokenModel .refresh_token_hash == token_hash
22+ )
2123 )
2224 model = result .scalar_one_or_none ()
2325 if not model :
2426 return None
2527 return RefreshToken (
2628 id = model .id ,
2729 user_id = model .user_id ,
28- token_hash = model .token_hash ,
30+ token_hash = model .refresh_token_hash ,
2931 expires_at = model .expires_at ,
3032 is_revoked = model .is_revoked ,
3133 )
@@ -34,7 +36,7 @@ async def save(self, refresh_token: RefreshToken) -> RefreshToken:
3436 model = RefreshTokenModel (
3537 id = refresh_token .id ,
3638 user_id = refresh_token .user_id ,
37- token_hash = refresh_token .token_hash ,
39+ refresh_token_hash = refresh_token .token_hash ,
3840 expires_at = refresh_token .expires_at ,
3941 is_revoked = refresh_token .is_revoked ,
4042 )
@@ -44,7 +46,7 @@ async def save(self, refresh_token: RefreshToken) -> RefreshToken:
4446 return RefreshToken (
4547 id = model .id ,
4648 user_id = model .user_id ,
47- token_hash = model .token_hash ,
49+ token_hash = model .refresh_token_hash ,
4850 expires_at = model .expires_at ,
4951 is_revoked = model .is_revoked ,
5052 )
0 commit comments