type HumanPlusActor = { kind: "human" | "agent" | "system"; id: string; name?: string; }; type HumanPlusPriority = "background" | "normal" | "attention" | "blocking"; type HumanPlusDisposition = "seen" | "handled" | "rejected" | "ignored"; interface HumanPlusEvent { id: string; sequence: number; timestamp: number; appId: string; surfaceId: string; sessionId?: string; type: string; payload: T; actor: HumanPlusActor; priority: HumanPlusPriority; correlationId?: string; causationId?: string; } type NewHumanPlusEvent = Omit, "id" | "sequence" | "timestamp"> & Partial, "id" | "timestamp">>; interface HumanPlusEventQuery { consumerId: string; after?: number; limit?: number; unacknowledgedOnly?: boolean; types?: string[]; surfaces?: string[]; } interface HumanPlusEventPage { events: HumanPlusEvent[]; nextCursor: number; } type HumanPlusEventListener = (event: HumanPlusEvent) => void; interface HumanPlusEventStore { append(event: NewHumanPlusEvent): Promise; list(query: HumanPlusEventQuery): Promise; acknowledge(consumerId: string, eventIds: string[], disposition: HumanPlusDisposition): Promise; subscribe(listener: HumanPlusEventListener): () => void; compact?(options?: { before?: number; keepLast?: number; }): Promise; } declare class MemoryHumanPlusEventStore implements HumanPlusEventStore { protected events: HumanPlusEvent[]; protected acknowledgements: Map>; protected listeners: Set; protected nextSequence: number; append(input: NewHumanPlusEvent): Promise; list(query: HumanPlusEventQuery): Promise; acknowledge(consumerId: string, eventIds: string[], disposition: HumanPlusDisposition): Promise; subscribe(listener: HumanPlusEventListener): () => void; compact(options?: { before?: number; keepLast?: number; }): Promise; } export { type HumanPlusActor, type HumanPlusDisposition, type HumanPlusEvent, type HumanPlusEventListener, type HumanPlusEventPage, type HumanPlusEventQuery, type HumanPlusEventStore, type HumanPlusPriority, MemoryHumanPlusEventStore, type NewHumanPlusEvent };