import { Observable, ReplaySubject } from "rxjs";
import { NostrEvent } from "../helpers/event.js";
import { Filter } from "../helpers/filter.js";
import { AddressPointer, AddressPointerWithoutD, EventPointer, ProfilePointer } from "../helpers/pointers.js";
import { IAsyncEventStore, IEventStore, IEventSubscriptions, ModelConstructor } from "./interface.js";
/**
 * Base class that provides model functionality for both sync and async event stores.
 * This class can be extended by other packages to add additional helpful subscription methods.
 *
 * @example
 * ```ts
 * // In another package (e.g., applesauce-common)
 * import { EventModels } from "applesauce-core/event-store";
 *
 * // Add methods to the prototype
 * EventModels.prototype.mutes = function(user) {
 *   return this.model(MuteModel, user);
 * };
 *
 * // Extend the type via module augmentation
 * declare module "applesauce-core/event-store" {
 *   interface EventModels {
 *     mutes(user: string | ProfilePointer): Observable<Mutes | undefined>;
 *   }
 * }
 * ```
 */
export declare class EventModels<TStore extends IEventStore | IAsyncEventStore = IEventStore | IAsyncEventStore> implements IEventSubscriptions {
    /** A directory of all active models */
    models: Map<ModelConstructor<any, any[], TStore>, Map<string, Observable<any>>>;
    /** How long a model should be kept "warm" while nothing is subscribed to it */
    modelKeepWarm: number;
    /**
     * Emits when {@link EventModels.dispose} is called to tear down all models.
     * A {@link ReplaySubject} so reset notifiers subscribed after disposal fire immediately.
     */
    protected destroy$: ReplaySubject<void>;
    /** Get or create a model on the event store */
    model<T extends unknown, Args extends Array<any>>(constructor: ModelConstructor<T, Args, TStore>, ...args: Args): Observable<T>;
    /**
     * Creates an observable that streams all events that match the filter
     * @param filters
     * @param [onlyNew=false] Only subscribe to new events
     */
    filters(filters: Filter | Filter[], onlyNew?: boolean): Observable<NostrEvent>;
    /** Subscribe to an event by pointer */
    event(pointer: string | EventPointer | AddressPointer | AddressPointerWithoutD): Observable<NostrEvent | undefined>;
    /** Subscribe to a replaceable event by pointer */
    replaceable(pointer: AddressPointer | AddressPointerWithoutD): Observable<NostrEvent | undefined>;
    replaceable(kind: number, pubkey: string, identifier?: string): Observable<NostrEvent | undefined>;
    /** Subscribe to an addressable event by pointer */
    addressable(pointer: AddressPointer): Observable<NostrEvent | undefined>;
    /** Creates a {@link TimelineModel} */
    timeline(filters: Filter | Filter[], includeOldVersion?: boolean): Observable<NostrEvent[]>;
    /** Subscribe to a users profile */
    profile(user: string | ProfilePointer): Observable<import("../helpers/profile.js").ProfileContent | undefined>;
    /** Subscribe to a users contacts */
    contacts(user: string | ProfilePointer): Observable<ProfilePointer[]>;
    /** Subscribe to a users mailboxes */
    mailboxes(user: string | ProfilePointer): Observable<{
        inboxes: string[];
        outboxes: string[];
    } | undefined>;
    /**
     * Tears down all models, completing active subscriptions and releasing their keep-warm timers immediately.
     * @note This is a terminal operation; the instance should be discarded after calling it.
     */
    dispose(): void;
}