Add Strategies API

src/app/api/strategies/route.ts

@@ -1,11 +1,67 @@
 import { NextResponse } from 'next/server';
+import { atom } from 'jotai';
+import ZkLendAtoms from '@/store/zklend.store';
+import { PoolInfo } from '@/store/pools';
+import NostraLendingAtoms from '@/store/nostralending.store';
+import { RpcProvider } from 'starknet';
+import { getStrategies } from '@/store/strategies.atoms';
+import { MY_STORE } from '@/store';
+import MyNumber from '@/utils/MyNumber';
+import { NFTInfo, TokenInfo } from '@/strategies/IStrategy';
 
 export const revalidate = 3600; // 1 hr
 
+const allPoolsAtom = atom<PoolInfo[]>((get) => {
+  const pools: PoolInfo[] = [];
+  const poolAtoms = [ZkLendAtoms, NostraLendingAtoms];
+  return poolAtoms.reduce((_pools, p) => _pools.concat(get(p.pools)), pools);
+  return [];
+});
+
+async function getPools(store: any, retry = 0) {
+  const allPools = store.get(allPoolsAtom);
+  if (!allPools.length && retry < 10) {
+    await new Promise((resolve) => setTimeout(resolve, 1000));
+    return getPools(store, retry + 1);
+  }
+  if (retry >= 10) {
+    throw new Error('Failed to fetch pools');
+  }
+  return allPools;
+}
+
+const provider = new RpcProvider({
+  nodeUrl: process.env.RPC_URL || 'https://starknet-mainnet.public.blastapi.io',
+});
+
 export async function GET(req: Request) {
+  const allPools = await getPools(MY_STORE);
+  const strategies = getStrategies();
+  strategies.forEach((strategy) => {
+    strategy.solve(allPools, '1000');
+  });
+
   try {
     return NextResponse.json({
       status: true,
+      strategies: strategies.map((s) => {
+        return {
+          name: s.name,
+          id: s.id,
+          apy: s.netYield,
+          depositToken: s
+            .depositMethods(MyNumber.fromZero(), '', provider)
+            .map((t) => t.tokenInfo.token),
+          leverage: s.leverage,
+          contract: s.holdingTokens.map((t) => ({
+            name: t.name,
+            address: (<any>t).token
+              ? (<TokenInfo>t).token
+              : (<NFTInfo>t).address,
+          })),
+          status: s.liveStatus,
+        };
+      }),
     });
   } catch (err) {
     console.error('Error /api/strategies', err);

src/app/slinks/template.tsx

@@ -1,6 +1,7 @@
 'use client';
 
 import Navbar from '@/components/Navbar';
+import { MY_STORE } from '@/store';
 import {
   Center,
   ChakraBaseProvider,
@@ -99,7 +100,7 @@ export default function Template({ children }: { children: React.ReactNode }) {
   }
 
   return (
-    <JotaiProvider>
+    <JotaiProvider store={MY_STORE}>
       <StarknetConfig
         chains={chains}
         provider={provider}

src/app/template.tsx

@@ -1,6 +1,7 @@
 'use client';
 
 import Navbar from '@/components/Navbar';
+import { MY_STORE } from '@/store';
 import {
   Center,
   ChakraBaseProvider,
@@ -99,7 +100,7 @@ export default function Template({ children }: { children: React.ReactNode }) {
   }
 
   return (
-    <JotaiProvider>
+    <JotaiProvider store={MY_STORE}>
       <StarknetConfig
         chains={chains}
         provider={provider}

src/components/Filters.tsx

@@ -1,6 +1,5 @@
 import React from 'react';
 import Select, { StylesConfig } from 'react-select';
-import { ALL_FILTER, filters, updateFiltersAtom } from '@/store/pools';
 import * as chroma from 'chroma.ts';
 import { useSetAtom } from 'jotai';
 import {
@@ -13,6 +12,7 @@ import {
   Text,
 } from '@chakra-ui/react';
 import { HamburgerIcon } from '@chakra-ui/icons';
+import { ALL_FILTER, filters, updateFiltersAtom } from '@/store/protocols';
 
 export interface Option {
   readonly value: string;

src/components/Pools.tsx

@@ -1,11 +1,6 @@
 'use client';
 
-import {
-  PoolInfo,
-  allPoolsAtomUnSorted,
-  filteredPools,
-  sortPoolsAtom,
-} from '@/store/pools';
+import { PoolInfo } from '@/store/pools';
 import {
   Avatar,
   AvatarGroup,
@@ -38,6 +33,11 @@ import {
 import CONSTANTS from '@/constants';
 import Filters from '@/components/Filters';
 import mixpanel from 'mixpanel-browser';
+import {
+  allPoolsAtomUnSorted,
+  filteredPools,
+  sortPoolsAtom,
+} from '@/store/protocols';
 
 export default function Pools() {
   const allPools = useAtomValue(allPoolsAtomUnSorted);

src/components/Strategies.tsx

@@ -1,5 +1,4 @@
 import CONSTANTS from '@/constants';
-import { allPoolsAtomUnSorted } from '@/store/pools';
 import { StrategyInfo, strategiesAtom } from '@/store/strategies.atoms';
 import { IStrategyProps, StrategyLiveStatus } from '@/strategies/IStrategy';
 import { getUniqueById } from '@/utils';
@@ -36,6 +35,7 @@ import { useAtomValue } from 'jotai';
 import mixpanel from 'mixpanel-browser';
 import React from 'react';
 import TVL from './TVL';
+import { allPoolsAtomUnSorted } from '@/store/protocols';
 
 const Strategies: React.FC = () => {
   const allPools = useAtomValue(allPoolsAtomUnSorted);

src/constants.ts

@@ -13,16 +13,18 @@ const LOGOS = {
 export type TokenName = 'USDT' | 'USDC' | 'ETH' | 'STRK' | 'WBTC' | 'DAI';
 
 const CONSTANTS = {
-  DEX_INCENTIVE_URL: '/strk-incentives/fetchFile?file=strk_grant.json',
+  DEX_INCENTIVE_URL:
+    'https://kx58j6x5me.execute-api.us-east-1.amazonaws.com/starknet/fetchFile?file=strk_grant.json',
   NOSTRA_DEGEN_INCENTIVE_URL: 'https://api.nostra.finance/query/pool_aprs',
   CARMINE_INCENTIVES_URL: '/carmine/api/v1/mainnet/defispring',
   CARMINE_URL: '/carmine/api/v2/mainnet',
   LENDING_INCENTIVES_URL:
-    '/strk-incentives/fetchFile?file=prod-api/lending/lending_strk_grant.json',
+    'https://kx58j6x5me.execute-api.us-east-1.amazonaws.com/starknet/fetchFile?file=prod-api/lending/lending_strk_grant.json',
   LOGOS,
   COMMUNITY_TG: 'https://t.me/+HQ_eHaXmF-1lZDc1',
   NOSTRA: {
-    LENDING_GRAPH_URL: '/nostra/app/data-yqlpb/endpoint/data/v1/action/find',
+    LENDING_GRAPH_URL:
+      'https://us-east-2.aws.data.mongodb-api.com/app/data-yqlpb/endpoint/data/v1/action/find',
   },
   ZKLEND: {
     BASE_APR_API: '/zklend/api/pools',

src/store/IDapp.store.ts

@@ -2,6 +2,7 @@ import { AtomWithQueryResult } from 'jotai-tanstack-query';
 import { APRSplit, PoolInfo, PoolMetadata } from './pools';
 import { TokenName } from '@/constants';
 import { StrategyAction } from '@/strategies/IStrategy';
+import { CustomAtomWithQueryResult } from '@/utils/customAtomWithQuery';
 
 export interface APRInfo {
   asset: TokenName;
@@ -20,7 +21,7 @@ export class IDapp<BaseAPYT> {
 
   addBaseAPYs<BaseAPYT>(
     pools: PoolInfo[],
-    data: AtomWithQueryResult<BaseAPYT, Error>,
+    data: CustomAtomWithQueryResult<BaseAPYT, Error>,
   ): PoolInfo[] {
     console.log(`lending: ${this.name}`, data);
     if (data.isError) {

src/store/ekobu.store.ts

@@ -1,5 +1,3 @@
-'use client';
-
 import CONSTANTS, { TokenName } from '@/constants';
 import { atom } from 'jotai';
 import { AtomWithQueryResult, atomWithQuery } from 'jotai-tanstack-query';

src/store/haiko.store.ts

@@ -1,5 +1,3 @@
-'use client';
-
 import CONSTANTS, { TokenName } from '@/constants';
 import {
   APRSplit,

src/store/index.ts

@@ -0,0 +1,3 @@
+import { createStore } from 'jotai';
+
+export const MY_STORE = createStore();

src/store/myswap.store.ts

@@ -1,5 +1,3 @@
-'use client';
-
 import {
   APRSplit,
   Category,

src/store/nostralending.store.ts

@@ -3,13 +3,14 @@ import {
   APRSplit,
   PoolInfo,
   PoolMetadata,
-  ProtocolAtoms,
+  ProtocolAtoms2,
   StrkLendingIncentivesAtom,
 } from './pools';
 import { atom } from 'jotai';
-import { AtomWithQueryResult, atomWithQuery } from 'jotai-tanstack-query';
+import { AtomWithQueryResult } from 'jotai-tanstack-query';
 import { LendingSpace } from './lending.base';
 import { IDapp } from './IDapp.store';
+import { customAtomWithFetch } from '@/utils/customAtomWithFetch';
 
 interface MyBaseAprDoc {
   _id: string;
@@ -119,27 +120,25 @@ export class NostraLending extends IDapp<LendingSpace.MyBaseAprDoc[]> {
 }
 
 export const nostraLending = new NostraLending();
-const NostraLendingAtoms: ProtocolAtoms = {
-  baseAPRs: atomWithQuery((get) => ({
-    queryKey: ['nostra_lending_base_aprs'],
-    queryFn: async ({ queryKey }) => {
-      const res = await fetch(CONSTANTS.NOSTRA.LENDING_GRAPH_URL, {
-        method: 'POST',
-        headers: {
-          Accept: 'application/json',
-          'Content-Type': 'application/json',
-        },
-        body: JSON.stringify({
-          dataSource: 'nostra-production',
-          database: 'prod-a-nostra-db',
-          collection: 'apyStats',
-          filter: { timestamp: { $gte: 1697500800 } },
-          sort: { timestamp: -1 },
-        }),
-      });
-      return res.json();
+const NostraLendingAtoms: ProtocolAtoms2 = {
+  baseAPRs: customAtomWithFetch({
+    queryKey: 'nostra_lending_base_aprs',
+    url: CONSTANTS.NOSTRA.LENDING_GRAPH_URL,
+    fetchOptions: {
+      method: 'POST',
+      headers: {
+        Accept: 'application/json',
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({
+        dataSource: 'nostra-production',
+        database: 'prod-a-nostra-db',
+        collection: 'apyStats',
+        filter: { timestamp: { $gte: 1697500800 } },
+        sort: { timestamp: -1 },
+      }),
     },
-  })),
+  }),
   pools: atom((get) => {
     const poolsInfo = get(StrkLendingIncentivesAtom);
     const empty: PoolInfo[] = [];