feat: draft

Author: ilinikh.a1

.eslintrc.js

@@ -21,5 +21,6 @@ module.exports = {
     '@typescript-eslint/explicit-function-return-type': 'off',
     '@typescript-eslint/explicit-module-boundary-types': 'off',
     '@typescript-eslint/no-explicit-any': 'off',
+    '@typescript-eslint/no-misused-new': 'off'
   },
 };

examples/index.ts

@@ -0,0 +1,61 @@
+import { ApiAccount } from '@app/bingx/account/api-account';
+import { BingxRequestInterface } from '@app/bingx/endpoints/bingx-request.interface';
+import { BingxResponseInterface } from '@app/bingx/endpoints/bingx-response.interface';
+import { EndpointInterface } from '@app/bingx/endpoints/endpoint.interface';
+import { BingxRequest } from '@app/bingx/endpoints/bingx-request';
+import { BingxGenerateListenKeyEndpoint } from '@app/bingx/endpoints/bingx-generate-listen-key-endpoint';
+
+async function examples() {
+  /** Basic usage **/
+  const account = new ApiAccount('aaaa', 'ddd');
+
+  const listenKeyResponseBingxResponse = await new BingxRequest(
+    new BingxGenerateListenKeyEndpoint(account),
+  ).getResponse();
+
+  console.log(listenKeyResponseBingxResponse);
+
+  /**
+   * {
+   *   code: 0,
+   *   msg: "success",
+   *   data: {
+   *     listenKey: 'dawddawdda'
+   *   }
+   * }
+   */
+
+  /** Override Request Class **/
+  class RmqCustomRequest<T> implements BingxRequestInterface<T> {
+    constructor(private readonly endpoint: EndpointInterface<T>) {}
+
+    async getEndpoint(): Promise<Readonly<EndpointInterface<T>>> {
+      return this.endpoint;
+    }
+
+    getResponse(): Promise<Readonly<BingxResponseInterface<T>>> {
+      /**
+       * Logic to send request via rmq
+       */
+
+      return {} as never;
+    }
+  }
+
+  const response = await new RmqCustomRequest(
+    new BingxGenerateListenKeyEndpoint(account),
+  ).getResponse();
+
+  console.log(response);
+  /**
+   * {
+   *   code: 0,
+   *   msg: "success",
+   *   data: {
+   *     listenKey: 'dawddawdda'
+   *   }
+   * }
+   */
+}
+
+examples().then();

package-lock.json

@@ -20,11 +20,15 @@
     "test:e2e": "jest --config ./test/jest-e2e.json"
   },
   "dependencies": {
+    "@nestjs/axios": "^3.0.0",
     "@nestjs/common": "^10.0.0",
     "@nestjs/core": "^10.0.0",
     "@nestjs/platform-express": "^10.0.0",
+    "axios": "^1.5.1",
+    "axios-request-throttle": "^1.0.0",
     "reflect-metadata": "^0.1.13",
-    "rxjs": "^7.8.1"
+    "rxjs": "^7.8.1",
+    "ws": "^8.14.2"
   },
   "devDependencies": {
     "@nestjs/cli": "^10.0.0",
@@ -34,6 +38,7 @@
     "@types/jest": "^29.5.2",
     "@types/node": "^20.3.1",
     "@types/supertest": "^2.0.12",
+    "@types/ws": "^8.5.6",
     "@typescript-eslint/eslint-plugin": "^6.0.0",
     "@typescript-eslint/parser": "^6.0.0",
     "eslint": "^8.42.0",

package.json

@@ -1,6 +1,5 @@
 import { Module } from '@nestjs/common';
 import { HttpModule, HttpService } from '@nestjs/axios';
-import { BingxTradeService } from '@app/bingx/services/bingx.trade.service';
 import { BingxListenKeyService } from '@app/bingx/services/bingx-listen-key.service';
 import { BingxWebsocketClient } from '@app/bingx/websocket/bingx-websocket.client';
 import axiosThrottle from 'axios-request-throttle';
@@ -18,13 +17,11 @@ import { BingxMarketWebsocketClient } from '@app/bingx/websocket/bingx-market-we
     }),
   ],
   providers: [
-    BingxTradeService,
     BingxListenKeyService,
     BingxWebsocketClient,
     BingxMarketWebsocketClient,
   ],
   exports: [
-    BingxTradeService,
     BingxListenKeyService,
     BingxWebsocketClient,
     BingxMarketWebsocketClient,

src/bingx/bingx.module.ts

@@ -1,16 +1,22 @@
-import { Endpoint } from '@app/bingx/request/endpoint';
-import { EndpointInterface } from '@app/bingx/request/endpoint.interface';
+import { Endpoint } from '@app/bingx/endpoints/endpoint';
+import { EndpointInterface } from '@app/bingx/endpoints/endpoint.interface';
 import { SignatureParametersInterface } from '@app/bingx/account/signature-parameters.interface';
-import { Throughput } from '@app/bingx/rate-limit/throughput';
 import { DefaultSignatureParameters } from '@app/bingx/account/default-signature-parameters';
-import { MarketThroughput } from '@app/bingx/rate-limit/market-throughput';
 import { AccountInterface } from '@app/bingx/account/account.interface';
 
-export class BingxCancelAllOrdersEndpoint
+export interface CancelAllOrdersData {
+  success: unknown[];
+  failed: unknown[];
+}
+
+export class BingxCancelAllOrdersEndpoint<R = CancelAllOrdersData>
   extends Endpoint
-  implements EndpointInterface
+  implements EndpointInterface<R>
 {
-  constructor(private readonly symbol: string, account: AccountInterface) {
+  constructor(
+    private readonly symbol: string,
+    account: AccountInterface,
+  ) {
     super(account);
   }
 
@@ -28,7 +34,5 @@ export class BingxCancelAllOrdersEndpoint
     return '/openApi/swap/v2/trade/allOpenOrders';
   }
 
-  throughput(): Throughput {
-    return new MarketThroughput();
-  }
+  readonly t!: R;
 }

src/bingx/request/bingx-cancel-all-orders-endpoint.ts src/bingx/endpoints/bingx-cancel-all-orders-endpoint.ts

@@ -1,14 +1,18 @@
-import { Endpoint } from '@app/bingx/request/endpoint';
-import { EndpointInterface } from '@app/bingx/request/endpoint.interface';
+import { Endpoint } from '@app/bingx/endpoints/endpoint';
+import { EndpointInterface } from '@app/bingx/endpoints/endpoint.interface';
 import { SignatureParametersInterface } from '@app/bingx/account/signature-parameters.interface';
-import { Throughput } from '@app/bingx/rate-limit/throughput';
 import { DefaultSignatureParameters } from '@app/bingx/account/default-signature-parameters';
-import { MarketThroughput } from '@app/bingx/rate-limit/market-throughput';
 
-export class BingxCloseAllPositionsEndpoint
+export interface BingxCloseAllPositionsData {
+  success: number[];
+  failed: number[];
+}
+
+export class BingxCloseAllPositionsEndpoint<R = BingxCloseAllPositionsData>
   extends Endpoint
-  implements EndpointInterface
+  implements EndpointInterface<R>
 {
+  readonly t!: R;
   method(): 'get' | 'post' | 'put' | 'patch' | 'delete' {
     return 'post';
   }
@@ -20,8 +24,4 @@ export class BingxCloseAllPositionsEndpoint
   path(): string {
     return '/openApi/swap/v2/trade/closeAllPositions';
   }
-
-  throughput(): Throughput {
-    return new MarketThroughput();
-  }
 }