Upload 157 files

src/apis/controllers/post_controller.py

@@ -121,46 +121,76 @@ async def list_all_posts_controller(user_id: str):
         return {"status": "error", "message": str(e)}
 
 
-async def list_posts_destination_controller(destination: str):
+async def list_posts_by_destination_controller(destination_id: str, user_id: str):
     try:
-        posts = await PostCRUD.read({"destination_id": destination})
-        user_ids = [post.get("user_id") for post in posts]
-        user_infos = await gather(
-            *[UserCRUD.find_by_id(user_id) for user_id in user_ids]
-        )
+        # Filtered posts only for the given destination_id
+        posts = await PostCRUD.find_many({"destination_id": destination_id})
+        if not posts:
+            return {"status": "success", "message": []}
+
+        # Get unique user_ids
+        user_ids = list({post.get("user_id") for post in posts})
+        user_infos = await gather(*[UserCRUD.find_by_id(uid) for uid in user_ids])
         user_info_map = {
-            user_info.get("_id"): user_info for user_info in user_infos if user_info
+            info.get("_id"): {
+                "name": info.get("name"),
+                "picture": info.get("picture"),
+            }
+            for info in user_infos if info
         }
 
+        # Get destination name
+        destination_info = await DestinationCRUD.find_by_id(destination_id)
+        destination_name = destination_info.get("name") if destination_info else None
+
+        # Reactions by current user for these posts
+        formatted_user_reactions_map = {}
+        if user_id:
+            all_post_ids = [serialize_datetime(post.get("_id")) for post in posts]
+            reactions = await gather(
+                *[
+                    ReactionCRUD.read_one({"user_id": user_id, "post_id": post_id})
+                    for post_id in all_post_ids
+                ]
+            )
+            for reaction in reactions:
+                if reaction:
+                    post_id = reaction.get("post_id")
+                    formatted_user_reactions_map[post_id] = {
+                        "id": serialize_datetime(reaction.get("_id")),
+                        "post_id": post_id,
+                        "user_id": reaction.get("user_id"),
+                        "reaction_type": reaction.get("type"),
+                    }
+
+        # Final serialization
         serialized_posts = []
         for post in posts:
-            user_id = post.get("user_id")
-            user_info = user_info_map.get(user_id)
+            post_id = serialize_datetime(post.get("_id"))
+            uid = post.get("user_id")
             serialized_post = {
-                "id": serialize_datetime(post.get("_id")),
+                "id": post_id,
                 "content": post.get("content"),
-                "destination_id": post.get("destination_id"),
-                "comment_ids": post.get("comment_ids", []),
-                "like": post.get("like", []),
+                "destination_id": destination_id,
+                "destination_name": destination_name,
+                "comment_count": post.get("comment_count", []),
+                "reaction_count": post.get("reaction_count", []),
+                "current_user_reaction": formatted_user_reactions_map.get(post_id),
                 "picture": post.get("picture", []),
                 "created_at": serialize_datetime(post.get("created_at")),
                 "updated_at": serialize_datetime(post.get("updated_at")),
-                "user_info": (
-                    {
-                        "name": user_info.get("name"),
-                        "picture": user_info.get("picture"),
-                    }
-                    if user_info
-                    else None
-                ),
+                "user_info": user_info_map.get(uid),
             }
             serialized_posts.append(serialized_post)
+
         return {"status": "success", "message": serialized_posts}
+
     except Exception as e:
-        logger.error(f"Error listing posts: {str(e)}")
+        logger.error(f"Error listing posts by destination: {str(e)}")
         return {"status": "error", "message": str(e)}
 
 
+
 async def update_a_post_controller(
     user_id: str, post_id: str, content: str, destination_id: str
 ) -> Dict:

src/apis/routes/post_router.py

@@ -8,7 +8,7 @@ from src.apis.middlewares.auth_middleware import get_current_user
 from src.apis.controllers.post_controller import (
     create_a_post_controller,
     list_all_posts_controller,
-    list_posts_destination_controller,
+    list_posts_by_destination_controller,
     get_a_post_controller,
     update_a_post_controller,
     delete_a_post_controller,
@@ -80,24 +80,16 @@ async def list_all_posts(user_id: Optional[str] = None):
         return JSONResponse(content=result, status_code=200)
 
 
-class BodyListPost(BaseDocument):
-    destination_id: str = Field("", description="Destination's id")
-
-    class Config:
-        json_schema_extra = {
-            "example": {
-                "destination_id": "1234567890",
-            }
-        }
-
-
-@router.post("/list_post_destination", status_code=status.HTTP_200_OK)
-async def list_all_posts_destination(body: BodyListPost):
+@router.get("/list_post_destination", status_code=status.HTTP_200_OK)
+async def list_all_posts_destination(
+    destination_id: str,
+    user_id: Optional[str] = None,
+):
     # result = await get_key_redis("all_posts")
     result = None
     result = eval(result) if result else None
     if not result:
-        result = await list_posts_destination_controller(body.destination_id)
+        result = await list_posts_by_destination_controller(destination_id, user_id)
         # background_tasks.add_task(set_key_redis, "all_posts", str(result),20)
     if result["status"] == "error":
         return JSONResponse(content=result, status_code=404)