Function fetchTaskRequests

models/taskRequests.js:27–76

(dev)

 * @return {Object}
 */
const fetchTaskRequests = async (dev) => {
  const taskRequests = [];
  const newTaskRequestsModel = [];
  try {
    const taskRequestsSnapshots = (await taskRequestsCollection.get()).docs;

    const taskPromises = [];
    const userPromises = [];

    const newUserPromises = [];

    taskRequestsSnapshots.forEach((taskRequestsSnapshot) => {
      const taskRequestData = taskRequestsSnapshot.data();
      taskRequestData.id = taskRequestsSnapshot.id;
      taskRequestData.url = new URL(`/taskRequests/${taskRequestData.id}`, config.get("services.rdsUi.baseUrl"));
      const { requestors } = taskRequestData;

      if (taskRequestData.taskId && !taskRequestData.requestType) {
        taskPromises.push(tasksModel.fetchTask(taskRequestData.taskId));
        userPromises.push(Promise.all(requestors.map((requestor) => userModel.fetchUser({ userId: requestor }))));
        taskRequests.push(taskRequestData);
      } else if (dev) {
        newUserPromises.push(Promise.all(requestors.map((requestor) => userModel.fetchUser({ userId: requestor }))));
        newTaskRequestsModel.push(taskRequestData);
      }
    });

    const tasks = await Promise.all(taskPromises);
    const users = await Promise.all(userPromises);

    if (dev) {
      const newUsers = await Promise.all(newUserPromises);
      newTaskRequestsModel.forEach((taskRequest, index) => {
        taskRequest.requestors = newUsers[+index];
      });
    }

    taskRequests.forEach((taskRequest, index) => {
      taskRequest.task = tasks[+index].taskData;
      taskRequest.requestors = users[+index];
    });
  } catch (err) {
    logger.error("Error in updating task", err);
  }

  if (dev) {
    return [...taskRequests, ...newTaskRequestsModel];
  }
  return taskRequests;
};

const fetchPaginatedTaskRequests = async (queries = {}) => {
  try {