/**
 * States are objects
 */
export type State = Record<string, any>;
/**
 * DeepPartial utility
 */
export type DeepPartial<T> = T extends Array<infer I> ? Array<DeepPartial<I>> : T extends object ? {
    [K in keyof T]?: DeepPartial<T[K]>;
} : T;
/**
 * Patches are deep partial states
 */
export type Patch<S extends State> = DeepPartial<S>;
/**
 * Messages map message states
 */
export type Messages = Record<string, Record<string, any>>;
/**
 * Messages have
 * - `name` a name
 * - `data` a payload
 * - `stream?` the target stream when message is a command
 * - `expectedVersion?` the expected version of the stream or a concurrency error is thrown
 * - `actor?` the actor invoking the command
 */
export type Message<M extends Messages = Messages, N extends keyof M & string = string> = {
    readonly name: N;
    readonly data: Readonly<M[N]>;
    readonly stream?: string;
    readonly expectedVersion?: number;
    readonly actor?: Actor;
};
/**
 * Actors are either humans or policies invoking commands
 * - `id` actor identifier
 *    - for human actors, this is usually a primary key to the users table, extracted from JWT, etc
 *    - for process managers, this is the secondary stream used to reduce the state
 * - `name` actor name
 *    - for human actors, could be the full name, email, etc ... for log auditing purposes
 *    - for process managers, the factory name
 * - `roles?` array of role names used for authorization invariants (usually extracted from JWT and used by validation middleware)
 * - `expectedCount?` expected count of actor events when process managers are enforcing transaction integrity
 */
export type Actor = {
    readonly id: string;
    readonly name: string;
    readonly roles?: string[];
    readonly expectedCount?: number;
};
/**
 * Command target
 * - `stream` the target stream
 * - `expectedVersion?` the expected version of the stream or a concurrency error is thrown
 * - `actor?` the actor invoking the command
 */
export type CommandTarget = {
    readonly stream: string;
    readonly expectedVersion?: number;
    readonly actor?: Actor;
};
/**
 * Committed events have metadata describing correlation and causation
 * - `correlation` unique id that correlates message flows across time and systems
 * - `causation` The direct cause of the event
 */
export type CommittedEventMetadata = {
    readonly correlation: string;
    readonly causation: {
        readonly command?: {
            readonly name: string;
            readonly stream?: string;
            readonly expectedVersion?: number;
            readonly actor?: Actor;
        };
        readonly event?: {
            readonly name: string;
            readonly stream: string;
            readonly id: number;
        };
    };
};
/**
 * Committed events are messages with commit details
 * - `id` the unique index of the event in the "all" stream
 * - `stream` the reducible stream name of the artifact that produced the event
 * - `version` the unique and continuous sequence number within the stream
 * - `created` the date-time of creation
 * - `metadata` the event metadata
 */
export type CommittedEvent<M extends Messages = Messages> = Message<M, keyof M & string> & {
    readonly id: number;
    readonly stream: string;
    readonly version: number;
    readonly created: Date;
    readonly metadata: CommittedEventMetadata;
};
/**
 * Snapshots hold reduced state and last applied event
 * - `state` the current state of the artifact
 * - `event?` the last event applied to the state
 * - `applyCount` the number of events reduced after last snapshot
 * - `stateCount` the number of state events after last snapshot
 */
export type Snapshot<S extends State = State, E extends Messages = Messages> = {
    readonly state: S;
    readonly event?: CommittedEvent<E>;
    readonly applyCount: number;
    readonly stateCount: number;
};
/**
 * Options to query the all stream
 * - `stream?` filter by stream
 * - `names?` filter by event names
 * - `before?` filter events before this id
 * - `after?` filter events after this id
 * - `limit?` limit the number of events to return
 * - `created_before?` filter events created before this date/time
 * - `created_after?` filter events created after this date/time
 * - `backward?` order descending when true
 * - `correlation?` filter by correlation
 * - `actor?` filter by actor id (mainly used to reduce process managers)
 * - `loading?` flag when loading to optimize queries
 */
export type AllQuery = {
    readonly stream?: string;
    readonly names?: string[];
    readonly before?: number;
    readonly after?: number;
    readonly limit?: number;
    readonly created_before?: Date;
    readonly created_after?: Date;
    readonly backward?: boolean;
    readonly correlation?: string;
    readonly actor?: string;
    readonly loading?: boolean;
};
//# sourceMappingURL=messages.d.ts.map