feat: add bulkOnly filters for datasetorders

Author: PierreJeanjacquot

api/openapi.yaml

@@ -477,6 +477,11 @@ paths:
           description: exclude orders with permissions allowing "any" requester (default false, ignored if `requester` is not specified)
           schema:
             type: boolean
+        - name: bulkOnly
+          in: query
+          description: exclude orders not eligible to bulk processing (default false)
+          schema:
+            type: boolean
         - $ref: '#/components/parameters/PageIndex'
         - $ref: '#/components/parameters/PageSize'
         - $ref: '#/components/parameters/Page'

api/src/controllers/router.js

@@ -373,6 +373,7 @@ router.get('/datasetorders', bodyParser(), async (ctx) => {
     minTag,
     maxTag,
     minVolume,
+    bulkOnly,
     page,
     pageIndex,
     pageSize,
@@ -394,6 +395,7 @@ router.get('/datasetorders', bodyParser(), async (ctx) => {
     minTag: bytes32Schema(),
     maxTag: bytes32Schema(),
     minVolume: positiveStrictIntSchema(),
+    bulkOnly: booleanSchema().default(false),
     page: positiveIntSchema(),
     pageIndex: positiveIntSchema(),
     pageSize: positiveIntSchema().max(maxPageSize).min(minPageSize),
@@ -411,6 +413,7 @@ router.get('/datasetorders', bodyParser(), async (ctx) => {
     minTag,
     maxTag,
     minVolume,
+    bulkOnly,
     page,
     pageIndex,
     pageSize,

api/src/services/order.js

@@ -576,6 +576,7 @@ const getDatasetorders = async ({
   minTag,
   maxTag,
   minVolume,
+  bulkOnly,
   page,
   pageIndex,
   pageSize,
@@ -586,6 +587,10 @@ const getDatasetorders = async ({
       status: STATUS_MAP.OPEN,
       ...(dataset && requiredDatasetOrAnyClause(dataset)),
       ...(datasetOwner && { signer: datasetOwner }),
+      ...(bulkOnly && {
+        'order.volume': Number.MAX_SAFE_INTEGER,
+        'order.datasetprice': 0,
+      }),
       ...apprestrictOrAnyClause(app, isAppStrict),
       ...workerpoolrestrictOrAnyClause(workerpool, isWorkerpoolStrict),
       ...requesterrestrictOrAnyClause(requester, isRequesterStrict),

api/test/datasetorders.test.js

@@ -904,6 +904,7 @@ describe('Offchain marketplace', () => {
     const maxGpuTagOrders = [];
     const minMaxTeeTagOrders = [];
     const minVolumeOrders = [];
+    const bulkOrders = [];
     let consumedOrders;
     let deadOrders;
     let datasetAddress;
@@ -949,6 +950,30 @@ describe('Offchain marketplace', () => {
       noRestrictOrders.push(...datasetPrice0);
       allOrders.push(...datasetPrice0);
 
+      const bulk = await Promise.all(
+        Array(2)
+          .fill(null)
+          .map(async () => {
+            const order = await iexecUser.order
+              .createDatasetorder({
+                dataset: datasetAddress,
+                datasetprice: 0, // bulk order must be free
+                volume: Number.MAX_SAFE_INTEGER, // bulk order must have max volume
+              })
+              .then(iexecUser.order.signDatasetorder);
+            const orderHash = await iexecUser.order.hashDatasetorder(order);
+            return {
+              order,
+              orderHash,
+              signer: ownerAddress,
+            };
+          }),
+      );
+      bulkOrders.push(...bulk);
+      minVolumeOrders.push(...bulk);
+      noRestrictOrders.push(...bulk);
+      allOrders.push(...bulk);
+
       const datasetPrice20 = await Promise.all(
         Array(5)
           .fill(null)
@@ -1803,6 +1828,24 @@ describe('Offchain marketplace', () => {
       });
     });
 
+    test('GET /datasetorders (bulkOnly filter)', async () => {
+      const { data, status } = await request
+        .get(
+          buildQuery('/datasetorders', {
+            chainId, // *
+            dataset: datasetAddress, // *
+            bulkOnly: true,
+          }),
+        )
+        .then(parseResult);
+      expect(status).toBe(OK_STATUS);
+      expect(data.ok).toBe(true);
+      expect(data.count).toBe(bulkOrders.length);
+      expect(data.orders).toBeDefined();
+      expect(Array.isArray(data.orders)).toBe(true);
+      expect(data.orders.length).toBe(bulkOrders.length);
+    });
+
     test('GET /datasetorders (isAppStrict = true & app = undefined): should return public orders including "any" app', async () => {
       const result = await request
         .get(