import { RedisAdapter, TimedKVPeer, TimedKVPeerOptions } from "@myunisoft/redis";
import type { TransactionMetadata, DispatcherApprovementMessage, IncomerRegistrationMessage, IncomerChannelMessages, DispatcherPingMessage, DistributedEventMessage, Instance } from "../../types/index.js";
type BaseTransaction<IsMain extends boolean = true, RelatedTransaction = IsMain extends true ? string[] | null : string> = {
    published?: boolean;
    mainTransaction: IsMain;
    relatedTransaction: RelatedTransaction;
    resolved: boolean;
};
type HandlerTransaction = BaseTransaction<false> & {
    eventTransactionId?: string;
};
export type DispatcherMainTransaction = DispatcherPingMessage & {
    redisMetadata: BaseTransaction<true> & IncomerChannelMessages["DispatcherMessages"]["redisMetadata"];
};
export interface DispatcherSpreadTransaction {
    dispatcherApprovementTransaction: DispatcherApprovementMessage & {
        redisMetadata: BaseTransaction<false> & DispatcherApprovementMessage["redisMetadata"];
    };
    dispatcherDistributedEventTransaction: DistributedEventMessage & {
        redisMetadata: BaseTransaction<false> & IncomerChannelMessages["DispatcherMessages"]["redisMetadata"];
    };
}
export interface IncomerMainTransaction {
    incomerRegistrationTransaction: IncomerRegistrationMessage & {
        redisMetadata: BaseTransaction<true> & IncomerRegistrationMessage["redisMetadata"];
    };
    incomerEventCastTransaction: IncomerChannelMessages["IncomerMessages"] & {
        redisMetadata: BaseTransaction<true> & IncomerChannelMessages["IncomerMessages"]["redisMetadata"];
    };
}
type IncomerTransaction = IncomerMainTransaction["incomerRegistrationTransaction"] | IncomerMainTransaction["incomerEventCastTransaction"];
type DispatcherTransaction = DispatcherSpreadTransaction["dispatcherApprovementTransaction"] | DispatcherSpreadTransaction["dispatcherDistributedEventTransaction"] | DispatcherMainTransaction;
export type Transaction<T extends Instance> = (T extends "dispatcher" ? DispatcherTransaction : IncomerTransaction) & {
    aliveSince: number;
};
type MetadataWithoutTransactionId<T extends Instance> = T extends "dispatcher" ? Omit<TransactionMetadata<"dispatcher">, "to" | "transactionId"> & {
    to?: string;
} & (BaseTransaction<true> | BaseTransaction<false>) : Omit<TransactionMetadata<"incomer">, "transactionId"> & (BaseTransaction<true> | HandlerTransaction);
export type PartialTransaction<T extends Instance = Instance> = Omit<Transaction<T>, "redisMetadata" | "aliveSince"> & {
    redisMetadata: MetadataWithoutTransactionId<T>;
};
export type Transactions<T extends Instance> = Map<string, Transaction<T>>;
export type TransactionStoreOptions<T extends Instance> = (Omit<TimedKVPeerOptions, "prefix" | "adapter"> & (T extends "incomer" ? {
    prefix: string;
} : {
    prefix?: string;
}) & {
    adapter: RedisAdapter<Transaction<T>>;
    instance: T;
});
export declare class TransactionStore<T extends Instance = Instance> extends TimedKVPeer<Transaction<T>> {
    #private;
    adapter: RedisAdapter<Transaction<T>>;
    constructor(options: TransactionStoreOptions<T>);
    transactionLazyFetch(count?: number): AsyncGenerator<string[], void, unknown>;
    getTransactions(): Promise<Transactions<T>>;
    setTransaction(transaction: PartialTransaction<T>, transactionId?: string): Promise<Transaction<T>>;
    updateTransaction(transactionId: string, transaction: Transaction<T>): Promise<void>;
    getTransactionById(transactionId: string): Promise<Transaction<T> | null>;
    deleteTransaction(transactionId: string): Promise<void>;
    deleteTransactions(transactionIds: string[]): Promise<void>;
}
export {};
//# sourceMappingURL=transaction.class.d.ts.map