ingest

type AddOptions struct {
	URL         string
	TargetDir   string
	Author      string
	Contributor string
	WorkingDir  string
	Timeout     time.Duration
}

type AddResult struct {
	Artifact string
	Result   Result
}

type Engine interface {
	Preflight(context.Context) (string, error)
	Add(context.Context, AddOptions) (AddResult, error)
	Extract(context.Context, ExtractOptions) (GraphStats, Result, error)
}

type ExtractOptions struct {
	CorpusDir      string
	OutputDir      string
	WorkingDir     string
	Backend        string
	Model          string
	Mode           string
	MaxWorkers     int
	TokenBudget    int
	MaxConcurrency int
	APITimeout     time.Duration
	Timeout        time.Duration
	Force          bool
	NoCluster      bool
	// Env contains per-attempt credentials and routing overrides. Adapters must
	// pass it only to the child engine process and must not persist or log it.
	Env []string
}

type GraphStats struct {
	Path  string `json:"path"`
	Nodes int    `json:"nodes"`
	Edges int    `json:"edges"`
}

type Result struct {
	Stdout   string
	Stderr   string
	ExitCode int
	Duration time.Duration
	Err      error
}