feat: added chart Indicator tool

package.json

@@ -55,6 +55,7 @@
     "date-fns": "^4.1.0",
     "framer-motion": "^11.18.1",
     "helius-sdk": "^1.4.1",
+    "indicatorts": "^2.2.1",
     "keyv": "4.5.4",
     "lodash": "^4.17.21",
     "lucide-react": "^0.468.0",

src/ai/generic/indicator.tsx

@@ -0,0 +1,84 @@
+import { checkIndicatorsAction } from "@/server/actions/indicator";
+import { z } from 'zod';
+
+// Define the schema for the tool's parameters
+const indicatorToolParameters = z.object({
+  indicator: z.enum(['rsi', 'sma', 'bb', 'macd']).describe('The indicator to check'),
+  parameters: z.object({
+    period: z.number().optional().describe('The period for the indicator'),
+    fast: z.number().optional(),
+    slow: z.number().optional(),
+    signal: z.number().optional(),
+  }),
+  contractAddress: z.string().describe('The contract address of the token to check'),
+  fromTimestamp: z.number().optional().describe('The timestamp to start checking from'),
+});
+
+// Define the tool
+export const indicatorTools = {
+  checkIndicators: {
+    displayName: '📈 Indicator Tool',
+    description: 'Check financial indicators like RSI, SMA, BB, and MACD for a given contract address.',
+    parameters: indicatorToolParameters,
+    execute: async (input: z.infer<typeof indicatorToolParameters>) => {
+        try {
+            // Call the existing checkIndicatorsAction function
+            const result = await checkIndicatorsAction(input);
+
+            if(!result?.data) {
+                return {
+                    success: false,
+                    error: 'Unable to fetch indicator data.',
+                };
+            }
+
+            if (result?.data?.success) {
+                return {
+                    success: true,
+                    data: result.data.data,
+                    suppressFollowUp: true,
+                };
+            } else {
+                return {
+                    success: false,
+                    error: result.data.error,
+                };
+            }
+        } catch (error) {
+            return {
+                success: false,
+                error: 'Unexpected error during indicator check',
+            };
+        }
+    },
+    render: (result: unknown) => {
+        const typedResult = result as {
+            success: boolean;
+            data?: number;
+            error?: string;
+        };
+
+        if (!typedResult.success) {
+            return (
+                <div className="relative overflow-hidden rounded-2xl bg-muted p-4">
+                <div className="flex items-center gap-3">
+                    <p className="text-md text-center">
+                    {typedResult.error || 'Unable to fetch indicator data.'}
+                    </p>
+                </div>
+                </div>
+            );
+        }
+
+        return (
+        <div className="space-y-4">
+            <div className="rounded-lg bg-muted p-4">
+            <p className="text-sm text-muted-foreground">Indicator Result</p>
+
+            <p className="font-medium">{typedResult.data}</p>
+            </div>
+        </div>
+        );
+    },
+  },
+};

src/server/actions/chart.ts

@@ -98,7 +98,7 @@ export async function getPriceHistoryFromCG(
   return parsed.prices.map(([time, value]) => ({ time, value }));
 }
 
