BackRunMe: arbOnlyMEV

Search…
Name: arbOnlyMEV
arbOnlyMEV is an opt-in stream of private transactions that are available for arbitrage opportunities where the searcher shares the profit with the transaction sender, miner, and bloXroute. Full transaction details are not made available on this stream (no signature fields) to retain the privacy of the sender, though MEV bundles that reference these transaction hashes can be created via submit_arb_only_bundle. Transactions that appear in the arbOnlyMEV stream are not available in public mempool and do not appear in the newTxs or pendingTxs feeds.
This stream is only available on special Cloud API instance (backrunme.blxrbdn.com) to Enterprise users.
Options
Key
Description
Values
include
Fields to include in the transaction stream. 
transactions
Examples
Python
Node.js
Golang
wscat
1
from bloxroute_cli.provider.cloud_wss_provider import CloudWssProvider
2
​
3
​
4
async with WsProvider(
5
    uri="wss://backrunme.blxrbdn.com/ws",
6
    headers={"Authorization": <YOUR-AUTHORIZATION-HEADER>}
7
) as ws:
8
    subscription_id = await ws.subscribe("arbOnlyMEV", {"include": ["transactions"]})
9
    while True:
10
        next_notification = await ws.get_next_subscription_notification_by_id(subscription_id)
11
        print(next_notification)  # or process it generally
12
    await ws.unsubscribe(subscription_id)
13
    
Copied!
1
var fs = require('fs');
2
const WebSocket = require('ws');
3
​
4
const ws = new WebSocket(
5
  "wss://backrunme.blxrbdn.com/ws", 
6
  {
7
    headers: { 
8
      "Authorization" : <YOUR-AUTHORIZATION-HEADER> 
9
    },
10
    rejectUnauthorized: false,
11
  }
12
);
13
​
14
function proceed() {
15
    ws.send(`{"jsonrpc": "2.0", "id": 1, "method": "subscribe", "params": ["arbOnlyMEV", {"include": ["transactions"]}]}`);
16
}
17
​
18
​
19
function handle(nextNotification) {
20
    console.log(nextNotification.toString()); // or process it generally
21
}
22
​
23
ws.on('open', proceed);
24
ws.on('message', handle);
25
​
Copied!
1
package main
2
​
3
import (
4
	"crypto/tls"
5
	"fmt"
6
	"github.com/gorilla/websocket"
7
	"net/http"
8
)
9
​
10
func main() {
11
  tlsConfig := &tls.Config{
12
  	InsecureSkipVerify: true,
13
  }
14
  dialer := websocket.DefaultDialer
15
  dialer.TLSClientConfig = tlsConfig
16
  wsSubscriber, _, err := dialer.Dial("wss://backrunme.blxrbdn.com/ws", http.Header{"Authorization": []string{<YOUR-AUTHORIZATION-HEADER>}})
17
​
18
	if err != nil {
19
		fmt.Println(err)
20
		return
21
	}
22
​
23
	subRequest := `{"id": 1, "method": "subscribe", "params": ["arbOnlyMEV", {"include": ["transactions"]}]}`
24
	err = wsSubscriber.WriteMessage(websocket.TextMessage, []byte(subRequest))
25
	if err != nil {
26
		fmt.Println(err)
27
		return
28
	}
29
​
30
	for {
31
		_, nextNotification, err := wsSubscriber.ReadMessage()
32
		if err != nil {
33
			fmt.Println(err)
34
		}
35
		fmt.Println(string(nextNotification)) // or process it generally
36
	}
37
}
Copied!
1
wscat -c wss://backrunme.blxrbdn.com/ws --no-check --header "Authorization: <YOUR-AUTHORIZATION-HEADER>"
2
> {"id": 1, "method": "subscribe", "params": ["arbOnlyMEV", {"include": ["transactions"]}]}
3
< ......
4
​
Copied!
​
Response (Tx Events)
Transaction Event
1
<<< {
2
  "jsonrpc": "2.0",
3
  "id": null,
4
  "method": "subscribe",
5
  "params": {
6
    "subscription": "3c87cccd-0df5-4938-947e-b24f7602f147",
7
    "result": {
8
      "transactions": [
9
          {
10
          "txHash": "0x88b...296",
11
          "txContents": {
12
            "from": "0x6e9...f89",
13
            "gas": "0x299b6",
14
            "gasPrice": "0xf9982de00",
15
            "hash": "0x88b...296",
16
            "input": "0x18...cc2",
17
            "nonce": "0xf",
18
            "value": "0x0",
19
            "type": "0x0",
20
            "to": "0x7a2...88d"
21
          },
22
          "localRegion": true
23
        }
24
      ]
25
    }
26
  }
27
}
Copied!
ethOnBlock
BDN Architecture
Last modified 2mo ago
Copy link