Function updateTaskStatus

models/tasks.js:625–679

()

};

const updateTaskStatus = async () => {
  try {
    const snapshot = await tasksModel.where("status", "==", "COMPLETED").get();
    const tasksStatusCompleted = [];
    let summary = {
      totalTasks: snapshot.size,
      totalUpdatedStatus: 0,
      totalOperationsFailed: 0,
      updatedTaskDetails: [],
      failedTaskDetails: [],
    };

    if (snapshot.size === 0) {
      return summary;
    }

    snapshot.forEach((task) => {
      const id = task.id;
      const taskData = task.data();
      tasksStatusCompleted.push({ ...taskData, id });
    });
    const taskStatusCompletedChunks = chunks(tasksStatusCompleted, DOCUMENT_WRITE_SIZE);

    const updatedTasksPromises = await Promise.all(
      taskStatusCompletedChunks.map(async (tasks) => {
        const res = await updateTaskStatusToDone(tasks);
        return {
          totalUpdatedStatus: res.totalUpdatedStatus,
          totalOperationsFailed: res.totalOperationsFailed,
          updatedTaskDetails: res.updatedTaskDetails,
          failedTaskDetails: res.failedTaskDetails,
        };
      })
    );

    updatedTasksPromises.forEach((res) => {
      summary = {
        ...summary,
        totalUpdatedStatus: (summary.totalUpdatedStatus += res.totalUpdatedStatus),
        totalOperationsFailed: (summary.totalOperationsFailed += res.totalOperationsFailed),
        updatedTaskDetails: [...summary.updatedTaskDetails, ...res.updatedTaskDetails],
        failedTaskDetails: [...summary.failedTaskDetails, ...res.failedTaskDetails],
      };
    });

    if (summary.totalOperationsFailed === summary.totalTasks) {
      throw Error(INTERNAL_SERVER_ERROR);
    }

    return summary;
  } catch (error) {
    logger.error(`Error in updating task status:  ${error}`);
    throw error;
  }
};

const updateOrphanTasksStatus = async () => {
  try {