build

type Build struct {
	Project   *BuildProject
	DAG       *DAG
	Engine    *TemplateEngine
	Options   BuildOptions
	Selected  []string // selected node names after selector filtering
	SubBuilds []*Build // compiled sub-projects (for multi-target compile mode)

	ExecRows  uint64 // sum of model/seed rows after Execute
	ExecBytes uint64
	Results   []ExecutionResult // per-node results after Execute
	// contains filtered or unexported fields
}

type BuildConfig struct {
	Target     string         `json:"target,omitempty" yaml:"target"`
	Dev        *DevConfig     `json:"dev,omitempty" yaml:"dev,omitempty"`
	DbtProject any            `json:"dbt_project,omitempty" yaml:"dbt_project,omitempty"`
	Vars       map[string]any `json:"vars,omitempty" yaml:"vars,omitempty"`
	Defaults   BuildDefaults  `json:"defaults,omitempty" yaml:"defaults,omitempty"`

	// Order and Nodes are the compiled output, set by Build.Compile.
	// They live on the root config only; mergeConfigs does not carry them.
	Order    []string `json:"order" yaml:"-"`
	Nodes    []Node   `json:"nodes" yaml:"-"`
	Compiled bool     `json:"compiled" yaml:"-"`
	// contains filtered or unexported fields
}

type BuildDefaults struct {
	Mode          string        `yaml:"mode,omitempty"`
	Schema        string        `yaml:"schema,omitempty"`
	Database      string        `yaml:"database,omitempty"` // three-part dialects only
	Tags          []string      `yaml:"tags,omitempty"`     // additive across nesting
	UniqueKey     any           `yaml:"unique_key,omitempty"`
	UpdateKey     string        `yaml:"update_key,omitempty"`
	MergeStrategy string        `yaml:"merge_strategy,omitempty"`
	Enabled       *bool         `yaml:"enabled,omitempty"`
	Hooks         sling.HookMap `yaml:"hooks,omitempty"` // additive across nesting
	DropCascade   *bool         `yaml:"drop_cascade,omitempty"`
}

type BuildModelState struct {
	Name     string `json:"name,omitempty"`
	Schema   string `json:"schema,omitempty"`
	Database string `json:"database,omitempty"`
	FullName string `json:"full_name,omitempty"`
	Mode     string `json:"mode,omitempty"`
}

type BuildOptions struct {
	Target      string
	Schema      string
	Prod        bool
	Vars        map[string]any
	FullRefresh bool
	Select      []string
	Exclude     []string
	Compile     bool
	Threads     int
	FailFast    bool
	List        bool
	NoSeeds     bool
	Range       *string // CLI --range: "start,end[,step]"
	Recursive   bool    // CLI --recursive/-R: discover sling_build.yml in immediate subdirectories
	Test        bool    // CLI --test: run data tests only (no materialization)
	JSON        bool    // CLI --json: machine-readable compile/list output
	// SkipUnresolvedCheck skips the ${VAR} error for fields in effect.
	// sling validate uses this because it does not choose a run mode.
	SkipUnresolvedCheck bool
}

type BuildProject struct {
	Dir            string
	Config         *BuildConfig            // from sling_build.yml (nil if missing)
	Models         map[string]*Model       // keyed by unique model name
	Seeds          map[string]*Seed        // keyed by unique seed name
	Macros         []*MacroFile            // collected .macros.sql files
	Mode           string                  // "dev" or "prod"
	SchemaOverride string                  // dev mode schema
	DefaultSchema  string                  // default schema for root-level files (default: "public")
	ChildConfigs   map[string]*BuildConfig // child sling_build.yml configs keyed by relative dir
	SubProjects    []*BuildProject         // independent build projects (when no root yml)
	Recursive      bool                    // CLI --recursive: keep immediate child projects
}

type BuildState struct {
	State     map[string]map[string]any `json:"state,omitempty"`
	Store     map[string]any            `json:"store,omitempty"`
	Env       map[string]any            `json:"env,omitempty"`
	Timestamp sling.DateTimeState       `json:"timestamp,omitempty"`
	Model     BuildModelState           `json:"model,omitempty"`
	Target    BuildTargetState          `json:"target,omitempty"`
}

type BuildTargetState struct {
	Name string `json:"name,omitempty"`
}

type DAG struct {
	Nodes map[string]*DAGNode
	Order []string // topological sort result
}

type DAGNode struct {
	Name         string
	Model        *Model // nil for seeds
	Seed         *Seed  // nil for models
	Dependencies []string
	Dependents   []string
	Depth        int
}

type DbtProjectConfig struct {
	ModelsPath string `yaml:"models_path,omitempty"` // default: "models"
	SeedsPath  string `yaml:"seeds_path,omitempty"`  // default: "seeds"
}

type DevConfig struct {
	Target   string `yaml:"target,omitempty"`   // optional, falls back to top-level target
	Schema   string `yaml:"schema"`             // mandatory for dev mode
	Database string `yaml:"database,omitempty"` // optional; falls back to defaults.database
}

type ExecutionResult struct {
	Name      string
	NodeType  string // "seed", "model", or "test"
	Mode      string // "full-refresh", "view", "truncate", "incremental", "append"
	Duration  time.Duration
	Err       error
	Skipped   bool
	StartTime *time.Time
	// Rows is sql.Result.RowsAffected, or COUNT(*) on column-store
	// full-refresh / truncate / first-run append. Incremental and subsequent
	// append count the staging temp table. CREATE VIEW reports 0.
	Rows  uint64
	Bytes uint64
}

type Executor struct {
	Build    *Build
	ConnName string              // resolved target connection name
	DbConn   database.Connection // database connection (nil until Connect)
	Results  []ExecutionResult   // per-node results
	RunID    string              // unique per Execute() for temp table isolation
	// contains filtered or unexported fields
}

