/**
 * 通道模块统一类型：与传输方式（webhook / 长连接）解耦。
 */
/** 统一入站消息：所有入站解析后的共同结构 */
export interface UnifiedMessage {
    /** 通道标识，如 feishu / telegram */
    channelId: string;
    /** 平台内会话/群组/单聊标识，回复时用 */
    threadId: string;
    /** 平台内用户标识 */
    userId: string;
    /** 用户显示名（可选） */
    userName?: string;
    /** 消息正文 */
    messageText: string;
    /** 附件（可选） */
    attachments?: {
        type: string;
        url?: string;
        name?: string;
    }[];
    /** 原始 payload（排查用） */
    raw?: unknown;
    /** 回复应交给哪个出站，如 "default" 或 connectionId */
    replyTarget?: string;
    /** 平台消息 ID（可选，用于回复引用等） */
    messageId?: string;
    /** 通道可选：回复发送完成后调用的 ack（如钉钉 Stream 需回调响应防重试），参数为 send 返回值 */
    ack?: (sendResult?: unknown) => void | Promise<void>;
}
/** 统一出站回复 */
export interface UnifiedReply {
    text: string;
    attachments?: {
        type: string;
        url?: string;
        name?: string;
    }[];
}
/** 入站传输：从外部收数据 → 产出 UnifiedMessage */
export interface IInboundTransport {
    start(): Promise<void>;
    stop(): Promise<void>;
    /** 设置收到消息时的回调 */
    setMessageHandler(handler: (msg: UnifiedMessage) => void | Promise<void>): void;
}
/** 流式出站：先发一条占位消息，再由调用方按累积内容多次更新。返回的 sink 由 channel-core 在 onChunk / onTurnEnd / onDone 时调用。 */
export interface StreamSink {
    /** 更新当前已累积的全文（节流后调用），通道可用来做占位或实时更新 */
    onChunk(accumulated: string): void | Promise<void>;
    /** 可选：agent 每轮结束（turn_end）时调用，通道可在此发一条消息（如钉钉按轮发） */
    onTurnEnd?(accumulated: string): void | Promise<void>;
    /** 流结束，做最终一次更新 */
    onDone(accumulated: string): void | Promise<void>;
}
/** 出站传输：将 UnifiedReply 发到外部；返回值可传给 UnifiedMessage.ack */
export interface IOutboundTransport {
    send(targetId: string, reply: UnifiedReply): Promise<unknown>;
    /** 可选：该出站是否还能往 targetId 发（如连接是否有效） */
    canSend?(targetId: string): boolean;
    /** 可选：流式发送。先创建占位消息，返回 sink 供调用方按累积内容更新（如飞书 create + patch）。 */
    sendStream?(targetId: string): Promise<StreamSink>;
}
/** 通道：身份 + 入站/出站列表 + 回复路由 */
export interface IChannel {
    id: string;
    name: string;
    /** 默认 agentId，用于会话 */
    defaultAgentId?: string;
    getInbounds(): IInboundTransport[];
    getOutbounds(): IOutboundTransport[];
    /** 根据消息或 threadId 选择出站；默认返回第一个 outbound */
    getOutboundForMessage?(msg: UnifiedMessage): IOutboundTransport | undefined;
}