Merge branch 'feat/add-testing-optimizations' of https://github.com/m…

…etaDAOproject/futarchy-sdk into feat/add-testing-optimizations

lib/client/client.ts

@@ -20,7 +20,8 @@ import {
   ProposalAccounts,
   ProgramVersionLabel,
   ProposalWithFullData,
-  Dao
+  Dao,
+  TokenCache
 } from "@/types";
 import { SwapType } from "@metadaoproject/futarchy";
 import { Observable } from "rxjs";
@@ -220,3 +221,7 @@ export interface CreateProposal {
     proposalDetails: ProposalDetails
   ): void;
 }
+
+export interface FutarchyTokenClient {
+  fetchFutarchyTokens(): Promise<TokenCache[] | undefined>;
+}

lib/client/indexer/indexerClient.ts

@@ -8,13 +8,15 @@ import { ClientOptions, createClient as createWsClient } from "graphql-ws";
 import { FutarchyProtocol } from "@/types";
 import { Observable } from "rxjs";
 import { FutarchyIndexerUserClient } from "./user";
+import { FutarchyIndexerTokenClient } from "./tokens";
 
 export class FutarchyIndexerClient implements FutarchyClient {
   public daos: FutarchyIndexerDaoClient;
   public proposals: FutarchyIndexerProposalsClient;
   public balances: FutarchyIndexerBalancesClient;
   public markets: FutarchyIndexerMarketsClient;
   public user: FutarchyIndexerUserClient;
+  public tokens: FutarchyIndexerTokenClient;
   private protocolMap: Map<string, FutarchyProtocol>;
   private wsClient;
 
@@ -75,6 +77,10 @@ export class FutarchyIndexerClient implements FutarchyClient {
       graphqlClient,
       this.protocolMap,
     )
+    this.tokens = new FutarchyIndexerTokenClient(
+      rpcClient.daos,
+      graphqlClient
+    )
   }
 
   watchSlot() {

lib/client/indexer/tokens.ts

@@ -0,0 +1,64 @@
+import {
+  Tokens__GQL,
+  TokenCache
+} from "@/types";
+import { FutarchyTokenClient } from "@/client";
+import { FutarchyRPCDaoClient } from "../rpc";
+import {
+  Client as IndexerGraphQLClient,
+} from "./__generated__";
+
+export class FutarchyIndexerTokenClient implements FutarchyTokenClient {
+  private rpcDaoClient: FutarchyRPCDaoClient;
+  private graphqlClient: IndexerGraphQLClient;
+  constructor(
+    rpcDaoClient: FutarchyRPCDaoClient,
+    graphqlClient: IndexerGraphQLClient,
+  ) {
+    this.rpcDaoClient = rpcDaoClient;
+    this.graphqlClient = graphqlClient;
+  }
+  async fetchFutarchyTokens(): Promise<TokenCache[]> {
+    try {
+
+      const { tokens } = await this.graphqlClient.query?.({
+        tokens: {
+          __args: {
+            where: {}
+          },
+          // pass arguments to the query
+          decimals: true,
+          symbol: true,
+          mint_acct: true,
+          name: true,
+          image_url: true,
+          supply: true,
+          updated_at: true,
+        }
+      });
+
+      const tokenDetails = this.getTokenCacheFromQuery(tokens) ?? [] as TokenCache[]
+
+      return tokenDetails;
+    } catch (e) {
+      console.error(e);
+      //return this.rpcDaoClient.fetchFutarchyTokens();
+      return []
+    }
+  }
+
+  private getTokenCacheFromQuery(
+    tokens: Tokens__GQL
+  ): TokenCache[] {
+    return tokens.map((t) => {
+      return {
+        symbol: t.symbol,
+        decimals: t.decimals,
+        name: t.name ?? null,
+        mint_acct: t.mint_acct,
+        url: t.image_url,
+        supply: t.supply ?? null
+      } as TokenCache
+    }) as TokenCache[]
+  };
+}

lib/types/autocrats.ts

@@ -82,6 +82,16 @@ export type Dao = {
   };
 };
 
+// Tokens Cache
+export type TokenCache = {
+  symbol: string;
+  decimals: number;
+  name: string | null;
+  mint_acct: string;
+  url: string;
+  supply: number | null;
+}
+
 // we might want to consider changing this to be DaoDetails as the main component and
 export type DaoAggregate = {
   name: string;
@@ -142,3 +152,12 @@ export type DaoDetails__GQL = {
     };
   }>;
 };
+
+export type Tokens__GQL = {
+  symbol: string;
+  decimals: number;
+  name: string | null;
+  mint_acct: string;
+  image_url: string | null;
+  supply: number | null;
+}[]