deploy

type DeployListResult struct {
	Items      []*Deployment `json:"items"`
	NextCursor string        `json:"next_cursor,omitempty"`
	Total      int           `json:"total"`
}

type DeployRequest struct {
	InstanceID id.ID             `json:"instance_id"          validate:"required"`
	Image      string            `json:"image"                validate:"required"`
	Env        map[string]string `json:"env,omitempty"`
	Strategy   string            `json:"strategy,omitempty"`
	Notes      string            `json:"notes,omitempty"`
	CommitSHA  string            `json:"commit_sha,omitempty"`
}

type DeployState string

type Deployment struct {
	ctrlplane.Entity

	TenantID    string            `db:"tenant_id"    json:"tenant_id"`
	InstanceID  id.ID             `db:"instance_id"  json:"instance_id"`
	ReleaseID   id.ID             `db:"release_id"   json:"release_id"`
	State       DeployState       `db:"state"        json:"state"`
	Strategy    string            `db:"strategy"     json:"strategy"`
	Image       string            `db:"image"        json:"image"`
	Env         map[string]string `db:"env"          json:"env,omitempty"`
	ProviderRef string            `db:"provider_ref" json:"provider_ref,omitempty"`
	StartedAt   *time.Time        `db:"started_at"   json:"started_at,omitempty"`
	FinishedAt  *time.Time        `db:"finished_at"  json:"finished_at,omitempty"`
	Error       string            `db:"error"        json:"error,omitempty"`
	Initiator   string            `db:"initiator"    json:"initiator"`
}

type ListOptions struct {
	Cursor string `json:"cursor,omitempty"`
	Limit  int    `json:"limit,omitempty"`
}

type Release struct {
	ctrlplane.Entity

	TenantID   string            `db:"tenant_id"   json:"tenant_id"`
	InstanceID id.ID             `db:"instance_id" json:"instance_id"`
	Version    int               `db:"version"     json:"version"`
	Image      string            `db:"image"       json:"image"`
	Env        map[string]string `db:"env"         json:"env,omitempty"`
	Notes      string            `db:"notes"       json:"notes,omitempty"`
	CommitSHA  string            `db:"commit_sha"  json:"commit_sha,omitempty"`
	Active     bool              `db:"active"      json:"active"`
}

type ReleaseListResult struct {
	Items      []*Release `json:"items"`
	NextCursor string     `json:"next_cursor,omitempty"`
	Total      int        `json:"total"`
}

type Service interface {
	// Deploy creates a new release and deploys it to the instance.
	Deploy(ctx context.Context, req DeployRequest) (*Deployment, error)

	// Rollback reverts to a specific release.
	Rollback(ctx context.Context, instanceID id.ID, releaseID id.ID) (*Deployment, error)

	// Cancel aborts an in-progress deployment.
	Cancel(ctx context.Context, deploymentID id.ID) error

	// GetDeployment returns a specific deployment.
	GetDeployment(ctx context.Context, deploymentID id.ID) (*Deployment, error)

	// ListDeployments lists deployments for an instance.
	ListDeployments(ctx context.Context, instanceID id.ID, opts ListOptions) (*DeployListResult, error)

	// GetRelease returns a specific release.
	GetRelease(ctx context.Context, releaseID id.ID) (*Release, error)

	// ListReleases lists releases for an instance.
	ListReleases(ctx context.Context, instanceID id.ID, opts ListOptions) (*ReleaseListResult, error)
}

type Store interface {
	// InsertDeployment persists a new deployment.
	InsertDeployment(ctx context.Context, d *Deployment) error

	// GetDeployment retrieves a deployment by ID within a tenant.
	GetDeployment(ctx context.Context, tenantID string, deployID id.ID) (*Deployment, error)

	// UpdateDeployment persists changes to an existing deployment.
	UpdateDeployment(ctx context.Context, d *Deployment) error

	// ListDeployments returns a filtered, paginated list of deployments for an instance.
	ListDeployments(ctx context.Context, tenantID string, instanceID id.ID, opts ListOptions) (*DeployListResult, error)

	// InsertRelease persists a new release.
	InsertRelease(ctx context.Context, r *Release) error

	// GetRelease retrieves a release by ID within a tenant.
	GetRelease(ctx context.Context, tenantID string, releaseID id.ID) (*Release, error)

	// ListReleases returns a filtered, paginated list of releases for an instance.
	ListReleases(ctx context.Context, tenantID string, instanceID id.ID, opts ListOptions) (*ReleaseListResult, error)

	// NextReleaseVersion returns the next auto-incrementing version number for an instance.
	NextReleaseVersion(ctx context.Context, tenantID string, instanceID id.ID) (int, error)
}

type Strategy interface {
	// Name returns the strategy identifier (e.g., "rolling", "blue-green").
	Name() string

	// Execute performs the deployment according to the strategy.
	Execute(ctx context.Context, params StrategyParams) error
}

type StrategyParams struct {
	Deployment *Deployment
	Provider   provider.Provider
	OnProgress func(phase string, percent int, message string)
}