chore(rpc): migrate Ethermint RPCs (evmos#1309)

* chore: add initial files from rpc folder * fix: imports * fix: more rpc imports * fix: futrher file migration - types, server, indexer and encoding * fix: more import fixes * fix: migrate only rpc folder * fix: fixed all linter and formatter * fix: linter * linter * linter * Apply suggestions from code review Co-authored-by: Tomas Guerra <[email protected]> * Update rpc/backend/account_info.go Co-authored-by: Federico Kunze Küllmer <[email protected]> * fix: added maxInt64 check to block number * fix: fixed gosec issues * fix: nosec in loop * fix: gosec errors --------- Co-authored-by: Tomas Guerra <[email protected]> Co-authored-by: Federico Kunze Küllmer <[email protected]>
kiloonen · Feb 2, 2023 · 3aea2f4 · 3aea2f4
1 parent 5aa41c6
commit 3aea2f4
Show file tree

Hide file tree

Showing 60 changed files with 15,461 additions and 54 deletions.
diff --git a/rpc/apis.go b/rpc/apis.go
@@ -0,0 +1,205 @@
+// Copyright 2021 Evmos Foundation
+// This file is part of Evmos' Ethermint library.
+//
+// The Ethermint library is free software: you can redistribute it and/or modify
+// it under the terms of the GNU Lesser General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// The Ethermint library is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+// GNU Lesser General Public License for more details.
+//
+// You should have received a copy of the GNU Lesser General Public License
+// along with the Ethermint library. If not, see https://github.com/evmos/ethermint/blob/main/LICENSE
+package rpc
+
+import (
+	"fmt"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/server"
+
+	"github.com/ethereum/go-ethereum/rpc"
+
+	ethermint "github.com/evmos/ethermint/types"
+	"github.com/evmos/evmos/v11/rpc/backend"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/debug"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/eth"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/eth/filters"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/miner"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/net"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/personal"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/txpool"
+	"github.com/evmos/evmos/v11/rpc/namespaces/ethereum/web3"
+
+	rpcclient "github.com/tendermint/tendermint/rpc/jsonrpc/client"
+)
+
+// RPC namespaces and API version
+const (
+	// Cosmos namespaces
+
+	CosmosNamespace = "cosmos"
+
+	// Ethereum namespaces
+
+	Web3Namespace     = "web3"
+	EthNamespace      = "eth"
+	PersonalNamespace = "personal"
+	NetNamespace      = "net"
+	TxPoolNamespace   = "txpool"
+	DebugNamespace    = "debug"
+	MinerNamespace    = "miner"
+
+	apiVersion = "1.0"
+)
+
+// APICreator creates the JSON-RPC API implementations.
+type APICreator = func(
+	ctx *server.Context,
+	clientCtx client.Context,
+	tendermintWebsocketClient *rpcclient.WSClient,
+	allowUnprotectedTxs bool,
+	indexer ethermint.EVMTxIndexer,
+) []rpc.API
+
+// apiCreators defines the JSON-RPC API namespaces.
+var apiCreators map[string]APICreator
+
+func init() {
+	apiCreators = map[string]APICreator{
+		EthNamespace: func(ctx *server.Context,
+			clientCtx client.Context,
+			tmWSClient *rpcclient.WSClient,
+			allowUnprotectedTxs bool,
+			indexer ethermint.EVMTxIndexer,
+		) []rpc.API {
+			evmBackend := backend.NewBackend(ctx, ctx.Logger, clientCtx, allowUnprotectedTxs, indexer)
+			return []rpc.API{
+				{
+					Namespace: EthNamespace,
+					Version:   apiVersion,
+					Service:   eth.NewPublicAPI(ctx.Logger, evmBackend),
+					Public:    true,
+				},
+				{
+					Namespace: EthNamespace,
+					Version:   apiVersion,
+					Service:   filters.NewPublicAPI(ctx.Logger, clientCtx, tmWSClient, evmBackend),
+					Public:    true,
+				},
+			}
+		},
+		Web3Namespace: func(*server.Context, client.Context, *rpcclient.WSClient, bool, ethermint.EVMTxIndexer) []rpc.API {
+			return []rpc.API{
+				{
+					Namespace: Web3Namespace,
+					Version:   apiVersion,
+					Service:   web3.NewPublicAPI(),
+					Public:    true,
+				},
+			}
+		},
+		NetNamespace: func(_ *server.Context, clientCtx client.Context, _ *rpcclient.WSClient, _ bool, _ ethermint.EVMTxIndexer) []rpc.API {
+			return []rpc.API{
+				{
+					Namespace: NetNamespace,
+					Version:   apiVersion,
+					Service:   net.NewPublicAPI(clientCtx),
+					Public:    true,
+				},
+			}
+		},
+		PersonalNamespace: func(ctx *server.Context,
+			clientCtx client.Context,
+			_ *rpcclient.WSClient,
+			allowUnprotectedTxs bool,
+			indexer ethermint.EVMTxIndexer,
+		) []rpc.API {
+			evmBackend := backend.NewBackend(ctx, ctx.Logger, clientCtx, allowUnprotectedTxs, indexer)
+			return []rpc.API{
+				{
+					Namespace: PersonalNamespace,
+					Version:   apiVersion,
+					Service:   personal.NewAPI(ctx.Logger, evmBackend),
+					Public:    false,
+				},
+			}
+		},
+		TxPoolNamespace: func(ctx *server.Context, _ client.Context, _ *rpcclient.WSClient, _ bool, _ ethermint.EVMTxIndexer) []rpc.API {
+			return []rpc.API{
+				{
+					Namespace: TxPoolNamespace,
+					Version:   apiVersion,
+					Service:   txpool.NewPublicAPI(ctx.Logger),
+					Public:    true,
+				},
+			}
+		},
+		DebugNamespace: func(ctx *server.Context,
+			clientCtx client.Context,
+			_ *rpcclient.WSClient,
+			allowUnprotectedTxs bool,
+			indexer ethermint.EVMTxIndexer,
+		) []rpc.API {
+			evmBackend := backend.NewBackend(ctx, ctx.Logger, clientCtx, allowUnprotectedTxs, indexer)
+			return []rpc.API{
+				{
+					Namespace: DebugNamespace,
+					Version:   apiVersion,
+					Service:   debug.NewAPI(ctx, evmBackend),
+					Public:    true,
+				},
+			}
+		},
+		MinerNamespace: func(ctx *server.Context,
+			clientCtx client.Context,
+			_ *rpcclient.WSClient,
+			allowUnprotectedTxs bool,
+			indexer ethermint.EVMTxIndexer,
+		) []rpc.API {
+			evmBackend := backend.NewBackend(ctx, ctx.Logger, clientCtx, allowUnprotectedTxs, indexer)
+			return []rpc.API{
+				{
+					Namespace: MinerNamespace,
+					Version:   apiVersion,
+					Service:   miner.NewPrivateAPI(ctx, evmBackend),
+					Public:    false,
+				},
+			}
+		},
+	}
+}
+
+// GetRPCAPIs returns the list of all APIs
+func GetRPCAPIs(ctx *server.Context,
+	clientCtx client.Context,
+	tmWSClient *rpcclient.WSClient,
+	allowUnprotectedTxs bool,
+	indexer ethermint.EVMTxIndexer,
+	selectedAPIs []string,
+) []rpc.API {
+	var apis []rpc.API
+
+	for _, ns := range selectedAPIs {
+		if creator, ok := apiCreators[ns]; ok {
+			apis = append(apis, creator(ctx, clientCtx, tmWSClient, allowUnprotectedTxs, indexer)...)
+		} else {
+			ctx.Logger.Error("invalid namespace value", "namespace", ns)
+		}
+	}
+
+	return apis
+}
+
+// RegisterAPINamespace registers a new API namespace with the API creator.
+// This function fails if the namespace is already registered.
+func RegisterAPINamespace(ns string, creator APICreator) error {
+	if _, ok := apiCreators[ns]; ok {
+		return fmt.Errorf("duplicated api namespace %s", ns)
+	}
+	apiCreators[ns] = creator
+	return nil
+}