chore_: implement eth service for use in integration tests

node/get_status_node.go

@@ -39,6 +39,7 @@ import (
 	"github.com/status-im/status-go/services/communitytokens"
 	"github.com/status-im/status-go/services/connector"
 	"github.com/status-im/status-go/services/ens"
+	"github.com/status-im/status-go/services/eth"
 	"github.com/status-im/status-go/services/gif"
 	localnotifications "github.com/status-im/status-go/services/local-notifications"
 	"github.com/status-im/status-go/services/mailservers"
@@ -132,6 +133,7 @@ type StatusNode struct {
 	pendingTracker         *transactions.PendingTxTracker
 	connectorSrvc          *connector.Service
 	appGeneralSrvc         *appgeneral.Service
+	ethSrvc                *eth.Service
 
 	accountsFeed event.Feed
 	walletFeed   event.Feed

node/status_node_services.go

@@ -40,6 +40,7 @@ import (
 	"github.com/status-im/status-go/services/communitytokens"
 	"github.com/status-im/status-go/services/connector"
 	"github.com/status-im/status-go/services/ens"
+	"github.com/status-im/status-go/services/eth"
 	"github.com/status-im/status-go/services/ext"
 	"github.com/status-im/status-go/services/gif"
 	localnotifications "github.com/status-im/status-go/services/local-notifications"
@@ -174,6 +175,8 @@ func (b *StatusNode) initServices(config *params.NodeConfig, mediaServer *server
 	}
 	services = append(services, lns)
 
+	services = append(services, b.ethService())
+
 	b.peerSrvc.SetDiscoverer(b)
 
 	for i := range services {
@@ -617,6 +620,13 @@ func (b *StatusNode) peerService() *peer.Service {
 	return b.peerSrvc
 }
 
+func (b *StatusNode) ethService() *eth.Service {
+	if b.ethSrvc == nil {
+		b.ethSrvc = eth.NewService(b.rpcClient)
+	}
+	return b.ethSrvc
+}
+
 func registerWakuMailServer(wakuService *waku.Waku, config *params.WakuConfig) (err error) {
 	var mailServer mailserver.WakuMailServer
 	wakuService.RegisterMailServer(&mailServer)

services/eth/private_api.go

@@ -0,0 +1,151 @@
+//go:build enable_private_api
+
+package eth
+
+import (
+	"context"
+	"math/big"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/ethereum/go-ethereum/common/hexutil"
+	"github.com/ethereum/go-ethereum/core/types"
+	geth_rpc "github.com/ethereum/go-ethereum/rpc"
+
+	"github.com/status-im/status-go/rpc"
+)
+
+func privateAPIs(client *rpc.Client) (apis []geth_rpc.API) {
+	return []geth_rpc.API{
+		{
+			Namespace: "ethclient",
+			Version:   "1.0",
+			Service:   NewPrivateAPI(client),
+			Public:    true,
+		},
+	}
+}
+
+type PrivateAPI struct {
+	client *rpc.Client
+}
+
+func NewPrivateAPI(client *rpc.Client) *PrivateAPI {
+	return &PrivateAPI{client: client}
+}
+
+type blockResponse struct {
+	Header       *types.Header      `json:"header"`
+	Transactions types.Transactions `json:"transactions"`
+	Withdrawals  types.Withdrawals  `json:"withdrawals"`
+}
+
+func newBlockResponse(b *types.Block) *blockResponse {
+	return &blockResponse{
+		Header:       b.Header(),
+		Transactions: b.Transactions(),
+		Withdrawals:  b.Withdrawals(),
+	}
+}
+
+func (pa *PrivateAPI) BlockByHash(ctx context.Context, chainId uint64, hash common.Hash) (*blockResponse, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	block, err := client.BlockByHash(ctx, hash)
+	if err != nil {
+		return nil, err
+	}
+
+	return newBlockResponse(block), nil
+}
+
+func (pa *PrivateAPI) BlockByNumber(ctx context.Context, chainId uint64, number *hexutil.Big) (*blockResponse, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	block, err := client.BlockByNumber(ctx, (*big.Int)(number))
+	if err != nil {
+		return nil, err
+	}
+
+	return newBlockResponse(block), nil
+}
+
+func (pa *PrivateAPI) HeaderByHash(ctx context.Context, chainId uint64, hash common.Hash) (*types.Header, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	return client.HeaderByHash(ctx, hash)
+}
+
+func (pa *PrivateAPI) HeaderByNumber(ctx context.Context, chainId uint64, number *hexutil.Big) (*types.Header, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	return client.HeaderByNumber(ctx, (*big.Int)(number))
+}
+
+type transactionByHashResponse struct {
+	Tx        *types.Transaction `json:"tx"`
+	IsPending bool               `json:"isPending"`
+}
+
+func (pa *PrivateAPI) TransactionByHash(ctx context.Context, chainId uint64, txHash common.Hash) (*transactionByHashResponse, error) {
+
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	tx, isPending, err := client.TransactionByHash(ctx, txHash)
+	if err != nil {
+		return nil, err
+	}
+
+	ret := &transactionByHashResponse{
+		Tx:        tx,
+		IsPending: isPending,
+	}
+
+	return ret, nil
+}
+
+func (pa *PrivateAPI) TransactionReceipt(ctx context.Context, chainId uint64, txHash common.Hash) (*types.Receipt, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	return client.TransactionReceipt(ctx, txHash)
+}
+
+func (pa *PrivateAPI) SuggestGasPrice(ctx context.Context, chainId uint64) (*hexutil.Big, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return nil, err
+	}
+
+	ret, err := client.SuggestGasPrice(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	return (*hexutil.Big)(ret), nil
+}
+
+func (pa *PrivateAPI) BlockNumber(ctx context.Context, chainId uint64) (uint64, error) {
+	client, err := pa.client.EthClient(chainId)
+	if err != nil {
+		return 0, err
+	}
+
+	return client.BlockNumber(ctx)
+}

services/eth/private_api_nop.go

@@ -0,0 +1,12 @@
+//go:build !enable_private_api
+
+package eth
+
+import (
+	geth_rpc "github.com/ethereum/go-ethereum/rpc"
+	"github.com/status-im/status-go/rpc"
+)
+
+func privateAPIs(*rpc.Client) (apis []geth_rpc.API) {
+	return nil
+}

services/eth/service.go

@@ -0,0 +1,36 @@
+package eth
+
+import (
+	"github.com/ethereum/go-ethereum/p2p"
+	geth_rpc "github.com/ethereum/go-ethereum/rpc"
+
+	rpc_client "github.com/status-im/status-go/rpc"
+)
+
+type Service struct {
+	rpcClient *rpc_client.Client
+}
+
+func NewService(
+	rpcClient *rpc_client.Client,
+) *Service {
+	return &Service{
+		rpcClient: rpcClient,
+	}
+}
+
+func (s *Service) APIs() []geth_rpc.API {
+	return privateAPIs(s.rpcClient)
+}
+
+func (s *Service) Protocols() []p2p.Protocol {
+	return nil
+}
+
+func (s *Service) Start() error {
+	return nil
+}
+
+func (s *Service) Stop() error {
+	return nil
+}

tests-functional/config.json

@@ -8,7 +8,7 @@
     "HTTPHost": "0.0.0.0",
     "HTTPPort": 3333,
     "HTTPVirtualHosts": ["*", "status-go"],
-    "APIModules": "eth,admin,wallet,accounts,waku,wakuext",
+    "APIModules": "eth,admin,wallet,accounts,waku,wakuext,ethclient",
     "WalletConfig": {
       "Enabled": true
     },

tests-functional/docker-compose.test.status-go.yml

@@ -5,7 +5,7 @@ services:
       context: ../
       dockerfile: _assets/build/Dockerfile
       args:
-        build_tags: gowaku_no_rln
+        build_tags: gowaku_no_rln,enable_private_api
         build_target: statusd
         build_flags: -cover
     entrypoint: [
@@ -37,7 +37,7 @@ services:
       context: ../
       dockerfile: _assets/build/Dockerfile
       args:
-        build_tags: gowaku_no_rln
+        build_tags: gowaku_no_rln,enable_private_api
         build_target: statusd
         build_flags: -cover
     entrypoint: [
@@ -72,7 +72,7 @@ services:
       dockerfile: Dockerfile.tests-rpc
     entrypoint: [
       "pytest",
-      "-m", "wallet",
+      "-m", "wallet or ethclient",
       "--rpc_url=http://status-go:3333",
       "--rpc_url_2=http://status-go-no-funds:3333",
       "--anvil_url=http://anvil:8545",

tests-functional/pytest.ini

@@ -10,3 +10,4 @@ markers =
     tx
     wakuext
     accounts
+    ethclient