feat(exchanges): add paper trading (#38)

* feat(exchanges): add `destroy` method

* feat(exchanges): add `isPaper` property to exchange instance

packages/bot/src/channels/orders/order-synchronizer-ws.watcher.ts

@@ -25,7 +25,7 @@ export class OrderSynchronizerWsWatcher extends OrderSynchronizerWatcher {
 
   override async disable() {
     await super.disable();
-    await this.exchangeService.ccxt.close();
+    await this.exchangeService.destroy();
   }
 
   protected async watchOrders() {

packages/db/src/xprisma.ts

@@ -87,6 +87,7 @@ const xprismaClient = prismaClient.$extends({
           secretKey: true,
           password: true,
           isDemoAccount: true,
+          isPaperAccount: true,
         },
         compute(exchangeAccount) {
           return {
@@ -95,6 +96,7 @@ const xprismaClient = prismaClient.$extends({
             secretKey: exchangeAccount.secretKey,
             password: exchangeAccount.password,
             isDemoAccount: exchangeAccount.isDemoAccount,
+            isPaperAccount: exchangeAccount.isPaperAccount,
           };
         },
       },

packages/exchanges/package.json

@@ -8,7 +8,7 @@
   "types": "src/index.ts",
   "exports": {
     ".": "./src/index.ts",
-    "./client": "./src/client/cache/providers/memory-cache.provider.ts",
+    "./client": "./src/client/index.ts",
     "./server": "./src/server/cache/providers/prisma-cache.provider.ts",
     "./dist": "./src/index.ts"
   },

packages/exchanges/src/client/index.ts

@@ -0,0 +1,2 @@
+export * from "./constants.js";
+export * from "./cache/providers/memory-cache.provider.js";

packages/exchanges/src/exchange.provider.ts

@@ -97,7 +97,7 @@ export class ExchangeProvider {
       return;
     }
 
-    void exchange.ccxt.close();
+    void exchange.destroy();
     delete this.privateExchanges[id];
 
     console.log(

packages/exchanges/src/exchanges/ccxt/exchange.ts

@@ -50,9 +50,10 @@ import type { IExchange, IExchangeCredentials } from "../../types/index.js";
 import { cache } from "../../cache.js";
 import { fetcher } from "../../utils/next/fetcher.js";
 import { normalize } from "./normalize.js";
-import { exchangeCodeMapCCXT } from "./constants.js";
+import { exchangeCodeMapCCXT } from "../../client/constants.js";
 
 export class CCXTExchange implements IExchange {
+  public isPaper = false;
   public exchangeCode: ExchangeCode;
   public ccxt: Exchange;
 
@@ -81,6 +82,10 @@ export class CCXTExchange implements IExchange {
     }
   }
 
+  async destroy() {
+    await this.ccxt.close();
+  }
+
   async loadMarkets(): Promise<Dictionary<Market>> {
     const cacheProvider = cache.getCacheProvider();
     return cacheProvider.getMarkets(this.exchangeCode, this.ccxt);

packages/exchanges/src/exchanges/ccxt/factory.ts

@@ -1,8 +1,12 @@
 import { ExchangeCode } from "@opentrader/types";
 import { CCXTExchange } from "./exchange.js";
+import { PaperExchange } from "./paper-exchange.js";
 import type { IExchangeCredentials } from "../../types/index.js";
 
 export function createExchange(exchangeCode: ExchangeCode) {
-  return (credentials?: IExchangeCredentials) =>
-    new CCXTExchange(exchangeCode, credentials);
+  return (credentials?: IExchangeCredentials) => {
+    if (credentials?.isPaperAccount) return new PaperExchange(exchangeCode);
+
+    return new CCXTExchange(exchangeCode, credentials);
+  };
 }