-async function getTokenPools(
+export async function getTokenPools(
   contractAddress: string,
   network: string = 'solana',
 ): Promise<string> {
@@ -121,13 +121,13 @@ async function getTokenPools(
   return topPoolId;
 }
 
-async function getDexOhlcv(
+export async function getDexOhlcv(
   poolId: string,
   network: string = 'solana',
   timeFrame: TIMEFRAME = TIMEFRAME.MINUTES,
   aggregator?: string,
   beforeTimestamp?: number,
-): Promise<{ time: number; value: number }[]> {
+): Promise<number[][]> {
   if (!API_KEY) throw new Error('API key not found');
   const path = mapTimeframeToDexPath(timeFrame);
   const agg = validateAggregator(timeFrame, aggregator);
@@ -143,12 +143,8 @@ async function getDexOhlcv(
   const parsed = dexOhlcvApiResponseSchema.parse(data);
   const ohlcvList = parsed.data.attributes.ohlcv_list;
 
-  const reversedOhlcv = ohlcvList.map(([timestamp, open, high, low, close]) => {
-    const price = close ?? open ?? 0;
-    return { time: timestamp * 1000, value: price };
-  });
-  reversedOhlcv.reverse();
-  return reversedOhlcv;
+  ohlcvList.reverse();
+  return ohlcvList;
 }
 
 export async function getDexPriceHistory(
@@ -159,13 +155,17 @@ export async function getDexPriceHistory(
   beforeTimestamp?: number,
 ): Promise<{ time: number; value: number }[]> {
   const topPoolId = await getTokenPools(contractAddress, network);
-  return getDexOhlcv(
+  const ohlcvList = await getDexOhlcv(
     topPoolId,
     network,
     timeFrame,
     aggregator,
     beforeTimestamp,
   );
+  return ohlcvList.map(([timestamp, open, high, low, close, volume]) => {
+    const price = close ?? open ?? 0;
+    return { time: timestamp * 1000, value: price };
+  });
 }
 
 export async function getPriceHistory(

src/server/actions/indicator.ts

@@ -0,0 +1,74 @@
+import { actionClient, ActionResponse } from "@/lib/safe-action";
+import { z } from 'zod';
+import { getDexOhlcv, getTokenPools } from '@/server/actions/chart';
+import { rsi, sma, bb , macd } from 'indicatorts';
+import { TIMEFRAME } from "@/types/chart";
+
+const indicatorSchema = z.object({
+  indicator: z.enum(['rsi', 'sma', 'bb' , 'macd']),
+  parameters: z.object({
+    period: z.number().optional(),
+    fast: z.number().optional(),
+    slow: z.number().optional(),
+    signal: z.number().optional(),
+  }),
+  contractAddress: z.string(),
+  fromTimestamp: z.number().optional(),
+});
+
+function getClosingValues(olhcvList: number[][] , fromTimestamp?: number): number[] {
+
+  let closingValues;
+
+  if (fromTimestamp) {
+    closingValues = olhcvList.filter(([timestamp]) => timestamp >= fromTimestamp).map(([timestamp, open, high, low, close , volume]) => close);
+  } else {
+    closingValues = olhcvList.map(([timestamp, open, high, low, close , volume]) => close);
+  }
+
+  return closingValues;
+}
+
+export const checkIndicatorsAction = actionClient
+  .schema(indicatorSchema)
+  .action(async (input): Promise<ActionResponse<number>> => {
+    try {
+      const { indicator, parameters, contractAddress, fromTimestamp  } = input.parsedInput;
+
+      const topPoolId = await getTokenPools(contractAddress , 'solana');
+      const olhcvList = await getDexOhlcv(topPoolId, 'solana', TIMEFRAME.MINUTES, '1');
+      let result;
+
+      const closingValues = getClosingValues(olhcvList , fromTimestamp);
+
+      if(closingValues.length === 0) {
+        return { success: false, error: 'No closing values found' };
+      }
+
+      switch (indicator) {
+        case 'rsi':
+            const rsiResult = rsi(closingValues, { period: parameters.period || 14 });
+            result = rsiResult[rsiResult.length - 1];
+          break;
+        case 'sma':
+            const smaResult = sma(closingValues, { period: parameters.period || 14 });
+            result = smaResult[smaResult.length - 1];
+          break;
+        case 'bb':
+            const bbResult = bb(closingValues, { period: parameters.period || 14 });
+            result = bbResult.upper[bbResult.upper.length - 1];
+          break;    
+        case 'macd':
+            const macdResult = macd(closingValues, { fast: parameters.fast || 12, slow: parameters.slow || 26, signal: parameters.signal || 9 });
+            result = macdResult.macdLine[macdResult.macdLine.length - 1];
+          break;
+        default:
+          throw new Error('Unsupported indicator');
+      }
+
+      return { success: true, data: result };
+    } catch (error) {
+      return { success: false, error: error instanceof Error ? error.message : 'Unexpected error' };
+    }
+  });
+