/**
 * ActivityStreamService — FR-W04 活动流数据层
 *
 * AC1: 核心事件记录（创建、更新、废弃、冲突检测/解决、调研完成、规则变更）
 * AC2: 按事件类型筛选 + 按日期分组 + 统一时间格式
 * AC3: 实时推送（通过 EventBus 订阅 pipeline 事件）
 * AC4: 断线重连补发（基于 cursor 的增量拉取）
 */
import type { EventBus } from '../pipeline/event-bus.js';
import type { ActivityEvent, ActivityStreamQuery, ActivityStreamResult, DateGroup } from './workbench-types.js';
export type ActivityListener = (event: ActivityEvent) => void;
export declare class ActivityStreamService {
    private eventBus?;
    private events;
    private listeners;
    private idCounter;
    constructor(eventBus?: EventBus | undefined);
    /** AC3: 注册实时监听器 */
    subscribe(listener: ActivityListener): () => void;
    /** 手动推入活动事件 */
    push(event: Omit<ActivityEvent, 'id'>): ActivityEvent;
    /** AC2 + AC4: 查询活动流（支持 cursor 增量拉取 + 类型筛选） */
    query(q: ActivityStreamQuery): ActivityStreamResult;
    /** AC2: 按日期分组 */
    groupByDate(events: ActivityEvent[]): DateGroup[];
    /** AC3: 订阅 pipeline EventBus，自动转换为活动事件 */
    private subscribeToPipeline;
}
//# sourceMappingURL=activity-stream-service.d.ts.map