Register all APIs

Author: StephenButtolph

sae/rpc.go

@@ -40,6 +40,7 @@ import (
 type APIBackend interface {
 	ethapi.Backend
 	tracers.Backend
+	filters.Backend
 	filters.BloomOverrider
 }
 
@@ -85,45 +86,65 @@ func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 		// - eth_syncing
 		{"eth", ethapi.NewEthereumAPI(b)},
 		// Standard Ethereum node APIs:
+		// - eth_gasPrice
+		// - eth_syncing
+		//
+		// Undocumented APIs:
+		// - eth_feeHistory
+		// - eth_maxPriorityFeePerGas
+		{"eth", ethapi.NewEthereumAPI(b)},
+		// Standard Ethereum node APIs:
 		// - eth_blockNumber
+		// - eth_call
 		// - eth_chainId
+		// - eth_estimateGas
+		// - eth_getBalance
 		// - eth_getBlockByHash
 		// - eth_getBlockByNumber
-		// - eth_getBlockReceipts
+		// - eth_getCode
+		// - eth_getStorageAt
 		// - eth_getUncleByBlockHashAndIndex
 		// - eth_getUncleByBlockNumberAndIndex
 		// - eth_getUncleCountByBlockHash
 		// - eth_getUncleCountByBlockNumber
 		//
 		// Geth-specific APIs:
+		// - eth_createAccessList
 		// - eth_getHeaderByHash
 		// - eth_getHeaderByNumber
+		//
+		// Undocumented APIs:
+		// - eth_getBlockReceipts
+		// - eth_getProof
 		{"eth", &blockChainAPI{ethapi.NewBlockChainAPI(b), b}},
 		// Standard Ethereum node APIs:
 		// - eth_getBlockTransactionCountByHash
 		// - eth_getBlockTransactionCountByNumber
 		// - eth_getTransactionByBlockHashAndIndex
 		// - eth_getTransactionByBlockNumberAndIndex
 		// - eth_getTransactionByHash
+		// - eth_getTransactionCount
 		// - eth_getTransactionReceipt
 		// - eth_sendRawTransaction
 		// - eth_sendTransaction
 		// - eth_sign
 		// - eth_signTransaction
 		//
 		// Undocumented APIs:
+		// - eth_fillTransaction
 		// - eth_getRawTransactionByBlockHashAndIndex
 		// - eth_getRawTransactionByBlockNumberAndIndex
 		// - eth_getRawTransactionByHash
 		// - eth_pendingTransactions
+		// - eth_resend
 		{
 			"eth",
 			immediateReceipts{
 				vm.exec,
 				ethapi.NewTransactionAPI(b, new(ethapi.AddrLocker)),
 			},
 		},
-		// Standard Ethereum node APIS:
+		// Standard Ethereum node APIs:
 		// - eth_getFilterChanges
 		// - eth_getFilterLogs
 		// - eth_getLogs
@@ -139,7 +160,6 @@ func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 		//  - logs
 		{"eth", filterAPI},
 	}
-
 	if vm.config.RPCConfig.EnableDBInspecting {
 		apis = append(apis, api{
 			// Geth-specific APIs:
@@ -148,18 +168,15 @@ func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 			// - debug_dbAncient
 			// - debug_dbAncients
 			// - debug_dbGet
-			// - debug_getRawTransaction
-			// - debug_printBlock
-			// - debug_setHead          (no-op, logs info)
-			//
-			// TODO: implement once BlockByNumberOrHash and GetReceipts exist:
 			// - debug_getRawBlock
 			// - debug_getRawHeader
 			// - debug_getRawReceipts
+			// - debug_getRawTransaction
+			// - debug_printBlock
+			// - debug_setHead
 			"debug", ethapi.NewDebugAPI(b),
 		})
 	}
