Created test user

This commit is contained in:
Yarne Coppens 2024-09-10 16:00:52 +02:00
parent c8af5f6638
commit f7cf0da546
3 changed files with 25 additions and 2 deletions

View file

@ -28,4 +28,10 @@ def get_single_product(barcode: int) -> product_classes.Product:
return product return product
def create_db_and_tables() -> None: def create_db_and_tables() -> None:
db_connection.create_db_and_tables() db_connection.create_db_and_tables()
def get_db_engine():
return db_connection.get_engine()
def delete_database():
db_connection.delete_database()

View file

@ -3,6 +3,7 @@ from fastapi.middleware.cors import CORSMiddleware
from fastapi.responses import FileResponse from fastapi.responses import FileResponse
import os import os
from contextlib import asynccontextmanager from contextlib import asynccontextmanager
from sqlmodel import Session
from src.classes import product_classes, cash_classes, user_classes from src.classes import product_classes, cash_classes, user_classes
@ -11,10 +12,23 @@ from src.modules import price_to_cash_calculator
from shop_validators import image_validator from shop_validators import image_validator
from src import data_connection from src import data_connection
async def get_session():
with Session(data_connection.get_db_engine()) as session:
yield session
def create_test_data():
user_1 = user_classes.UserInDB(username="yarninator", email="yarn@inator.com",full_name="Yarn Inator", disabled=False, hashed_password="abcdefghijklmnop")
with Session(data_connection.get_db_engine()) as session:
session.add(user_1)
session.commit()
@asynccontextmanager @asynccontextmanager
async def lifespan(app: FastAPI): async def lifespan(app: FastAPI):
# Startup # Startup
data_connection.delete_database()
data_connection.create_db_and_tables() data_connection.create_db_and_tables()
create_test_data()
yield yield
# Shutdown # Shutdown

View file

@ -11,4 +11,7 @@ def get_engine():
return engine return engine
def create_db_and_tables() -> None: def create_db_and_tables() -> None:
SQLModel.metadata.create_all(engine) SQLModel.metadata.create_all(engine)
def delete_database():
SQLModel.metadata.drop_all(engine)