pipeline

type BatchFunc func(Envelope) (Envelope, error)

type BatchRunner struct {
	Name string
	// Context 是本次命令调用的生命周期；未设置时使用 Background。
	Context context.Context
	// Kinds 是文本 ref 输入分配的 kind 与消费者接受的 kind。
	Kinds []Kind
	// ClientFactory 每次批量执行调用一次，返回携带默认 token 的 client。
	ClientFactory func() (*javdb.Client, error)
	// RunOne 执行单项并返回输出信封。
	RunOne func(*javdb.Client, context.Context, Envelope) (Envelope, error)
	// RunMany 执行单项并返回多个输出信封（fan-out）；设置时优先于 RunOne。
	// 调用方负责在返回的信封中携带稳定 ref/id。
	RunMany func(*javdb.Client, context.Context, Envelope) ([]Envelope, error)
	// Legacy 处理单项既有路径（args 为位置参数列表）。
	Legacy func(args []string) error
	// RenderText 是 pipeline 文本/人类模式的领域投影；nil 时输出稳定 ref。
	RenderText func(io.Writer, Envelope) error
	// RenderError 是 pipeline 文本/人类模式的错误投影；nil 使用 Name 前缀。
	RenderError func(io.Writer, error) error
	// RouteTextThroughPipeline 让单项纯文本输入的非 TTY OutputText 走 Consumer。
	// 未启用时保留本地/有副作用命令的既有 Legacy 文本语义；需要稳定记录的
	// 只读命令应显式启用此选项。
	RouteTextThroughPipeline bool
	// LegacyJSON 表示 Legacy 路径已支持显式 --json 输出（保持既有 shape）。
	// 为 false 时，单项显式 --json 也走 consumer 路径（RunOne + 信封对象输出），
	// 避免本地命令（mark/config 等）在 --json 下静默输出裸文本或无输出。
	LegacyJSON bool
	// Preflight 在批处理路径开始前校验全部输入（如 download 的全量目标展开
	// 与冲突检查）；返回错误时整个批处理失败，不做任何写入。
	Preflight func([]Envelope) error
	// Concurrency 控制批量执行并发度；<= 0 表示串行。
	Concurrency int
}

type Classification int

type Consumer struct {
	Name string
	// Context 是本次命令调用的生命周期；未设置时使用 Background。
	Context context.Context
	// AcceptedKinds 是输入项允许的 kind；nil 表示接受任意 kind（文本 ref）。
	AcceptedKinds []Kind
	// RunOne 执行单项并返回输出信封。
	RunOne func(context.Context, Envelope) (Envelope, error)
	// RunMany 执行单项并返回多个输出信封（fan-out）；设置时优先于 RunOne。
	RunMany func(context.Context, Envelope) ([]Envelope, error)
	// RenderText 输出默认的人类文本。
	RenderText func(io.Writer, Envelope) error
	// RenderError 将文本/人类模式的单项错误写到 stderr；nil 使用 Name 前缀。
	RenderError func(io.Writer, error) error
	// LegacyJSON 输出单项显式 --json 的既有 shape；nil 时输出信封对象。
	LegacyJSON func(io.Writer, Envelope) error
	// Concurrency 控制批量执行并发度；<= 0 表示串行。并发时结果按输入顺序
	// 写出，单项失败不阻塞其他项。
	Concurrency int
}

type Envelope struct {
	Schema string         `json:"schema"`
	Kind   Kind           `json:"kind"`
	Ref    string         `json:"ref,omitempty"`
	ID     string         `json:"id,omitempty"`
	Data   map[string]any `json:"data,omitempty"`
	Meta   map[string]any `json:"meta,omitempty"`
}

type Kind string

type ListProducer struct {
	Name string
	// ClientFactory 每次执行调用一次。
	ClientFactory func() (*javdb.Client, error)
	// Fetch 执行并返回列表项。
	Fetch func(context.Context, *javdb.Client) ([]map[string]any, error)
	// JSON 构造显式 --json 的既有 shape 载荷。
	JSON func([]map[string]any) (map[string]any, error)
	// ErrNote 可选：输出前写 stderr 注解。
	ErrNote func(io.Writer, []map[string]any)
	// ItemKind 是信封 kind（默认 movie）。
	ItemKind Kind
	// ItemRef 提取 (ref, id)（默认 number/id）。
	ItemRef func(map[string]any) (string, string)
	// RowText 渲染人类文本行（默认 movie 投影行）。
	RowText func(io.Writer, io.Writer, []map[string]any) error
}

type MovieListProducer = ListProducer

type OutputMode int

type Producer struct {
	Name string
	// Produce 执行并返回输出信封序列（空切片表示无结果）。
	Produce func(context.Context) ([]Envelope, error)
	// RenderText 渲染人类文本。
	RenderText func(io.Writer, []Envelope) error
	// LegacyJSON 输出显式 --json 的既有 shape。
	LegacyJSON func(io.Writer) error
}

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