Skip to content

Commit 32a57fa

Browse files
committed
test: retry i param in respondToTask
1 parent c674b01 commit 32a57fa

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

core/chainio/avs_writer.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -74,11 +74,11 @@ func NewAvsWriterFromConfig(baseConfig *config.BaseConfig, ecdsaConfig *config.E
7474
func (w *AvsWriter) SendAggregatedResponse(batchIdentifierHash [32]byte, batchMerkleRoot [32]byte, senderAddress [20]byte, nonSignerStakesAndSignature servicemanager.IBLSSignatureCheckerNonSignerStakesAndSignature) (*types.Receipt, error) {
7575
txOpts := *w.Signer.GetTxOpts()
7676
txOpts.NoSend = true // simulate the transaction
77-
tx, err := w.AvsContractBindings.ServiceManager.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature)
77+
tx, err := w.AvsContractBindings.ServiceManager.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature, new(big.Int).SetUint64(5))
7878

7979
if err != nil {
8080
// Retry with fallback
81-
tx, err = w.AvsContractBindings.ServiceManagerFallback.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature)
81+
tx, err = w.AvsContractBindings.ServiceManagerFallback.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature, new(big.Int).SetUint64(5))
8282
if err != nil {
8383
return nil, fmt.Errorf("transaction simulation failed: %v", err)
8484
}
@@ -111,15 +111,15 @@ func (w *AvsWriter) SendAggregatedResponse(batchIdentifierHash [32]byte, batchMe
111111
return nil, err
112112
}
113113

114-
tx, err = w.AvsContractBindings.ServiceManager.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature)
114+
tx, err = w.AvsContractBindings.ServiceManager.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature, new(big.Int).SetUint64(i))
115115
if err != nil {
116116
// Retry with fallback
117-
tx, err = w.AvsContractBindings.ServiceManagerFallback.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature)
117+
tx, err = w.AvsContractBindings.ServiceManagerFallback.RespondToTaskV2(&txOpts, batchMerkleRoot, senderAddress, nonSignerStakesAndSignature, new(big.Int).SetUint64(i))
118118
if err != nil {
119119
return nil, err
120120
}
121121
}
122-
ctx, cancel := context.WithTimeout(context.Background(), time.Second*36)
122+
ctx, cancel := context.WithTimeout(context.Background(), time.Second*1)
123123
defer cancel()
124124
receipt, err := utils.WaitForTransactionReceipt(w.Client, ctx, tx.Hash())
125125

0 commit comments

Comments
 (0)