Skip to content

Commit 13e1332

Browse files
SeddikBellaminePierreJeanjacquot
authored andcommitted
feat: add processBulkRequest for bulk data processing
- Add processBulkRequest function for processing multiple protected data orders - Implement while loop to match orders until volume is reached - Support waiting for workerpool orders when none are available - Add processBulkRequest method to IExecDataProtectorCore class - Return deals, transaction hashes, and signed request orders
1 parent fe22f99 commit 13e1332

File tree

2 files changed

+484
-0
lines changed

2 files changed

+484
-0
lines changed

packages/sdk/src/lib/dataProtectorCore/IExecDataProtectorCore.ts

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,8 @@ import {
88
GrantedAccessResponse,
99
ProcessProtectedDataParams,
1010
ProcessProtectedDataResponse,
11+
ProcessBulkRequestParams,
12+
ProcessBulkRequestResponse,
1113
ProtectDataParams,
1214
ProtectedData,
1315
GetResultFromCompletedTaskParams,
@@ -23,6 +25,7 @@ import { getProtectedData } from './getProtectedData.js';
2325
import { getResultFromCompletedTask } from './getResultFromCompletedTask.js';
2426
import { grantAccess } from './grantAccess.js';
2527
import { processProtectedData } from './processProtectedData.js';
28+
import { processBulkRequest } from './processBulkRequest.js';
2629
import { protectData } from './protectData.js';
2730
import { revokeAllAccess } from './revokeAllAccess.js';
2831
import { revokeOneAccess } from './revokeOneAccess.js';
@@ -80,6 +83,18 @@ class IExecDataProtectorCore extends IExecDataProtectorModule {
8083
});
8184
}
8285

86+
async processBulkRequest(
87+
args: ProcessBulkRequestParams
88+
): Promise<ProcessBulkRequestResponse> {
89+
await this.init();
90+
await isValidProvider(this.iexec);
91+
return processBulkRequest({
92+
...args,
93+
iexec: this.iexec,
94+
defaultWorkerpool: this.defaultWorkerpool,
95+
});
96+
}
97+
8398
// ----- READ METHODS -----
8499
async getProtectedData(
85100
args?: GetProtectedDataParams

0 commit comments

Comments
 (0)