feat: adds recent watches

metaDAOproject · Aug 4, 2024 · dc49a92 · dc49a92
1 parent 35c2e93
commit dc49a92
Show file tree

Hide file tree

Showing 3 changed files with 119 additions and 3 deletions.
diff --git a/lib/client/client.ts b/lib/client/client.ts
@@ -149,6 +149,8 @@ export interface FutarchyMarketsClient {
   ): Observable<{ orders: Order[]; totalOrders: number }>;
   watchTwapPrices(marketKey: PublicKey): Observable<TwapObservation[]>;
   watchSpotPrices(marketKey: PublicKey): Observable<SpotObservation[]>;
+  // watchCurrentSpotPrice(marketKey: PublicKey): Observable<SpotObservation[]>;
+  // watchConditionalSpotPrice(marketKey: PublicKey): Observable<SpotObservation[]>;
 }
 
 export interface FutarchyOrderbookMarketsClient<

diff --git a/lib/client/indexer/markets.ts b/lib/client/indexer/markets.ts
@@ -156,9 +156,9 @@ export class FutarchyIndexerMarketsClient implements FutarchyMarketsClient {
           },
           order_by: [
             {
-              interv: "asc"
+              interv: "desc"
             }
-          ]
+          ], limit: 1
         },
         token_amount: true,
         market: {
@@ -421,6 +421,119 @@ export class FutarchyIndexerMarketsClient implements FutarchyMarketsClient {
       limit: pageSizeValue
     });
   }
+  watchConditionalSpotPrice(
+    marketKey: PublicKey,
+    filters?: prices_chart_data_bool_exp
+  ): Observable<SpotObservation[]> {
+    const { query, variables } = generateSubscriptionOp({
+      prices_chart_data: {
+        __args: {
+          where: {
+            market_acct: { _eq: marketKey.toString() },
+            prices_type: {
+              _in: ["conditional"]
+            },
+            ...filters
+          },
+          order_by: [
+            {
+              interv: "desc"
+            }
+          ],
+          limit: 1
+        },
+        interv: true,
+        price: true,
+        quote_amount: true,
+        base_amount: true
+      }
+    });
+
+    return new Observable((subscriber) => {
+      const subscriptionCleanup = this.graphqlWSClient.subscribe<{
+        prices_chart_data: {
+          interv: string;
+          price: number;
+          quote_amount: number;
+          base_amount: number;
+        }[];
+      }>(
+        { query, variables },
+        {
+          next: (data) => {
+            const spotObservations =
+              data.data?.prices_chart_data?.map<SpotObservation>((d) => ({
+                priceUi: d.price,
+                createdAt: new Date(d.interv),
+                quoteAmount: d.quote_amount,
+                baseAmount: d.base_amount
+              }));
+            subscriber.next(spotObservations);
+          },
+          error: (error) => subscriber.error(error),
+          complete: () => subscriber.complete()
+        }
+      );
+      return () => subscriptionCleanup();
+    });
+  }
+
+  watchCurrentSpotPrice(
+    marketKey: PublicKey,
+    filters?: prices_chart_data_bool_exp
+  ): Observable<SpotObservation[]> {
+    const { query, variables } = generateSubscriptionOp({
+      prices_chart_data: {
+        __args: {
+          where: {
+            market_acct: { _eq: marketKey.toString() },
+            prices_type: {
+              _in: ["spot"]
+            },
+            ...filters
+          },
+          order_by: [
+            {
+              interv: "desc"
+            }
+          ],
+          limit: 1
+        },
+        interv: true,
+        price: true,
+        quote_amount: true,
+        base_amount: true
+      }
+    });
+
+    return new Observable((subscriber) => {
+      const subscriptionCleanup = this.graphqlWSClient.subscribe<{
+        prices_chart_data: {
+          interv: string;
+          price: number;
+          quote_amount: number;
+          base_amount: number;
+        }[];
+      }>(
+        { query, variables },
+        {
+          next: (data) => {
+            const spotObservations =
+              data.data?.prices_chart_data?.map<SpotObservation>((d) => ({
+                priceUi: d.price,
+                createdAt: new Date(d.interv),
+                quoteAmount: d.quote_amount,
+                baseAmount: d.base_amount
+              }));
+            subscriber.next(spotObservations);
+          },
+          error: (error) => subscriber.error(error),
+          complete: () => subscriber.complete()
+        }
+      );
+      return () => subscriptionCleanup();
+    });
+  }
 
   watchSpotPrices(
     marketKey: PublicKey,

diff --git a/lib/client/indexer/proposals.ts b/lib/client/indexer/proposals.ts
@@ -351,7 +351,8 @@ export class FutarchyIndexerProposalsClient implements FutarchyProposalsClient {
             {
               created_at: "desc"
             }
-          ]
+          ],
+          limit: 1
         },
         dao: {
           dao_detail: {
-Original file line number
+Diff line change
@@ Expand Up @@
                 {
                   created_at: "desc"
                 }
-              ]
+              ],
+              limit: 1
             },
             dao: {
               dao_detail: {
@@ Expand Down @@