dbcopy

type BackendRef struct {
	Scheme string
	// Path holds the scheme-specific resource locator.
	// - sqlite:    filesystem path to the .db file (e.g. "/tmp/foo.db" or "./rel.db")
	// - ingitdb:   filesystem path to the project directory
	// - postgres:  full original URL (passed verbatim to the future driver)
	Path string
	// Raw is the original input string, preserved for error messages.
	Raw string
}

type CopyOpts struct {
	// Overwrite is "" (require empty target), "recreate" (drop source-named
	// tables, then create from source), or "reload" (reserved — row-level
	// semantics; behaves like "recreate" for schema-only copies until row
	// CRUD lands).
	Overwrite string

	// Stderr receives per-table skip / row-error notes and the final
	// summary note. Defaults to discard if nil.
	Stderr io.Writer

	// Progress, if non-nil, receives per-table progress lines.
	Progress *ProgressWriter

	// SchemaOnly, if true, skips row streaming entirely and only replicates
	// the target schema. Useful for E2E-test scaffolding and for backends
	// where row streaming isn't supported in this direction.
	SchemaOnly bool

	// ParallelStreams is the requested max number of source tables copied
	// concurrently. 0 means "use the default": runtime.NumCPU()-1 (with a
	// floor of 1). Negative values are normalized to 1. Capped to 1 when
	// either source or target advertises SupportsConcurrentConnections()==false
	// (REQ:concurrency-cap).
	ParallelStreams int

	// Filters carries resolved filtering directives (table include/exclude,
	// row WHERE predicates, row limits). nil or empty means "no filtering
	// — copy whole DB per parent Feature ACs". Subsequent tasks consume
	// this at two seams (pre-worker table filter; engine_rows query builder).
	// Spec: spec/features/cli/db/copy/filtering/README.md
	Filters *filter.Directives
}

type NonEmptyTargetError struct {
	Table string
	Rows  int64
}

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

type ReloadSchemaMismatchError struct {
	Table       string
	Column      string
	SourceValue string
	TargetValue string
	Reason      string // short reason: "missing column", "type mismatch", "primary key mismatch"
}

type SourceSummary struct {
	Tables        int
	Created       int
	CreatedNames  []string // names of collections created on the target, in source-iteration order
	Skipped       []string // tables skipped at DescribeCollection time
	RowsCopied    int64    // total rows inserted into the target across all tables
	RowsByTable   map[string]int64
	RowSkips      map[string]string // table → reason (e.g. composite PK, no PK)
	TargetBackend string            // adapter name of target, for error messages
}

type UnsupportedTypeError struct {
	// SourceType is the dbschema.Type that could not be mapped.
	SourceType dbschema.Type
	// TargetBackend is the backend name supplied to MapType.
	TargetBackend string
}