Creating a Balancer API provider to fetch pool state for join txs;

.gitignore

@@ -80,3 +80,5 @@ typechain-types
 cache
 artifacts
 
+#IDE
+.idea

src/data/providers/balancer-api-provider/client/index.ts

@@ -0,0 +1,22 @@
+export class BalancerApiClient {
+  subgraphUrl: string;
+  chainId: number;
+  constructor(subgraphUrl: string, chainId: number) {
+    this.subgraphUrl = subgraphUrl;
+    this.chainId = chainId;
+  }
+
+  async fetch(operationName: string, query: any, variables: any) {
+    const requestQuery = {
+      operationName,
+      query,
+      variables,
+    };
+    const response = await fetch(this.subgraphUrl, {
+      method: 'post',
+      body: JSON.stringify(requestQuery),
+      headers: { 'Content-Type': 'application/json', ChainId: this.chainId.toString() },
+    });
+    return response.json();
+  }
+}

src/data/providers/balancer-api-provider/index.ts

@@ -0,0 +1,16 @@
+import { JoinData } from "./modules/join";
+import { BalancerApiClient } from "./client";
+
+export default class BalancerApi {
+
+  balancerApiClient: BalancerApiClient;
+  joinData: JoinData;
+
+
+  constructor(balancerApiUrl: string, chainId: number){
+    this.balancerApiClient = new BalancerApiClient(balancerApiUrl, chainId);
+    this.joinData = new JoinData(this.balancerApiClient);
+  }
+
+
+}

src/data/providers/balancer-api-provider/modules/join/index.ts

@@ -0,0 +1,88 @@
+import { BalancerApiClient } from '../../client';
+import { PoolState } from './types';
+
+export class JoinData {
+  readonly poolStateQuery = `query GetPool($id: String!){
+    poolGetPool(id:$id) {
+      id
+      address
+      name
+      type
+      version
+      ... on GqlPoolWeighted {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+      ... on GqlPoolStable {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+      ... on GqlPoolPhantomStable {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+      ... on GqlPoolGyro {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+      ... on GqlPoolLiquidityBootstrapping {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+      ... on GqlPoolElement {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+      ... on GqlPoolLiquidityBootstrapping {
+        tokens {
+          ... on GqlPoolTokenBase {
+            address
+             decimals
+            index
+          }
+        }
+      }
+    }
+}`;
+
+  constructor(private readonly balancerApiClient: BalancerApiClient) {}
+
+  async fetchPoolState(id: string): Promise<PoolState> {
+    const {
+      data: { poolGetPool },
+    } = await this.balancerApiClient.fetch('GetPool', this.poolStateQuery, {
+      id,
+    });
+    return poolGetPool;
+  }
+}

src/data/providers/balancer-api-provider/modules/join/types.ts

@@ -0,0 +1,14 @@
+import { Address } from "viem";
+
+export type PoolState = {
+  id: Address;
+  address: Address;
+  type: string;
+  version: string;
+  tokens: {
+    address: Address;
+    decimals: number;
+    index: number;
+  };
+}[];
+