Merge pull request metachris#2 from metachris/relay-error

properly handle relay errors

Author: metachris

examples/sendbundle/main.go

@@ -0,0 +1,29 @@
+package main
+
+import (
+	"fmt"
+
+	"github.com/ethereum/go-ethereum/crypto"
+	"github.com/metachris/flashbotsrpc"
+)
+
+var privateKey, _ = crypto.GenerateKey() // creating a new private key for testing. you probably want to use an existing key.
+
+func main() {
+	rpc := flashbotsrpc.New("https://relay.flashbots.net")
+	rpc.Debug = true
+
+	sendBundleArgs := flashbotsrpc.FlashbotsSendBundleRequest{
+		Txs:         []string{"YOUR_HASH"},
+		BlockNumber: fmt.Sprintf("0x%x", 13281018),
+	}
+
+	result, err := rpc.FlashbotsSendBundle(privateKey, sendBundleArgs)
+	if err != nil {
+		fmt.Printf("%+v\n", err)
+		return
+	}
+
+	// Print result
+	fmt.Printf("%+v\n", result)
+}

examples/userstats/main.go

@@ -12,8 +12,13 @@ var privateKey, _ = crypto.GenerateKey() // creating a new private key for testi
 func main() {
 	rpc := flashbotsrpc.New("https://relay.flashbots.net")
 
-	// Query relay for user stats
-	result, err := rpc.FlashbotsGetUserStats(privateKey, 13281018)
+	sendBundleArgs := flashbotsrpc.FlashbotsSendBundleRequest{
+		Txs: []string{"0x02f9019d011e843b9aca008477359400830247fa94def1c0ded9bec7f1a1670819833240f027b25eff88016345785d8a0000b90128d9627aa40000000000000000000000000000000000000000000000000000000000000080000000000000000000000000000000000000000000000000016345785d8a000000000000000000000000000000000000000000000000001394b63b2cbaea253a00000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000002000000000000000000000000eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee0000000000000000000000006b175474e89094c44da98b954eedeac495271d0f869584cd00000000000000000000000086003b044f70dac0abc80ac8957305b6370893ed0000000000000000000000000000000000000000000000d3443651ba615f6cd6c001a011a9f58ebe30aa679783b31793f897fdb603dd2ea086845723a22dae85ab2864a0090cf1fcce0f6e85da54f4eccf32a485d71a7d39bc0b43a53a9e64901c656230"},
+		// BlockNumber: fmt.Sprintf("0x%x", blockNumber),
+		BlockNumber: "13281018",
+	}
+
+	result, err := rpc.FlashbotsSendBundle(privateKey, sendBundleArgs)
 	if err != nil {
 		panic(err)
 	}

flashbotsrpc.go

@@ -12,6 +12,8 @@ import (
 	"os"
 	"time"
 
+	"github.com/pkg/errors"
+
 	"github.com/ethereum/go-ethereum/accounts"
 	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/core/types"
@@ -181,6 +183,13 @@ func (rpc *FlashbotsRPC) CallWithFlashbotsSignature(method string, privKey *ecds
 		rpc.log.Println(fmt.Sprintf("%s\nRequest: %s\nSignature: %s\nResponse: %s\n", method, body, signature, data))
 	}
 
+	// On error, response looks like this instead of JSON-RPC: {"error":"block param must be a hex int"}
+	errorResp := new(RelayErrorResponse)
+	if err := json.Unmarshal(data, errorResp); err == nil && errorResp.Error != "" {
+		// relay returned an error
+		return nil, errors.New(errorResp.Error)
+	}
+
 	resp := new(rpcResponse)
 	if err := json.Unmarshal(data, resp); err != nil {
 		return nil, err

go.mod

@@ -6,6 +6,7 @@ require (
 	github.com/btcsuite/btcd v0.22.0-beta // indirect
 	github.com/ethereum/go-ethereum v1.10.8
 	github.com/jarcoal/httpmock v1.0.8
+	github.com/pkg/errors v0.9.1
 	github.com/stretchr/testify v1.7.0
 	github.com/tidwall/gjson v1.8.1
 	golang.org/x/crypto v0.0.0-20210921155107-089bfa567519 // indirect

types.go

@@ -321,6 +321,10 @@ func (proxy *proxyBlockWithoutTransactions) toBlock() Block {
 	return block
 }
 
+type RelayErrorResponse struct {
+	Error string `json:"error"`
+}
+
 type FlashbotsUserStats struct {
 	IsHighPriority       bool   `json:"is_high_priority"`
 	AllTimeMinerPayments string `json:"all_time_miner_payments"`