Spaces:
Sleeping
Sleeping
from sqlalchemy import Column, String, Integer | |
from sqlalchemy.orm import relationship, Session | |
from app.backend.models.base_model import Base | |
from app.backend.controllers.base_controller import engine | |
class User(Base): | |
__tablename__ = "users" | |
id = Column("id", Integer, autoincrement=True, primary_key=True, unique=True) | |
email = Column("email", String, unique=True, nullable=False) | |
password_hash = Column("password_hash", String, nullable=False) | |
language = Column("language", String, default="English", nullable=False) | |
theme = Column("theme", String, default="light", nullable=False) | |
access_string_hash = Column("access_string_hash", String, nullable=True) | |
chats = relationship("Chat", back_populates="user") | |
def add_new_user(email: str, password_hash: str, access_string_hash: str) -> None: | |
with Session(autoflush=False, bind=engine) as db: | |
db.add(User(email=email, password_hash=password_hash, access_string_hash=access_string_hash)) | |
db.commit() | |
def find_user_by_id(id: int) -> User | None: | |
with Session(autoflush=False, bind=engine) as db: | |
return db.query(User).where(User.id == id).first() | |
def find_user_by_email(email: str) -> User | None: | |
with Session(autoflush=False, bind=engine) as db: | |
return db.query(User).where(User.email == email).first() | |
def find_user_by_access_string(access_string_hash: str) -> User | None: | |
with Session(autoflush=False, bind=engine) as db: | |
return db.query(User).where(User.access_string_hash == access_string_hash).first() | |
def update_user(user: User, language: str = None, theme: str = None, access_string_hash: str = None) -> None: | |
with Session(autoflush=False, bind=engine) as db: | |
user = db.merge(user) | |
if language: | |
user.language = language | |
if theme: | |
user.theme = theme | |
if access_string_hash: | |
user.access_string_hash = access_string_hash | |
db.commit() | |