Add executeAll to QueryExecutor and update searchRecords to return multiple matches

Author: julie-gordon

src/services/dataio.service.ts

@@ -200,15 +200,19 @@ export const searchRecords = (req: IReq<SearchRecordsBody>, res: IRes): IRes =>
     }
     const db: FileDB = new FileDB(generateFilePath(query.from));
     const data: object[] = db.readFile();
-    const index: number = QueryExecutor.execute(query, data);
-    if (index === -1) {
+    const indices: number[] = QueryExecutor.executeAll(query, data);
+    if (!indices || indices.length === 0) {
       console.log('No results found');
       return res.json({ records: [] })
     }
-    const dataResult: object = data[index];
-    convertDateToISO8601(dataResult, query.from);
 
-    return res.json({ records: [ResultRehydrator.filterAndRehydrate(query.attributesToSelect, data[index])] });
+    const records = indices.map((idx: number) => {
+      const record: object = data[idx];
+      convertDateToISO8601(record, query.from);
+      return ResultRehydrator.filterAndRehydrate(query.attributesToSelect, record);
+    });
+
+    return res.json({ records });
   } catch (err) {
     console.log(`Encountered an error searching data: ${err.message}`);
     return res.status(500).json(generateErrorResponse(ErrorCode.INTERNAL_ERROR, err)).send();

src/utils/queryExecutor.ts

@@ -31,6 +31,23 @@ export class QueryExecutor {
         return -1;
     }
 
+    /**
+     * Executes a query on the given input data and returns all matching indices.
+     * @param {IQuery} query - The query to execute.
+     * @param {object[]} inputData - The data to query against.
+     * @returns {number[]} An array of indices for matching records (empty if none).
+     */
+    public static executeAll(query: IQuery, inputData: object[]): number[] {
+        const operation: OperationUnion = query.queryFilter.operation;
+        const results: number[] = [];
+        for (let index: number = 0; index < inputData.length; index++) {
+            if (this.evaluateOperation(operation, inputData[index])) {
+                results.push(index);
+            }
+        }
+        return results;
+    }
+
     /**
      * Evaluates an operation on a given record.
      * @param {OperationUnion} operation - The operation to evaluate.