model

type CHInserter interface {
	Insert(ctx context.Context, ds *Datasource, rows []map[string]any) error
}

type CHQuerier interface {
	Query(ctx context.Context, sql string, params, settings map[string]string) ([]byte, error)
}

type CHWriter interface {
	InsertSelect(ctx context.Context, sql string, params map[string]string) error
}

type Column struct {
	Name string
	Type string // ClickHouse type verbatim, e.g. "String", "DateTime", "JSON"
}

type Copy struct {
	Name             string
	TargetDatasource string  // INSERT target; validated to exist at deploy time
	Schedule         string  // cron expression from COPY_SCHEDULE; "" = on-demand only
	SQL              string  // the SELECT whose rows are inserted
	Params           []Param // {{Type(name)}} placeholders in the copy SQL, in order
}

type CopyRunner interface {
	RunCopy(ctx context.Context, name string, params url.Values) (body []byte, status int, err error)
}

type Datasource struct {
	Name       string            // file basename without extension
	Schema     []Column          // ordered, as written
	Engine     string            // "MergeTree" if ENGINE omitted
	EngineOpts map[string]string // ENGINE_* keys (full key incl. prefix) -> value, verbatim
	Raw        string            // original file text
}

type DatasourceRegistry interface {
	Get(ctx context.Context, name string) (*Datasource, bool, error)
	Put(ctx context.Context, ds *Datasource) error
	List(ctx context.Context) ([]*Datasource, error)
}

type Endpoint struct {
	Name      string
	SQL       string
	Params    []Param // extracted from SQL, in order of appearance
	RateLimit int     // requests/sec, 0 = unset
	CacheTTL  int     // seconds; 0 = caching off (ADR 0009)
}

type Ingester interface {
	Ingest(ctx context.Context, datasource string, rows []json.RawMessage) (successful, quarantined int, err error)
}

type JobRecord struct {
	ID        string
	Kind      string // "copy" today; other job kinds (gap #6 import) would add values
	Status    string // "done" | "error" until an async path exists
	PipeName  string
	Target    string
	CreatedAt time.Time
}

type JobStore interface {
	Put(ctx context.Context, rec JobRecord) error
	Get(ctx context.Context, id string) (JobRecord, bool, error)
	// List returns up to limit most-recent records, newest first.
	List(ctx context.Context, limit int) ([]JobRecord, error)
}

type Materialization struct {
	Name        string
	TargetTable string
	SQL         string
}

type Node struct {
	Name string
	SQL  string
}

type OutputFormat string

type Param struct {
	Name       string
	Type       ParamType
	Default    string
	HasDefault bool
}

type ParamType string

type Pinger interface {
	Ping(ctx context.Context) error
}

type Pipe struct {
	Name     string
	Nodes    []Node
	Endpoint *Endpoint
	Material *Materialization
	Copy     *Copy
	Raw      string
}

type PipeRegistry interface {
	Get(name string) (*Pipe, bool)
	Put(p *Pipe)
	List() []*Pipe
}

type PipeRunner interface {
	Run(ctx context.Context, name string, params url.Values) (body []byte, status int, err error)
	RunFormat(ctx context.Context, name string, params url.Values, format OutputFormat) (body []byte, status int, err error)
}

type QueryStat struct {
	Pipe       string
	DurationMS float64
	ReadRows   int64
	ReadBytes  int64
	StatusCode int
	Error      string // empty on success
}

type StatsRecorder interface {
	Record(stat QueryStat)
}

type Token struct {
	Name   string
	Value  string
	Scopes []string
}

type TokenManager interface {
	// List returns every stored token. Callers MUST NOT expose Token.Value.
	List(ctx context.Context) ([]*Token, error)
	// Create mints a new opaque bearer value, persists the token, and returns it
	// (Value populated) exactly once — the only time the secret is revealed.
	Create(ctx context.Context, name string, scopes []string) (*Token, error)
	// DeleteByName revokes the token with the given name; ok=false if none matched.
	DeleteByName(ctx context.Context, name string) (ok bool, err error)
}

type TokenStore interface {
	// Validate returns the token for a bearer value, or ok=false if unknown.
	Validate(ctx context.Context, value string) (*Token, bool, error)
	Put(ctx context.Context, t *Token) error
}

type Truncater interface {
	Truncate(ctx context.Context, table string) error
}