feat: meteora actions

src/actions/index.ts

@@ -91,6 +91,11 @@ import createOrcaCLMMAction from "./orca/createOrcaCLMM";
 import fetchOrcaPositionsAction from "./orca/fetchOrcaPositions";
 import openOrcaCenteredPositionWithLiquidityAction from "./orca/openOrcaCenteredPositionWithLiquidity";
 import openOrcaSingleSidedPositionAction from "./orca/openOrcaSingleSidedPosition";
+import removeLiquidityFromMeteoraDLMMPositionOrClosePositionAction from "./meteora/removeLiquidityFromDLMMPositionOrClosePosition";
+import createMeteoraDLMMPoolAction from "./meteora/createMeteoraDLMMPool";
+import getMeteoraDLMMPositionByUserAction from "./meteora/getMeteoraDLMMPositionByUser";
+import createMeteoraDLMMPositionAction from "./meteora/createMeteoraDLMMPosition";
+import createDynamicMeteoraAMMPoolAction from "./meteora/createMeteoraDynamicAMMPool";
 import getDebridgeSupportedChainsAction from "./debridge/getSupportedChains";
 import getDebridgeTokensInfoAction from "./debridge/getTokensInfo";
 import createDebridgeBridgeOrderAction from "./debridge/createBridgeOrder";
@@ -200,6 +205,12 @@ export const ACTIONS = {
   SOLUTIOFI_BURN_TOKENS_ACTION: burnTokensAction,
   SOLUTIOFI_MERGE_TOKENS_ACTION: mergeTokensAction,
   SOLUTIOFI_SPREAD_TOKEN_ACTION: spreadTokenAction,
+  REMOVE_LIQUIDITY_FROM_DLMM_POSITION_OR_CLOSE_POSITION_ACTION:
+    removeLiquidityFromMeteoraDLMMPositionOrClosePositionAction,
+  CREATE_METEORA_DLMM_POOL_ACTION: createMeteoraDLMMPoolAction,
+  GET_METEORA_DLMM_POSITION_BY_USER_ACTION: getMeteoraDLMMPositionByUserAction,
+  CREATE_METEORA_DLMM_POSITION_ACTION: createMeteoraDLMMPositionAction,
+  CREATE_DYNAMIC_METEORA_AMM_POOL_ACTION: createDynamicMeteoraAMMPoolAction,
 };
 
 export type { Action, ActionExample, Handler } from "../types/action";

src/actions/meteora/createMeteoraDLMMPool.ts

@@ -0,0 +1,79 @@
+import { z } from "zod";
+import { Action } from "../../types";
+import { ActivationType } from "@meteora-ag/dlmm";
+import { PublicKey } from "@solana/web3.js";
+import { createMeteoraDlmmPool } from "../../tools";
+import { BN } from "bn.js";
+
+const createMeteoraDLMMPoolAction: Action = {
+  name: "CREATE_METEORA_DLMM_POOL_ACTION",
+  description: "Create a Meteora DLMM pool",
+  similes: [
+    "create a meteora dlmm pool",
+    "create a dlmm pool",
+    "create a meteora pool",
+  ],
+  examples: [
+    [
+      {
+        input: {
+          binStep: 100,
+          tokenAMint: "4jRr...",
+          tokenBMint: "8nRi...",
+          initialPrice: 1,
+          priceRoundingUp: true,
+          feeBps: 100,
+          activationType: "Timestamp",
+          hasAlphaVault: true,
+          activationPoint: 100,
+        },
+        output: {
+          status: "success",
+          signature: "33jHD...",
+        },
+        explanation: "Create a Meteora DLMM pool",
+      },
+    ],
+  ],
+  schema: z.object({
+    binStep: z.number().int().positive(),
+    tokenAMint: z.string().nonempty(),
+    tokenBMint: z.string().nonempty(),
+    initialPrice: z.number().nonnegative(),
+    priceRoundingUp: z.boolean().optional(),
+    feeBps: z.number().int().positive().max(500),
+    activationType: z.nativeEnum(ActivationType),
+    hasAlphaVault: z.boolean().optional(),
+    activationPoint: z.number().int().optional(),
+  }),
+  handler: async (agent, input) => {
+    try {
+      const signature = await createMeteoraDlmmPool(
+        agent,
+        input.binStep,
+        new PublicKey(input.tokenAMint),
+        new PublicKey(input.tokenBMint),
+        input.initialPrice,
+        input.priceRoundingUp,
+        input.feeBps,
+        input.activationType,
+        input.hasAlphaVault,
+        input.activationPoint ? new BN(input.activationPoint) : undefined,
+      );
+
+      return {
+        status: "success",
+        signature,
+      };
+    } catch (error) {
+      console.log(error);
+      return {
+        status: "error",
+        // @ts-expect-error error message is a string
+        message: `An error occurred while creating a Meteora DLMM pool: ${error.message}`,
+      };
+    }
+  },
+};
+
+export default createMeteoraDLMMPoolAction;

