remove average rating field

app/models/movie_model.py

@@ -1,5 +1,5 @@
 from decimal import Decimal
-from sqlalchemy import String, Integer, DECIMAL, ForeignKey
+from sqlalchemy import String, Integer, DECIMAL, ForeignKey, Float
 from sqlalchemy.orm import Mapped, relationship, mapped_column
 
 from app.database import Base
@@ -31,6 +31,7 @@ class Review(Base):
     author: Mapped[str]
     comment: Mapped[str]
     rating: Mapped[int]
+    average_rating: Mapped[float] = mapped_column(Float, nullable=True)
     ip_address: Mapped[str] = mapped_column(String(255))
     movie_id: Mapped[int] = mapped_column(ForeignKey("movies.id"), nullable=False)
     movie = relationship(Movie, back_populates="reviews")

app/schema/review_schema.py

@@ -10,7 +10,7 @@ class ReviewCreateSchema(BaseModel):
 class ReviewResponseSchema(ReviewCreateSchema):
     id: int
     movie_id: int
-
+    average_rating: float | None
 
 
 class AverageMovieRating(BaseModel):

app/services/reviews_service.py

@@ -18,6 +18,7 @@ def add_new_review(
     movie_id: int, ip_address: str, review: ReviewCreateSchema, db: session
 ):
     existing_review = db.query(Review).filter(Review.movie_id == movie_id, Review.ip_address == ip_address).first()
+    ratings = db.query(Review).filter(Review.movie_id == movie_id).all()
 
     if existing_review:
         raise HTTPException(
@@ -37,6 +38,10 @@ def add_new_review(
             db.commit()
             db.refresh(new_review)
 
+            new_review.average_raring = sum([rating.rating for rating in ratings] if len(ratings) > 0 else 0)
+            db.commit()
+            db.refresh(new_review)
+
             return new_review
     except Exception:
         session.rollback()