import { ObserverDashboardDataStream } from './ObservedDashboardDataStream';
import { DatabaseFrameSchema, DatabaseFrameConditions } from './datastreams/DatabaseFrame';
import { DashboardDataStreamOperations, DashboardMessage, DashboardQueryOperations, FindCallsResponsePayload, GetSummaryResponsePayload, OngoingCallsResponsePayload } from './protocols/DashboardMessageProtocol';
import { WebSocketConnector, WebSocketConnectorConfig } from './WebSocketConnector';
import { EventEmitter } from 'events';
import { CallSnapshot, ClientSnapshot } from './protocols/CallSnapshotSchema';
import { ReportSchemas } from './datastreams/ReportSchemas';
export type ObserverDashboardClientConfig = {
    connection: WebSocketConnectorConfig;
};
export type ObserverDashboardClientEventMap = {
    close: [];
};
type CreateDataStreamOptions = DashboardDataStreamOperations['create'] & {
    create: (dataStreamId: string) => ObserverDashboardDataStream<any>;
};
export declare interface ObserverDashboardClient {
    on<U extends keyof ObserverDashboardClientEventMap>(event: U, listener: (...args: ObserverDashboardClientEventMap[U]) => void): this;
    off<U extends keyof ObserverDashboardClientEventMap>(event: U, listener: (...args: ObserverDashboardClientEventMap[U]) => void): this;
    once<U extends keyof ObserverDashboardClientEventMap>(event: U, listener: (...args: ObserverDashboardClientEventMap[U]) => void): this;
    emit<U extends keyof ObserverDashboardClientEventMap>(event: U, ...args: ObserverDashboardClientEventMap[U]): boolean;
}
export declare class ObserverDashboardClient extends EventEmitter {
    readonly config: ObserverDashboardClientConfig;
    readonly connection: WebSocketConnector;
    private readonly _dataStreams;
    private _closed;
    constructor(config: ObserverDashboardClientConfig);
    get closed(): boolean;
    close(): void;
    connect(accessToken?: string): Promise<void>;
    findCalls(params: DashboardQueryOperations['findCalls']): Promise<FindCallsResponsePayload>;
    fetchOngoingCalls(): Promise<OngoingCallsResponsePayload>;
    getSummaryStats(params: DashboardQueryOperations['getSummaryStats']): Promise<GetSummaryResponsePayload>;
    getTurnStats(params: DashboardQueryOperations['getTurnStats']): Promise<GetSummaryResponsePayload>;
    /**
     * @deprecated Use createReportsFrame instead loading reports from bucket
     * @param resourceId
     * @param conditions
     * @param updateOnCreate
     * @returns
     */
    createDatabaseFrame<K extends keyof DatabaseFrameSchema>(resourceId: K, conditions: DatabaseFrameConditions<DatabaseFrameSchema[K]>, updateOnCreate?: boolean): Promise<ObserverDashboardDataStream<DatabaseFrameSchema[K]>>;
    createReportsFrame<K extends keyof ReportSchemas>(reportType: K, settings: ReportSchemas[K]['request']): Promise<ObserverDashboardDataStream<ReportSchemas[K]["response"]>>;
    createCallSnapshotsFrame(callId: string): Promise<ObserverDashboardDataStream<CallSnapshot>>;
    createClientSnapshotsFrame(options: {
        callId: string;
        clientId: string;
    }): Promise<ObserverDashboardDataStream<ClientSnapshot>>;
    protected _createDataStream<T>(options: CreateDataStreamOptions, updateOnCreate: boolean): Promise<ObserverDashboardDataStream<T>>;
    protected _receive(message: DashboardMessage): void;
}
export {};
//# sourceMappingURL=ObserverDashboardClient.d.ts.map