import type { ILifecycle } from '@omnitron-dev/titan/types';
import type { MessagingTransport, TransportMiddleware, NotificationHandler, DLQStats, DLQQueryOptions, DLQMessageInfo, DLQCleanupConfig } from './transport/transport.interface.js';
import type { NotificationPayload, NotificationRecipient, SendOptions, SendResult, BroadcastOptions, BroadcastResult, ScheduleResult, IRateLimiter, IPreferenceStore, IChannelRouter, StoredNotification } from './notifications.types.js';
import { ChannelRegistry } from './channel/channel-registry.js';
export declare class NotificationsService implements ILifecycle {
    private readonly transport;
    private readonly rateLimiter?;
    private readonly preferenceStore?;
    private readonly channelRouter?;
    private readonly channelRegistry?;
    constructor(transport: MessagingTransport, rateLimiter?: IRateLimiter | undefined, preferenceStore?: IPreferenceStore | undefined, channelRouter?: IChannelRouter | undefined, channelRegistry?: ChannelRegistry | undefined);
    send(recipient: NotificationRecipient, payload: NotificationPayload, options?: SendOptions): Promise<SendResult>;
    broadcast(recipients: NotificationRecipient[], payload: NotificationPayload, options?: BroadcastOptions): Promise<BroadcastResult>;
    schedule(recipient: NotificationRecipient, payload: NotificationPayload, scheduledAt: Date | number, options?: SendOptions): Promise<ScheduleResult>;
    cancel(notificationId: string): Promise<boolean>;
    getStatus(notificationId: string): Promise<SendResult | null>;
    getTransport(): MessagingTransport;
    healthCheck(): Promise<import("./transport/transport.interface.js").TransportHealth>;
    waitUntilReady(): Promise<void>;
    onInit(): Promise<void>;
    onStart(): Promise<void>;
    onStop(): Promise<void>;
    onDestroy(): Promise<void>;
    use(middleware: TransportMiddleware): void;
    subscribeToDLQ(handler: NotificationHandler): Promise<void>;
    requeueFromDLQ(count?: number): Promise<number>;
    getDLQStats(): Promise<DLQStats>;
    getDLQMessages(options?: DLQQueryOptions): Promise<DLQMessageInfo[]>;
    cleanupDLQ(): Promise<number>;
    clearDLQ(): Promise<void>;
    updateDLQConfig(config: Partial<DLQCleanupConfig>): void;
    private deliverToChannels;
    getUnreadNotifications(recipientId: string, limit?: number): Promise<StoredNotification[]>;
    markNotificationAsRead(recipientId: string, notificationId: string): Promise<void>;
    markAllNotificationsAsRead(recipientId: string): Promise<void>;
    getUnreadCount(recipientId: string): Promise<number>;
    getChannelRegistry(): ChannelRegistry | undefined;
    getChannelsHealth(): Promise<Map<string, any> | undefined>;
    private generateId;
    private buildChannel;
}
export type { IRateLimiter, IPreferenceStore, IChannelRouter };
//# sourceMappingURL=notifications.service.d.ts.map