pipeline

type DiagnosticsError struct {
	Diagnostic queryanalyzer.Diagnostic
	Cause      error
}

type Environment struct {
	FSResolver    func(string) (fileset.Resolver, error)
	Logger        logging.Logger
	Writer        Writer
	SchemaParser  schemaparser.SchemaParser // injectable schema parser (deprecated: use Engine)
	Generator     codegen.Generator         // injectable generator
	Cache         cache.Cache               // injectable cache
	Engine        engine.Engine             // injectable database engine
	Verifier      verify.Verifier           // optional; nil => pure static analysis
	VerifiedCache *verify.Cache             // committed verified types loaded by the CLI; nil = none
}

type Hooks struct {
	// BeforeParse is called before parsing schema files.
	// Return an error to abort the pipeline.
	BeforeParse func(ctx context.Context, schemaPaths []string) error

	// AfterParse is called after all schemas are parsed.
	// Return an error to abort the pipeline.
	AfterParse func(ctx context.Context, catalog *model.Catalog) error

	// BeforeAnalyze is called before analyzing queries.
	// Return an error to abort the pipeline.
	BeforeAnalyze func(ctx context.Context, queryPaths []string) error

	// AfterAnalyze is called after all queries are analyzed.
	// Return an error to abort the pipeline.
	AfterAnalyze func(ctx context.Context, analyses []analyzer.Result) error

	// BeforeGenerate is called before generating code.
	// Return an error to abort the pipeline.
	BeforeGenerate func(ctx context.Context, analyses []analyzer.Result) error

	// AfterGenerate is called after code is generated.
	// Return an error to abort the pipeline.
	AfterGenerate func(ctx context.Context, files []codegen.File) error

	// BeforeWrite is called before writing files.
	// Return an error to abort the pipeline.
	BeforeWrite func(ctx context.Context, files []codegen.File) error

	// AfterWrite is called after all files are written.
	// This is the final hook, called even if earlier stages failed.
	AfterWrite func(ctx context.Context, summary Summary) error
}

type MemoryWriter struct {
	Files map[string][]byte
	// contains filtered or unexported fields
}

type Pipeline struct {
	Env   Environment
	Hooks Hooks // extension hooks
}

type RunOptions struct {
	ConfigPath          string
	OutOverride         string
	DryRun              bool
	ListQueries         bool
	StrictConfig        bool
	NoJSONTags          bool
	EmitPointersForNull bool
	SQLDialect          string
	EmitIFNotExists     bool
	// SkipVerifiedCache suppresses the applyVerifiedCache branch even when
	// [verify] is enabled. Used by the 'verify' subcommand's internal dry-run
	// so it does not emit a spurious "no verified cache" warning/error.
	SkipVerifiedCache bool
}

type Summary struct {
	Files       []codegen.File
	Diagnostics []queryanalyzer.Diagnostic
	Analyses    []queryanalyzer.Result
	Catalog     *model.Catalog
}

type WriteError struct {
	Path string
	Err  error
}

type Writer interface {
	WriteFile(path string, data []byte) error
}