server

Sep 4, 2025

Changes in this version

+ const OriginKeyword

+ var ErrUnsupportedRefundKeyword = errors.New("Unsupported refund keyword (only 'origin' is supported).")

type ConfigurationWatcher

+ ParsedPresets map[string]URLParameters

type CustomersConfig

+ Presets map[string]string

Aug 21, 2025

Changes in this version

+ var ErrCustomerNotConfigured = errors.New("customer is not configured")

+ func EquivalentURLParams(left URLParameters, right URLParameters) bool

+ func MetricsMiddleware(next http.Handler) http.Handler

type Configuration

+ ConfigurationWatcher *ConfigurationWatcher

+ type ConfigurationWatcher struct

+ ParsedCustomersConfig map[string][]URLParameters

+ func NewConfigurationWatcher(customersConfig CustomersConfig) (*ConfigurationWatcher, error)

+ func ReadCustomerConfigFromFile(fileName string) (*ConfigurationWatcher, error)

+ func (watcher *ConfigurationWatcher) Customers() []string

+ func (watcher *ConfigurationWatcher) IsConfigurationUpdated(customer string, urlParams URLParameters) bool

+ type CustomersConfig struct

+ URLs map[string][]string

Feb 10, 2025

Changes in this version

+ var RedisExpiryNonceOfTxHash = 24 * time.Hour

+ var RedisPrefixNonceOfTxHash = RedisPrefix + "txnonce-of-txhash:"

+ func RedisKeyNonceOfTxHash(txHash string) string

type RedisState

+ func (s *RedisState) GetNonceOfTxHash(txHash string) (txNonce uint64, found bool, err error)

+ func (s *RedisState) SetSenderAndNonceOfTxHash(txHash string, txFrom string, txNonce uint64) error

Feb 5, 2025

Changes in this version

+ var ErrIncorrectMempoolURL = errors.New("Incorrect mempool URL.")

+ var ErrIncorrectURLParam = errors.New("Incorrect URL parameter")

type Configuration

+ DefaultMempoolRPC string

Aug 22, 2024

Changes in this version

type RedisState

+ func (s *RedisState) DelSenderMaxNonce(txFrom string) error

Aug 7, 2024

Changes in this version

type RpcRequest

+ func (r *RpcRequest) CheckFlashbotsSignature(signature string, body []byte) error

Jul 24, 2024

Changes in this version

+ type Fingerprint uint64

+ func FingerprintFromRequest(req *http.Request, at time.Time, seed uint64) (Fingerprint, error)

+ func (f Fingerprint) ToIPv6() net.IP

Jul 22, 2024

Changes in this version

+ var DefaultAuctionHint = []string

+ var ErrEmptyHintQuery = errors.New("Hint query must be non-empty if set.")

+ var ErrEmptyTargetBuilderQuery = errors.New("Target builder query must be non-empty if set.")

+ var ErrIncorrectAuctionHints = errors.New(...)

+ var ErrIncorrectOriginId = errors.New("Incorrect origin id, must be less then 255 char.")

+ var ErrIncorrectRefundAddressQuery = errors.New("Incorrect refund address.")

+ var ErrIncorrectRefundPercentageQuery = errors.New("Incorrect refund percentage.")

+ var ErrIncorrectRefundQuery = errors.New("Incorrect refund query, must be 0xaddress:percentage.")

+ var ErrIncorrectRefundTotalPercentageQuery = errors.New("Incorrect refund total percentage, must be bellow 100%.")

+ func AuctionPreferenceErrorToJSONRPCResponse(jsonReq *types.JsonRpcRequest, err error) *types.JsonRpcResponse

+ func GetEnv(key string, defaultValue string) string

+ func GetSenderAddressFromTx(tx *ethtypes.Transaction) (common.Address, error)

+ type BuilderNameProvider interface

+ BuilderNames func() []string

+ type Configuration struct

+ BuilderInfoSource string

+ DB database.Store

+ DrainAddress string

+ DrainSeconds int

+ FetchInfoInterval int

+ ListenAddress string

+ Logger log.Logger

+ ProxyTimeoutSeconds int

+ ProxyUrl string

+ RedisUrl string

+ RelaySigningKey *ecdsa.PrivateKey

+ RelayUrl string

+ TTLCacheSeconds int64

+ Version string

+ type URLParameters struct

+ func ExtractParametersFromUrl(url *url.URL, allBuilders []string) (params URLParameters, err error)

Mar 18, 2022

Changes in this version

+ var RedisExpiryBlockedTxHash = 24 * time.Hour

