import { EventEmitter } from "node:events";
import { Channel } from "@myunisoft/redis";
import { ValidateFunction } from "ajv";
import type { Logger } from "pino";
import { Transaction, TransactionStore } from "./store/transaction.class.js";
import type { DispatcherApprovementMessage, GenericEvent, IncomerChannelMessages, IncomerRegistrationMessage, RetryMessage, TransactionMetadata } from "../types/index.js";
import { NestedValidationFunctions, type StandardLog } from "../utils/index.js";
export declare const APPROVEMENT_SYM: unique symbol;
export declare const CLOSE_SYM: unique symbol;
export declare const RETRY_SYM: unique symbol;
export declare const CUSTOM_EVENT_SYM: unique symbol;
type AnyIncomerChannelMessage<T extends GenericEvent> = (IncomerChannelMessages<T>["DispatcherMessages"] | (IncomerChannelMessages<T>["IncomerMessages"] | RetryMessage));
type AnyEventChannelMessage<T extends GenericEvent> = IncomerRegistrationMessage | AnyIncomerChannelMessage<T>;
type DispatchedEvent<T extends GenericEvent> = (Omit<IncomerChannelMessages<T>["DispatcherMessages"] | DispatcherApprovementMessage, "redisMetadata">) & {
    redisMetadata: Omit<TransactionMetadata<"dispatcher">, "transactionId" | "iteration">;
};
export interface DispatchEventOptions<T extends GenericEvent> {
    channel: Channel<IncomerChannelMessages<T>["DispatcherMessages"] | DispatcherApprovementMessage>;
    event: DispatchedEvent<T>;
    redisMetadata: {
        mainTransaction: boolean;
        resolved: boolean;
        relatedTransaction?: null | string;
        eventTransactionId?: null | string;
        iteration?: number;
    };
    store: TransactionStore<"incomer"> | TransactionStore<"dispatcher">;
    dispatcherTransactionUUID?: string;
}
export type customValidationCbFn<T extends GenericEvent> = (event: T) => void;
export type eventsValidationFn<T extends GenericEvent> = Map<string, ValidateFunction<T> | NestedValidationFunctions>;
export interface EventsHandlerOptions<T extends GenericEvent> {
    privateUUID: string;
    dispatcherChannelName: string;
    eventsValidation?: {
        eventsValidationFn?: eventsValidationFn<T>;
        customValidationCbFn?: customValidationCbFn<T>;
    };
    standardLog?: StandardLog<T>;
    parentLogger: Logger;
}
export declare class EventsHandler<T extends GenericEvent> extends EventEmitter {
    #private;
    readonly privateUUID: string;
    readonly dispatcherChannelName: string;
    constructor(options: EventsHandlerOptions<T>);
    dispatch(options: DispatchEventOptions<T>): Promise<Transaction<"dispatcher"> | Transaction<"incomer">>;
    handleEvents(channel: string, event: AnyEventChannelMessage<T>): Promise<void>;
    private redisMetadataValidation;
    private dispatcherChannelMessagesSchemaValidation;
    private incomerChannelMessagesSchemaValidation;
}
export {};
//# sourceMappingURL=events.class.d.ts.map