refactor: happy path for EspressoReader.readEspresso

cartesi · Feb 27, 2025 · 9374914 · 9374914
1 parent c449ca5
commit 9374914
Show file tree

Hide file tree

Showing 3 changed files with 421 additions and 2 deletions.
diff --git a/DEV2DEV.md b/DEV2DEV.md
@@ -1,5 +1,13 @@
 # Dev 2 Dev
 
+## Run just one test
+
+```sh
+watchexec --exts go --watch . 'go test -p 1 ./... -testify.m ^TestReadEspresso$'
+```
+
+## Run all integrated
+
 Run the database
 
 ```sh

diff --git a/internal/espressoreader/espresso_reader.go b/internal/espressoreader/espresso_reader.go
@@ -25,13 +25,26 @@ import (
 	"github.com/cartesi/rollups-espresso-reader/internal/services/retry"
 
 	"github.com/EspressoSystems/espresso-sequencer-go/client"
+	"github.com/EspressoSystems/espresso-sequencer-go/types"
+	espresso "github.com/EspressoSystems/espresso-sequencer-go/types/common"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/tidwall/gjson"
 )
 
+type EspressoClient interface {
+	FetchVidCommonByHeight(ctx context.Context, blockHeight uint64) (espresso.VidCommon, error)
+	FetchLatestBlockHeight(ctx context.Context) (uint64, error)
+	FetchHeaderByHeight(ctx context.Context, blockHeight uint64) (types.HeaderImpl, error)
+	FetchHeadersByRange(ctx context.Context, from uint64, until uint64) ([]types.HeaderImpl, error)
+	FetchTransactionByHash(ctx context.Context, hash *types.TaggedBase64) (types.TransactionQueryData, error)
+	FetchBlockMerkleProof(ctx context.Context, rootHeight uint64, hotshotHeight uint64) (types.HotShotBlockMerkleProof, error)
+	FetchTransactionsInBlock(ctx context.Context, blockHeight uint64, namespace uint64) (client.TransactionsInBlock, error)
+	SubmitTransaction(ctx context.Context, tx types.Transaction) (*types.TaggedBase64, error)
+}
+
 type EspressoReader struct {
 	url                     string
-	client                  client.Client
+	client                  EspressoClient
 	startingBlock           uint64
 	namespace               uint64
 	repository              repository.Repository
@@ -44,7 +57,7 @@ type EspressoReader struct {
 
 func NewEspressoReader(url string, startingBlock uint64, namespace uint64, repository repository.Repository, evmReader *evmreader.EvmReader, chainId uint64, inputBoxDeploymentBlock uint64, maxRetries uint64, maxDelay uint64) EspressoReader {
 	client := client.NewClient(url)
-	return EspressoReader{url: url, client: *client, startingBlock: startingBlock, namespace: namespace, repository: repository, evmReader: evmReader, chainId: chainId, inputBoxDeploymentBlock: inputBoxDeploymentBlock, maxRetries: maxRetries, maxDelay: maxDelay}
+	return EspressoReader{url: url, client: client, startingBlock: startingBlock, namespace: namespace, repository: repository, evmReader: evmReader, chainId: chainId, inputBoxDeploymentBlock: inputBoxDeploymentBlock, maxRetries: maxRetries, maxDelay: maxDelay}
 }
 
 func (e *EspressoReader) Run(ctx context.Context, ready chan<- struct{}) error {