+ var RedisPrefixBlockedTxHash = RedisPrefix + "blocked-tx-hash:"

+ func RedisKeyBlockedTxHash(txHash string) string

type RedisState

+ func (s *RedisState) GetBlockedTxHash(txHash string) (returnValue string, found bool, err error)

+ func (s *RedisState) SetBlockedTxHash(txHash string, returnValue string) error

Mar 7, 2022

Changes in this version

+ func GetIPHash(r *http.Request) string

+ func NewRequestRecord(db database.Store) *requestRecord

Feb 16, 2022

Changes in this version

+ func AddressPtrToStr(a *common.Address) string

+ func BigIntPtrToStr(i *big.Int) string

+ func ParseJsonRPCResponse(resp *http.Response) (*types.JsonRpcResponse, error)

+ type RPCProxyClient interface

+ ProxyRequest func(body []byte) (*http.Response, error)

+ func NewRPCProxyClient(proxyURL string) RPCProxyClient

Feb 4, 2022

Changes in this version

+ var RedisExpiryWhitehatBundleTransactions = time.Duration(24 * time.Hour)

+ var RedisPrefixWhitehatBundleTransactions = RedisPrefix + "tx-for-whitehat-bundle:"

+ func RedisKeyWhitehatBundleTransactions(bundleId string) string

+ type Log struct

+ func (l *Log) CreateChildLogger(suffix string) Logger

+ type Logger interface

+ CreateChildLogger func(suffix string) Logger

+ func NewLogger(uid string) Logger

type RedisState

+ func (s *RedisState) AddTxToWhitehatBundle(bundleId string, signedTx string) error

+ func (s *RedisState) DelWhitehatBundleTx(bundleId string) error

+ func (s *RedisState) GetWhitehatBundleTx(bundleId string) ([]string, error)

type RpcEndPointServer

+ func (s *RpcEndPointServer) HandleBundleRequest(respw http.ResponseWriter, req *http.Request)

type RpcRequest

+ func (r *RpcRequest) ProcessRequest() *types.JsonRpcResponse

+ func (r *RpcRequest) WhitehatBalanceCheckerRewrite()

+ type RpcRequestHandler struct

+ func NewRpcRequestHandler(respw *http.ResponseWriter, req *http.Request, proxyUrl string, ...) *RpcRequestHandler

Dec 15, 2021

Changes in this version

+ var FlashbotsRPC *flashbotsrpc.FlashbotsRPC

+ var RedisExpiryNonceFixForAccount = time.Duration(24 * time.Hour)

+ var RedisExpirySenderMaxNonce = time.Duration(2 * time.Hour)

+ var RedisExpirySenderOfTxHash = time.Duration(24 * time.Hour)

+ var RedisExpiryTxHashForSenderAndNonce = time.Duration(24 * time.Hour)

+ var RedisExpiryTxSentToRelay = time.Duration(24 * time.Hour)

+ var RedisPrefix = "rpc-endpoint:"

+ var RedisPrefixNonceFixForAccount = RedisPrefix + "txsender-with-nonce-fix:"

+ var RedisPrefixSenderMaxNonce = RedisPrefix + "txsender-pending-max-nonce:"

+ var RedisPrefixSenderOfTxHash = RedisPrefix + "txsender-of-txhash:"

+ var RedisPrefixTxHashForSenderAndNonce = RedisPrefix + "txsender-and-nonce-to-txhash:"

+ var RedisPrefixTxSentToRelay = RedisPrefix + "tx-sent-to-relay:"

+ func Max(a uint64, b uint64) uint64

+ func Min(a uint64, b uint64) uint64

+ func RedisKeyNonceFixForAccount(txFrom string) string

+ func RedisKeySenderMaxNonce(txFrom string) string

+ func RedisKeySenderOfTxHash(txHash string) string

+ func RedisKeyTxHashForSenderAndNonce(txFrom string, nonce uint64) string

+ func RedisKeyTxSentToRelay(txHash string) string

+ type RedisState struct

+ RedisClient *redis.Client

+ var RState *RedisState

+ func NewRedisState(redisUrl string) (*RedisState, error)

+ func (s *RedisState) DelNonceFixForAccount(txFrom string) error

+ func (s *RedisState) GetNonceFixForAccount(txFrom string) (numTimesSent uint64, found bool, err error)

+ func (s *RedisState) GetSenderMaxNonce(txFrom string) (senderMaxNonce uint64, found bool, err error)

+ func (s *RedisState) GetSenderOfTxHash(txHash string) (txSender string, found bool, err error)

