import {
  WebsocketClient,
  WSClientConfigurableOptions,
  WS_KEY_MAP,
} from '../../src';
import {
  logAllEvents,
  promiseSleep,
  getSilentLogger,
  waitForSocketEvent,
  WS_OPEN_EVENT_PARTIAL,
} from '../ws.util';

describe('Private Spot V1 Websocket Client', () => {
  let wsClient: WebsocketClient;
  const API_KEY = process.env.API_KEY_COM;
  const API_SECRET = process.env.API_SECRET_COM;

  it('should have api credentials to test with', () => {
    expect(API_KEY).toStrictEqual(expect.any(String));
    expect(API_SECRET).toStrictEqual(expect.any(String));
  });

  const wsClientOptions: WSClientConfigurableOptions = {
    market: 'spot',
    key: API_KEY,
    secret: API_SECRET,
  };

  beforeAll(() => {
    wsClient = new WebsocketClient(
      wsClientOptions,
      getSilentLogger('expectSuccess')
    );
    logAllEvents(wsClient);
  });

  afterAll(() => {
    wsClient.closeAll(true);
  });

  // TODO: how to detect if auth failed for the v1 spot ws
  it('should open a private ws connection', async () => {
    const wsOpenPromise = waitForSocketEvent(wsClient, 'open');
    // const wsUpdatePromise = waitForSocketEvent(wsClient, 'update');

    wsClient.connectPrivate();

    try {
      expect(await wsOpenPromise).toMatchObject({
        event: WS_OPEN_EVENT_PARTIAL,
        // wsKey: WS_KEY_MAP.spotPrivate,
        // also opens public conn automatically, which can confuse the test
      });
    } catch (e) {
      expect(e).toBeFalsy();
    }
    // expect(wsUpdatePromise).resolves.toMatchObject({
    //   topic: 'wsTopic',
    //   data: expect.any(Array),
    // });

    // await Promise.all([wsUpdatePromise]);
    // await promiseSleep(4000);
  });
});