Function fetchPaginatedTaskRequests

models/taskRequests.js:78–168

(queries = {})

};

const fetchPaginatedTaskRequests = async (queries = {}) => {
  try {
    let taskRequestsSnapshot = taskRequestsCollection;
    let { next, prev, size, q: queryString } = queries;
    if (size) size = parseInt(size);

    const rqlQueryParser = new RQLQueryParser(queryString);

    const filterQueries = rqlQueryParser.getFilterQueries();

    for (const [filterKey, filterValue] of Object.entries(filterQueries)) {
      const valuesList = filterValue
        .map((query) =>
          query.operator === Operators.INCLUDE ? Reflect.get(TASK_REQUEST_FILTER_VALUES, query.value) : null
        )
        .filter(Boolean);

      if (Reflect.has(TASK_REQUEST_FILTER_KEYS, filterKey)) {
        const fieldName = Reflect.get(TASK_REQUEST_FILTER_KEYS, filterKey);
        taskRequestsSnapshot = taskRequestsSnapshot.where(fieldName, "in", valuesList);
      }
    }

    const sortQueries = rqlQueryParser.getSortQueries();
    const sortQueryEntries = Object.entries(sortQueries);

    if (sortQueryEntries.length) {
      for (const [sortKey, sortValue] of sortQueryEntries) {
        if (Reflect.has(TASK_REQUEST_SORT_KEYS, sortKey) && Reflect.has(TASK_REQUEST_SORT_VALUES, sortValue)) {
          const sortField = Reflect.get(TASK_REQUEST_SORT_KEYS, sortKey);
          const orderDirection = Reflect.get(TASK_REQUEST_SORT_VALUES, sortValue);
          taskRequestsSnapshot = taskRequestsSnapshot.orderBy(sortField, orderDirection);
        }
      }
    } else {
      const defaultField = Reflect.get(TASK_REQUEST_SORT_KEYS, "created");
      taskRequestsSnapshot = taskRequestsSnapshot.orderBy(defaultField, "desc");
    }

    if (next) {
      const data = await taskRequestsCollection.doc(next).get();
      if (!data.data()) {
        return {
          statusCode: 400,
          error: "Bad Request",
          message: `${TASK_REQUEST_ERROR_MESSAGE.INVALID_NEXT}: ${next}`,
        };
      }
      taskRequestsSnapshot = taskRequestsSnapshot.startAfter(data).limit(size);
    } else if (prev) {
      const data = await taskRequestsCollection.doc(prev).get();
      if (!data.data()) {
        return {
          statusCode: 400,
          error: "Bad Request",
          message: `${TASK_REQUEST_ERROR_MESSAGE.INVALID_PREV}: ${prev}`,
        };
      }