[ORCT-145] - add pagination support

app/lib/domain/dtos/stdRequest.dto.js

@@ -26,7 +26,12 @@ const emptyDataRequestDTO = Joi.object({
  * query.filter - object for building sequelize where-cluase
  */
 const stdDataRequestDTO = Joi.object({
-    query: tokenDTO.keys({ filter: Joi.object({}).unknown(true) }), //TODO make more strict
+    query: tokenDTO.keys({
+        filter: Joi.object({}).unknown(true),
+        page: Joi.object({
+            limit: Joi.number(),
+            offset: Joi.number(),
+        }) }), //TODO make more strict
     params: emptyDTO,
     body: emptyDTO,
 });

app/lib/services/dataPasses/DataPassService.js

@@ -30,9 +30,10 @@ class DataPassService {
      * @param {Object} query -  Filtering query definiton from http request
      * @returns {Promise<DataPass[]>} Promise object represents the result of this use case.
      */
-    async getAll({ filter }) {
+    async getAll({ filter, page }) {
         const periods = await DataPassRepository.findAll({
             where: filterToSequelizeWhereClause(filter),
+            ...page,
         });
         return periods.map((dataPass) => dataPassAdapter.toEntity(dataPass));
     }
@@ -43,12 +44,13 @@ class DataPassService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<DataPass[]>} Promise object represents the result of this use case.
      */
-    async getDataPassesPerPeriod(periodId, { filter }) {
+    async getDataPassesPerPeriod(periodId, { filter, page }) {
         const runs = await DataPassRepository.findAll({
             where: {
                 period_id: periodId,
                 ...filterToSequelizeWhereClause(filter),
             },
+            ...page,
         });
         return runs.map((dataPass) => dataPassAdapter.toEntity(dataPass));
     }
@@ -59,7 +61,7 @@ class DataPassService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<DataPass[]>} Promise object represents the result of this use case.
      */
-    async getAnchoredToSimulationPass(simulationPassId, { filter }) {
+    async getAnchoredToSimulationPass(simulationPassId, { filter, page }) {
         const runs = await DataPassRepository.findAll({
             include: [
                 {
@@ -77,6 +79,7 @@ class DataPassService {
             where: {
                 ...filterToSequelizeWhereClause(filter),
             },
+            ...page,
         });
         return runs.map((dataPass) => dataPassAdapter.toEntity(dataPass));
     }

app/lib/services/periods/PeriodService.js

@@ -33,7 +33,7 @@ class PeriodService {
      * @param {Object} query -  Filtering query definiton from http request,... #TODO
      * @returns {Promise<Period[]>} Promise object represents the result of this use case.
      */
-    async getAll({ filter }) {
+    async getAll({ filter, page }) {
         const periods = await PeriodRepository.findAll({
             include: [
                 {
@@ -61,6 +61,7 @@ class PeriodService {
             group: ['Period.id', 'BeamType.id'],
 
             where: filterToSequelizeWhereClause(filter),
+            ...page,
         });
         return periods.map((period) => periodAdapter.toEntity(period));
     }

app/lib/services/qualityControl/QualityControlService.js

@@ -33,7 +33,7 @@ class QualityControlService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<Quality[]>} Promise object represents the result of this use case.
      */
-    async getAllTimeBasedFlags({ filter }) {
+    async getAllTimeBasedFlags({ filter, page }) {
         const qualityFlags = await QualityControlFlagRepository.findAll({
             include: [
                 {
@@ -51,6 +51,7 @@ class QualityControlService {
                 },
             ],
             where: filterToSequelizeWhereClause(filter),
+            ...page,
         });
         return qualityFlags.map((qualityFlags) => qualityControlFlagAdapter.toEntity(qualityFlags));
     }

app/lib/services/runs/RunService.js

@@ -32,9 +32,10 @@ class RunService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<Run[]>} Promise object represents the result of this use case.
      */
-    async getAll({ filter }) {
+    async getAll({ filter, page }) {
         const runs = await RunRepository.findAllWithDetectors({
             where: filterToSequelizeWhereClause(filter),
+            ...page,
         });
         return runs.map((run) => runAdapter.toEntity(run));
     }
@@ -45,12 +46,13 @@ class RunService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<Run[]>} Promise object represents the result of this use case.
      */
-    async getRunsPerPeriod(periodId, { filter }) {
+    async getRunsPerPeriod(periodId, { filter, page }) {
         const runs = await RunRepository.findAllWithDetectors({
             where: {
                 period_id: periodId,
                 ...filterToSequelizeWhereClause(filter),
             },
+            ...page,
         });
         return runs.map((run) => runAdapter.toEntity(run));
     }
@@ -61,7 +63,7 @@ class RunService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<Run[]>} Promise object represents the result of this use case.
      */
-    async getRunsPerDataPass(dataPassId, { filter }) {
+    async getRunsPerDataPass(dataPassId, { filter, page }) {
         const runs = await RunRepository.findAllWithDetectors({
             include: [
                 {
@@ -78,6 +80,7 @@ class RunService {
             where: {
                 ...filterToSequelizeWhereClause(filter),
             },
+            ...page,
         });
         return runs.map((run) => runAdapter.toEntity(run));
     }
@@ -88,7 +91,7 @@ class RunService {
      * @param {Object} query - Filtering query definiton from http request,... #TODO
      * @returns {Promise<Run[]>} Promise object represents the result of this use case.
      */
-    async getRunsPerSimulationPass(simulationPassId, { filter }) {
+    async getRunsPerSimulationPass(simulationPassId, { filter, page }) {
         const runs = await RunRepository.findAllWithDetectors({
             include: [
                 {
@@ -105,6 +108,7 @@ class RunService {
             where: {
                 ...filterToSequelizeWhereClause(filter),
             },
+            ...page,
         });
         return runs.map((run) => runAdapter.toEntity(run));
     }