+ func (s *RedisState) GetTxHashForSenderAndNonce(txFrom string, nonce uint64) (txHash string, found bool, err error)

+ func (s *RedisState) GetTxSentToRelay(txHash string) (timeSent time.Time, found bool, err error)

+ func (s *RedisState) SetNonceFixForAccount(txFrom string, numTimesSent uint64) error

+ func (s *RedisState) SetSenderMaxNonce(txFrom string, nonce uint64) error

+ func (s *RedisState) SetSenderOfTxHash(txHash string, txFrom string) error

+ func (s *RedisState) SetTxHashForSenderAndNonce(txFrom string, nonce uint64, txHash string) error

+ func (s *RedisState) SetTxSentToRelay(txHash string) error

type RpcRequest

+ func (r *RpcRequest) GetAddressNonceRange(address string) (minNonce, maxNonce uint64)

Nov 19, 2021

Changes in this version

+ type BoolWithTime struct

+ func NewBoolWithTime(v bool) BoolWithTime

Nov 18, 2021

Changes in this version

+ var DebugDontSendTx = os.Getenv("DEBUG_DONT_SEND_RAWTX") != ""

+ var ProtectTxApiHost = "https://protect.flashbots.net"

+ var State = NewGlobalState()

+ func NewNonceFix(txHash string) *nonceFix

+ func ShouldSendTxToRelay(txHash string) bool

+ type GlobalState struct

+ func NewGlobalState() *GlobalState

type HealthResponse

+ StartTime time.Time

type PrivateTxApiResponse

+ func GetTxStatus(txHash string) (*PrivateTxApiResponse, error)

+ type RelayErrorResponse struct

+ Error string

+ type StringWithTime struct

+ func NewStringWithTime(s string) StringWithTime

Nov 15, 2021

Changes in this version

+ type HealthResponse struct

+ Now time.Time

+ Version string

Nov 12, 2021

Changes in this version

type JsonRpcResponse

+ func SendRpcWithSignatureAndParseResponse(url string, privKey *ecdsa.PrivateKey, jsonRpcReq *JsonRpcRequest) (jsonRpcResponse *JsonRpcResponse, responseBytes *[]byte, err error)

+ type PrivateTxApiResponse struct

+ Hash string

+ MaxBlockNumber int

+ Status string

Oct 22, 2021

Changes in this version

+ var MetaMaskFix = NewMetaMaskFixer()

+ var Now = time.Now

+ func GetIP(r *http.Request) string

+ func GetSenderFromRawTx(tx *types.Transaction) (string, error)

+ func GetSenderFromTx(tx *types.Transaction) (string, error)

+ func GetTx(rawTxHex string) (*types.Transaction, error)

+ func IsBlacklisted(ip string) bool

+ func IsMetamask(r *http.Request) bool

+ func IsMetamaskMoz(r *http.Request) bool

+ func NewMetaMaskFixer() metaMaskFixer

+ func ProxyRequest(proxyUrl string, body []byte) (*http.Response, error)

+ func TruncateText(s string, max int) string

+ type GetBundleStatusByTransactionHashResponse struct

+ BlocksCount int

+ Error string

+ Message string

+ ReceivedTimestamp int

+ Status string

+ StatusTimestamp int

+ TxHash string

+ type JsonRpcError struct

+ Code int

+ Message string

+ func (err JsonRpcError) Error() string

+ type JsonRpcRequest struct

+ Id interface{}

+ Method string

+ Params []interface{}

+ Version string

+ func NewJsonRpcRequest(id interface{}, method string, params []interface{}) *JsonRpcRequest

+ func NewJsonRpcRequest1(id interface{}, method string, param interface{}) *JsonRpcRequest

+ type JsonRpcResponse struct

+ Error *JsonRpcError

+ Id interface{}

+ Result json.RawMessage

+ Version string

+ func NewJsonRpcResponse(id interface{}, result json.RawMessage) *JsonRpcResponse

+ func SendRpcAndParseResponseTo(url string, req *JsonRpcRequest) (*JsonRpcResponse, error)

+ type RpcEndPointServer struct

+ func NewRpcEndPointServer(listenAddress, proxyUrl, txManagerUrl string) *RpcEndPointServer

+ func (r *RpcEndPointServer) HandleHttpRequest(respw http.ResponseWriter, req *http.Request)

+ func (r *RpcEndPointServer) Start()

+ type RpcRequest struct

+ func NewRpcRequest(respw *http.ResponseWriter, req *http.Request, proxyUrl string, ...) *RpcRequest