sendPrivateTransaction + cancelPrivateTransaction

Author: metachris

examples/cancelPrivateTransaction/main.go

@@ -0,0 +1,28 @@
+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
+
+	cancelPrivTxArgs := flashbotsrpc.FlashbotsCancelPrivateTransactionRequest{
+		TxHash: "0xfb34b88cd77215867aa8e8ff0abc7060178b8fed6519a85d0b22853dfd5e9fec",
+	}
+
+	cancelled, err := rpc.FlashbotsCancelPrivateTransaction(privateKey, cancelPrivTxArgs)
+	if err != nil {
+		fmt.Printf("%+v\n", err)
+		return
+	}
+
+	// Print result
+	fmt.Printf("was cancelled: %v\n", cancelled)
+}

examples/sendPrivateTransaction/main.go

@@ -0,0 +1,33 @@
+package main
+
+import (
+	"errors"
+	"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
+
+	sendPrivTxArgs := flashbotsrpc.FlashbotsSendPrivateTransactionRequest{
+		Tx: "0xYourTxHash",
+	}
+
+	txHash, err := rpc.FlashbotsSendPrivateTransaction(privateKey, sendPrivTxArgs)
+	if err != nil {
+		if errors.Is(err, flashbotsrpc.ErrRelayErrorResponse) {
+			fmt.Println(err.Error()) // standard error response from relay
+		} else {
+			fmt.Printf("unknown error: %+v\n", err)
+		}
+		return
+	}
+
+	// Print txHash
+	fmt.Printf("txHash: %s\n", txHash)
+}

flashbotsrpc.go

@@ -12,8 +12,6 @@ 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"
@@ -187,7 +185,7 @@ func (rpc *FlashbotsRPC) CallWithFlashbotsSignature(method string, privKey *ecds
 	errorResp := new(RelayErrorResponse)
 	if err := json.Unmarshal(data, errorResp); err == nil && errorResp.Error != "" {
 		// relay returned an error
-		return nil, errors.New(errorResp.Error)
+		return nil, fmt.Errorf("%w: %s", ErrRelayErrorResponse, errorResp.Error)
 	}
 
 	resp := new(rpcResponse)
@@ -621,7 +619,7 @@ func (rpc *FlashbotsRPC) FlashbotsSendBundle(privKey *ecdsa.PrivateKey, param Fl
 	return res, err
 }
 
-// numTx is the maximum number of tx to include (used for troubleshooting). default 0 (all transactions)
+// Simulate a full Ethereum block. numTx is the maximum number of tx to include, used for troubleshooting (default: 0 - all transactions)
 func (rpc *FlashbotsRPC) FlashbotsSimulateBlock(privKey *ecdsa.PrivateKey, block *types.Block, maxTx int) (res FlashbotsCallBundleResponse, err error) {
 	if rpc.Debug {
 		fmt.Printf("Simulating block %s 0x%x %s \t %d tx \t timestamp: %d\n", block.Number(), block.Number(), block.Header().Hash(), len(block.Transactions()), block.Header().Time)
@@ -682,3 +680,23 @@ func (rpc *FlashbotsRPC) FlashbotsSimulateBlock(privKey *ecdsa.PrivateKey, block
 	res, err = rpc.FlashbotsCallBundle(privKey, params)
 	return res, err
 }
+
+// docs todo
+func (rpc *FlashbotsRPC) FlashbotsSendPrivateTransaction(privKey *ecdsa.PrivateKey, param FlashbotsSendPrivateTransactionRequest) (txHash string, err error) {
+	rawMsg, err := rpc.CallWithFlashbotsSignature("eth_sendPrivateTransaction", privKey, param)
+	if err != nil {
+		return "", err
+	}
+	err = json.Unmarshal(rawMsg, &txHash)
+	return txHash, err
+}
+
+// docs todo
+func (rpc *FlashbotsRPC) FlashbotsCancelPrivateTransaction(privKey *ecdsa.PrivateKey, param FlashbotsCancelPrivateTransactionRequest) (cancelled bool, err error) {
+	rawMsg, err := rpc.CallWithFlashbotsSignature("eth_sendPrivateTransaction", privKey, param)
+	if err != nil {
+		return false, err
+	}
+	err = json.Unmarshal(rawMsg, &cancelled)
+	return cancelled, err
+}

types.go

@@ -5,8 +5,12 @@ import (
 	"encoding/json"
 	"math/big"
 	"unsafe"
+
+	"github.com/pkg/errors"
 )
 
+var ErrRelayErrorResponse = errors.New("relay error response")
+
 // Syncing - object with syncing data info
 type Syncing struct {
 	IsSyncing     bool
@@ -369,6 +373,7 @@ type FlashbotsCallBundleResponse struct {
 	TotalGasUsed      int64                       `json:"totalGasUsed"`      // 63197
 }
 
+// sendBundle
 type FlashbotsSendBundleRequest struct {
 	Txs          []string  `json:"txs"`                         // Array[String], A list of signed transactions to execute in an atomic bundle
 	BlockNumber  string    `json:"blockNumber"`                 // String, a hex encoded block number for which this bundle is valid on
@@ -380,3 +385,13 @@ type FlashbotsSendBundleRequest struct {
 type FlashbotsSendBundleResponse struct {
 	BundleHash string `json:"bundleHash"`
 }
+
+// sendPrivateTransaction
+type FlashbotsSendPrivateTransactionRequest struct {
+	Tx string `json:"tx"`
+}
+
+// cancelPrivateTransaction
+type FlashbotsCancelPrivateTransactionRequest struct {
+	TxHash string `json:"txHash"`
+}