SHARD-946 - Fix: By default use main program to handle global txs

src/Config.ts

@@ -98,6 +98,8 @@ export interface Config {
   workerProcessesDebugLog: boolean // To enable debug logs for worker processes managed by the main process
   restrictFirstNodeSelectionByPublicKey: boolean // The flag to pick the first node that matches the PUBLIC_KEY specified in the firstNodeInfo
   firstNodePublicKey: string // The public key of the first node to be selected
+  disableOffloadReceipt: boolean // To disable offloading of receipts globally
+  disableOffloadReceiptForGlobalModification: boolean // To disable offloading of receipts for global modifications receipts
 }
 
 let config: Config = {
@@ -188,6 +190,8 @@ let config: Config = {
   workerProcessesDebugLog: false,
   restrictFirstNodeSelectionByPublicKey: false,
   firstNodePublicKey: '',
+  disableOffloadReceipt: false,
+  disableOffloadReceiptForGlobalModification: true,
 }
 // Override default config params from config file, env vars, and cli args
 export async function overrideDefaultConfig(file: string): Promise<void> {

src/primary-process/index.ts

@@ -233,6 +233,26 @@ export const offloadReceipt = async (
   receivedReceiptCount++ // Increment the counter for each receipt received
   receiptLoadTraker++ // Increment the receipt load tracker
   let verificationResult: ReceiptVerificationResult
+
+  // Check if offloading is disabled globally or for global modifications
+  if (
+    config.disableOffloadReceipt ||
+    (config.disableOffloadReceiptForGlobalModification && receipt.globalModification)
+  ) {
+    mainProcessReceiptTracker++
+    if (config.workerProcessesDebugLog) console.log('Verifying on the main program', txId, timestamp)
+    verificationResult = await verifyArchiverReceipt(receipt, requiredSignatures)
+    mainProcessReceiptTracker--
+    verifiedReceiptCount++
+    if (verificationResult.success) {
+      successReceiptCount++
+    } else {
+      failureReceiptCount++
+    }
+    return verificationResult
+  }
+
+  // Existing logic for offloading
   if (workers.length === 0 && mainProcessReceiptTracker > config.receiptLoadTrakerLimit) {
     // If there are extra workers available, put them to the workers list
     if (extraWorkers.size > 0) {