fully working code

src/app/views/player.py

@@ -1,3 +1,4 @@
+from datetime import datetime
 from typing import Optional
 
 from pydantic import BaseModel
@@ -31,8 +32,8 @@ class PlayerUpdate(BaseModel):
 
 class PlayerInDB(PlayerCreate):
     id: int
-    created_at: str
-    updated_at: str
+    created_at: datetime
+    updated_at: datetime
 
 
 class Player(PlayerInDB):

src/core/config.py

@@ -6,7 +6,7 @@ class Settings(BaseSettings):
     DATABASE_URL: str
     POOL_TIMEOUT: int
     POOL_RECYCLE: int
-    ENV: str = "DEV"
+    ENV: str = "PRD"
 
 
 settings = Settings()

src/database/database.py

@@ -28,4 +28,9 @@ async def get_session() -> AsyncSession:
     return SessionFactory()
 
 
+def model_to_dict(model):
+    """Converts an SQLAlchemy model instance to a dictionary."""
+    return {c.name: getattr(model, c.name) for c in model.__table__.columns}
+
+
 Base = declarative_base()

src/main.py

@@ -15,7 +15,7 @@
 from app.views.player import PlayerInDB
 from app.views.report import ReportInQueue, StgReportCreate, convert_report_q_to_db
 from core.config import settings
-from database.database import get_session
+from database.database import get_session, model_to_dict
 from database.models.player import Player
 from database.models.report import StgReport
 
@@ -27,15 +27,15 @@ async def select_player(session: AsyncSession, name: str) -> PlayerInDB:
     sql = sql.where(Player.name == name)
     result: AsyncResult = await session.execute(sql)
     data = result.scalars().all()
-    return PlayerInDB(**data[0]) if data else None
+    return PlayerInDB(**model_to_dict(data[0])) if data else None
 
 
 # TODO: pydantic data
 async def insert_report(session: AsyncSession, data: StgReportCreate):
     sql: Insert = insert(StgReport)
     sql = sql.values(data.model_dump(mode="json"))
     sql = sql.prefix_with("IGNORE")
-    # await session.execute(sql)
+    await session.execute(sql)
     return
 
 
@@ -62,8 +62,6 @@ async def process_data(receive_queue: Queue, error_queue: Queue, shutdown_event:
         # Get a message from the chosen queue
         message: dict = await receive_queue.get()
         parsed_msg = ReportInQueue(**message)
-        # TEMP
-        print(parsed_msg)
 
         try:
             # Acquire an asynchronous database session
@@ -73,15 +71,15 @@ async def process_data(receive_queue: Queue, error_queue: Queue, shutdown_event:
                     session=session, name=parsed_msg.reporter
                 )
                 if reporter is None:
-                    logger.error(f"reporter does not exist {parsed_msg.reporter}")
+                    logger.error(f"reporter does not exist: '{parsed_msg.reporter}'")
                     receive_queue.task_done()
                     continue
 
                 reported = await select_player(
                     session=session, name=parsed_msg.reported
                 )
                 if reported is None:
-                    logger.error(f"reported does not exist {parsed_msg.reported}")
+                    logger.error(f"reported does not exist: '{parsed_msg.reported}'")
                     receive_queue.task_done()
                     continue