@@ -47,31 +47,24 @@ def __init__(self,
4747 @router .post ("/token_refresh" , response_class = JSONResponse )
4848 async def token_refresh (request : Request ) -> JSONResponse :
4949 try :
50- print ( "keycloak token refresh" )
50+ # get body
5151 body = await request .json ()
52- print (f"body: { body } " )
5352 new_token = body .get ("token" )
54- print (f"new token: { new_token } " )
55- print (f"not new_token: { not new_token } " )
5653 if not new_token :
57- print ("No token, raising HTTPException" )
54+ flame_log ("No token, raising HTTPException" , silent )
5855 raise HTTPException (status_code = 400 , detail = "Token is required" )
5956
6057 # refresh token in message-broker
61- print ("message broker token refresh" )
6258 message_broker .refresh_token (new_token )
6359 # refresh token in data client
64- print ("data client token refresh" )
6560 data_client .refresh_token (new_token )
6661 # refresh token in result client
67- print ("result client token refresh" )
6862 result_client .refresh_token (new_token )
6963 # refresh token in self
70- print ("self token refresh" )
7164 self .keycloak_token = new_token
7265 return JSONResponse (content = {"message" : "Token refreshed successfully" })
7366 except Exception as e :
74- print (f"stack trace { e } " )
67+ flame_log (f"stack trace { e } " , silent )
7568 raise HTTPException (status_code = 500 , detail = str (e ))
7669
7770 @router .get ("/healthz" , response_class = JSONResponse )
0 commit comments