Merge pull request #615 from topcoder-platform/fix/search

fix: search

Author: rakibansary

.circleci/config.yml

@@ -83,14 +83,14 @@ workflows:
           branches:
             only:
             - dev
-            - fix/schema
+            - fix/search
 
     - "build-qa":
         context: org-global
         filters:
           branches:
             only:
-            - refactor/domain-challenge
+            - qa
 
     # Production builds are exectuted only on tagged commits to the
     # master branch.

README.md

@@ -22,13 +22,11 @@ Dev: [![CircleCI](https://circleci.com/gh/topcoder-platform/challenge-api/tree/d
 
 - [Resources API](https://github.com/topcoder-platform/resources-api)
 - [ES Processor](https://github.com/topcoder-platform/challenge-processor-es) - Updates data in ElasticSearch
-- [Legacy Processor](https://github.com/topcoder-platform/legacy-challenge-processor) - Moves data from DynamoDB back to Informix
-- [Legacy Migration Script](https://github.com/topcoder-platform/legacy-challenge-migration-script) - Moves data from Informix to DynamoDB
-- [Frontend App](https://github.com/topcoder-platform/challenge-engine-ui)
+- [Domain Challenge](https://github.com/topcoder-platform/domain-challenge) - Domain Challenge
 
 ## Prerequisites
 
-- [NodeJS](https://nodejs.org/en/) (v10)
+- [NodeJS](https://nodejs.org/en/) (v18+)
 - [AWS S3](https://aws.amazon.com/s3/)
 - [Elasticsearch v6](https://www.elastic.co/)
 - [Docker](https://www.docker.com/)

src/common/helper.js

@@ -754,36 +754,21 @@ function calculateChallengeEndDate(challenge, data) {
 async function listChallengesByMember(memberId) {
   const token = await m2mHelper.getM2MToken();
   let allIds = [];
-  // get search is paginated, we need to get all pages' data
-  let page = 1;
-  while (true) {
-    let result = {};
-    try {
-      result = await axios.get(`${config.RESOURCES_API_URL}/${memberId}/challenges`, {
-        headers: { Authorization: `Bearer ${token}` },
-        params: {
-          page,
-          perPage: 10000,
-        },
-      });
-    } catch (e) {
-      // only log the error but don't throw it, so the following logic can still be executed.
-      logger.debug(`Failed to get challenges that accessible to the memberId ${memberId}`, e);
-    }
-    const ids = result.data || [];
-    if (ids.length === 0) {
-      break;
-    }
-    allIds = allIds.concat(ids);
-    page += 1;
-    if (
-      result.headers &&
-      result.headers["x-total-pages"] &&
-      page > Number(result.headers["x-total-pages"])
-    ) {
-      break;
-    }
+
+  try {
+    const result = await axios.get(`${config.RESOURCES_API_URL}/${memberId}/challenges`, {
+      headers: { Authorization: `Bearer ${token}` },
+      params: {
+        useScroll: true,
+      },
+    });
+
+    allIds = result.data || [];
+  } catch (e) {
+    // only log the error but don't throw it, so the following logic can still be executed.
+    logger.debug(`Failed to get challenges that accessible to the memberId ${memberId}`, e);
   }
+
   return allIds;
 }
 

src/services/ChallengeService.js

@@ -149,7 +149,6 @@ async function searchChallenges(currentUser, criteria) {
       _.includes(config.SELF_SERVICE_WHITELIST_HANDLES, currentUser.handle.toLowerCase()));
 
   const includedTrackIds = _.isArray(criteria.trackIds) ? criteria.trackIds : [];
-
   const includedTypeIds = _.isArray(criteria.typeIds) ? criteria.typeIds : [];
 
   if (criteria.type) {
@@ -168,7 +167,6 @@ async function searchChallenges(currentUser, criteria) {
       criteria.trackId = _.get(trackSearchRes, "result[0].id");
     }
   }
-
   if (criteria.types) {
     for (const t of criteria.types) {
       const typeSearchRes = await ChallengeTypeService.searchChallengeTypes({ abbreviation: t });
@@ -187,7 +185,6 @@ async function searchChallenges(currentUser, criteria) {
       }
     }
   }
-
   if (criteria.typeId) {
     includedTypeIds.push(criteria.typeId);
   }
@@ -604,10 +601,10 @@ async function searchChallenges(currentUser, criteria) {
         match_phrase: { "task.isAssigned": criteria.taskIsAssigned },
       });
     }
-    if (criteria.taskMemberId || criteria.memberId) {
+    if (criteria.taskMemberId) {
       boolQuery.push({
         match_phrase: {
-          "task.memberId": criteria.taskMemberId || criteria.memberId,
+          "task.memberId": criteria.taskMemberId,
         },
       });
     }