squasher

type AuthServiceType string

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

type ConsolidationConflict struct {
	ObjectName string
	ObjectType types.ObjectType
	Operations []string
	Reason     string
}

type ConsolidationPlan struct {
	TotalMigrations    int
	TotalOperations    int
	Consolidations     []PlannedConsolidation
	CannotConsolidate  []ConsolidationConflict
	EstimatedReduction ConsolidationStats
}

type ConsolidationStats struct {
	OriginalFiles      int
	OriginalOperations int
	FinalFiles         int
	FinalOperations    int
	FilesReduced       int
	OperationsReduced  int
	PercentageReduced  float64
}

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

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

type EngineConfig struct {
	Config  *config.Config
	Context context.Context

	// Version is the tool version stamped into provenance metadata
	// (.squashmap.json). Callers set it from their release metadata (e.g. the
	// CLI passes its rootCmd version). Empty falls back to "dev" - never a
	// hardcoded release string.
	Version string

	EnableStreaming     bool
	BatchSize           int
	WorkerCount         int
	MemoryLimitMB       int
	EnableProgressTrack bool
	ProgressCallback    func(processed, total int64, phase string)

	// Transformation options
	EnableBackup         bool
	EnableRollback       bool
	EnableTransformation bool
	BackupConfig         *transformation.BackupConfig
	TransformationConfig *transformation.TransformationConfig
	RollbackPath         string // Directory for rollback scripts
	BackupPath           string // Directory for pg_dump backups (default: <output dir>/.backups)
	BackupRetentionDays  int    // Retention window for old backups (0 = keep forever)

	// Output options
	ExcludeDataFromBaseline bool // If true, filter data operations from baseline SQL (default: false, meaning include)

	EnableCycleDetection bool
	ShowCycleDetails     bool
	CycleDetectionDepth  int
}

type ExtensionAnalysis struct {
	RequiredExtensions    []string                 // List of extensions found
	ExtensionDetails      map[string]ExtensionInfo // Detailed info for each extension
	RecommendedDockerBase string                   // Best Docker image to use
	InstallationScript    string                   // Script to install extensions
	ValidationScript      string                   // Script to validate extensions
	MissingExtensions     []string                 // Extensions we don't know about
	AuthService           AuthServiceType          // Detected authentication service
	AuthCompatibilitySQL  string                   // SQL to create service compatibility
}

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

type ExtensionInfo struct {
	Name            string   // Extension name
	PackageName     string   // APT package name for installation
	DockerImage     string   // Preferred Docker image that includes this extension
	Dependencies    []string // Other extensions this depends on
	InstallCommand  string   // Custom installation command if needed
	ValidationSQL   string   // SQL to test if extension is available
	RequiresCASCADE bool     // Whether this extension typically needs CASCADE
	RequiresPostGIS bool     // Whether this requires PostGIS base
}

type ExtensionRef struct {
	Name    string // Extension name
	Version string // Extension version (e.g., "0.6.0")
	Schema  string // Schema where extension is installed (e.g., "public")
	Line    int    // Line number where extension is defined
}

type ForeignKeyConstraint struct {
	ConstraintName string
	SourceTable    string
	SourceColumns  []string
	RefTable       string
	RefColumns     []string
	OnDelete       string
	OnUpdate       string
	Deferrable     bool
	Initially      string
	OriginalSQL    string // Original SQL for the constraint
}

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

type ModernPatternRule struct {
	Name        string
	Priority    int // Higher number = higher priority
	Pattern     string
	AuthType    types.AuthPatternType
	Conflicts   []string    // Rule names that conflict with this one
	SafetyLevel SafetyLevel // Minimum safety level required
	Consolidate func([]*types.Statement) []*types.Statement
}

type PlannedConsolidation struct {
	ObjectName   string
	ObjectType   types.ObjectType
	ObjectSchema string
	Operations   []string // SQL snippets
	ResultSQL    string
	Rule         string
	Reason       string
	SafetyLevel  string
	RiskLevel    tracking.RiskLevel
}

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

type SQLDependencyInfo struct {
	ObjectKey     string
	Result        *tracking.ConsolidationResult
	Dependencies  []string // Objects this depends on
	Provides      []string // Objects this provides/creates
	RequiredFirst bool     // Must be first in category (extensions, schemas)
	RequiredLast  bool     // Must be last in category (data operations)
}

type SafetyLevel string

type SquashMap struct {
	// Metadata
	Version     string    `json:"version"`      // pgsquash version
	Timestamp   time.Time `json:"timestamp"`    // When the squash was performed
	SafetyMode  string    `json:"safety_mode"`  // Safety level used (paranoid, conservative, standard, aggressive)
	PGVersion   string    `json:"pg_version"`   // PostgreSQL version targeted
	Extensions  []string  `json:"extensions"`   // Extensions detected/required
	ContentHash string    `json:"content_hash"` // SHA256 hash of squashed output

	// Input/Output
	Inputs  []string `json:"inputs"`  // List of original migration files
	Outputs []string `json:"outputs"` // List of generated output files

	// Detailed Mappings
	Mappings []StatementMapping `json:"mappings"` // Statement-level mappings

	// Statistics
	Stats SquashStatistics `json:"statistics"` // Consolidation statistics

	// Warnings
	Warnings []string `json:"warnings,omitempty"` // Any warnings during squash
}

type SquashResult struct {
	BaselineSQL       string     // DDL-only SQL (000_baseline.sql)
	DataOperationsSQL string     // Data operations SQL (010_data.sql)
	Warnings          []string   // Warnings generated during squash
	ProvenanceMap     *SquashMap // Provenance tracking information
	Extensions        []string   // Extensions detected/required

	// Auth compatibility for validation
	AuthCompatibilitySQL string `json:"auth_compatibility_sql,omitempty"`
}

type SquashStatistics struct {
	OriginalStatements     int     `json:"original_statements"`     // Total statements in original migrations
	ConsolidatedStatements int     `json:"consolidated_statements"` // Total statements in output
	ReductionRate          float64 `json:"reduction_rate"`          // Percentage reduction
	FilesProcessed         int     `json:"files_processed"`         // Number of input files
	FilesGenerated         int     `json:"files_generated"`         // Number of output files
	TotalLinesOriginal     int     `json:"total_lines_original"`    // Total lines in original
	TotalLinesSquashed     int     `json:"total_lines_squashed"`    // Total lines in output
}

type SquashStats struct {
	Phase                 string        `json:"current_phase"`
	MigrationsProcessed   int64         `json:"migrations_processed"`
	TotalMigrations       int64         `json:"total_migrations"`
	ObjectsTracked        int64         `json:"objects_tracked"`
	ConsolidationsApplied int64         `json:"consolidations_applied"`
	ProcessingTime        time.Duration `json:"processing_time"`
	PeakMemoryUsage       int64         `json:"peak_memory_usage"`
	ThroughputMPS         float64       `json:"throughput_migrations_per_sec"`
}

type StatementMapping struct {
	SourceFile      string `json:"source_file"`      // Original migration file
	SourceLine      int    `json:"source_line"`      // Line number in source file
	SourceStatement string `json:"source_statement"` // The original SQL statement (first 100 chars)

	OutputFile      string `json:"output_file"`       // Output file name
	OutputLineStart int    `json:"output_line_start"` // Starting line in output
	OutputLineEnd   int    `json:"output_line_end"`   // Ending line in output

	Action     string `json:"action"`      // What happened: "preserved", "merged", "eliminated", "reordered"
	ObjectType string `json:"object_type"` // Type of object (table, index, function, etc.)
	ObjectName string `json:"object_name"` // Name of the object
}

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