add workerpool address to chain_config

Author: SeddikBellamine

packages/sdk/src/config/config.ts

@@ -8,6 +8,7 @@ export interface ChainConfig {
   ipfsGateway: string;
   ipfsNode: string;
   smsDebugURL: string;
+  workerpoolAddress: string;
 }
 
 export const CHAIN_CONFIG: Record<ChainId, ChainConfig> = {
@@ -20,6 +21,7 @@ export const CHAIN_CONFIG: Record<ChainId, ChainConfig> = {
     ipfsGateway: 'https://ipfs-gateway.v8-bellecour.iex.ec',
     ipfsNode: 'https://ipfs-upload.v8-bellecour.iex.ec',
     smsDebugURL: 'https://sms-debug.iex.ec',
+    workerpoolAddress:'prod-v8-bellecour.main.pools.iexec.eth'
   },
 
   // Arbitrum
@@ -31,6 +33,7 @@ export const CHAIN_CONFIG: Record<ChainId, ChainConfig> = {
     ipfsGateway: 'https://your-arbitrum-ipfs-gateway',
     ipfsNode: 'https://your-arbitrum-ipfs-node',
     smsDebugURL: 'https://your-arbitrum-sms-url',
+    workerpoolAddress:'WorkerpoolAddress'
   },
 
   // Avalanche 
@@ -42,12 +45,12 @@ export const CHAIN_CONFIG: Record<ChainId, ChainConfig> = {
     ipfsGateway: 'https://your-avalanche-ipfs-gateway',
     ipfsNode: 'https://your-avalanche-ipfs-node',
     smsDebugURL: 'https://your-avalanche-sms-url',
+    workerpoolAddress:'WorkerpoolAddress'
   },
 };
 
 export const DEFAULT_CHAIN_ID = 134;
 export const DEFAULT_DATA_NAME = '';
-export const WORKERPOOL_ADDRESS = 'prod-v8-bellecour.main.pools.iexec.eth';
 export const SCONE_TAG = ['tee', 'scone'];
 export const DEFAULT_MAX_PRICE = 0;
 export const MAX_DESIRED_DATA_ORDER_PRICE = 0;

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

@@ -1,10 +1,10 @@
 import { ethers } from 'ethers';
 import {
+  CHAIN_CONFIG,
   MAX_DESIRED_APP_ORDER_PRICE,
   MAX_DESIRED_DATA_ORDER_PRICE,
   MAX_DESIRED_WORKERPOOL_ORDER_PRICE,
   SCONE_TAG,
-  WORKERPOOL_ADDRESS,
 } from '../../config/config.js';
 import {
   WorkflowError,
@@ -60,6 +60,7 @@ export const processProtectedData = async ({
   onStatusUpdate = () => {},
 }: IExecConsumer &
   ProcessProtectedDataParams): Promise<ProcessProtectedDataResponse> => {
+  const { chainId } = await iexec.network.getNetwork();
   const vProtectedData = addressOrEnsSchema()
     .required()
     .label('protectedData')
@@ -87,7 +88,7 @@ export const processProtectedData = async ({
   const vArgs = stringSchema().label('args').validateSync(args);
   const vSecrets = secretsSchema().label('secrets').validateSync(secrets);
   const vWorkerpool = addressOrEnsSchema()
-    .default(WORKERPOOL_ADDRESS) // Default workerpool if none is specified
+    .default(CHAIN_CONFIG[chainId].workerpoolAddress) // Default workerpool if none is specified
     .label('workerpool')
     .validateSync(workerpool);
   const vUseVoucher = booleanSchema()
@@ -101,7 +102,7 @@ export const processProtectedData = async ({
       validateOnStatusUpdateCallback<
         OnStatusUpdateFn<ProcessProtectedDataStatuses>
       >(onStatusUpdate);
-
+    
     let requester = await iexec.wallet.getAddress();
     if (vUserWhitelist) {
       const isValidWhitelist = await isERC734(iexec, vUserWhitelist);

packages/sdk/src/lib/dataProtectorSharing/consumeProtectedData.ts

@@ -1,8 +1,8 @@
 import { string } from 'yup';
 import {
   SCONE_TAG,
-  WORKERPOOL_ADDRESS,
   DEFAULT_MAX_PRICE,
+  CHAIN_CONFIG,
 } from '../../config/config.js';
 import {
   WorkflowError,
@@ -109,8 +109,9 @@ export const consumeProtectedData = async ({
     isDone: false,
   });
   try {
+    const { chainId } = await iexec.network.getNetwork();
     const workerpoolOrderbook = await iexec.orderbook.fetchWorkerpoolOrderbook({
-      workerpool: vWorkerpool || WORKERPOOL_ADDRESS,
+      workerpool: vWorkerpool || CHAIN_CONFIG[chainId].workerpoolAddress,
       app: vApp,
       dataset: vProtectedData,
       minTag: SCONE_TAG,