cleanup

Author: tripolskypetr

packages/api-binance/src/helper/holdUSDT.ts

@@ -196,10 +196,12 @@ export const createHoldUSDT = (binance: Binance, logger: LoggerService) => {
 
   const holdUSDT = async (sellPercent = 1.01, usdtAmount = 100) => {
     if (await hasOpenOrders('ETHUSDT')) {
+      logger.log("has orders");
       return;
     }
 
     if ((await getBalance('USDT')) <= usdtAmount * 1.03) {
+      logger.log("no funds");
       return;
     }
 

src/config/params.ts

@@ -15,6 +15,5 @@ export const CC_TRADE_AMOUNT = 100;
 export const CC_TRADE_PERCENT = 1.01;
 
 export const CC_PLAYSOUND_MINUTES = 15;
-export const CC_FREEZE_SECONDS = 30;
 export const CC_LIVENESS_DELAY = 5_000;
 export const CC_NET_TICK = 5_000;

src/pages/MainPage/emitters.ts

@@ -1,13 +1,12 @@
-import { Subject, Source, Operator, singlerun } from "react-declarative";
+import { Subject, Source, singlerun } from "react-declarative";
 
-import dayjs, { Dayjs } from "dayjs";
+import dayjs from "dayjs";
 
-import getTimeLabel from "../../utils/getTimeLabel";
 import playSound, { Sound } from "../../utils/playSound";
 
 import { doNotify, doTrade, doRollback, errorSubject } from "./api";
 
-import { CC_FREEZE_SECONDS, CC_PLAYSOUND_MINUTES, CC_TRADE_AMOUNT, CC_TRADE_PERCENT } from "../../config/params";
+import { CC_PLAYSOUND_MINUTES, CC_TRADE_AMOUNT, CC_TRADE_PERCENT } from "../../config/params";
 
 export const predictEmitter = new Subject<"train" | "upward" | "downward" | "untrained" | null>();
 
@@ -34,24 +33,9 @@ soundEmitter.connect((stamp) => {
     }
 });
 
-const upwardEmitter = Source.multicast(() => {
-    let lastDownward: Dayjs | null = null;
-    return predictEmitter
-        .operator(Operator.skip(1))
-        .tap((trend) => {
-            if (trend === "downward") {
-                lastDownward = dayjs();
-            }
-        })
-        .filter(() => {
-            if (lastDownward && dayjs().diff(lastDownward, 'second') <= CC_FREEZE_SECONDS) {
-                console.log(`ambiguously rise prediction skipped ${getTimeLabel(new Date())}`)
-                return false;
-            }
-            return true;
-        })
-        .filter((trend) => trend === "upward")
-});
+const upwardEmitter = Source.multicast(() => predictEmitter
+    .filter((trend) => trend === "upward")
+);
 
 const downwardEmitter = Source.multicast(() => predictEmitter
     .filter((trend) => trend === "downward")