serving

type Binding struct {
	Channel channel.Channel
	Agent   Runnable
	// SessionMapping:chat(群共享会话)| chat_user(群内每人独立会话)。
	SessionMapping string
	// ReplyMode 是**无装饰器时的内置默认策略**:text(整段回复,跳过
	// processing)| card(占位卡+原地更新)| stream(占位+流式刷新)。
	// 装了 Decorator 后生命周期全模式统一驱动,发不发由装饰器 Skip 定。
	// card/stream 需通道支持 Update,不支持自动退化为整段。
	ReplyMode string
	// AskTimeout 是 ask_user / 审批等待用户回复的超时,默认 10 分钟。
	AskTimeout time.Duration
	// Placeholder 是 processing 占位文案的快捷覆盖,空 = 取 Texts.Placeholder
	// (再空则英文默认「⏳ Working…」)。
	Placeholder string
	// Texts 覆盖面向用户的文案(nil = 全英文默认);部分填充即可,空字段
	// 回落默认。IM 部署(如中文机器人)在此配中文。
	Texts *Texts
	// Decorator 装饰每条出站消息(nil = 不装饰,按 ReplyMode 默认策略)。
	Decorator Decorator
	// OnProgress 是第三方进度订阅(装了它,内置的卡片过程更新让位)。
	OnProgress ProgressHandler
}

type ContextHook func(ctx context.Context, info InboundInfo) context.Context

type Decorator func(ctx context.Context, conv channel.ConvRef, out channel.Outbound) channel.Outbound

type Dispatcher struct {
	// contains filtered or unexported fields
}

type InboundInfo struct {
	Channel string // "http" | "a2a" | 通道名(如 feishu)
	User    string // 终端用户身份(可空)
	Session string // 会话标识
}

type ProgressHandler func(ctx context.Context, conv channel.ConvRef, ev runctx.ProgressEvent)

type Runnable interface {
	Name() string
	Description() string
	Run(ctx context.Context, sessionID, input string) (string, error)
	Stream(ctx context.Context, sessionID, input string) (*schema.StreamReader[*schema.Message], error)
	// Interrupt 叫停会话当前运行;Steer 向运行中注入插话。均幂等,无运行时为空操作。
	Interrupt(sessionID string)
	Steer(sessionID, msg string)
}

type Server struct {
	// contains filtered or unexported fields
}

type Texts struct {
	Placeholder string // processing placeholder (no verbs)
	StepRunning string // in-progress step line: %s = step name
	StepDone    string // finished step line: %s name, %.1f seconds
	StepFailed  string // failed step line: %s name, %.1f seconds
	Summary     string // completion meta: %.1f seconds, %d tool calls
	Stopped     string // ack for a stop command (no verbs)
	Steered     string // ack for a steer command (no verbs)
	Overloaded  string // session queue full (no verbs)
	Thinking    string // stream placeholder (no verbs)
	Suspended   string // waiting-for-reply close line (no verbs)
	Failure     string // error close line: %s = error text
	Approval    string // approval question: %s description, %s arguments
	AskTimeout  string // ask/approval reply timeout (no verbs)
	Deliverable string // deliverable follow-up header: %s id, %s title; empty format = content only
}