import { IndexedSnapshot, Incoming, MessageBeforeTransform, MergeableWrapper } from './data_structure'; import { SportsFeedMessageGroup } from './message_class'; import { IMessageClass } from '@jayesol/jayeson.lib.delivery'; import { IBetMatch, PartitionKey } from '@jayesol/jayeson.lib.record'; import * as Collections from 'typescript-collections'; export declare enum MsgType { INSERT = 0, UPDATE = 1, DELETE = 2 } export declare class SnapshotUtil { private static readonly SPORTS_GROUP; static combineSnapshots(msgType: IMessageClass, childSs: IndexedSnapshot, parentSs: IndexedSnapshot): MessageBeforeTransform; static processRefresh(childSs: IndexedSnapshot, parentSs: IndexedSnapshot): MessageBeforeTransform; static processReset(childSs: IndexedSnapshot, parentSs: IndexedSnapshot): MessageBeforeTransform; static processMatches(msgType: MsgType, childSs: IndexedSnapshot, parentSs: IndexedSnapshot): MessageBeforeTransform; static processEvents(msgType: MsgType, childSs: IndexedSnapshot, parentSs: IndexedSnapshot): MessageBeforeTransform; static processOdds(msgType: MsgType, childSs: IndexedSnapshot, parentSs: IndexedSnapshot): MessageBeforeTransform; } export declare class DeltaTransformingLogicImpl { static transform(sportsGrp: SportsFeedMessageGroup, stream: string, msgType: IMessageClass, delta: IndexedSnapshot, msgBefore: MessageBeforeTransform): Incoming[]; static combineEventState(msgBefore: MessageBeforeTransform, sportsGrp: SportsFeedMessageGroup, msgType: IMessageClass, stream: string, delta: IndexedSnapshot, msg: Incoming[]): Incoming[]; static suppressInsertEvent(msgBefore: MessageBeforeTransform, sportsGrp: SportsFeedMessageGroup, msgType: IMessageClass, stream: string, delta: IndexedSnapshot, msg: Incoming[]): Incoming[]; static transformTTLRestore(ttlRestoredList: IndexedSnapshot[], grp: SportsFeedMessageGroup, stream: string, before: IndexedSnapshot, after: IndexedSnapshot, matches: { [sport: number]: IBetMatch[]; }, restoredKeys: Collections.Dictionary): MergeableWrapper; static transformTTLRemove(ttlRemoveList: IndexedSnapshot[], grp: SportsFeedMessageGroup, stream: string, before: IndexedSnapshot, after: IndexedSnapshot, keysRemoved: Collections.Dictionary): MergeableWrapper; static breakdownTTL(grp: SportsFeedMessageGroup, stream: string, restoredSS: IndexedSnapshot): Incoming[]; static breakdownReset(grp: SportsFeedMessageGroup, stream: string, removeSs: IndexedSnapshot): Incoming[]; static suppressInsertMatch(msgBefore: MessageBeforeTransform, sportsGrp: SportsFeedMessageGroup, msgType: IMessageClass, stream: string, delta: IndexedSnapshot, msg: Incoming[]): Incoming[]; static suppressDeleteEvent(msgBefore: MessageBeforeTransform, sportsGrp: SportsFeedMessageGroup, msgType: IMessageClass, stream: string, delta: IndexedSnapshot, msg: Incoming[]): Incoming[]; static suppressDeleteMatch(msgBefore: MessageBeforeTransform, sportsGrp: SportsFeedMessageGroup, msgType: IMessageClass, stream: string, delta: IndexedSnapshot, msg: Incoming[]): Incoming[]; }