@@ -36,10 +36,11 @@ async def authenticate(self, request: Request) -> None:
36
36
37
37
token = await token_service .find_by_id (token_id )
38
38
if token is None :
39
+ await self .stop_session (request )
39
40
raise token_missing_exception
40
41
41
42
await self .check_token_validity (token )
42
- await self .start_session (request , None , token = token )
43
+ await self .start_session (request , token )
43
44
44
45
async def check_token_validity (self , token : SubscriberToken ) -> None :
45
46
"""
@@ -50,11 +51,10 @@ async def check_token_validity(self, token: SubscriberToken) -> None:
50
51
await SubscriberTokenService ().delete (token )
51
52
raise SuperdeskApiError .forbiddenError (message = _ ("Authorization token expired." ))
52
53
53
- async def start_session (self , request : Request , user : Any , ** kwargs ) -> None :
54
+ async def start_session (self , request : Request , token : SubscriberToken ) -> None : # type: ignore[override]
54
55
"""
55
56
Puts the subscriber id into ``g.user``.
56
57
"""
57
- token = cast (SubscriberToken , kwargs .get ("token" ))
58
58
request .storage .request .set ("user" , str (token .subscriber ))
59
59
60
60
async def stop_session (self , request : Request ) -> None :
0 commit comments