Get Task dependency (#1099)

* get dependsOn on taskdata

* added task-list test

* retry ECONNRESET error

* retry ECONNRESET error

* change task to taskdata

Author: vinit717

controllers/tasks.js

@@ -153,12 +153,14 @@ const getSelfTasks = async (req, res) => {
 const getTask = async (req, res) => {
   try {
     const taskId = req.params.id;
-    const { taskData } = await tasks.fetchTask(taskId);
-
+    const { taskData, dependencyDocReference } = await tasks.fetchTask(taskId);
     if (!taskData) {
       return res.boom.notFound("Task not found");
     }
-    return res.json({ message: "task returned successfully", taskData });
+    return res.json({
+      message: "task returned successfully",
+      taskData: { ...taskData, dependsOn: dependencyDocReference },
+    });
   } catch (err) {
     return res.boom.badImplementation(INTERNAL_SERVER_ERROR);
   }

models/tasks.js

@@ -17,6 +17,7 @@ const { OLD_ACTIVE, OLD_BLOCKED, OLD_PENDING, OLD_COMPLETED } = TASK_STATUS_OLD;
 const updateTask = async (taskData, taskId = null) => {
   try {
     taskData = await toFirestoreData(taskData);
+
     if (taskId) {
       const task = await tasksModel.doc(taskId).get();
       if (taskData.status === "VERIFIED") {
@@ -73,8 +74,15 @@ const fetchTasks = async () => {
     const tasks = buildTasks(tasksSnapshot);
     const promises = tasks.map(async (task) => fromFirestoreData(task));
     const updatedTasks = await Promise.all(promises);
-    const taskList = updatedTasks.map((task) => {
+    const taskList = updatedTasks.map(async (task) => {
       task.status = TASK_STATUS[task.status.toUpperCase()] || task.status;
+      const taskId = task.id;
+      const dependencySnapshot = await dependencyModel.where("taskId", "==", taskId).get();
+      task.dependsOn = [];
+      dependencySnapshot.docs.forEach((doc) => {
+        const dependsId = doc.get("dependsId");
+        task.dependsOn.push(dependsId);
+      });
       return task;
     });
     return taskList;
@@ -116,11 +124,16 @@ const fetchActiveTaskMembers = async () => {
 const fetchTask = async (taskId) => {
   try {
     const task = await tasksModel.doc(taskId).get();
+    const dependencySnapshot = await dependencyModel.where("taskId", "==", taskId).get();
+    const dependencyDocReference = dependencySnapshot.docs.map((doc) => {
+      const dependsId = doc.get("dependsId");
+      return dependsId;
+    });
     const taskData = await fromFirestoreData(task.data());
     if (taskData?.status) {
       taskData.status = TASK_STATUS[taskData.status.toUpperCase()] || task.status;
     }
-    return { taskData };
+    return { taskData, dependencyDocReference };
   } catch (err) {
     logger.error("Error retrieving task data", err);
     throw err;

test/integration/tasks.test.js

@@ -158,6 +158,7 @@ describe("Tasks", function () {
           expect(res.body).to.be.a("object");
           expect(res.body.message).to.equal("Tasks returned successfully!");
           expect(res.body.tasks).to.be.a("array");
+          expect(res.body.tasks[0].dependsOn).to.be.a("array");
           const taskWithParticipants = res.body.tasks[0];
 
           if (taskWithParticipants.type === "group") {
@@ -185,6 +186,8 @@ describe("Tasks", function () {
           expect(res.body).to.be.a("object");
           expect(res.body.message).to.be.equal("task returned successfully");
           expect(res.body.taskData).to.be.a("object");
+          expect(res.body.taskData.dependsOn).to.be.a("array");
+
           return done();
         });
     });