add switch for pending transaction filter (#18)

jsonrpc/config.go

@@ -38,6 +38,9 @@ type Config struct {
 	// TraceBatchUseHTTPS enables, in the debug_traceBatchByNum endpoint, the use of the HTTPS protocol (instead of HTTP)
 	// to do the parallel requests to RPC.debug_traceTransaction endpoint
 	TraceBatchUseHTTPS bool `mapstructure:"TraceBatchUseHTTPS"`
+
+	// EnablePendingTransactionFilter enables pending transaction filter that can support query L2 pending transaction
+	EnablePendingTransactionFilter bool `mapstructure:"EnablePendingTransactionFilter"`
 }
 
 // WebSocketsConfig has parameters to config the rpc websocket support

jsonrpc/endpoints_eth.go

@@ -830,13 +830,14 @@ func (e *EthEndpoints) NewPendingTransactionFilter() (interface{}, types.Error)
 
 // internal
 func (e *EthEndpoints) newPendingTransactionFilter(wsConn *websocket.Conn) (interface{}, types.Error) {
-	return nil, types.NewRPCError(types.DefaultErrorCode, "not supported yet")
-	// id, err := e.storage.NewPendingTransactionFilter(wsConn)
-	// if err != nil {
-	// 	return rpcErrorResponse(types.DefaultErrorCode, "failed to create new pending transaction filter", err)
-	// }
-
-	// return id, nil
+	if !e.cfg.EnablePendingTransactionFilter {
+		return nil, types.NewRPCError(types.DefaultErrorCode, "not supported yet")
+	}
+	id, err := e.storage.NewPendingTransactionFilter(wsConn)
+	if err != nil {
+		return RPCErrorResponse(types.DefaultErrorCode, "failed to create new pending transaction filter", err)
+	}
+	return id, nil
 }
 
 // SendRawTransaction has two different ways to handle new transactions: