Feat fetch last trades

package.json

@@ -43,6 +43,7 @@
   },
   "dependencies": {
     "@apollo/client": "^3.10.8",
+    "@compolabs/spark-orderbook-ts-sdk": "^1.14.12",
     "axios": "^1.7.7",
     "bignumber.js": "^9.1.2",
     "graphql-ws": "^5.16.0",

src/IndexerApi.ts

@@ -5,7 +5,11 @@ import {
   Observable,
 } from "@apollo/client";
 
-import { getActiveOrdersQuery, getOrdersQuery } from "./query/indexerQuery";
+import {
+  getActiveOrdersQuery,
+  getLastTradeQuery,
+  getOrdersQuery,
+} from "./query/indexerQuery";
 import BN from "./utils/BN";
 import { generateWhereFilter } from "./utils/generateWhereFilter";
 import { GraphClient } from "./utils/GraphClient";
@@ -14,6 +18,7 @@ import {
   GetActiveOrdersParams,
   GetOrdersParams,
   GetTradeOrderEventsParams,
+  LastPriceReturn,
   Order,
   OrderType,
   TradeOrderEvent,
@@ -47,6 +52,12 @@ export class IndexerApi extends GraphClient {
     );
   };
 
+  getLastTrade = async (
+    params: GetOrdersParams,
+  ): Promise<ApolloQueryResult<any>> => {
+    return this.client.query<LastPriceReturn>(getLastTradeQuery(params));
+  };
+
   subscribeActiveOrders = <T extends OrderType>(
     params: GetActiveOrdersParams,
   ): Observable<FetchResult<ActiveOrderReturn<T>>> => {
@@ -95,7 +106,6 @@ export class IndexerApi extends GraphClient {
       query,
       variables: {
         limit,
-        orderBy: "desc",
         where: generateWhereFilter(restParams),
       },
     });

src/SparkOrderbook.ts

@@ -26,6 +26,7 @@ import {
   GetTradeOrderEventsParams,
   GetUserScoreSnapshotParams,
   GraphClientConfig,
+  LastPriceReturn,
   MarketInfo,
   Markets,
   Options,
@@ -363,6 +364,12 @@ export class SparkOrderbook {
     return this.activeSentioApi?.getLeaderboard(params);
   }
 
+  async fetchLastTrade<T extends OrderType>(
+    params: GetOrdersParams,
+  ): Promise<ApolloQueryResult<LastPriceReturn>> {
+    return this.activeIndexerApi.getLastTrade(params);
+  }
+
   /**
    * @experimental
    * Returns the current instance to allow method chaining.

src/interface.ts

@@ -122,6 +122,10 @@ export interface CreateOrderParams {
   type: OrderType;
 }
 
+export interface LastPriceReturn {
+  tradePrice: string;
+}
+
 export interface CreateOrderWithDepositParams {
   amount: string;
   amountToSpend: string;

src/query/indexerQuery.ts

@@ -83,3 +83,22 @@ export const getActiveOrdersQuery = (
     },
   };
 };
+
+export const getLastTradeQuery = (params: GetOrdersParams): QueryOptions => {
+  const { limit, ...restParams } = params;
+  const query = gql`
+    query OrderQuery($limit: Int!, $where: TradeOrderEvent_bool_exp) {
+      TradeOrderEvent(limit: $limit, where: $where) {
+        tradePrice
+      }
+    }
+  `;
+
+  return {
+    query,
+    variables: {
+      limit,
+      where: generateWhereFilter({ ...restParams }),
+    },
+  };
+};