Commit 8f939cf5 authored by Jonathan Rohde's avatar Jonathan Rohde
Browse files

feat(sqlalchemy): some fixes

parent a9b14879
...@@ -185,6 +185,7 @@ class UsersTable: ...@@ -185,6 +185,7 @@ class UsersTable:
Session.query(User).filter_by(id=id).update( Session.query(User).filter_by(id=id).update(
{"last_active_at": int(time.time())} {"last_active_at": int(time.time())}
) )
Session.commit()
user = Session.query(User).filter_by(id=id).first() user = Session.query(User).filter_by(id=id).first()
return UserModel.model_validate(user) return UserModel.model_validate(user)
......
...@@ -794,11 +794,10 @@ app.add_middleware( ...@@ -794,11 +794,10 @@ app.add_middleware(
) )
@app.middleware("http") @app.middleware("http")
async def remove_session_after_request(request: Request, call_next): async def commit_session_after_request(request: Request, call_next):
response = await call_next(request) response = await call_next(request)
log.debug("Removing session after request") log.debug("Commit session after request")
Session.commit() Session.commit()
Session.remove()
return response return response
......
...@@ -113,8 +113,8 @@ def get_current_user( ...@@ -113,8 +113,8 @@ def get_current_user(
) )
def get_current_user_by_api_key(db: Session, api_key: str): def get_current_user_by_api_key(api_key: str):
user = Users.get_user_by_api_key(db, api_key) user = Users.get_user_by_api_key(api_key)
if user is None: if user is None:
raise HTTPException( raise HTTPException(
...@@ -122,7 +122,7 @@ def get_current_user_by_api_key(db: Session, api_key: str): ...@@ -122,7 +122,7 @@ def get_current_user_by_api_key(db: Session, api_key: str):
detail=ERROR_MESSAGES.INVALID_TOKEN, detail=ERROR_MESSAGES.INVALID_TOKEN,
) )
else: else:
Users.update_user_last_active_by_id(db, user.id) Users.update_user_last_active_by_id(user.id)
return user return user
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment