feat(vendor-ccxt): enable ccxt pro (#469)

No-Trade-No-Life · Feb 24, 2024 · 4fb6153 · 4fb6153
1 parent add6255
commit 4fb6153
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 5 deletions.
diff --git a/apps/vendor-ccxt/src/index.ts b/apps/vendor-ccxt/src/index.ts
@@ -67,7 +67,7 @@ interface IGeneralSpecificRelation {
   };
   console.info(formatTime(Date.now()), 'init', EXCHANGE_ID, CCXT_PARAMS);
   // @ts-ignore
-  const ex: Exchange = new ccxt[EXCHANGE_ID](CCXT_PARAMS);
+  const ex: Exchange = new ccxt.pro[EXCHANGE_ID](CCXT_PARAMS);
 
   let accountInfoLock = false;
 
@@ -334,7 +334,7 @@ interface IGeneralSpecificRelation {
     }
     return (
       ex.has['watchTicker']
-        ? defer(() => ex.watchTicker(symbol))
+        ? defer(() => ex.watchTicker(symbol)).pipe(repeat())
         : defer(() => ex.fetchTicker(symbol)).pipe(
             //
             repeat({ delay: 1000 }),
@@ -387,7 +387,7 @@ interface IGeneralSpecificRelation {
     }
     return (
       ex.has['watchOHLCV']
-        ? defer(() => ex.watchOHLCV(symbol, timeframe))
+        ? defer(() => ex.watchOHLCV(symbol, timeframe)).pipe(repeat())
         : defer(() => {
             const since = Date.now() - 3 * period_in_sec * 1000;
             return ex.fetchOHLCV(symbol, timeframe, since);
@@ -424,15 +424,15 @@ interface IGeneralSpecificRelation {
       mergeMap(() => {
         const balance$ = (
           ex.has['watchBalance']
-            ? defer(() => ex.watchBalance())
+            ? defer(() => ex.watchBalance()).pipe(repeat())
             : defer(() => ex.fetchBalance()).pipe(repeat({ delay: 1000 }))
         ).pipe(
           //
           shareReplay(1),
         );
         const positions$ = (
           ex.has['watchPositions']
-            ? defer(() => ex.watchPositions())
+            ? defer(() => ex.watchPositions()).pipe(repeat())
             : defer(() => ex.fetchPositions()).pipe(
                 //
                 repeat({ delay: 1000 }),

diff --git a/common/changes/@yuants/vendor-ccxt/2024-02-24-15-16.json b/common/changes/@yuants/vendor-ccxt/2024-02-24-15-16.json
@@ -0,0 +1,10 @@
+{
+  "changes": [
+    {
+      "packageName": "@yuants/vendor-ccxt",
+      "comment": "enable ccxt pro",
+      "type": "patch"
+    }
+  ],
+  "packageName": "@yuants/vendor-ccxt"
+}