order is now sent to kafka

1 files changed, 7 insertions, 1 deletions

diff --git a/order-service/app/api/v1/endpoints/orders.py b/order-service/app/api/v1/endpoints/orders.py
index 4530958..dc81835 100644
--- a/order-service/app/api/v1/endpoints/orders.py
+++ b/order-service/app/api/v1/endpoints/orders.py
@@ -5,6 +5,8 @@ from sqlalchemy.orm import Session
 from app.api import deps
 from app.models.order import Order, OrderItem
 from app.schemas.order import OrderCreate, OrderOut
+from app.kafka_producer import send_order_created_event
+
 
 router = APIRouter()
 
@@ -38,10 +40,14 @@ def create_order(order_in: OrderCreate, db: Session = Depends(deps.get_db)):
         db.commit()
         db.refresh(db_order)
 
+        event_payload = {"order_id": db_order.id, "customer_id": order_in.customer_id}
+        send_order_created_event(event_payload)
+
         return db_order
 
-    except Exception:
+    except Exception as e:
         db.rollback()
+        print(e)
         raise HTTPException(
             status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
             detail="Could not initialize checkout process.",