import { ApiEndpoints, Session } from '../session/session';
import { EndpointResponse } from '../delivery/endpoint-request';
import { ConfigEndpoint } from '../config';
import { PricingStreamEvents } from './pricing/stream';
import { HistoricalPricingStreamEvents } from './historical-pricing/stream';
import { StreamType, TimeSeriesStreamEvents } from './historical-pricing/time-series/stream';
export interface ContentDefinition<TTable = any, TParam = any> {
    getData(session?: Session): Promise<ContentResponse<TTable>>;
    getInstrument?(): TParam;
}
export interface ContentProvider {
    readonly apiGroup: keyof ApiEndpoints;
    readonly endpointName: string;
    getEndpointPath(pathName: string): string;
    getEndpointConfig(): ConfigEndpoint | undefined;
    toContentResponse<TTable>(endpointResponse: EndpointResponse, buildTable?: () => TTable): ContentResponse<TTable>;
}
export interface ContentObjectResponse<TTable> {
    raw: any;
    table?: TTable;
    [index: string]: any;
}
export type ContentResponse<TTable = any, TContentObjectResponse = ContentObjectResponse<TTable>> = EndpointResponse<TContentObjectResponse>;
export interface ExtendedParams {
    extendedParams?: {
        [key: string]: any;
    };
}
export interface StreamDefinition<TStream = any> {
    getStream(session?: Session, api?: string): TStream;
}
export interface TableBuilder<TData = any, TTable = any> {
    build(data: TData): TTable;
}
export interface DataInterface<TData = any, THeaders = any> {
    data: TData;
    headers: THeaders;
}
export interface TableInterface<TRow> {
    [key: string]: TRow;
}
export type PossibleStreamEvents = PricingStreamEvents | HistoricalPricingStreamEvents | TimeSeriesStreamEvents<StreamType>;
export interface BaseStream<StreamEvents extends PossibleStreamEvents, OpenStreamParams> {
    onRefresh(cb: StreamEvents['Refresh']): this;
    onUpdate(cb: StreamEvents['Update']): this;
    onStatus(cb: StreamEvents['Status']): this;
    onComplete(cb: StreamEvents['Complete']): this;
    onError(cb: StreamEvents['error']): this;
    open(params?: OpenStreamParams): Promise<this>;
}