@@ -141,44 +141,16 @@ describe('web3telegram.sendTelegramCampaign() - Bulk Processing', () => {
141141
142142 const bulkOrders = contacts . map ( ( contact ) => contact . grantedAccess ) ;
143143
144- // Prepare the telegram campaign using prepareTelegramCampaign
145- // Note: This may fail on networks that don't support bulk processing (e.g., bellecour)
146- // We expect this error and handle it gracefully
147- let bulkProcessingAvailable = true ;
148- let campaignRequest ;
149- try {
150- const prepareResult = await web3telegram . prepareTelegramCampaign ( {
151- telegramContent : 'Bulk test message' ,
152- grantedAccesses : bulkOrders ,
153- maxProtectedDataPerTask : 3 ,
154- appMaxPrice : 1000 ,
155- workerpoolMaxPrice : 1000 ,
156- workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
157- senderName : 'Bulk Test Sender' ,
158- } ) ;
159- campaignRequest = prepareResult . campaignRequest ;
160- } catch ( error : unknown ) {
161- // Expect error if bulk processing is not available on this network
162- // The error message is "Failed to prepareTelegramCampaign" but the cause contains the actual reason
163- const errorMessage = error instanceof Error ? error . message : '' ;
164- const errorCause =
165- error instanceof Error && error . cause
166- ? error . cause instanceof Error
167- ? error . cause . message
168- : String ( error . cause )
169- : '' ;
170- const fullError = `${ errorMessage } ${ errorCause } ` ;
171- if ( fullError . includes ( 'Bulk processing is not available' ) ) {
172- bulkProcessingAvailable = false ;
173- } else {
174- throw error ;
175- }
176- }
177-
178- // Skip the rest of the test if bulk processing is not supported
179- if ( ! bulkProcessingAvailable ) {
180- return ;
181- }
144+ const prepareResult = await web3telegram . prepareTelegramCampaign ( {
145+ telegramContent : 'Bulk test message' ,
146+ grantedAccesses : bulkOrders ,
147+ maxProtectedDataPerTask : 3 ,
148+ appMaxPrice : 1000 ,
149+ workerpoolMaxPrice : 1000 ,
150+ workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
151+ senderName : 'Bulk Test Sender' ,
152+ } ) ;
153+ const campaignRequest = prepareResult . campaignRequest ;
182154
183155 // Process the bulk request using sendTelegramCampaign
184156 // Use the workerpool from campaignRequest (already resolved to address)
@@ -218,39 +190,16 @@ describe('web3telegram.sendTelegramCampaign() - Bulk Processing', () => {
218190 // Use only the first contact
219191 const bulkOrders = [ contacts [ 0 ] . grantedAccess ] ;
220192
221- // Prepare the telegram campaign using prepareTelegramCampaign
222- let bulkProcessingAvailable = true ;
223- let campaignRequest ;
224- try {
225- const prepareResult = await web3telegram . prepareTelegramCampaign ( {
226- telegramContent : 'Single contact bulk test message' ,
227- grantedAccesses : bulkOrders ,
228- maxProtectedDataPerTask : 1 ,
229- appMaxPrice : 1000 ,
230- workerpoolMaxPrice : 1000 ,
231- workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
232- senderName : 'Single Contact Test' ,
233- } ) ;
234- campaignRequest = prepareResult . campaignRequest ;
235- } catch ( error : unknown ) {
236- const errorMessage = error instanceof Error ? error . message : '' ;
237- const errorCause =
238- error instanceof Error && error . cause
239- ? error . cause instanceof Error
240- ? error . cause . message
241- : String ( error . cause )
242- : '' ;
243- const fullError = `${ errorMessage } ${ errorCause } ` ;
244- if ( fullError . includes ( 'Bulk processing is not available' ) ) {
245- bulkProcessingAvailable = false ;
246- } else {
247- throw error ;
248- }
249- }
250-
251- if ( ! bulkProcessingAvailable ) {
252- return ;
253- }
193+ const prepareResult = await web3telegram . prepareTelegramCampaign ( {
194+ telegramContent : 'Single contact bulk test message' ,
195+ grantedAccesses : bulkOrders ,
196+ maxProtectedDataPerTask : 1 ,
197+ appMaxPrice : 1000 ,
198+ workerpoolMaxPrice : 1000 ,
199+ workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
200+ senderName : 'Single Contact Test' ,
201+ } ) ;
202+ const campaignRequest = prepareResult . campaignRequest ;
254203
255204 // Process the bulk request using sendTelegramCampaign
256205 // Use the workerpool from campaignRequest (already resolved to address)
@@ -287,41 +236,17 @@ describe('web3telegram.sendTelegramCampaign() - Bulk Processing', () => {
287236
288237 const bulkOrders = contacts . map ( ( contact ) => contact . grantedAccess ) ;
289238
290- // Prepare the telegram campaign with maxProtectedDataPerTask = 1
291- // This should create multiple tasks if we have more than 1 contact
292- let bulkProcessingAvailable = true ;
293- let campaignRequest ;
294- try {
295- const prepareResult = await web3telegram . prepareTelegramCampaign ( {
296- telegramContent : 'Max protected data per task test' ,
297- grantedAccesses : bulkOrders ,
298- maxProtectedDataPerTask : 1 , // Force one protected data per task
299- appMaxPrice : 1000 ,
300- workerpoolMaxPrice : 1000 ,
301- workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
302- senderName : 'Max Data Test' ,
303- label : 'MAXDATA' ,
304- } ) ;
305- campaignRequest = prepareResult . campaignRequest ;
306- } catch ( error : unknown ) {
307- const errorMessage = error instanceof Error ? error . message : '' ;
308- const errorCause =
309- error instanceof Error && error . cause
310- ? error . cause instanceof Error
311- ? error . cause . message
312- : String ( error . cause )
313- : '' ;
314- const fullError = `${ errorMessage } ${ errorCause } ` ;
315- if ( fullError . includes ( 'Bulk processing is not available' ) ) {
316- bulkProcessingAvailable = false ;
317- } else {
318- throw error ;
319- }
320- }
321-
322- if ( ! bulkProcessingAvailable ) {
323- return ;
324- }
239+ const prepareResult = await web3telegram . prepareTelegramCampaign ( {
240+ telegramContent : 'Max protected data per task test' ,
241+ grantedAccesses : bulkOrders ,
242+ maxProtectedDataPerTask : 1 , // Force one protected data per task
243+ appMaxPrice : 1000 ,
244+ workerpoolMaxPrice : 1000 ,
245+ workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
246+ senderName : 'Max Data Test' ,
247+ label : 'MAXDATA' ,
248+ } ) ;
249+ const campaignRequest = prepareResult . campaignRequest ;
325250
326251 // Process the bulk request using sendTelegramCampaign
327252 // Use the workerpool from campaignRequest (already resolved to address)
@@ -356,40 +281,17 @@ describe('web3telegram.sendTelegramCampaign() - Bulk Processing', () => {
356281
357282 const bulkOrders = contacts . map ( ( contact ) => contact . grantedAccess ) ;
358283
359- // Prepare the telegram campaign with custom parameters
360- let bulkProcessingAvailable = true ;
361- let campaignRequest ;
362- try {
363- const prepareResult = await web3telegram . prepareTelegramCampaign ( {
364- telegramContent : 'Custom parameters test message' ,
365- grantedAccesses : bulkOrders ,
366- maxProtectedDataPerTask : 3 ,
367- appMaxPrice : 1000 ,
368- workerpoolMaxPrice : 1000 ,
369- workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
370- senderName : 'CustomSender' ,
371- label : 'CUSTOM123' ,
372- } ) ;
373- campaignRequest = prepareResult . campaignRequest ;
374- } catch ( error : unknown ) {
375- const errorMessage = error instanceof Error ? error . message : '' ;
376- const errorCause =
377- error instanceof Error && error . cause
378- ? error . cause instanceof Error
379- ? error . cause . message
380- : String ( error . cause )
381- : '' ;
382- const fullError = `${ errorMessage } ${ errorCause } ` ;
383- if ( fullError . includes ( 'Bulk processing is not available' ) ) {
384- bulkProcessingAvailable = false ;
385- } else {
386- throw error ;
387- }
388- }
389-
390- if ( ! bulkProcessingAvailable ) {
391- return ;
392- }
284+ const prepareResult = await web3telegram . prepareTelegramCampaign ( {
285+ telegramContent : 'Custom parameters test message' ,
286+ grantedAccesses : bulkOrders ,
287+ maxProtectedDataPerTask : 3 ,
288+ appMaxPrice : 1000 ,
289+ workerpoolMaxPrice : 1000 ,
290+ workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
291+ senderName : 'CustomSender' ,
292+ label : 'CUSTOM123' ,
293+ } ) ;
294+ const campaignRequest = prepareResult . campaignRequest ;
393295
394296 // Process the bulk request using sendTelegramCampaign
395297 // Use the workerpool from campaignRequest (already resolved to address)
@@ -417,39 +319,16 @@ describe('web3telegram.sendTelegramCampaign() - Bulk Processing', () => {
417319
418320 const bulkOrders = contacts . map ( ( contact ) => contact . grantedAccess ) ;
419321
420- // Prepare the telegram campaign
421- let bulkProcessingAvailable = true ;
422- let campaignRequest ;
423- try {
424- const prepareResult = await web3telegram . prepareTelegramCampaign ( {
425- telegramContent : 'Workerpool mismatch test' ,
426- grantedAccesses : bulkOrders ,
427- maxProtectedDataPerTask : 3 ,
428- appMaxPrice : 1000 ,
429- workerpoolMaxPrice : 1000 ,
430- workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
431- senderName : 'Mismatch Test' ,
432- } ) ;
433- campaignRequest = prepareResult . campaignRequest ;
434- } catch ( error : unknown ) {
435- const errorMessage = error instanceof Error ? error . message : '' ;
436- const errorCause =
437- error instanceof Error && error . cause
438- ? error . cause instanceof Error
439- ? error . cause . message
440- : String ( error . cause )
441- : '' ;
442- const fullError = `${ errorMessage } ${ errorCause } ` ;
443- if ( fullError . includes ( 'Bulk processing is not available' ) ) {
444- bulkProcessingAvailable = false ;
445- } else {
446- throw error ;
447- }
448- }
449-
450- if ( ! bulkProcessingAvailable ) {
451- return ;
452- }
322+ const prepareResult = await web3telegram . prepareTelegramCampaign ( {
323+ telegramContent : 'Workerpool mismatch test' ,
324+ grantedAccesses : bulkOrders ,
325+ maxProtectedDataPerTask : 3 ,
326+ appMaxPrice : 1000 ,
327+ workerpoolMaxPrice : 1000 ,
328+ workerpoolAddressOrEns : TEST_CHAIN . prodWorkerpool ,
329+ senderName : 'Mismatch Test' ,
330+ } ) ;
331+ const campaignRequest = prepareResult . campaignRequest ;
453332
454333 // Try to send with a different workerpool (should fail)
455334 const differentWorkerpool =
0 commit comments