type IncrementalContext struct {
	WhereCond     string // e.g., `"created_at" > '2024-01-01'` or "1=1"
	Value         string // e.g., `'2024-01-01'` or "null"
	IsIncremental bool   // drives is_incremental() for dbt-style models
}

type MacroFile struct {
	FilePath string // absolute path
	Dir      string // directory relative to project root ("" for root, "staging", "marts/core")
	RawSQL   string // raw file content with {% macro %} definitions
}

type Model struct {
	Name              string      // file stem, unique across the project, e.g. "events"
	FilePath          string      // absolute path
	RelPath           string      // relative path from project root
	Schema            string      // derived from first folder or override
	Database          string      // optional catalog; three-part dialects only
	FullTableName     string      // [database.]schema.name (current mode)
	ProdFullTableName string      // [database.]schema.name (always prod-mode, for SQL matching)
	RawSQL            string      // raw file content (frontmatter stripped)
	CompiledSQL       string      // after Jinja rendering
	PreStatements     []string    // SQL statements before the model query (from multi-statement splitting)
	PostStatements    []string    // SQL statements after the model query (from multi-statement splitting)
	Config            ModelConfig // from YAML frontmatter or config() block
	HasFrontmatter    bool        // true if config was set via YAML frontmatter (config() becomes no-op)
	Style             Style       // detected incremental pattern: StyleDbt or StyleSling (populated at load)
	Refs              []string    // ref() dependencies
	Sources           []string    // src() references
	DependsOn         []string    // all DAG dependencies (refs + bare refs + auto-detected)
	// contains filtered or unexported fields
}

type ModelConfig struct {
	Mode          string        `yaml:"mode,omitempty"`
	Materialized  string        `yaml:"materialized,omitempty"` // dbt alias for mode
	UniqueKey     any           `yaml:"unique_key,omitempty"`   // string or []string
	MergeStrategy string        `yaml:"merge_strategy,omitempty"`
	UpdateKey     string        `yaml:"update_key,omitempty"`
	Tags          []string      `yaml:"tags,omitempty"`
	Hooks         sling.HookMap `yaml:"hooks,omitempty"`
	PreHook       string        `yaml:"pre_hook,omitempty"`  // deprecated: kept for validation only
	PostHook      string        `yaml:"post_hook,omitempty"` // deprecated: kept for validation only
	Schema        string        `yaml:"schema,omitempty"`
	Database      string        `yaml:"database,omitempty"`
	Enabled       *bool         `yaml:"enabled,omitempty"`
	Engine        string        `yaml:"engine,omitempty"`
	Range         *RangeConfig  `yaml:"range,omitempty"`
	DropCascade   *bool         `yaml:"drop_cascade,omitempty"` // default false; CASCADE on DROP when true
	Rewrite       *bool         `yaml:"rewrite,omitempty"`      // default true; set false to skip bare-name rewrite
	Tests         []any         `yaml:"tests,omitempty"`        // declarative data tests
}

type ModelSQL struct {
	PreStatements  []string
	ModelQuery     string
	PostStatements []string
}

type NameNotFoundError struct {
	Query       string
	Kind        string // "ref" or "selector"
	Suggestions []NameRef
}

type NameRef struct {
	Name          string
	RelPath       string
	FullTableName string
	Model         *Model
	Seed          *Seed
}

type Node struct {
	Name         string   `json:"name" yaml:"name"`
	Type         string   `json:"type,omitempty" yaml:"type,omitempty"` // model or seed
	Table        string   `json:"table,omitempty" yaml:"table,omitempty"`
	File         string   `json:"file,omitempty" yaml:"file,omitempty"`
	Mode         string   `json:"mode,omitempty" yaml:"mode,omitempty"`                 // models only
	Dependencies []string `json:"dependencies,omitempty" yaml:"dependencies,omitempty"` // models only
	SQL          string   `json:"sql,omitempty" yaml:"sql,omitempty"`                   // models only
	Tests        []any    `json:"tests,omitempty" yaml:"tests,omitempty"`               // models only
}

type Range struct {
	Chunks      []RangeChunk // ordered; 0 chunks = no-op
	UpdateState bool         // advance SLING_STATE after last chunk succeeds
	FromCLI     bool         // came from --range (print resume hint on failure)
	CLIRaw      string       // original raw --range value (for resume hint)
	Step        string       // parsed step for resume hint, may be ""
}

type RangeChunk struct {
	Lower          string         // already-quoted SQL literal, or "" for unbounded
	Upper          string         // already-quoted SQL literal, or "" for unbounded
	LowerInclusive bool           // true → use >= for lower
	ColType        iop.ColumnType // for state writes
	LowerRaw       string         // raw display form for logs/resume hint
	UpperRaw       string         // raw display form for logs/resume hint
}

type RangeConfig struct {
	Start    string `yaml:"start,omitempty"`    // literal value; parsed lazily at execution time
	Advance  string `yaml:"advance,omitempty"`  // duration (5m, 5h, 5d, 5w, 1mo, 1y) — per-run forward advance
	Lookback string `yaml:"lookback,omitempty"` // duration
}

type Seed struct {
	Name              string // file stem, unique across the project
	FilePath          string // absolute path
	RelPath           string // relative path from project root
	Schema            string
	Database          string // optional catalog; three-part dialects only
	FullTableName     string // [database.]schema.name (current mode)
	ProdFullTableName string // [database.]schema.name (always prod-mode, for SQL matching)
	Format            string // csv, json, parquet
}

type Selector struct {
	Includes []string
	Excludes []string
	Project  *BuildProject
}

type Style int

type TableIdentity struct {
	Name     string // file stem
	Schema   string
	Database string // optional; three-part dialects only
}

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