[1958] Move fetchUserInfo to subscribe (#48)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@compolabs/spark-orderbook-ts-sdk",
-  "version": "1.12.0",
+  "version": "1.12.1",
   "type": "module",
   "main": "./dist/index.сjs",
   "module": "./dist/index.js",

src/IndexerApi.ts

@@ -4,7 +4,6 @@ import {
   gql,
   Observable,
 } from "@apollo/client";
-import { Undefinable } from "tsdef";
 
 import BN from "./utils/BN";
 import { generateWhereFilter } from "./utils/generateWhereFilter";
@@ -174,11 +173,11 @@ export class IndexerApi extends GraphClient {
     };
   };
 
-  getUserInfo = async (
+  subscribeUserInfo = (
     params: UserInfoParams,
-  ): Promise<Undefinable<UserInfo>> => {
+  ): Observable<FetchResult<{ User: UserInfo[] }>> => {
     const query = gql`
-      query UserQuery($where: User_bool_exp) {
+      subscription UserQuery($where: User_bool_exp) {
         User(where: $where) {
           id
           active
@@ -189,19 +188,13 @@ export class IndexerApi extends GraphClient {
       }
     `;
 
-    const response = await this.client.query<{
-      UserQuery: UserInfo[];
+    return this.client.subscribe<{
+      User: UserInfo[];
     }>({
       query,
       variables: {
         where: generateWhereFilter(params),
       },
     });
-
-    if (!response.data.UserQuery.length) {
-      return;
-    }
-
-    return response.data.UserQuery[0];
   };
 }

src/SparkOrderbook.ts

@@ -241,8 +241,10 @@ export class SparkOrderbook {
     return this.activeIndexerApi.getVolume(params);
   }
 
-  async fetchUserInfo(params: UserInfoParams): Promise<Undefinable<UserInfo>> {
-    return this.activeIndexerApi.getUserInfo(params);
+  subscribeUserInfo(
+    params: UserInfoParams,
+  ): Observable<FetchResult<{ User: UserInfo[] }>> {
+    return this.activeIndexerApi.subscribeUserInfo(params);
   }
 
   async fetchMarkets(assetIdPairs: [string, string][]): Promise<Markets> {

src/interface.ts

@@ -212,7 +212,7 @@ export interface UserProtocolFee {
 }
 
 export interface UserInfoParams {
-  user: string;
+  id: string;
 }
 
 export interface UserInfo {