Домашнє Завдання: Аналітика відвідувань сторінок продуктів

Dockerfile

@@ -6,7 +6,7 @@ COPY pyproject.toml pyproject.toml
 
 RUN pip install poetry
 RUN poetry config virtualenvs.create false
-RUN poetry install --no-dev
+RUN poetry install --no-root
 
 COPY . /app
 

src/catalogue/models/pydantic.py

@@ -11,7 +11,7 @@ class ProductModel(BaseModel):
     title: str
     description: Optional[str]
     short_description: Optional[constr(max_length=20)]
-    is_active: bool
+    is_active: Optional[bool] = None
 
     class Config:
         from_attributes = True

src/common/databases/mongo_db.py

@@ -20,6 +20,6 @@ async def init_mongo_db():
     await init_beanie(
         database=client.get_database(),
         document_models=[
-            ProductReview,
+            ProductReview
         ],
     )

src/reviews/models/mongo.py

@@ -1,4 +1,5 @@
 import uuid
+from datetime import datetime
 from typing import Optional
 
 from beanie import Document
@@ -28,3 +29,10 @@ class ProductReview(Document, BaseProductReview):
 
     class Settings:
         name = 'productReviews'
+
+class ProductAnalytics(Document):
+    product_id: int
+    timestamp: datetime
+
+    class Settings:
+        name = "productAnalytics"

src/reviews/repositories.py

@@ -1,6 +1,9 @@
 from src.common.repository.beanie import BaseMongoRepository
-from src.reviews.models.mongo import ProductReview
+from src.reviews.models.mongo import ProductReview, ProductAnalytics
 
 
 class ProductReviewRepository(BaseMongoRepository[ProductReview]):
     __model__ = ProductReview
+
+class ProductAnalyticsRepository(BaseMongoRepository[ProductAnalytics]):
+    __model__ = ProductAnalytics

src/reviews/services.py

@@ -6,10 +6,10 @@
 from src.common.service import BaseService
 from src.reviews.models.mongo import (
     ProductReview,
-    Reply,
+    Reply, ProductAnalytics,
 )
-from src.reviews.repositories import ProductReviewRepository
-
+from src.reviews.repositories import ProductReviewRepository, ProductAnalyticsRepository
+from datetime import datetime
 
 class ProductReviewService(BaseService):
     def __init__(
@@ -44,3 +44,21 @@ async def add_reply(self, pk: str, reply: Reply) -> ProductReview:
         review.replies.append(reply.model_dump())
 
         return await review.save()
+
+
+
+
+class ProductAnalyticsService(BaseService):
+    def __init__(
+        self,
+        repository: Annotated[ProductAnalyticsRepository, Depends(ProductAnalyticsRepository)],
+    ):
+        super().__init__(repository=repository)
+
+    async def create_record(self, product_id: int) -> ProductAnalytics:
+        record = ProductAnalytics(
+            product_id=product_id,
+            timestamp=datetime.utcnow()
+        )
+        return await self.repository.create(record)
+

src/reviews/views/product_reviews.py

@@ -9,24 +9,25 @@
     Response,
     status,
 )
-
+from datetime import datetime
 from src.common.exceptions.base import ObjectDoesNotExistException
 from src.common.schemas.common import ErrorResponse
 from src.reviews.models.mongo import (
     BaseProductReview,
-    ProductReview,
+    ProductReview, ProductAnalytics,
     Reply,
 )
 from src.reviews.routes import (
     ProductReviewRoutesPrefixes,
-    ReviewsRoutesPrefixes,
+    ReviewsRoutesPrefixes
 )
-from src.reviews.services import ProductReviewService
+from src.reviews.services import ProductReviewService, ProductAnalyticsService
+from src.catalogue.services import ProductService
+from src.catalogue.models.pydantic import ProductModel
 
 
 router = APIRouter(prefix=ReviewsRoutesPrefixes.product_reviews)
 
-
 @router.get(
     ProductReviewRoutesPrefixes.root,
     status_code=status.HTTP_200_OK,
@@ -113,3 +114,19 @@ async def add_reply_to_review(
         return ErrorResponse(message=exc.message)
 
     return response
+
+
+
+
+@router.get("/catalogue/product/{pk}")
+async def product_detail(
+    pk: int,
+    analytics_service: ProductAnalyticsService = Depends()
+):
+    try:
+        await analytics_service.create_record(product_id=pk)
+    except Exception as e:
+        print(f"Analytics save failed: {e}")
+
+    return Response(status_code=status.HTTP_204_NO_CONTENT)
+