newTxs and pendingTxs

from bloxroute_cli.provider.cloud_wss_provider import CloudWssProvider
​
# Enterprise users can follow line 4-7 to use wss://eth.feed.blxrbdn.com:28333 for ETH
async with CloudWssProvider(
    ssl_dir="/usr/bloxroute/certificate/external_gateway/registration_only",
    ws_uri="wss://eth.feed.blxrbdn.com:28333" # use wss://bsc.feed.blxrbdn.com:28333 for BSC
) as ws:
​
# Non Enterprise users should follow line 10-13 to use wss://api.blxrbdn.com/ws
# async with WsProvider(
#     uri="wss://api.blxrbdn.com/ws",
#     headers={"Authorization": <YOUR-AUTHORIZATION-HEADER>}
#  ) as ws:
​
    # ETH Example
    subscription_id = await ws.subscribe("newTxs", {"include": ["tx_hash"]})
    # BSC Example (only available at endpoint wss://bsc.feed.blxrbdn.com:28333)
    # subscription_id = await ws.subscribe("newTxs", {"include": ["tx_hash"], "blockchain_network": "BSC-Mainnet"})
    while True:
        next_notification = await ws.get_next_subscription_notification_by_id(subscription_id)
        print(next_notification)  # or process it generally
    await ws.unsubscribe(subscription_id)
    

var fs = require('fs');
const WebSocket = require('ws');
​
// Enterprise users can follow line 5-12 to use wss://eth.feed.blxrbdn.com:28333 for ETH
const ws = new WebSocket(
  'wss://eth.feed.blxrbdn.com:28333', // use wss://bsc.feed.blxrbdn.com:28333 for BSC
  {
    cert: fs.readFileSync('/usr/bloxroute/certificate/external_gateway/registration_only/external_gateway_cert.pem'),
    key: fs.readFileSync('/usr/bloxroute/certificate/external_gateway/registration_only/external_gateway_key.pem'),
    rejectUnauthorized: false,
  }
);
​
//  Non Enterprise users should follow line 15-23 to use wss://api.blxrbdn.com/ws
//  const ws = new WebSocket(
//    "wss://api.blxrbdn.com/ws", 
//    {
//      headers: { 
//        "Authorization" : <YOUR-AUTHORIZATION-HEADER> 
//      },
//      rejectUnauthorized: false,
//    }
//  );
​
function proceed() {
    // ETH Example
    ws.send(`{"jsonrpc": "2.0", "id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_hash"]}]}`);
    // BSC Example (only available at endpoint wss://bsc.feed.blxrbdn.com:28333)
    // ws.send(`{"jsonrpc": "2.0", "id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_hash"], "blockchain_network": "BSC-Mainnet"}]}`);
}
​
​
function handle(nextNotification) {
    console.log(nextNotification.toString()); // or process it generally
}
​
ws.on('open', proceed);
ws.on('message', handle);
​

package main
​
import (
	"crypto/tls"
	"fmt"
	"github.com/gorilla/websocket"
	"net/http"
)
​
func main() {
	// Enterprise users can follow line 12-27 to use wss://eth.feed.blxrbdn.com:28333 for ETH
	cert, err := tls.LoadX509KeyPair(
		"/usr/bloxroute/certificate/external_gateway/registration_only/external_gateway_cert.pem", 
		"/usr/bloxroute/certificate/external_gateway/registration_only/external_gateway_key.pem",
	)
	if err != nil {
		fmt.Println(err)
		return
	}
​
	tlsConfig := &tls.Config{
		Certificates:       []tls.Certificate{cert},
		InsecureSkipVerify: true,
	}
	dialer := websocket.DefaultDialer
	dialer.TLSClientConfig = tlsConfig
	wsSubscriber, _, err := dialer.Dial("wss://eth.feed.blxrbdn.com:28333", nil) // use wss://bsc.feed.blxrbdn.com:28333 for BSC
	
	// Non Enterprise users should follow line 30-35 to use wss://api.blxrbdn.com/ws
	//  tlsConfig := &tls.Config{
	//  	InsecureSkipVerify: true,
	//  }
	//  dialer := websocket.DefaultDialer
	//  dialer.TLSClientConfig = tlsConfig
	//  wsSubscriber, _, err := dialer.Dial("wss://api.blxrbdn.com/ws", http.Header{"Authorization": []string{<YOUR-AUTHORIZATION-HEADER>}})
​
	if err != nil {
		fmt.Println(err)
		return
	}
​
  // ETH Example
	subRequst := `{"id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_hash"]}]}`
	// BSC Example (only available at endpoint wss://bsc.feed.blxrbdn.com:28333)
	// subRequst := `{"id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_hash"], "blockchain_network": "BSC-Mainnet"}]}`
	err = wsSubscriber.WriteMessage(websocket.TextMessage, []byte(subRequst))
	if err != nil {
		fmt.Println(err)
		return
	}
​
	for {
		_, nextNotification, err := wsSubscriber.ReadMessage()
		if err != nil {
			fmt.Println(err)
		}
		fmt.Println(string(nextNotification)) // or process it generally
	}
}
​

from bloxroute_cli.provider.ws_provider import WsProvider
ws_uri = "ws://127.0.0.1:28333"
while True:
   try:
       async with WsProvider(ws_uri) as ws:
           subscription_id = await ws.subscribe("newTxs", {"include": ["tx_hash"]})
           while True:
               next_notification = await ws.get_next_subscription_notification_by_id(subscription_id)
               print(next_notification)  # or process it generally
   except Exception as e:
       print(f"Connection broken to feed, {str(e)}, retrying.")
await ws.unsubscribe(subscription_id)
​

const WebSocket = require('ws');
​
const ws = new WebSocket(
  'ws://127.0.0.1:28333', 
);
​
​
function proceed() {
    ws.send(`{"jsonrpc": "2.0", "id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_hash"]}]}`);
}
​
​
function handle(nextNotification) {
    console.log(nextNotification.toString()); // or process it generally
}
​
ws.on('open', proceed);
ws.on('message', handle);
​

package main
​
import (
	"fmt"
	"github.com/gorilla/websocket"
)
​
func main() {
	dialer := websocket.DefaultDialer
	wsSubscriber, _, err := dialer.Dial("ws://127.0.0.1:28333", nil)
	
	if err != nil {
		fmt.Println(err)
		return
	}
​
	subRequst := `{"id": 1, "method": "subscribe", "params": ["newTxs", {"include": ["tx_hash"]}]}`
	err = wsSubscriber.WriteMessage(websocket.TextMessage, []byte(subRequst))
	if err != nil {
		fmt.Println(err)
		return
	}
​
	for {
		_, nextNotification, err := wsSubscriber.ReadMessage()
		if err != nil {
			fmt.Println(err)
		}
		fmt.Println(string(nextNotification)) // or process it generally
	}
}
​