push

package.json

@@ -12,6 +12,7 @@
     "@coral-xyz/anchor": "^0.29.0",
     "@hxronetwork/dexterity-ts": "^1.6.33",
     "@solana/web3.js": "^1.90.0",
+    "dotenv": "^16.4.5",
     "node-telegram-bot-api": "^0.64.0"
   }
 }

src/bot-utils/cancelTraderSubHandler.ts

@@ -1,3 +1,22 @@
 export async function cancelTraderSub() {
+  const baseUrl = process.env.TRADING_API_URL || "http://localhost:3000";
+  const url = `${baseUrl}/cancel-subscription`;
 
+  try {
+    const response = await fetch(url, {
+      method: "GET",
+      headers: {
+        "Content-Type": "application/json",
+      },
+    });
+
+    if (!response.ok) {
+      throw new Error(`HTTP error! status: ${response.status}`);
+    }
+
+    const data = await response.json();
+    return data;
+  } catch (error) {
+    console.error("Error making request:", error);
+  }
 }

src/bot-utils/newTraderSubHandler.ts

@@ -1,3 +1,23 @@
 export async function newTraderSubHandler(trader: string) {
-
-}
+    const baseUrl = process.env.TRADING_API_URL || 'http://localhost:3000';
+    const url = `${baseUrl}/new-subscription?trg=${trader}`;
+
+    try {
+      const response = await fetch(url, {
+        method: "GET",
+        headers: {
+          "Content-Type": "application/json",
+        },
+      });
+
+      if (!response.ok) {
+        throw new Error(`HTTP error! status: ${response.status}`);
+      }
+
+      const data = await response.json();
+      return data;
+    } catch (error) {
+      console.error("Error making request:", error);
+    }
+  }
+

src/index.ts

@@ -6,6 +6,8 @@ import {
   handleNewSubscription,
 } from "./api-utils/subscritionHandler";
 import { tradeHandler } from "./api-utils/tradeHandler";
+import * as dotenv from 'dotenv';
+dotenv.config();
 
 const AppState = new Map<string, any>();