/// <reference types="node" />
import { EventEmitter } from 'events';
import { WebSocketChannelKey } from './constant.js';
export type WebSocketRequestType = 'login' | 'subscribe' | 'unsubscribe';
export type WebSocketReqponseType = WebSocketRequestType | 'error';
export type Channel = 'account' | 'orders' | 'rfqs' | 'quotes' | 'struc-block-trades' | 'tickers' | 'public-struc-block-trades' | 'instruments' | 'open-interest' | 'funding-rate' | 'price-limit' | 'opt-summary' | 'estimated-price' | 'deposit-info' | 'withdrawal-info' | 'liquidation-orders' | 'balance_and_position';
export interface Arg {
    channel?: Channel;
}
export interface WebSocketRequest<T extends Arg> {
    op: WebSocketRequestType;
    args: T[];
}
export interface WebSocketResponse<T extends Arg> {
    event: WebSocketReqponseType;
    arg: T;
}
export interface WebSocketLoginResponse {
    event: 'login';
    code: string;
    msg: string;
}
export interface WebSocketPush<T extends Arg, TD> {
    arg: T;
    data: TD[];
}
export interface Options {
    apiKey: string;
    passphrase: string;
    secretKey: string;
}
export interface ResponseEventData<T extends Arg> {
    channel: WebSocketChannelKey;
    data: WebSocketResponse<T>;
}
export interface PushEventData<T extends Arg, TD> {
    channel: WebSocketChannelKey;
    data: WebSocketPush<T, TD>;
}
export declare interface OkxWebSocketClient {
    emit(event: 'authorized'): boolean;
    emit<T extends Arg, TD>(event: 'push', data: PushEventData<T, TD>): boolean;
    emit<T extends Arg>(event: 'response', data: ResponseEventData<T>): boolean;
    on(event: 'authorized', listener: () => void): this;
    on(event: 'push', listener: <T extends Arg, TD>(data: PushEventData<T, TD>) => void): this;
    on(event: 'response', listener: <T extends Arg>(data: {
        channel: WebSocketChannelKey;
        data: WebSocketResponse<T>;
    }) => void): this;
}
export declare class OkxWebSocketClient extends EventEmitter {
    /**
     * WebSocket clients for different channels
     */
    private _clients;
    private _apiKey;
    private _passphrase;
    private _secretKey;
    private _authorized;
    /**
     * @deprecated use `OkxWebSocket.getInstance` instead to ensure the application will use the same clients all the time.
     */
    constructor(options: Options);
    /**
     * Init WebSocket Client for certain Channel
     * @param key {WebSocketChannelKey}
     * @returns {WebSocket}
     */
    private _initClient;
    /**
     * Login to private channel
     */
    private _loginToPrivateChannel;
    /**
     * Handle message received from a specific channel
     * @param key {WebSocketChannelKey} Key of the channel
     * @param message Message content
     */
    private _handleMessage;
    /**
     * Send message to certain channel
     * @param key Key of the channel
     * @param message Message content
     */
    send(key: WebSocketChannelKey, message: string | object): void;
    privateChannelReady(): Promise<boolean>;
    private static _instance;
    static getInstance(opts: Options): OkxWebSocketClient;
}