Core Functions: Low-Level Order and Fetch Primitives

COMMIT_BUY_FN(
  { symbol, amountUSDT, averagePrice }: IParams,
  binance: Binance
): Promise<number>

import Binance from "node-binance-api";
import { COMMIT_BUY_FN } from "./src/function/commit_buy.function";

const binance = new Binance().options({
  APIKEY: process.env.CC_BINANCE_API_KEY,
  APISECRET: process.env.CC_BINANCE_API_SECRET,
});

// Place a guarded 20 USDT limit BUY on SOLUSDT at the current market price
const fillPrice = await COMMIT_BUY_FN(
  { symbol: "SOLUSDT", amountUSDT: 20, averagePrice: 77.56 },
  binance
);

if (fillPrice === 0) {
  console.log("Buy skipped: open orders exist or insufficient USDT balance.");
} else {
  console.log(`Filled at average price: ${fillPrice}`);
}

COMMIT_SELL_FN(
  { symbol, amountUSDT, averagePrice }: IParams,
  binance: Binance
): Promise<number>

import { COMMIT_SELL_FN } from "./src/function/commit_sell.function";

// Sell 20 USDT worth of SOL at ~77.40 (0.999 × 77.56)
const fillPrice = await COMMIT_SELL_FN(
  { symbol: "SOLUSDT", amountUSDT: 20, averagePrice: 77.56 },
  binance
);
console.log(`Sold at average price: ${fillPrice}`);

COMMIT_CANCEL_FN(
  { symbol, averagePrice }: IParams,
  binance: Binance
): Promise<number>

import { COMMIT_CANCEL_FN } from "./src/function/commit_cancel.function";

// Flatten the entire SOLUSDT position to cash
const exitPrice = await COMMIT_CANCEL_FN(
  { symbol: "SOLUSDT", averagePrice: 77.56 },
  binance
);

if (exitPrice === 0) {
  console.log("Nothing sold — balance was below minQty (dust).");
} else {
  console.log(`Exited at average price: ${exitPrice}`);
}

COMMIT_TRADE_FN(
  { symbol, amountUSDT, averagePrice, takeProfitPrice, stopLossPrice }: IParams,
  binance: Binance
): Promise<0 | { status: string; content: string }>

import { COMMIT_TRADE_FN } from "./src/function/commit_trade.function";

const result = await COMMIT_TRADE_FN(
  {
    symbol: "SOLUSDT",
    amountUSDT: 20,
    averagePrice: 77.56,
    takeProfitPrice: 85.0,
    stopLossPrice: 74.0,
  },
  binance
);

if (result === 0) {
  console.log("Trade skipped: open orders exist or insufficient USDT.");
} else {
  console.log(result.content);
  // "Бот купил SOLUSDT (в размере 0.25) по цене 77.56 (19.39$) и выставил OCO ордер ..."
}

FETCH_BALANCE_FN(binance: Binance): Promise<Record<string, { usdt: number; quantity: number }>>

const SYMBOL_LIST = [
  "BTCUSDT",
  "POLUSDT",
  "ZECUSDT",
  "HYPEUSDT",
  "DOGEUSDT",
  "SOLUSDT",
  "PENGUUSDT",
  "TRXUSDT",
  "HBARUSDT",
  "NEARUSDT",
  "FARTCOINUSDT",
  "ETHUSDT",
  "PUMPUSDT",
];

import { FETCH_BALANCE_FN } from "./src/function/fetch_balance.function";

const balances = await FETCH_BALANCE_FN(binance);
// {
//   SOL: { quantity: 0.25, usdt: 19.39 },
//   BTC: { quantity: 0,    usdt: 0 },
//   ETH: { quantity: 0,    usdt: 0 },
//   ...
// }
console.log(`SOL balance: ${balances.SOL.quantity} SOL (${balances.SOL.usdt} USDT)`);

FETCH_PRICE_FN({ symbol }: IParams, binance: Binance): Promise<number>

import { FETCH_PRICE_FN } from "./src/function/fetch_price.function";

const price = await FETCH_PRICE_FN({ symbol: "SOLUSDT" }, binance);
console.log(price); // e.g. 77.56

FETCH_FIAT_FN(binance: Binance): Promise<number>

import { FETCH_FIAT_FN } from "./src/function/fetch_fiat.function";

const totalUsdt = await FETCH_FIAT_FN(binance);
console.log(`Total USDT (free + locked): ${totalUsdt}`);

FETCH_ORDERS_FN(
  { symbol, limit }: IParams,
  binance: Binance
): Promise<IOrderData[]>

interface IOrderData {
  symbol: string;
  orderId: number;
  status: "FILLED" | "CANCELED" | "NEW";
  amount: string;       // origQty
  executedQty: string;
  price: string;
  time: string;         // ISO 8601
  side: "BUY" | "SELL";
}

import { FETCH_ORDERS_FN } from "./src/function/fetch_orders.function";

const orders = await FETCH_ORDERS_FN({ symbol: "SOLUSDT", limit: 25 }, binance);

for (const order of orders) {
  console.log(`[${order.time}] ${order.side} ${order.executedQty} @ ${order.price} — ${order.status}`);
}

FETCH_PNL_FN(
  { orders, symbol }: IParams,
  binance: Binance
): Promise<IDailyPnL[]>

interface IDailyPnL {
  date: string;         // ISO 8601 date of the trading day
  pnl: string;          // realized PnL for the day, formatted to tickSize
  walletCost: string;   // average buy cost of matched trades (VWAP of buys), formatted to tickSize
  amountQty: string;    // cumulative coin balance at end of day, formatted to stepSize
  amountUSDT: string;   // amountQty × daily VWAP, formatted to tickSize
  averagePrice: string; // daily VWAP from 1h candles, formatted to tickSize
}

import { FETCH_ORDERS_FN } from "./src/function/fetch_orders.function";
import { FETCH_PNL_FN } from "./src/function/fetch_pnl";

// Step 1: fetch recent order history
const orders = await FETCH_ORDERS_FN({ symbol: "SOLUSDT", limit: 50 }, binance);

// Step 2: compute daily PnL from those orders
const pnlHistory = await FETCH_PNL_FN({ orders, symbol: "SOLUSDT" }, binance);

for (const day of pnlHistory) {
  console.log(`${day.date}: PnL = ${day.pnl} USDT | Avg price = ${day.averagePrice} | Holdings = ${day.amountQty} (${day.amountUSDT} USDT)`);
}