src/actions/meteora/createMeteoraDLMMPosition.ts

@@ -0,0 +1,65 @@
+import { z } from "zod";
+import { Action } from "../../types";
+import createMeteoraDLMMPosition from "../../tools/meteora/create_meteora_dlmm_position";
+
+const createMeteoraDLMMPositionAction: Action = {
+  name: "CREATE_METEORA_DLMM_POSITION_ACTION",
+  description: "Create a Meteora DLMM position",
+  similes: [
+    "Create a Meteora DLMM position",
+    "open a Meteora DLMM position",
+    "start a Meteora DLMM position",
+  ],
+  examples: [
+    [
+      {
+        input: {
+          poolAddress: "poolAddress",
+          tokenAAmount: 100,
+          tokenBAmount: 100,
+          strategy: "strategy",
+          rangeInterval: 10,
+        },
+        output: {
+          status: "success",
+          data: {
+            txSig: "txSig",
+            positionAddress: "positionAddress",
+          },
+        },
+        explanation: "Create a Meteora DLMM position",
+      },
+    ],
+  ],
+  schema: z.object({
+    poolAddress: z.string(),
+    tokenAAmount: z.number(),
+    tokenBAmount: z.number(),
+    strategy: z.string(),
+    rangeInterval: z.number().optional(),
+  }),
+  handler: async (agent, input) => {
+    try {
+      const res = await createMeteoraDLMMPosition(
+        agent,
+        input.poolAddress,
+        input.tokenAAmount,
+        input.tokenBAmount,
+        input.strategy,
+      );
+
+      return {
+        status: "success",
+        data: res,
+      };
+    } catch (e) {
+      return {
+        status: "error",
+        // @ts-expect-error e is an object
+        error: e.message,
+      };
+    }
+  },
+};
+
+export default createMeteoraDLMMPositionAction;

src/actions/meteora/createMeteoraDynamicAMMPool.ts

@@ -0,0 +1,86 @@
+import { z } from "zod";
+import { Action } from "../../types";
+import { createMeteoraDynamicAMMPool } from "../../tools";
+import { ActivationType } from "@meteora-ag/dlmm";
+import { PublicKey } from "@solana/web3.js";
+import BN from "bn.js";
+
+const createDynamicMeteoraAMMPoolAction: Action = {
+  name: "CREATE_DYNAMIC_METEORA_AMM_POOL_ACTION",
+  description: "Create a dynamic Meteora AMM pool",
+  similes: [
+    "Create a dynamic Meteora AMM pool",
+    "open a dynamic Meteora AMM pool",
+    "start a dynamic Meteora AMM pool",
+  ],
+  examples: [
+    [
+      {
+        input: {
+          tokenAMint: "So11111111111111111111111111111111111111112",
+          tokenBMint: "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
+          tokenAAmount: 100,
+          tokenBAmount: 100,
+          tradeFeeNumerator: 25,
+          activationType: "Timestamp",
+          activationPoint: null,
+          hasAlphaVault: false,
+          padding: Array(90).fill(0),
+        },
+        output: {
+          status: "success",
+          data: {
+            signature: "4jRr...",
+          },
+        },
+        explanation: "Create a dynamic Meteora AMM pool",
+      },
+    ],
+  ],
+  schema: z.object({
+    tokenAMint: z.string(),
+    tokenBMint: z.string(),
+    tokenAAmount: z.number(),
+    tokenBAmount: z.number(),
+    tradeFeeNumerator: z.number(),
+    activationType: z.nativeEnum(ActivationType),
+    activationPoint: z.null(),
+    hasAlphaVault: z.boolean(),
+    padding: z.array(z.number()).optional(),
+  }),
+  handler: async (agent, input) => {
+    try {
+      const res = await createMeteoraDynamicAMMPool(
+        agent,
+        new PublicKey(input.tokenAMint),
+        new PublicKey(input.tokenBMint),
+        new BN(input.tokenAAmount),
+        new BN(input.tokenBAmount),
+        {
+          tradeFeeNumerator: input.tradeFeeNumerator,
+          padding: input.padding ?? Array(90).fill(0),
+          hasAlphaVault: input.hasAlphaVault,
+          activationType: input.activationType,
+          activationPoint: input.activationPoint
+            ? new BN(input.activationPoint)
+            : null,
+        },
+      );
+
+      return {
+        status: "success",
+        data: {
+          signature: res,
+        },
+      };
+    } catch (e) {
+      return {
+        status: "error",
+        // @ts-expect-error - e is an Error object
+        error: e.message,
+      };
+    }
+  },
+};
+
+export default createDynamicMeteoraAMMPoolAction;

