nodejs: add parse err function (#483)

Co-authored-by: Dmitry Rybalchenko <[email protected]>

Author: fanatid

CHANGELOG.md

@@ -15,6 +15,7 @@ The minor version will be incremented upon a breaking change and the patch versi
 ### Features
 
 - proto: add tonic feature ([#474](https://github.com/rpcpool/yellowstone-grpc/pull/474))
+- nodejs: add parse err function ([#483](https://github.com/rpcpool/yellowstone-grpc/pull/483))
 
 ### Breaking
 

Cargo.toml

@@ -7,7 +7,7 @@ members = [
     "yellowstone-grpc-proto", # 4.0.0
 ]
 exclude = [
-    "yellowstone-grpc-client-nodejs/solana-encoding-wasm", # 1.0.0
+    "yellowstone-grpc-client-nodejs/solana-encoding-wasm", # 3.0.0
 ]
 
 [workspace.package]

Makefile

@@ -1,4 +1,5 @@
 clean: clean-nodejs clean-rust
+	rm -rf test-ledger
 
 clean-nodejs:
 	rm -rf examples/typescript/dist

examples/typescript/package-lock.json

@@ -1,11 +1,13 @@
 import yargs from "yargs";
+import { inspect } from "node:util";
 import Client, {
   CommitmentLevel,
   SubscribeRequest,
   SubscribeRequestFilterAccountsFilter,
   SubscribeRequestFilterAccountsFilterLamports,
   SubscribeUpdateTransactionInfo,
   txEncode,
+  txErrDecode,
 } from "@triton-one/yellowstone-grpc";
 
 async function main() {
@@ -85,13 +87,24 @@ async function subscribeCommand(client, args) {
 
   // Handle updates
   stream.on("data", (data) => {
-    if (data.transaction && args.transactionsParsed) {
+    if (
+      data.transaction &&
+      (args.transactionsParsed || args.transactionsDecodeErr)
+    ) {
       const slot = data.transaction.slot;
       const message = data.transaction.transaction;
-      const tx = txEncode.encode(message, txEncode.encoding.Json, 255, true);
-      console.log(
-        `TX filters: ${data.filters}, slot#${slot}, tx: ${JSON.stringify(tx)}`
-      );
+      if (args.transactionsParsed) {
+        const tx = txEncode.encode(message, txEncode.encoding.Json, 255, true);
+        console.log(
+          `TX filters: ${data.filters}, slot#${slot}, tx: ${JSON.stringify(tx)}`
+        );
+      }
+      if (message.meta.err && args.transactionsDecodeErr) {
+        const err = txErrDecode.decode(message.meta.err.err);
+        console.log(
+          `TX filters: ${data.filters}, slot#${slot}, err: ${inspect(err)}}`
+        );
+      }
       return;
     }
 
@@ -391,6 +404,11 @@ function parseCommandLineArgs() {
           describe: "parse transaction to json",
           type: "boolean",
         },
+        "transactions-decode-err": {
+          default: false,
+          describe: "decode transactions errors",
+          type: "boolean",
+        },
         "transactions-status": {
           default: false,
           describe: "subscribe on transactionsStatus updates",

examples/typescript/src/client.ts

@@ -1,6 +1,6 @@
 {
   "name": "@triton-one/yellowstone-grpc",
-  "version": "1.2.0",
+  "version": "1.3.0",
   "license": "Apache-2.0",
   "author": "Triton One",
   "description": "Yellowstone gRPC Geyser Node.js Client",

yellowstone-grpc-client-nodejs/package-lock.json

@@ -1,6 +1,6 @@
 [package]
 name = "yellowstone-grpc-solana-encoding-wasm"
-version = "2.0.0"
+version = "3.0.0"
 authors = ["Triton One"]
 edition = "2021"
 homepage = "https://triton.one"

yellowstone-grpc-client-nodejs/package.json

@@ -2,7 +2,9 @@ use {
     solana_transaction_status::{TransactionWithStatusMeta, UiTransactionEncoding},
     wasm_bindgen::prelude::*,
     yellowstone_grpc_proto::{
-        convert_from, prelude::SubscribeUpdateTransactionInfo, prost::Message,
+        convert_from,
+        prelude::{SubscribeUpdateTransactionInfo, TransactionError as TransactionErrorProto},
+        prost::Message,
     },
 };
 
@@ -29,7 +31,7 @@ impl From<WasmUiTransactionEncoding> for UiTransactionEncoding {
 }
 
 #[wasm_bindgen]
-pub fn encode(
+pub fn encode_tx(
     data: &[u8],
     encoding: WasmUiTransactionEncoding,
     max_supported_transaction_version: Option<u8>,
@@ -49,3 +51,12 @@ pub fn encode(
         Err(JsError::new("tx with missing metadata"))
     }
 }
+
+#[wasm_bindgen]
+pub fn decode_tx_error(err: Vec<u8>) -> Result<String, JsError> {
+    match convert_from::create_tx_error(Some(&TransactionErrorProto { err })) {
+        Ok(Some(err)) => serde_json::to_string(&err).map_err(Into::into),
+        Ok(None) => Err(JsError::new("unexpected")),
+        Err(error) => Err(JsError::new(error)),
+    }
+}