bingx-request.ts

import { EndpointInterface } from 'bingx-api/bingx/endpoints/endpoint.interface';
import { lastValueFrom } from 'rxjs';
import { BingxRequestInterface } from 'bingx-api/bingx/endpoints/bingx-request.interface';
import { HttpService } from '@nestjs/axios';
import axios from 'axios';
import * as JSONBigNumber from 'json-bignumber';

export class BingxRequest<R> implements BingxRequestInterface<R> {
  private readonly http = new HttpService(
    axios.create({
      baseURL: 'https://open-api.bingx.com',
      headers: {
        'Content-Type': 'application/x-www-form-urlencoded',
      },
      transformResponse: (res) => {
        try {
          return JSON.parse(JSON.stringify(JSONBigNumber.parse(res)));
        } catch (e) {
          console.error('BingxRequest.http.transformResponse', e, res);
          return res;
        }
      },
    }),
  );

  constructor(private readonly endpoint: EndpointInterface<R>) {}

  async getResponse(): Promise<Readonly<R>> {
    const response = await lastValueFrom(
      this.http.request({
        method: this.endpoint.method(),
        params: {
          ...this.endpoint.parameters().asRecord(),
          signature: this.endpoint.signature().toString(),
        },
        headers: this.endpoint.apiKey().asHeader(),
        url: this.endpoint.path(),
      }),
    );

    return response.data;
  }

  async getEndpoint(): Promise<Readonly<EndpointInterface<R>>> {
    return this.endpoint;
  }
}