feat(hummingbot): add cancelAllOrders method and update types

Author: Sumeet Chougule

packages/core/package.json

@@ -60,6 +60,7 @@
         "@fal-ai/client": "1.2.0",
         "@types/uuid": "10.0.0",
         "ai": "3.4.33",
+        "@tavily/core": "^0.0.2",
         "anthropic-vertex-ai": "1.0.2",
         "fastembed": "1.14.1",
         "fastestsmallesttextencoderdecoder": "1.0.22",

packages/plugin-hummingbot/src/providers/order-provider.ts

@@ -130,6 +130,36 @@ export class OrderService {
     });
   }
 
+  async cancelAllOrders(exchange: string, symbol?: string): Promise<boolean> {
+    await this.checkRateLimit();
+
+    return this.retryOperation(async () => {
+      try {
+        const url = symbol ? `${this.baseUrl}/orders/${exchange}/${symbol}` : `${this.baseUrl}/orders/${exchange}`;
+        await axios.delete(url, {
+          headers: this.getHeaders()
+        });
+        return true;
+      } catch (error) {
+        if (error instanceof AxiosError) {
+          switch (error.response?.status) {
+            case 401:
+              throw new Error('Unauthorized: Invalid API key');
+            case 403:
+              throw new Error('Forbidden: Insufficient permissions');
+            case 429:
+              throw new Error('Rate limit exceeded. Please try again later.');
+            case 500:
+              throw new Error('Internal server error. Please try again later.');
+            default:
+              throw new Error(`Failed to cancel all orders: ${error.message}`);
+          }
+        }
+        throw error;
+      }
+    });
+  }
+
   async getOrder(orderId: string): Promise<OrderParams> {
     return this.retryOperation(async () => {
       try {

packages/plugin-hummingbot/src/types/index.ts

@@ -1,46 +1,60 @@
 export interface HummingbotConfig {
-  instance: {
-    url: string;
-    wsUrl: string;
-    apiKey: string;
-    instanceId: string;
-  };
+  apiUrl: string;
+  wsUrl: string;
+  apiKey: string;
+  strategy: StrategyConfig;
 }
 
 export interface MarketData {
-  exchange: string;
   symbol: string;
-  timestamp: number;
-  bid: number;
-  ask: number;
   lastPrice: number;
   volume24h: number;
+  price: number;
+  timestamp: number;
 }
 
 export interface OrderParams {
-  exchange: string;
   symbol: string;
   side: 'buy' | 'sell';
-  type: 'limit' | 'market';
   amount: number;
-  price?: number;
+  price: number;
+}
+
+export interface StrategyConfig {
+  symbol: string;
+  spread: number;
+  orderSize: number;
+  minProfitMargin: number;
+}
+
+export interface PortfolioBalance {
+  asset: string;
+  free: number;
+  total: number;
+}
+
+export interface HummingbotInstance {
+  id: string;
+  status: 'running' | 'stopped';
+  strategy: string;
+  config: HummingbotConfig;
 }
 
 export interface MarketMakingConfig {
   exchange: string;
   tradingPair: string;
   orderAmount: number;
-  orderLevels?: number;
-  maxOrderAge?: number;
-  inventorySkewEnabled?: boolean;
-  inventoryTargetBase?: number;
-  inventoryRangeMultiplier?: number;
+  orderLevels: number;
+  maxOrderAge: number;
+  inventorySkewEnabled: boolean;
+  inventoryTargetBase: number;
+  inventoryRangeMultiplier: number;
   bidSpread: number;
   askSpread: number;
-  minSpread?: number;
-  maxSpread?: number;
-  priceSource?: string;
-  minimumSpreadEnabled?: boolean;
-  pingPongEnabled?: boolean;
-  orderRefreshTime?: number;
+  minSpread: number;
+  maxSpread: number;
+  priceSource: string;
+  minimumSpreadEnabled: boolean;
+  pingPongEnabled: boolean;
+  orderRefreshTime: number;
 }