Skip to content

Commit d056da5

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 ba0a3b7 commit d056da5

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,
@@ -25,6 +27,7 @@ import { getProtectedData } from './getProtectedData.js';
2527
import { getResultFromCompletedTask } from './getResultFromCompletedTask.js';
2628
import { grantAccess } from './grantAccess.js';
2729
import { processProtectedData } from './processProtectedData.js';
30+
import { processBulkRequest } from './processBulkRequest.js';
2831
import { protectData } from './protectData.js';
2932
import { revokeAllAccess } from './revokeAllAccess.js';
3033
import { revokeOneAccess } from './revokeOneAccess.js';
@@ -83,6 +86,18 @@ class IExecDataProtectorCore extends IExecDataProtectorModule {
8386
});
8487
}
8588

89+
async processBulkRequest(
90+
args: ProcessBulkRequestParams
91+
): Promise<ProcessBulkRequestResponse> {
92+
await this.init();
93+
await isValidProvider(this.iexec);
94+
return processBulkRequest({
95+
...args,
96+
iexec: this.iexec,
97+
defaultWorkerpool: this.defaultWorkerpool,
98+
});
99+
}
100+
86101
// ----- READ METHODS -----
87102
async getProtectedData(
88103
args?: GetProtectedDataParams

0 commit comments

Comments
 (0)