/**
 * P1-8：`/events` 管理 SSE 的身份寿命绑定。
 *
 * SSE 的门禁只在建立连接的那一刻跑过一次，之后帧是**服务端主动推**的，请求门禁
 * 再也没有机会说话。于是登出 / token rotate / 平台解绑之后，旧连接照旧收帧——不
 * 只是「多看了会话板一会儿」，而是会收到 **吊销之后新产生的** 数据：会话行里的
 * `riffAccessUrl` 是 Riff 沙箱的写凭据，rotate 的本意就是让旧链接失效，结果旧
 * SSE 把 rotate 之后新签的写凭据继续送给上一任持有者。
 *
 * 这里给每条流两层保护：
 *  1. **推送前复核**：每帧写出前重查 authSession 是否仍有效，失效就结束响应，
 *    这一帧不写。哪怕主动关闭那条路径漏掉了某个入口（新增的吊销来源），也不会
 *    把新数据送出去。
 *  2. **主动关闭**：建流时登记进 authSession→连接索引，吊销时遍历 destroy，
 *    不等下一帧、不等心跳。
 *
 * 匿名（publicReadOnly）连接没有认证会话，不属于任何身份，行为保持原样。
 */
import type { ServerResponse } from 'node:http';
/**
 * 这条流的受众口径，必须与 REST 门禁同源：
 *  - `management`：本机管理 cookie（legacy owner），能力等同 `/api/*` 全集。
 *  - `workbench`：只有工作台能力的身份（飞书 H5 会话、平台注入角色，owner 也算）
 *    —— 走 `decideWorkbenchH5Auth` 窄门禁，能力表里**没有** `/api/schedules`。
 *  - `anonymous`：`publicReadOnly` 下的无身份访客，走既有的脱敏投影。
 */
export type DashboardEventAudience = 'management' | 'workbench' | 'anonymous';
/**
 * P1-14 姊妹项：`/events` 的推送必须服从与 REST 同一份能力表。
 *
 * `GET /api/schedules` 对 Workbench-only 身份是明确的 401（排程行带 `prompt`
 * 业务指令与 `workingDir` 仓库/客户路径，`schedule.fired` 还带 `error` 原文），
 * 但 SSE 的门禁只在建流那一刻跑过一次，之后帧是服务端主动推的——于是同一份数据
 * 换个管子照样出去了。这里在写出前按受众整类丢弃 `schedule.*`：REST 说不行的，
 * SSE 也一帧不给。
 *
 * 匿名 public-read 不变（`/api/schedules` 在 publicReadOnly 允许表里，帧由
 * dashboard.ts 做同款脱敏）；management 不变。
 */
export declare function dashboardEventVisibleTo(event: string, audience: DashboardEventAudience): boolean;
export interface DashboardEventsStreamOptions {
    res: ServerResponse;
    /** 本流归属的认证会话；匿名 public-read 连接为 null。 */
    authSessionId: string | null;
    /** 本流的受众能力口径。必填：漏传就等于默默放宽，所以不给缺省值。 */
    audience: DashboardEventAudience;
    /** 认证会话是否仍然有效（H5 会话表 / 活跃 token / 平台绑定的统一口径）。 */
    isAuthSessionLive: (authSessionId: string) => boolean;
    /** 登记进 authSession→长连接索引，返回注销闭包。 */
    bind?: (authSessionId: string, close: () => void) => () => void;
}
export interface DashboardEventsStream {
    /** 写一帧；身份已失效或流已关闭时返回 false 且不写任何字节。 */
    write(event: string, data: unknown): boolean;
    /** 客户端断开 / 服务端吊销后的清理（幂等）。 */
    dispose(): void;
    readonly closed: boolean;
}
export declare function createDashboardEventsStream(options: DashboardEventsStreamOptions): DashboardEventsStream;
//# sourceMappingURL=events-sse.d.ts.map