engine

type ConnectionConfig struct {
	Host       string
	Port       int
	Database   string
	User       string
	Password   string
	TLSEnabled bool
}

type ContainerSpec struct {
	Env []string
	Cmd []string
}

type CopyBootstrap struct {
	Database     string
	User         string
	Password     string
	RootPassword string
	TLSEnabled   bool
}

type DumpFromContainerRequest struct {
	Docker        *client.Client
	ContainerName string
	DestPath      string
	Copy          CopyBootstrap
	Options       DumpOptions
}

type DumpOptions struct {
	SchemaOnly bool // when true, dump DDL only — no row data
}

type DumpRequest struct {
	Docker      *client.Client
	ClientImage string
	Source      SourceConfig
	DestPath    string
	Options     DumpOptions
}

type Engine interface {
	// Name returns the identifier used in ditto.yaml (e.g. "postgres", "mysql").
	Name() string

	// Dump writes a compressed dump of src to destPath through the configured
	// Docker-compatible runtime. clientImage overrides the helper image used for
	// the dump when non-empty. opts controls whether the dump includes row data.
	Dump(ctx context.Context, req DumpRequest) error

	// DumpFromContainer creates a compressed dump of the database running inside
	// containerName and writes it to destPath on the host. The container must
	// have its dump directory mounted at /dump (as copy and staging containers do).
	// Used by the dump scheduler to bake obfuscation into the dump file.
	// opts controls whether the dump includes row data.
	DumpFromContainer(ctx context.Context, req DumpFromContainerRequest) error

	// ContainerSpec returns the environment variables and optional command line
	// used to initialize the database inside a copy or staging container.
	ContainerSpec(copy CopyBootstrap) ContainerSpec

	// ContainerImage returns the Docker image (with pinned tag) for copies.
	ContainerImage() string

	// ContainerPort returns the TCP port the database listens on inside the container.
	ContainerPort() int

	// WaitReady blocks until the database in the container on port is ready
	// to accept connections, or until timeout elapses.
	WaitReady(conn ConnectionConfig, timeout time.Duration) error

	// ConnectionString returns a DSN for connecting to the copy on port.
	ConnectionString(conn ConnectionConfig) string

	// Restore loads a dump file into a running container through the configured
	// Docker-compatible runtime. containerName is the Docker container name
	// (e.g. "ditto-<id>") as set by the copy manager.
	Restore(ctx context.Context, req RestoreRequest) error
}

type RestoreRequest struct {
	Docker        *client.Client
	DumpPath      string
	ContainerName string
	Copy          CopyBootstrap
}

type SourceConfig struct {
	Host           string
	Port           int
	Database       string
	User           string
	Password       string // resolved from PasswordSecret at runtime
	PasswordSecret string // secret reference: env:VAR, file:/path, or arn:aws:...
	// NetworkName, when non-empty, attaches the dump helper container to this
	// Docker network so it can reach the source by container hostname. Leave
	// empty when the source is a real network-addressable host.
	NetworkName string
}