@jayesol/jayeson.lib.sports/lib/client.d.ts

import { IBetEvent, IBetMatch, IBetRecord, IBetEventState, ISnapshot, PartitionKey } from '@jayesol/jayeson.lib.record';
import { IEndPointDispatcher, IEndPointGroupManager } from './dispatch';
import { FSRepo } from './core';
import { IMessageClass, Subscriber, EPEvent } from '@jayesol/jayeson.lib.delivery';
import * as T from 'ts-promise';
import { IndexedSnapshot, DeltaOutgoing, Outgoing, IndexedSnapshotImpl } from "./data_structure";
import { InEndPointEventHandler, SportsFeedInProcessor } from "./receive";
import { SportsFeedMessageGroup } from "./message_class";
import 'reflect-metadata';
import { RuleCombination } from '@jayesol/jayeson.model';
export declare class InsertMatch<M extends IBetMatch> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: M[]);
    after(): ISnapshot<IBetMatch>;
    get(): M[];
}
export declare class UpdateMatch<M extends IBetMatch> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: M[]);
    after(): ISnapshot<IBetMatch>;
    get(): M[];
}
export declare class DeleteMatch<M extends IBetMatch> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: M[]);
    after(): ISnapshot<IBetMatch>;
    get(): M[];
}
export declare class InsertEvent<E extends IBetEvent> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: E[]);
    after(): ISnapshot<IBetMatch>;
    get(): E[];
}
export declare class UpdateEvent<E extends IBetEvent> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: E[]);
    after(): ISnapshot<IBetMatch>;
    get(): E[];
}
export declare class DeleteEvent<E extends IBetEvent> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: E[]);
    after(): ISnapshot<IBetMatch>;
    get(): E[];
}
export declare class InsertOdd<R extends IBetRecord> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: R[]);
    after(): ISnapshot<IBetMatch>;
    get(): R[];
}
export declare class UpdateOdd<R extends IBetRecord> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: R[]);
    after(): ISnapshot<IBetMatch>;
    get(): R[];
}
export declare class DeleteOdd<R extends IBetRecord> {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: R[]);
    after(): ISnapshot<IBetMatch>;
    get(): R[];
}
export declare class Reset {
    private _after;
    private _get;
    constructor(_after: ISnapshot<IBetMatch>, _get: PartitionKey[]);
    after(): ISnapshot<IBetMatch>;
    get(): PartitionKey[];
}
export interface DeltaEventHandler<M extends IBetMatch, E extends IBetEvent, R extends IBetRecord> {
    onInsertMatch(insertMatch: InsertMatch<M>): void;
    onUpdateMatch(updateMatch: UpdateMatch<M>): void;
    onDeleteMatch(deleteMatch: DeleteMatch<M>): void;
    onInsertEvent(insertEvent: InsertEvent<E>): void;
    onUpdateEvent(updateEvent: UpdateEvent<E>): void;
    onDeleteEvent(deleteEvent: DeleteEvent<E>): void;
    onInsertOdd(insertOdd: InsertOdd<R>): void;
    onUpdateOdd(updateOdd: UpdateOdd<R>): void;
    onDeleteOdd(deleteOdd: DeleteOdd<R>): void;
    onReset(resetKeys: Reset): void;
    onSwitchFilterStart(requestId?: number): void;
    onSwitchFilterEnd(): void;
    onFullSnapshotStart(): void;
    onFullSnapshotEnd(): void;
    onSwitchFilterFail(requestId?: number): void;
}
export declare class FeedView<M extends IBetMatch> {
    private _fsRepo;
    private _epgm;
    private _grp;
    private _handlers;
    constructor(manager: IEndPointGroupManager, repo: FSRepo, grp: SportsFeedMessageGroup);
    fsRepo(): FSRepo;
    epgm(): IEndPointGroupManager;
    grp(): SportsFeedMessageGroup;
    snapshot(): IndexedSnapshot;
    register<E extends IBetEvent, R extends IBetRecord>(listener: DeltaEventHandler<M, E, R>): void;
    unregister<E extends IBetEvent, R extends IBetRecord>(listener: DeltaEventHandler<M, E, R>): void;
    private hasHandler;
    private removeHandler;
    handlerSize(): number;
    cleanUp(): void;
}
export declare class AbstractComparableEPDispatcher implements IEndPointDispatcher {
    private _stream;
    id(): string;
    submit(out: Outgoing): void;
    onException(e: Error): void;
    protected _grp: SportsFeedMessageGroup;
    protected _readyToDispatch: boolean;
    constructor(_stream: string, _grp: SportsFeedMessageGroup);
    stream(): string;
    grp(): SportsFeedMessageGroup;
    isInitialized(): T.Promise<Boolean>;
    readyToDispatch(): void;
    isReadyToDispatch(): boolean;
}
export declare class MemoryDispatcher extends AbstractComparableEPDispatcher {
    private _fsRepo;
    private _handler;
    static MEMORY_STREAM: string;
    lastPushedSs: IndexedSnapshotImpl;
    _id: string;
    constructor(_fsRepo: FSRepo, _grp: SportsFeedMessageGroup, _handler: DeltaEventHandler<IBetMatch, IBetEvent, IBetRecord>);
    grp(): SportsFeedMessageGroup;
    handler(): DeltaEventHandler<IBetMatch, IBetEvent, IBetRecord>;
    id(): string;
    submit(out: Outgoing): void;
    onException(e: Error): void;
    handleMessage(msg: Outgoing): void;
    protected pushSwitchFilterStart(requestId: number): void;
    protected pushSwitchFilterEnd(): void;
    protected pushFullSnapshotStart(): void;
    protected pushFullSnapshotEnd(): void;
    protected pushSwitchFilterFail(requestId: number): void;
    protected pushInsertMatch(ds: DeltaOutgoing): void;
    protected pushInsertEvent(ds: DeltaOutgoing): void;
    protected pushInsertOdd(ds: DeltaOutgoing): void;
    protected pushUpdateMatch(ds: DeltaOutgoing): void;
    protected pushUpdateEvent(ds: DeltaOutgoing): void;
    protected pushUpdateOdd(ds: DeltaOutgoing): void;
    protected pushDeleteMatch(ds: DeltaOutgoing): void;
    protected pushDeleteEvent(ds: DeltaOutgoing): void;
    protected pushDeleteOdd(ds: DeltaOutgoing): void;
    private pushReset;
    protected events(matches: IBetMatch[]): IBetEvent[];
    protected records(events: IBetEvent[]): IBetRecord[];
    protected states(events: IBetEvent[]): IBetEventState[];
    isSame(lhs: IMessageClass, rhs: IMessageClass): boolean;
    isInitialized(): T.Promise<Boolean>;
}
export declare class SportsFeedClient implements DeltaEventHandler<IBetMatch, IBetEvent, IBetRecord> {
    private _subscriber;
    private _eventHandler;
    private _viewTemplate;
    private _epgm;
    private _fsRepo;
    private _grp;
    private _views;
    private filterRequestCounter;
    private resolverMap;
    constructor(grp: SportsFeedMessageGroup, fsRepo: FSRepo, epgm: IEndPointGroupManager, subscriber: Subscriber, eventHandler: InEndPointEventHandler, inProcessor: SportsFeedInProcessor);
    subscriber(): Subscriber;
    epgm(): IEndPointGroupManager;
    InEndPointEventHandler(): InEndPointEventHandler;
    fsRepo(): FSRepo;
    grp(): SportsFeedMessageGroup;
    eventHandler(): InEndPointEventHandler;
    eventListener(event: EPEvent): void;
    configureEventHandler(eventHandler: InEndPointEventHandler): void;
    setUpStreamFilter(filterData: RuleCombination): T.Promise<Boolean>;
    getSubscriber(): Subscriber;
    start(): void;
    view<M extends IBetMatch>(): FeedView<M>;
    removeView<M extends IBetMatch>(view: FeedView<M>): void;
    onSwitchFilterFail(requestId: number): void;
    onSwitchFilterStart(requestId: number): void;
    onInsertMatch(insertMatch: InsertMatch<IBetMatch>): void;
    onUpdateMatch(updateMatch: UpdateMatch<IBetMatch>): void;
    onDeleteMatch(deleteMatch: DeleteMatch<IBetMatch>): void;
    onInsertEvent(insertEvent: InsertEvent<IBetEvent>): void;
    onUpdateEvent(updateEvent: UpdateEvent<IBetEvent>): void;
    onDeleteEvent(deleteEvent: DeleteEvent<IBetEvent>): void;
    onInsertOdd(insertOdd: InsertOdd<IBetRecord>): void;
    onUpdateOdd(updateOdd: UpdateOdd<IBetRecord>): void;
    onDeleteOdd(deleteOdd: DeleteOdd<IBetRecord>): void;
    onReset(resetKeys: Reset): void;
    onSwitchFilterEnd(): void;
    onFullSnapshotStart(): void;
    onFullSnapshotEnd(): void;
}