fix

taikoxyz · Oct 8, 2024 · e52775c · e52775c
1 parent 82cff3c
commit e52775c
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 7 deletions.
diff --git a/packages/taiko-client/prover/proof_submitter/proof_submitter.go b/packages/taiko-client/prover/proof_submitter/proof_submitter.go
@@ -418,7 +418,7 @@ func (s *ProofSubmitter) BatchSubmitProofs(ctx context.Context, batchProof *proo
 	// Build the TaikoL1.proveBlocks transaction and send it to the L1 node.
 	if err := s.sender.SendBatchProof(
 		ctx,
-		s.txBuilder.BuildProveBlocks(batchProof),
+		s.txBuilder.BuildProveBlocks(batchProof, s.graffiti),
 		batchProof,
 	); err != nil {
 		if err.Error() == transaction.ErrUnretryableSubmission.Error() {

diff --git a/packages/taiko-client/prover/proof_submitter/transaction/builder.go b/packages/taiko-client/prover/proof_submitter/transaction/builder.go
@@ -158,6 +158,7 @@ func (a *ProveBlockTxBuilder) Build(
 // BuildProveBlocks creates a new TaikoL1.ProveBlocks transaction with the given nonce.
 func (a *ProveBlockTxBuilder) BuildProveBlocks(
 	batchProof *proofProducer.BatchProofs,
+	graffiti [32]byte,
 ) TxBuilder {
 	return func(txOpts *bind.TransactOpts) (*txmgr.TxCandidate, error) {
 		var (
@@ -174,7 +175,7 @@ func (a *ProveBlockTxBuilder) BuildProveBlocks(
 				ParentHash: proof.Header.ParentHash,
 				BlockHash:  proof.Opts.BlockHash,
 				StateRoot:  proof.Opts.StateRoot,
-				Graffiti:   rpc.StringToBytes32(proof.Opts.Graffiti),
+				Graffiti:   graffiti,
 			}
 			blockIDs[i] = proof.BlockID.Uint64()
 		}

diff --git a/packages/taiko-client/prover/prover.go b/packages/taiko-client/prover/prover.go
@@ -419,11 +419,12 @@ func (p *Prover) aggregateOp() error {
 		go func(s proofSubmitter.Submitter) {
 			defer wg.Done()
 			if s.BufferSize() > 1 {
-				err := s.AggregateProofs(p.ctx)
-				log.Error("Failed to aggregate proofs",
-					"error", err,
-					"tier", s.Tier(),
-				)
+				if err := s.AggregateProofs(p.ctx); err != nil {
+					log.Error("Failed to aggregate proofs",
+						"error", err,
+						"tier", s.Tier(),
+					)
+				}
 			} else {
 				log.Debug("Skip this aggregateOp since low buffer size",
 					"tier", s.Tier(),