review api changes

app/app.py

@@ -2,7 +2,7 @@
 
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
-from app.routers import user_router, profile_router, account_router, wallet_router, address_router, pet_router, guest_router, favorite_router
+from app.routers import user_router, profile_router, account_router, wallet_router, address_router, pet_router, guest_router, favorite_router, review_router
 from app.middleware.rate_limiter import RateLimitMiddleware
 from app.middleware.security_middleware import SecurityMiddleware
 import logging
@@ -54,6 +54,7 @@ app.include_router(address_router.router, prefix="/addresses", tags=["address_ma
 app.include_router(pet_router.router, prefix="/api/v1/users", tags=["pet_management"])
 app.include_router(guest_router.router, prefix="/api/v1/users", tags=["guest_management"])
 app.include_router(favorite_router.router, prefix="/api/v1/users", tags=["favorites"])
+app.include_router(review_router.router,prefix="/review",tags=["reviews"])
 
 @app.get("/")
 def root():

app/models/review_model.py

@@ -0,0 +1,45 @@
+from fastapi import HTTPException
+from app.core.nosql_client import db
+import logging
+from datetime import datetime
+
+from app.utils.db import prepare_for_db
+
+logger = logging.getLogger(__name__)
+
+class ReviewModel:
+    collection = db["merchant_reviews"]
+
+    @staticmethod
+    async def create_review(
+        review_data:dict
+    )->dict:
+        logger.info(f"Creating review for merchant {review_data['merchant_id']}")
+        
+        try:
+            
+            # Creating review document
+            review_doc = {
+                "merchant_id":review_data["merchant_id"],
+                "location_id": review_data["location_id"],
+                "user_name":review_data["user_name"],
+                "rating": review_data[ "rating"],
+                "review_text":review_data["review_text"],
+                "review_date": datetime.utcnow(),
+                "verified_purchase":review_data["verified_purchase"]
+            }
+    
+            sanitized_review = prepare_for_db(review_doc)
+            
+            result = await ReviewModel.collection.insert_one(sanitized_review)
+            
+            logger.info(f"review data inserted successfully: {result}")
+
+            if result.inserted_id:
+                return review_doc
+            
+        except HTTPException:
+            raise
+        except Exception as e:
+            logger.error(f"Error while adding review: {str(e)}", exc_info=True)
+            raise HTTPException(status_code=500, detail="Failed to add review details")

app/routers/review_router.py

@@ -0,0 +1,48 @@
+from fastapi import APIRouter, Depends, HTTPException, status
+import logging
+from app.utils.jwt import get_current_user
+from typing import Dict, Any
+
+from app.schemas.review_schema import ReviewCreateRequest,ReviewResponse
+from app.models.review_model import ReviewModel
+
+logger = logging.getLogger(__name__)
+
+router = APIRouter()
+
+@router.post("/add", response_model=ReviewResponse,
+    status_code=status.HTTP_201_CREATED)
+async def create_review(
+    review_data: ReviewCreateRequest,
+    current_user: Dict[str, Any] = Depends(get_current_user)
+):
+    try:
+       
+
+        review_reponse=await ReviewModel.create_review(review_data.dict())
+        
+        if not review_reponse:
+            raise HTTPException(
+                status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+                detail="failed to add review details"
+            ) 
+        return  ReviewResponse(
+            merchant_id=review_reponse["merchant_id"],
+            location_id=review_reponse["location_id"],
+            user_name=review_reponse["user_name"],
+            rating=review_reponse["rating"],
+            review_text=review_reponse["review_text"],
+            review_date=review_reponse["review_date"],
+            verified_purchase=review_reponse["verified_purchase"]
+
+        )
+        
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Error while adding review: {str(e)}")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail="Failed to add review"
+        )
+

app/schemas/review_schema.py

@@ -0,0 +1,24 @@
+from pydantic import BaseModel, Field
+from typing import Optional, List
+from datetime import datetime
+
+class ReviewCreateRequest(BaseModel):
+    """Request schema for creating a review"""
+    merchant_id: str = Field(..., description="Unique ID of the merchant")
+    location_id: str = Field(..., description="ID of the merchant location")
+    user_name: str = Field(..., description="Name of the user submitting the review")
+    rating: float = Field(..., description="Rating given by the user")
+    review_text: str = Field(..., description="review text provided by the user")
+    verified_purchase: bool = Field(..., description="Indicates if the review is from a verified purchase")
+
+
+class ReviewResponse(BaseModel):
+    """Response schema for creating a review"""
+    merchant_id: str = Field(..., description="Unique ID of the merchant")
+    location_id: str = Field(..., description="ID of the merchant location")
+    user_name: str = Field(..., description="Name of the user submitting the review")
+    rating: float = Field(..., description="Rating given by the user")
+    review_text: str = Field(..., description="review text provided by the user")
+    review_date: datetime = Field(..., description="Date and time when the review was created")
+    verified_purchase: bool = Field(..., description="Indicates if the review is from a verified purchase")
+