refactor: extract bulk processing to sendTelegramCampaign function

Author: abbesBenayache

src/utils/validators.ts

@@ -1,6 +1,6 @@
 import { isAddress } from 'ethers';
 import { IExec } from 'iexec';
-import { ValidationError, boolean, number, string } from 'yup';
+import { ValidationError, boolean, number, object, string } from 'yup';
 
 export const isValidProvider = async (iexec: IExec) => {
   const client = await iexec.config.resolveContractsClient();
@@ -53,3 +53,6 @@ export const positiveNumberSchema = () =>
 
 export const booleanSchema = () =>
   boolean().strict().typeError('${path} should be a boolean');
+
+export const campaignRequestSchema = () =>
+  object().required().typeError('${path} should be a BulkRequest object');

src/web3telegram/IExecWeb3telegram.ts

@@ -5,6 +5,11 @@ import { GraphQLClient } from 'graphql-request';
 import { fetchUserContacts } from './fetchUserContacts.js';
 import { fetchMyContacts } from './fetchMyContacts.js';
 import { sendTelegram } from './sendTelegram.js';
+import {
+  sendTelegramCampaign,
+  SendTelegramCampaignParams,
+  SendTelegramCampaignResponse,
+} from './sendTelegramCampaign.js';
 import {
   Contact,
   FetchUserContactsParams,
@@ -115,23 +120,35 @@ export class IExecWeb3telegram {
     });
   }
 
-  async sendTelegram<Params extends SendTelegramParams>(
-    args: Params
-  ): Promise<SendTelegramResponse<Params>> {
+  async sendTelegram(
+    args: SendTelegramParams & { protectedData: string }
+  ): Promise<SendTelegramResponse> {
     await this.init();
     await isValidProvider(this.iexec);
     return sendTelegram({
       ...args,
       workerpoolAddressOrEns:
         args.workerpoolAddressOrEns || this.defaultWorkerpool,
       iexec: this.iexec,
-      dataProtector: this.dataProtector,
       ipfsNode: this.ipfsNode,
       ipfsGateway: this.ipfsGateway,
       dappAddressOrENS: this.dappAddressOrENS,
       dappWhitelistAddress: this.dappWhitelistAddress,
       graphQLClient: this.graphQLClient,
-    } as any) as Promise<SendTelegramResponse<Params>>;
+    });
+  }
+
+  async sendTelegramCampaign(
+    args: SendTelegramCampaignParams
+  ): Promise<SendTelegramCampaignResponse> {
+    await this.init();
+    await isValidProvider(this.iexec);
+    return sendTelegramCampaign({
+      ...args,
+      workerpoolAddressOrEns:
+        args.workerpoolAddressOrEns || this.defaultWorkerpool,
+      dataProtector: this.dataProtector,
+    });
   }
 
   async prepareTelegramCampaign(