Add getTransaction wasm function, to poll for new txs

crates/js_api/src/subgraph/mod.rs

@@ -8,6 +8,7 @@ use thiserror::Error;
 use wasm_bindgen::{JsError, JsValue};
 
 pub mod order;
+pub mod transaction;
 pub mod vault;
 
 #[derive(Error, Debug)]

crates/js_api/src/subgraph/transaction.rs

@@ -0,0 +1,16 @@
+use cynic::Id;
+use rain_orderbook_bindings::wasm_traits::prelude::*;
+use rain_orderbook_subgraph_client::{OrderbookSubgraphClient, OrderbookSubgraphClientError};
+use reqwest::Url;
+
+/// Internal function to fetch a single transaction
+/// Returns the Transaction struct
+#[wasm_bindgen(js_name = "getTransaction")]
+pub async fn get_sg_transaction(
+    url: &str,
+    id: &str,
+) -> Result<JsValue, OrderbookSubgraphClientError> {
+    let client = OrderbookSubgraphClient::new(Url::parse(url)?);
+    let transaction = client.transaction_detail(Id::new(id)).await?;
+    Ok(to_value(&transaction)?)
+}

crates/subgraph/src/orderbook_client.rs

@@ -8,6 +8,7 @@ use crate::types::order::{
     OrdersListQuery,
 };
 use crate::types::order_trade::{OrderTradeDetailQuery, OrderTradesListQuery};
+use crate::types::transaction::TransactionDetailQuery;
 use crate::types::vault::{VaultDetailQuery, VaultsListQuery};
 use crate::vault_balance_changes_query::VaultBalanceChangesListPageQueryClient;
 use cynic::Id;
@@ -379,4 +380,17 @@ impl OrderbookSubgraphClient {
         }
         Ok(all_pages_merged)
     }
+
+    pub async fn transaction_detail(
+        &self,
+        id: Id,
+    ) -> Result<Transaction, OrderbookSubgraphClientError> {
+        let data = self
+            .query::<TransactionDetailQuery, IdQueryVariables>(IdQueryVariables { id: &id })
+            .await?;
+        let transaction = data
+            .transaction
+            .ok_or(OrderbookSubgraphClientError::Empty)?;
+        Ok(transaction)
+    }
 }

crates/subgraph/src/types/mod.rs

@@ -3,6 +3,7 @@ mod impls;
 pub mod order;
 pub mod order_detail_traits;
 pub mod order_trade;
+pub mod transaction;
 pub mod vault;
 
 pub use cynic::Id;

crates/subgraph/src/types/transaction.rs

@@ -0,0 +1,12 @@
+use super::common::*;
+use crate::schema;
+use typeshare::typeshare;
+
+#[derive(cynic::QueryFragment, Debug)]
+#[cynic(graphql_type = "Query", variables = "IdQueryVariables")]
+#[typeshare]
+pub struct TransactionDetailQuery {
+    #[arguments(id: $id)]
+    #[typeshare(typescript(type = "TransactionSubgraph"))]
+    pub transaction: Option<Transaction>,
+}

packages/orderbook/test/js_api/transaction.test.ts

@@ -0,0 +1,31 @@
+import assert from 'assert';
+import { getLocal } from 'mockttp';
+import { describe, it, beforeEach, afterEach } from 'vitest';
+import { Transaction } from '../../dist/types/js_api.js';
+import { getTransaction } from '../../dist/cjs/js_api.js';
+
+const transaction1 = {
+	id: 'tx1',
+	from: '0x1',
+	blockNumber: '1',
+	timestamp: '1'
+} as unknown as Transaction;
+
+describe('Rain Orderbook JS API Package Bindgen Tests - Order', async function () {
+	const mockServer = getLocal();
+	beforeEach(() => mockServer.start(8090));
+	afterEach(() => mockServer.stop());
+
+	it('should fetch a single transaction', async () => {
+		await mockServer
+			.forPost('/sg1')
+			.thenReply(200, JSON.stringify({ data: { transaction: transaction1 } }));
+
+		try {
+			const result: Transaction = await getTransaction(mockServer.url + '/sg1', transaction1.id);
+			assert.equal(result.id, transaction1.id);
+		} catch (e) {
+			assert.fail('expected to resolve, but failed' + (e instanceof Error ? e.message : String(e)));
+		}
+	});
+});