69 lines
1.7 KiB
TypeScript
69 lines
1.7 KiB
TypeScript
import {
|
|
WebsocketClient,
|
|
WSClientConfigurableOptions,
|
|
WS_KEY_MAP,
|
|
} from '../../src';
|
|
import {
|
|
logAllEvents,
|
|
promiseSleep,
|
|
getSilentLogger,
|
|
waitForSocketEvent,
|
|
WS_OPEN_EVENT_PARTIAL,
|
|
fullLogger,
|
|
} 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,
|
|
// fullLogger
|
|
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);
|
|
});
|
|
});
|