import type { Activity, AgentActivityFeedPage } from '../../shared/activity.js';
import { ActivityStore, type ActivityRecordInput } from '../storage/schema/activity.store.js';
export interface ActivityListInput {
    before?: string;
    limit?: number;
}
export interface ActivityRecorder {
    record(agentId: string, input: ActivityRecordInput): Promise<Activity>;
}
export declare class ActivityService {
    private readonly store;
    constructor(agentId: string, store?: ActivityStore);
    record(input: ActivityRecordInput): Promise<Activity>;
    readAll(): Promise<Activity[]>;
    readLastN(n: number): Promise<Activity[]>;
    /** Newest `n` activities matching a predicate, newest-first. */
    readNewestMatching(n: number, matches: (activity: Activity) => boolean): Promise<Activity[]>;
    readNewestUntil(shouldStop: (activity: Activity) => boolean): Promise<Activity[]>;
    listActivityFeed(input?: ActivityListInput): Promise<AgentActivityFeedPage>;
}
export declare function activityServiceForAgent(agentId: string): ActivityService;
export declare const defaultActivityRecorder: ActivityRecorder;
//# sourceMappingURL=activity.service.d.ts.map