now the users can check their order status

app/app.py

@@ -1,4 +1,5 @@
- # app/app.py 
+ # app/app.py
+
 import os
 from fastapi import FastAPI, Security, File, UploadFile
 from fastapi.middleware.cors import CORSMiddleware
@@ -31,7 +32,7 @@
   remove_staff_member,
   update_staff_email,
 )
-from .user import get_user_menu, create_payment_order
+from .user import get_user_menu, create_payment_order, get_user_orders
 from .webhook import router as webhook_router
 
 app = FastAPI()
@@ -82,10 +83,16 @@
 ):
     return await create_payment_order(order_data, credentials.credentials)
 
+@app.get("/user/orders", tags=["user"])
+async def get_student_orders_endpoint(
+    credentials: HTTPAuthorizationCredentials = Security(security)
+):
+    return await get_user_orders(credentials.credentials)
+
 @app.post('/staff/add-member', tags=["manager"])
 async def add_staff_endpoint(
     staff_data: AddStaffSchema,
     credentials: HTTPAuthorizationCredentials = Security(security)
 ):
     return await add_staff_member(staff_data, credentials.credentials)
 

app/user.py

@@ -8,7 +8,7 @@
 from .firebase_init import db, firestore
 from datetime import datetime
 from .schema import CreateOrderSchema
 
 razorpay_client = razorpay.Client(auth=(
     os.environ.get("RAZORPAY_KEY_ID"),
     os.environ.get("RAZORPAY_KEY_SECRET")
@@ -63,7 +63,7 @@
             stall_data = stall_doc.to_dict()
             stall_id = stall_doc.id
 
             menu_items_ref = (
                 stall_doc.reference
                 .collection("menu_items")
                 .where("is_available", "==", True)
@@ -105,12 +105,12 @@
 
 
 async def create_payment_order(order_data: CreateOrderSchema, id_token: str):
   try:
     user_data, user_uid = await get_user_details(id_token)
     if not user_data:
       return JSONResponse(
         status_code=status.HTTP_401_UNAUTHORIZED,
         content={"message": "Invalid or expired token."}
       )
 
     college_id = user_data.get("college_id")
@@ -133,13 +133,13 @@
       if item_doc.exists:
         item_data = item_doc.to_dict()
 
         if item_data.get('is_available') is False:
           return JSONResponse(
             status_code=status.HTTP_400_BAD_REQUEST,
             content={"message": f"Sorry, {item_data.get('name')} is currently out of stock."}
           )
 
         price = item_data.get('price', 0)
         quantity = cart_item.quantity
         total_amount += price * quantity
 
@@ -147,7 +147,7 @@
           "item_id": cart_item.item_id,
           "name": item_data.get('name'),
           "price": price,
           "quantity": quantity
         })
 
       else:
@@ -165,9 +165,9 @@
     new_order_ref = db.collection('orders').document()
     internal_order_id = new_order_ref.id
 
     firestore_order_data = {
       "user_id": user_uid,
       "stall_id": stall_id,
       "college_id": college_id,
       "items": order_items,
       "amount": total_amount,
@@ -176,9 +176,9 @@
       "updated_at": firestore.SERVER_TIMESTAMP
     }
 
     new_order_ref.set(firestore_order_data)
 
     data = {
       "amount": int(total_amount * 100),
       "currency": "INR",
       "receipt": f"rcpt_{internal_order_id[:8]}",
@@ -211,3 +211,47 @@
       status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
       content={"message": f"Payment Error: {str(e)}"}
     )
+
+
+async def get_user_orders(id_token: str):
+  try:
+    user_data, user_uid = await get_user_details(id_token)
+    if not user_data:
+      return JSONResponse(
+        status_code=status.HTTP_401_UNAUTHORIZED,
+        content={"message": "Invalid or expired token."}
+      )
+
+    orders_ref = (
+      db.collection("orders")
+      .where("user_id", "==", user_uid)
+      .order_by("created_at", direction=firestore.Query.DESCENDING)
+    )
+
+    docs = orders_ref.stream()
+
+    my_orders = []
+    for doc in docs:
+      data = doc.to_dict()
+      data['order_id'] = doc.id
+
+      data = serialize_firestore_data(data)
+
+      data.pop("razorpay_payment_data", None)
+      data.pop("internal_order_id", None)
+
+      my_orders.append(data)
+
+    return JSONResponse(
+      status_code=status.HTTP_200_OK,
+      content={
+        "count": len(my_orders),
+        "orders": my_orders
+      }
+    )
+
+  except Exception as e:
+    return JSONResponse(
+      status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+      content={"message": str(e)}
+    )