src/actions/meteora/getMeteoraDLMMPositionByUser.ts

@@ -0,0 +1,67 @@
+import { z } from "zod";
+import { Action } from "../../types";
+import getMeteoraDLMMPositionsByUser from "../../tools/meteora/get_meteora_dlmm_positions_by_user";
+
+const getMeteoraDLMMPositionByUserAction: Action = {
+  name: "GET_METEORA_DLMM_POSITION_BY_USER_ACTION",
+  description: "Get Meteora DLMM position by user",
+  similes: [
+    "Get Meteora DLMM position by user",
+    "get my meteora dlmm position",
+    "get my wallet's meteora dlmm position",
+  ],
+  examples: [
+    [
+      {
+        input: {
+          userPubKey: "8Uikj...",
+        },
+        output: {
+          status: "success",
+          data: {
+            pools: {
+              poolAddress: "4jrR...",
+              tokenX: "EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v",
+              tokenY: "So11111111111111111111111111111111111111112",
+              positions: [
+                {
+                  positionAddress: "4jrR...",
+                  xAmount: 100,
+                  yAmount: 100,
+                  xReward: 100,
+                  yReward: 100,
+                  xFee: 100,
+                  yFee: 100,
+                },
+              ],
+            },
+          },
+        },
+        explanation: "Get Meteora DLMM positions by user",
+      },
+    ],
+  ],
+  schema: z.object({
+    userPublicKey: z.string().optional(),
+  }),
+  handler: async (agent, input) => {
+    try {
+      const res = await getMeteoraDLMMPositionsByUser(
+        agent,
+        input.userPublicKey,
+      );
+      return {
+        status: "success",
+        data: res,
+      };
+    } catch (e) {
+      return {
+        status: "error",
+        // @ts-expect-error error has a message property
+        message: e.message,
+      };
+    }
+  },
+};
+
+export default getMeteoraDLMMPositionByUserAction;

src/actions/meteora/removeLiquidityFromDLMMPositionOrClosePosition.ts

@@ -0,0 +1,64 @@
+import { z } from "zod";
+import { Action } from "../../types";
+import removeOrCloseLiquidityFromMeteoraDLMMPosition from "../../tools/meteora/remove_liquidity_from_meteora_dlmm_position";
+
+const removeLiquidityFromMeteoraDLMMPositionOrClosePositionAction: Action = {
+  name: "REMOVE_LIQUIDITY_FROM_DLMM_POSITION_OR_CLOSE_POSITION_ACTION",
+  description: "Remove liquidity from Meteora DLMM position or close position",
+  similes: [
+    "remove liquidity from a dlmm position",
+    "close a meteora dlmm position",
+    "remove liquidity from a meteora dlmm position",
+  ],
+  examples: [
+    [
+      {
+        input: {
+          poolAddress: "4jRr...",
+          positionAddress: "8nRi...",
+          percentageOfLiquidityToRemove: 100,
+          shouldClaimAndClose: true,
+        },
+        output: {
+          status: "success",
+          data: {
+            txSig: "33jHD...",
+            positionAddress: "8nRi...",
+          },
+        },
+        explanation:
+          "Close a liquidity a Meteora DLMM position and claim the rewards",
+      },
+    ],
+  ],
+  schema: z.object({
+    poolAddress: z.string().nonempty(),
+    positionAddress: z.string().nonempty(),
+    percentageOfLiquidityToRemove: z.number().int().positive(),
+    shouldClaimAndClose: z.boolean().optional(),
+  }),
+  handler: async (agent, input) => {
+    try {
+      const result = await removeOrCloseLiquidityFromMeteoraDLMMPosition(
+        agent,
+        input.poolAddress,
+        input.positionAddress,
+        input.percentageOfLiquidityToRemove,
+        input.shouldClaimAndClose,
+      );
+
+      return {
+        status: "success",
+        data: result,
+      };
+    } catch (error) {
+      return {
+        status: "error",
+        // @ts-expect-error error message is a string
+        message: `An error occurred while removing liquidity from Meteora DLMM position or closing position: ${error.message}`,
+      };
+    }
+  },
+};
+
+export default removeLiquidityFromMeteoraDLMMPositionOrClosePositionAction;