Watchlist fix (#246)

iamitprakash · web-flow · commit cbbc0cbc89fe · 2025-08-14T02:28:48.000+05:30
* Update watchlist_repository.py

* Update test_watchlist_service.py

* Update watchlist_dto.py

* Update watchlist_repository.py
diff --git a/todo/repositories/watchlist_repository.py b/todo/repositories/watchlist_repository.py
@@ -68,6 +68,16 @@ def get_watchlisted_tasks(cls, page, limit, user_id) -> Tuple[int, List[Watchlis
                             }
                         },
                         {"$unwind": "$task"},
+                        {
+                            "$lookup": {
+                                "from": "users",
+                                "let": {"createdById": "$task.createdBy"},
+                                "pipeline": [
+                                    {"$match": {"$expr": {"$eq": ["$_id", {"$toObjectId": "$$createdById"}]}}}
+                                ],
+                                "as": "created_by_user",
+                            }
+                        },
                         {
                             "$lookup": {
                                 "from": "task_details",
diff --git a/todo/tests/unit/services/test_watchlist_service.py b/todo/tests/unit/services/test_watchlist_service.py
@@ -63,7 +63,7 @@ def test_get_watchlisted_tasks_with_assignee(self):
             labels=[],
             dueAt=None,
             createdAt=datetime.now(timezone.utc),
-            createdBy=user_id,
+            createdBy="Test User",
             watchlistId=str(ObjectId()),
             assignee=assignee_dto,
         )

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ def test_get_watchlisted_tasks_with_assignee(self):`
`63`	`63`	`labels=[],`
`64`	`64`	`dueAt=None,`
`65`	`65`	`createdAt=datetime.now(timezone.utc),`
`66`		`- createdBy=user_id,`
	`66`	`+ createdBy="Test User",`
`67`	`67`	`watchlistId=str(ObjectId()),`
`68`	`68`	`assignee=assignee_dto,`
`69`	`69`	`)`