txReceipts

Search…
txReceipts
Only available on Go Gateways.
Name: txReceipts
txReceipts is a stream of all transaction receipts in each newly mined block. 
Gateway must have a local node connection as well as be using the eth-ws-uristartup argument.
Options
i.e receipt.block_hash .
Key
Description
Values
include
Fields to include in the receipts stream
block_hash, block_number, contract_address, cumulative_gas_used, from, gas_used, logs, logs_bloom, status, to, transaction_hash, transaction_index [Default: all]
​
Code Examples
wscat
Node.js
Python
Golang
wscat -c ws://127.0.0.1:28333/ws --header "Authorization: <YOUR-AUTHORIZATION-HEADER>"
> {"id": 1, "method": "subscribe", "params": ["txReceipts", {"include": []}]}
< ......
​
var fs = require('fs');
const WebSocket = require('ws');
​
 const ws = new WebSocket(
   "ws://127.0.0.1:28333/ws", 
   {
     headers: { 
       "Authorization" : <YOUR-AUTHORIZATION-HEADER>
     },
     rejectUnauthorized: false,
   }
 );
​
function proceed() {
    ws.send(`{"jsonrpc": "2.0", "id": 1, "method": "subscribe", "params": ["txReceipts", {"include": []}]}`);
}
​
​
function handle(nextNotification) {
    console.log(nextNotification.toString()); // or process it generally
}
​
ws.on('open', proceed);
ws.on('message', handle);
Go Gateway
import asyncio
from bxcommon.rpc.provider.ws_provider import WsProvider
async def main():
    async with WsProvider(
        uri="ws://127.0.0.1:28333/ws",
        headers={"Authorization": <YOUR-AUTHORIZATION-HEADER>}
    ) as ws:
        subscription_id = await ws.subscribe("txReceipts", {"include": []})
        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)
if __name__ == '__main__':
    asyncio.get_event_loop().run_until_complete(main())
package main
​
import (
	"crypto/tls"
	"fmt"
	"net/http"
	"github.com/gorilla/websocket"
)
​
func main() {
	tlsConfig := &tls.Config{
		InsecureSkipVerify: true,
	}
	dialer := websocket.DefaultDialer
	dialer.TLSClientConfig = tlsConfig
	wsSubscriber, _, err := dialer.Dial("ws://127.0.0.1:28333/ws", http.Header{"Authorization": []string{<YOUR-AUTHORIZATION-HEADER>}})
​
	if err != nil {
		fmt.Println(err)
		return
	}
​
	subRequest := `{"id": 1, "method": "subscribe", "params": ["txReceipts", {"include": []}]}`
	err = wsSubscriber.WriteMessage(websocket.TextMessage, []byte(subRequest))
	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
	}
}
​
​
Response Example 
Transaction Receipt Event
<<< {"jsonrpc": "2.0", "id": null,
     "result": {"blockHash":"0x1580cb....c950122b837",
                "blockNumber":"0xb128cc",
                "contractAddress":null,
                "cumulativeGasUsed":"0x4e1fb7",
                "from":"0x80bb1...7bf44058a48a",
                "gasUsed":"0x1d918",
                "logs":[{"address":"0x68caa...87846652822ae4b5",
                         "topics":["0x3ae9ad...c40b5a","0x000000000...058a48a"],
                         "data":"0x0000...f3784",
                         "blockNumber":"0xb128cc",
                         "transactionHash":"0x12316c...3080bc012",
                         "transactionIndex":"0x4b",
                         "blockHash":"0x1580cb8419...22b837",
                         "logIndex":"0x7a",
                         "removed":false}],
                "logsBloom":"0x00000...0000",
                "status":"0x1",
                "to":"0x68ca...22ae4b5",
                "transactionHash":"0x12316...0bc012",
                "transactionIndex":"0x4b",
                "type":"0x0"}}
transactionStatus
ethOnBlock
Last modified 13d ago
Copy link