Update app.py

app.py

@@ -258,13 +258,14 @@ def process_order_flow(user_id: str, message: str) -> str:
     return ""
 
 # --- User Profile Functions ---
+
 async def get_or_create_user_profile(user_id: str, phone_number: str = None) -> UserProfile:
     """Retrieve an existing profile or create a new one with user_id and phone_number."""
     async with async_session() as session:
         result = await session.execute(
-            UserProfile.__table__.select().where(UserProfile.user_id == user_id)
+            select(UserProfile).where(UserProfile.user_id == user_id)
         )
-        profile = result.scalar_one_or_none()
+        profile = result.scalars().first()
         if profile is None:
             profile = UserProfile(
                 user_id=user_id,
@@ -279,9 +280,9 @@ async def update_user_last_interaction(user_id: str):
     """Update the user's last interaction timestamp."""
     async with async_session() as session:
         result = await session.execute(
-            UserProfile.__table__.select().where(UserProfile.user_id == user_id)
+            select(UserProfile).where(UserProfile.user_id == user_id)
         )
-        profile = result.scalar_one_or_none()
+        profile = result.scalars().first()
         if profile:
             profile.last_interaction = datetime.utcnow()
             await session.commit()