txReceipts
Only available on Go Gateways.
Note: Gateway must have a node connection to both Consensus Layer and Execution Layer as well as be using the
eth-ws-uristartup argument (see How to connect Go-Gateway to consensus layer).Name:
txReceiptstxReceipts is a stream of all transaction receipts in each newly mined block. 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, json, websockets
async def main():
try:
uri = "ws://127.0.0.1:28333/ws"
auth_key = "YOUR_AUTHORIZATION_HEADER"
subscription_request = {
"jsonrpc": "2.0",
"id": 1,
"method": "subscribe",
"params": [
"txReceipts",
{
"include": []
}
]
}
async with websockets.connect(
uri,
header=["Authorization:{}".format(auth_key)],
sslopt={"cert_reqs": ssl.CERT_NONE},
) as websocket:
await websocket.send(json.dumps(subscription_request))
while True:
response = await websocket.recv()
print(response) # or process it generally
except Exception as e:
print(f"Connection failed, Reason: {e}")
if __name__ == '__main__':
asyncio.run(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"}}
Last modified 30d ago