-
 	if vm.config.RPCConfig.EnableProfiling {
 		apis = append(apis, api{
 			// Geth-specific APIs:
@@ -186,14 +203,51 @@ func (vm *VM) ethRPCServer() (*rpc.Server, error) {
 			"debug", debug.Handler,
 		})
 	}
-
 	if !vm.config.RPCConfig.DisableTracing {
 		apis = append(apis, api{
 			// Geth-specific APIs:
+			// - debug_intermediateRoots
+			// - debug_standardTraceBadBlockToFile
+			// - debug_standardTraceBlockToFile
+			// - debug_traceBadBlock
+			// - debug_traceBlock
+			// - debug_traceBlockByHash
+			// - debug_traceBlockByNumber
+			// - debug_traceBlockFromFile
+			// - debug_traceCall
+			// - debug_traceChain
+			// - debug_traceTransaction
 			"debug", tracers.NewAPI(b),
 		})
 	}
-
+	// Unsupported APIs:
+	//
+	// Standard Ethereum node APIs:
+	// - eth_protocolVersion
+	// - eth_coinbase
+	// - eth_mining
+	// - eth_hashrate
+	// - eth_accounts
+	//
+	// Block and state inspection APIs:
+	// - debug_accountRange
+	// - debug_dumpBlock
+	// - debug_getAccessibleState
+	// - debug_getBadBlocks
+	// - debug_getModifiedAccountsByHash
+	// - debug_getModifiedAccountsByNumber
+	// - debug_getTrieFlushInterval
+	// - debug_preimage
+	// - debug_setTrieFlushInterval
+	// - debug_storageRangeAt
+	//
+	// The admin namespace.
+	// The clique namespace.
+	// The les namespace.
+	// The miner namespace.
+	// The personal namespace.
+	//
+	// The graphql service.
 	s := rpc.NewServer()
 	for _, api := range apis {
 		if err := s.RegisterName(api.namespace, api.api); err != nil {
@@ -312,6 +366,7 @@ func (b bloomOverrider) OverrideHeaderBloom(header *types.Header) types.Bloom {
 	))
 }
 
+// TODO: Rename to apiBackend
 type ethAPIBackend struct {
 	vm             *VM
 	accountManager *accounts.Manager
@@ -337,7 +392,8 @@ func (b *ethAPIBackend) RPCTxFeeCap() float64 {
 }
 
 func (b *ethAPIBackend) UnprotectedAllowed() bool {
-	return false
+	// TODO(StephenButtolph) Expose this as a config and default to false.
+	return true
 }
 
 // ExtRPCEnabled reports that external RPC access is enabled. This adds an
@@ -599,7 +655,7 @@ func (b *ethAPIBackend) SubscribeChainEvent(ch chan<- core.ChainEvent) event.Sub
 	return b.vm.exec.SubscribeChainEvent(ch)
 }
 
-func (b *ethAPIBackend) SubscribeChainSideEvent(chan<- core.ChainSideEvent) event.Subscription {
+func (*ethAPIBackend) SubscribeChainSideEvent(chan<- core.ChainSideEvent) event.Subscription {
 	// SAE never reorgs, so there are no side events.
 	return newNoopSubscription()
 }
@@ -608,7 +664,7 @@ func (b *ethAPIBackend) SubscribeNewTxsEvent(ch chan<- core.NewTxsEvent) event.S
 	return b.Set.Pool.SubscribeTransactions(ch, true)
 }
 
-func (b *ethAPIBackend) SubscribeRemovedLogsEvent(chan<- core.RemovedLogsEvent) event.Subscription {
+func (*ethAPIBackend) SubscribeRemovedLogsEvent(chan<- core.RemovedLogsEvent) event.Subscription {
 	// SAE never reorgs, so no logs are ever removed.
 	return newNoopSubscription()
 }
@@ -617,7 +673,7 @@ func (b *ethAPIBackend) SubscribeLogsEvent(ch chan<- []*types.Log) event.Subscri
 	return b.vm.exec.SubscribeLogsEvent(ch)
 }
 
-func (b *ethAPIBackend) SubscribePendingLogsEvent(chan<- []*types.Log) event.Subscription {
+func (*ethAPIBackend) SubscribePendingLogsEvent(chan<- []*types.Log) event.Subscription {
 	// In SAE, "pending" refers to the execution status. There are no logs known
 	// for transactions pending execution.
 	return newNoopSubscription()

sae/temporary.go

@@ -30,8 +30,8 @@ func (b *ethAPIBackend) FeeHistory(context.Context, uint64, rpc.BlockNumber, []f
 	panic(errUnimplemented)
 }
 
-func (b *ethAPIBackend) GetPoolNonce(context.Context, common.Address) (uint64, error) {
-	panic(errUnimplemented)
+func (b *ethAPIBackend) GetPoolNonce(ctx context.Context, addr common.Address) (uint64, error) {
+	return b.Pool.Nonce(addr), nil
 }
 
 func (b *ethAPIBackend) StateAtBlock(ctx context.Context, block *types.Block, reexec uint64, base *state.StateDB, readOnly bool, preferDisk bool) (*state.StateDB, tracers.StateReleaseFunc, error) {