nodejs: add parse tx function (#471)

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

.editorconfig

@@ -16,3 +16,6 @@ indent_size = 2
 [*.rs]
 indent_style = space
 indent_size = 4
+
+[{Makefile,**.mk}]
+indent_style = tab

.github/workflows/test.yml

@@ -65,6 +65,7 @@ jobs:
 
       - uses: dtolnay/rust-toolchain@stable
         with:
+          targets: wasm32-unknown-unknown
           toolchain: ${{ env.RUST_STABLE }}
 
       - name: Install dependencies
@@ -78,16 +79,37 @@ jobs:
           git checkout Cargo.lock
           cargo tree --frozen
 
+      - name: cargo tree wasm
+        run: |
+          cd yellowstone-grpc-client-nodejs/solana-encoding-wasm
+          cargo tree
+          git checkout Cargo.lock
+          cargo tree --frozen
+
       - name: cargo fmt
         run: cargo +nightly fmt --all -- --check
 
+      - name: cargo fmt wasm
+        run: |
+          cd yellowstone-grpc-client-nodejs/solana-encoding-wasm
+          cargo +nightly fmt --all -- --check
+
       - name: cargo deny check advisories
         uses: EmbarkStudios/cargo-deny-action@v1
         with:
           command: check advisories
+      - name: cargo deny check advisories wasm
+        uses: EmbarkStudios/cargo-deny-action@v1
+        with:
+          command: check advisories
+          manifest-path: ./yellowstone-grpc-client-nodejs/solana-encoding-wasm/Cargo.toml
 
       - name: cargo clippy
         run: cargo clippy --workspace --all-targets
+      - name: cargo clippy wasm
+        run: |
+          cd yellowstone-grpc-client-nodejs/solana-encoding-wasm
+          cargo clippy --target wasm32-unknown-unknown --all-targets
 
       - name: check features in `client`
         run: cargo check -p yellowstone-grpc-client --all-targets

.gitignore

@@ -10,6 +10,7 @@ examples/typescript/dist
 examples/typescript/node_modules
 yellowstone-grpc-client-nodejs/dist
 yellowstone-grpc-client-nodejs/node_modules
+yellowstone-grpc-client-nodejs/src/encoding
 yellowstone-grpc-client-nodejs/src/grpc
 
 # Python

CHANGELOG.md

@@ -17,6 +17,7 @@ The minor version will be incremented upon a breaking change and the patch versi
 - proto: add tonic feature ([#474](https://github.com/rpcpool/yellowstone-grpc/pull/474))
 - geyser: use default compression as gzip and zstd ([#475](https://github.com/rpcpool/yellowstone-grpc/pull/475))
 - example: add connection options to Rust client ([#478](https://github.com/rpcpool/yellowstone-grpc/pull/478))
+- nodejs: add parse tx function ([#471](https://github.com/rpcpool/yellowstone-grpc/pull/471))
 
 ### Breaking
 

Cargo.toml

@@ -6,6 +6,9 @@ members = [
     "yellowstone-grpc-geyser", # 3.0.1
     "yellowstone-grpc-proto", # 3.0.0
 ]
+exclude = [
+    "yellowstone-grpc-client-nodejs/solana-encoding-wasm", # 1.0.0
+]
 
 [workspace.package]
 authors = ["Triton One"]

Makefile

@@ -1,6 +1,33 @@
+clean: clean-nodejs clean-rust
+
 clean-nodejs:
 	rm -rf examples/typescript/dist
 	rm -rf examples/typescript/node_modules
 	rm -rf yellowstone-grpc-client-nodejs/dist
 	rm -rf yellowstone-grpc-client-nodejs/node_modules
+	rm -rf yellowstone-grpc-client-nodejs/src/encoding
 	rm -rf yellowstone-grpc-client-nodejs/src/grpc
+
+clean-rust:
+	rm -rf target
+	rm -rf yellowstone-grpc-client-nodejs/solana-encoding-wasm/target
+
+solana-encoding-wasm-clippy:
+	cd yellowstone-grpc-client-nodejs/solana-encoding-wasm && \
+		cargo clippy --target wasm32-unknown-unknown --all-targets
+
+solana-encoding-wasm-build:
+	# RUSTFLAGS to disable `mold`
+	cd yellowstone-grpc-client-nodejs/solana-encoding-wasm && \
+		RUSTFLAGS="" cargo build \
+			--target wasm32-unknown-unknown \
+			--release
+
+	cd yellowstone-grpc-client-nodejs/solana-encoding-wasm && \
+		rm -rf ../src/encoding/ && \
+		wasm-bindgen \
+			--target nodejs \
+			--out-dir ../src/encoding/ \
+			target/wasm32-unknown-unknown/release/yellowstone_grpc_solana_encoding_wasm.wasm && \
+		mkdir -p ../dist/encoding/ && \
+		cp -ap ../src/encoding/ ../dist/

examples/typescript/src/client.ts

@@ -4,6 +4,8 @@ import Client, {
   SubscribeRequest,
   SubscribeRequestFilterAccountsFilter,
   SubscribeRequestFilterAccountsFilterLamports,
+  SubscribeUpdateTransactionInfo,
+  txEncode,
 } from "@triton-one/yellowstone-grpc";
 
 async function main() {
@@ -83,6 +85,16 @@ async function subscribeCommand(client, args) {
 
   // Handle updates
   stream.on("data", (data) => {
+    if (data.transaction && args.transactionsParsed) {
+      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)}`
+      );
+      return;
+    }
+
     console.log("data", data);
   });
 
@@ -374,6 +386,11 @@ function parseCommandLineArgs() {
           description: "filter required account in transactions",
           type: "array",
         },
+        "transactions-parsed": {
+          default: false,
+          describe: "parse transaction to json",
+          type: "boolean",
+        },
         "transactions-status": {
           default: false,
           describe: "subscribe on transactionsStatus updates",