fix(prover): submit L2 signal service root instead of L1 when submitt…

…ing proof (#219)

driver/anchor_tx_constructor/anchor_tx_constructor.go

@@ -71,7 +71,7 @@ func (c *AnchorTxConstructor) AssembleAnchorTx(
 		return nil, err
 	}
 
-	signalRoot, err := c.rpc.GetStorageRoot(ctx, c.signalServiceAddress, l1Height)
+	signalRoot, err := c.rpc.GetStorageRoot(ctx, c.rpc.L1GethClient, c.signalServiceAddress, l1Height)
 	if err != nil {
 		return nil, err
 	}

pkg/rpc/methods.go

@@ -14,6 +14,7 @@ import (
 	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/core/rawdb"
 	"github.com/ethereum/go-ethereum/core/types"
+	"github.com/ethereum/go-ethereum/ethclient/gethclient"
 	"github.com/ethereum/go-ethereum/log"
 	"github.com/taikoxyz/taiko-client/bindings"
 	"golang.org/x/sync/errgroup"
@@ -293,8 +294,13 @@ func (c *Client) GetProtocolStateVariables(opts *bind.CallOpts) (*bindings.Taiko
 }
 
 // GetStorageRoot returns a contract's storage root at the given height.
-func (c *Client) GetStorageRoot(ctx context.Context, contract common.Address, height *big.Int) (common.Hash, error) {
-	proof, err := c.L1GethClient.GetProof(
+func (c *Client) GetStorageRoot(
+	ctx context.Context,
+	gethclient *gethclient.Client,
+	contract common.Address,
+	height *big.Int,
+) (common.Hash, error) {
+	proof, err := gethclient.GetProof(
 		ctx,
 		contract,
 		[]string{"0x0000000000000000000000000000000000000000000000000000000000000000"},

prover/proof_producer/special_proof_producer.go

@@ -87,9 +87,13 @@ func (p *SpecialProofProducer) RequestProof(
 		return fmt.Errorf("invalid anchor transaction: %w", err)
 	}
 
-	signalRoot, err := p.anchorTxValidator.GetAnchoredSignalRoot(ctx, anchorTx)
+	signalRoot, err := p.rpc.GetStorageRoot(ctx, p.rpc.L2GethClient, opts.L2SignalService, block.Number())
 	if err != nil {
-		return err
+		return fmt.Errorf("error getting storageroot: %w", err)
+	}
+
+	if err := p.anchorTxValidator.ValidateAnchorTx(ctx, anchorTx); err != nil {
+		return fmt.Errorf("invalid anchor transaction: %w", err)
 	}
 
 	parent, err := p.rpc.L2.BlockByHash(ctx, block.ParentHash())

prover/proof_submitter/valid_proof_submitter.go

@@ -117,9 +117,9 @@ func (s *ValidProofSubmitter) RequestProof(ctx context.Context, event *bindings.
 		return errors.New("no transaction in block")
 	}
 
-	signalRoot, err := s.anchorTxValidator.GetAnchoredSignalRoot(ctx, block.Transactions()[0])
+	signalRoot, err := s.rpc.GetStorageRoot(ctx, s.rpc.L2GethClient, s.l2SignalService, block.Number())
 	if err != nil {
-		return err
+		return fmt.Errorf("error getting storageroot: %w", err)
 	}
 
 	// Request proof.