Use batches in broadcast to avoid resource communication errors

cmd/kaspawallet/broadcast.go

@@ -42,14 +42,29 @@ func broadcast(conf *broadcastConfig) error {
 		return err
 	}
 
-	response, err := daemonClient.Broadcast(ctx, &pb.BroadcastRequest{Transactions: transactions})
+	const batch = 50
-	if err != nil {
+	position := 0
-		return err
+
-	}
+	// We send in batches to avoid communication errors
-	fmt.Println("Transactions were sent successfully")
+	for position < len(transactions) {
-	fmt.Println("Transaction ID(s): ")
+		var transactionBatch [][]byte
-	for _, txID := range response.TxIDs {
+		if position+batch > len(transactions) {
-		fmt.Printf("\t%s\n", txID)
+			transactionBatch = transactions[position:]
+		} else {
+			transactionBatch = transactions[position : position+batch]
+		}
+		response, err := daemonClient.Broadcast(ctx, &pb.BroadcastRequest{Transactions: transactionBatch})
+		if err != nil {
+			return err
+		}
+		if position == 0 {
+			fmt.Println("Transactions were sent successfully")
+		}
+		fmt.Println("Transaction ID(s): ")
+		for _, txID := range response.TxIDs {
+			fmt.Printf("\t%s\n", txID)
+		}
+		position += batch
 	}
 
 	return nil