import { WebSocketEndPoint, WebSocketSet } from '../endpoints/WebSocketEndPoint';
import { RawData } from 'ws';
import { IntentManager } from '@dooboostore/simple-boot';
import { RouterManager } from '@dooboostore/simple-boot';
export type WebSocketRequest = {
    webSocketSet: WebSocketSet;
    uuid: string;
    webSocketManager: WebSocketManager;
    sendEvent: <R>(event: string, body: any, config?: {
        responseTimeout?: number;
    }) => Promise<R>;
};
export type TopicType = 'intent' | 'router';
export type SubscribeType = 'subscribe';
export type UnsubscribeType = 'unsubscribe';
export type TopicRequest<T = any> = {
    type?: TopicType;
    uuid: string;
    requestUUID: string;
    body?: T;
};
export type TopicSubscribeRequest<T = any> = {
    type: SubscribeType;
    target: string;
    uuid: string;
    body?: T;
};
export type TopicUnsubscribeRequest = {
    type: UnsubscribeType;
    uuid: string;
};
export type TopicResponse<T = any> = {
    state: 'success' | 'error';
    target: string;
    uuid: string;
    requestUUID?: string;
    body: T;
};
export type TopicServerEventRequest<T = any> = {
    type: 'event';
    uuid: string;
    eventUUID: string;
    event: string;
    body?: T;
};
export type TopicServerEventUnSubscribeRequest = {
    type: 'unsubscribe';
    uuid: string;
};
export type TopicServerEventResponse<T = any> = {
    type: 'event';
    uuid: string;
    eventUUID: string;
    body?: T;
};
export declare const isTopicRequest: <T = any>(obj: any) => obj is TopicRequest<T>;
export declare const isTopicSubscribeRequest: <T = any>(obj: any) => obj is TopicSubscribeRequest<T>;
export declare const isTopicUnsubscribeRequest: (obj: any) => obj is TopicUnsubscribeRequest;
export declare const isTopicResponse: <T = any>(obj: any) => obj is TopicResponse<T>;
export declare const isTopicServerEventRequest: <T = any>(obj: any) => obj is TopicServerEventRequest<T>;
export declare const isTopicServerEventResponse: <T = any>(obj: any) => obj is TopicServerEventResponse<T>;
export declare const isTopicServerEventUnSubscribeRequest: (obj: any) => obj is TopicServerEventUnSubscribeRequest;
type EventResponseCallBack = <T>(data: T, wsSet: WebSocketSet) => void;
export type RegisteredClient<T = any> = {
    uuid: string;
    target: string;
    subscribeBody?: T;
};
type RegisteredClientSet<T = any> = RegisteredClient<T> & {
    webSocketSet: WebSocketSet;
};
export declare class WebSocketManager implements WebSocketEndPoint {
    private intentManager;
    private routerManager;
    private clients;
    private eventSubscriptions;
    private subject;
    constructor(intentManager: IntentManager, routerManager: RouterManager);
    get observable(): import("@dooboostore/core").Observable<TopicUnsubscribeRequest | TopicRequest<any> | TopicSubscribeRequest<any> | TopicServerEventResponse<any>, any>;
    connect(wsSet: WebSocketSet): void;
    close(wsSet: WebSocketSet): void;
    setClientTopic(wsSet: WebSocketSet, uuid: string, target: string, subscribeBody?: any): void;
    findAllClientsByTarget(target: string): RegisteredClientSet[];
    findClientsByTarget(target: string): RegisteredClientSet;
    removeClientByUUID(uuid: string): boolean;
    findClientByUUID(uuid: string): RegisteredClientSet | undefined;
    sendDataByUUID({ uuid, body }: {
        uuid: string;
        body?: any;
    }): boolean;
    sendUnSubscribeByUUID({ uuid }: {
        uuid: string;
    }): boolean;
    sendAllDataByTarget({ target, body }: {
        target: string;
        body?: any;
    }): number;
    sendAllUnSubscribeByTarget({ target }: {
        target: string;
    }): number;
    sendEventDataByUUID({ uuid, event, body }: {
        uuid: string;
        event: string;
        body?: any;
    }, config?: {
        responseCallBack?: EventResponseCallBack;
    }): string | undefined;
    sendEventDataByUUIDPromise<R>({ uuid, event, body }: {
        uuid: string;
        event: string;
        body?: any;
    }, config?: {
        responseTimeout?: number;
    }): Promise<R>;
    sendEventDataByUUIDPromiseSettled<R>({ uuid, event, body }: {
        uuid: string;
        event: string;
        body?: any;
    }, config?: {
        responseTimeout?: number;
    }): Promise<PromiseSettledResult<R>>;
    sendAllEventDataByTargetPromise<R>({ target, event, body }: {
        target: string;
        event: string;
        body?: any;
    }, config?: {
        responseTimeout?: number;
    }): Promise<{
        body: R;
        uuid: string;
    }[]>;
    sendAllEventDataByTargetPromiseSettled<R>({ target, event, body }: {
        target: string;
        event: string;
        body?: any;
    }, config?: {
        responseTimeout?: number;
    }): Promise<PromiseSettledResult<{
        body: R;
        uuid: string;
    }>[]>;
    sendAllEventDataByTarget({ target, event, body }: {
        target: string;
        event: string;
        body?: any;
    }, config?: {
        responseCallBack?: EventResponseCallBack;
    }): number;
    private addEventSubscribes;
    getOpenClients(): WebSocketSet[];
    private isBinaryPayload;
    private hasBinaryPayload;
    private buildBinaryTopic;
    private sendTopic;
    private parseBinaryTopic;
    message(wsSet: WebSocketSet, data: {
        data: RawData;
        isBinary: boolean;
    }): void;
    private removeAllClientsByWebSocketSet;
}
export {};
//# sourceMappingURL=WebSocketManager.d.ts.map