import type { SignalEventsRepository } from "../../storage/signalEventsRepository.js";
import type { SignalSubscriptionsRepository } from "../../storage/signalSubscriptionsRepository.js";
import type { EngineEventBus } from "../ipc/events.js";
import type { Signal, SignalGenerateInput, SignalSubscribeInput, SignalSubscription, SignalUnsubscribeInput } from "./signalTypes.js";
type SignalsRepositoryOptions = {
    signalEvents: Pick<SignalEventsRepository, "create" | "findAll" | "findRecentAll">;
    signalSubscriptions: Pick<SignalSubscriptionsRepository, "create" | "delete" | "findByUserAndAgent" | "findMany" | "findMatching">;
};
type SignalsLegacyOptions = {
    configDir: string;
};
export type SignalsOptions = {
    eventBus: EngineEventBus;
    onDeliver?: (signal: Signal, subscriptions: SignalSubscription[]) => Promise<void> | void;
} & (SignalsRepositoryOptions | SignalsLegacyOptions);
export declare class Signals {
    private readonly eventBus;
    private readonly signalEvents;
    private readonly signalSubscriptions;
    private readonly onDeliver;
    constructor(options: SignalsOptions);
    ensureDir(): Promise<void>;
    /**
     * Generates a signal event and publishes it to the engine event bus.
     * Expects: input.type is non-empty after trim.
     */
    generate(input: SignalGenerateInput): Promise<Signal>;
    subscribe(input: SignalSubscribeInput): Promise<SignalSubscription>;
    /**
     * Returns a subscription for an exact agent + pattern pair when present.
     * Returns: null when no subscription exists.
     */
    subscriptionGet(input: SignalUnsubscribeInput): Promise<SignalSubscription | null>;
    /**
     * Removes an existing signal subscription for agent + pattern.
     * Returns: true when a subscription existed and was removed.
     */
    unsubscribe(input: SignalUnsubscribeInput): Promise<boolean>;
    /**
     * Returns all active signal subscriptions as a snapshot array.
     */
    listSubscriptions(): Promise<SignalSubscription[]>;
    /**
     * Returns all persisted signal events in append order.
     */
    listAll(): Promise<Signal[]>;
    listRecent(limit?: number): Promise<Signal[]>;
    private signalDeliver;
}
export {};
//# sourceMappingURL=signals.d.ts.map