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)
	// contains filtered or unexported fields
}

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

type BuildDefaults struct {
	Mode          string        `yaml:"mode,omitempty"`
	Schema        string        `yaml:"schema,omitempty"`
	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"`
	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
}

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
}

type ExecutionResult struct {
	Name     string
	NodeType string // "seed" or "model"
	Mode     string // "full-refresh", "view", "truncate", "incremental", "append"
	Duration time.Duration
	Err      error
	Skipped  bool
}

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      // e.g., "dim_customers"
	FilePath          string      // absolute path
	RelPath           string      // relative path from project root
	Schema            string      // derived from folder or override
	Prefix            string      // underscore-joined nested folder names
	FullTableName     string      // schema.prefix_name (current mode)
	ProdFullTableName string      // schema.prefix_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"`
	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 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 // e.g., "country_codes"
	FilePath          string // absolute path
	RelPath           string // relative path from project root
	Schema            string
	Prefix            string
	FullTableName     string // schema.prefix_name (current mode)
	ProdFullTableName string // schema.prefix_name (always prod-mode, for SQL matching)
	Format            string // csv, json, parquet
}

type Selector struct {
	Includes []string
	Excludes []string
}

type Style int

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