store

type Blueprint struct {
	Name       string            `json:"name" db:"name"`
	Desc       string            `json:"description" db:"description"`
	Source     string            `json:"source" db:"source"`
	Runtime    RuntimeObj        `json:"runtime" db:"runtime"`
	Remote     RemoteObj         `json:"remote" db:"remote"`
	RunCmd     string            `json:"run_cmd,omitempty" db:"run_cmd"`
	BuildCmd   string            `json:"build_cmd,omitempty" db:"build_cmd"`
	Port       int               `json:"port" db:"port"`
	WorkingDir string            `json:"working_dir,omitempty" db:"working_dir"`
	StaticDir  string            `json:"static_dir,omitempty" db:"static_dir"`
	Image      string            `json:"image,omitempty" db:"image"`
	EnvVars    map[string]string `json:"env_vars,omitempty" db:"env_vars"`
	Status     string            `json:"status" db:"status"`
	ProjectID  *string           `json:"project_id,omitempty" db:"project_id"`
}

type Deployment struct {
	ID        string    `json:"id" db:"id"`
	UserId    *string   `json:"user_id,omitempty" db:"user_id"`
	Blueprint Blueprint `json:"config" db:"config"`
	Status    Status    `json:"status" db:"status"`
	Metadata  string    `json:"metadata" db:"metadata"`
	CreatedAt time.Time `json:"created_at" db:"created_at"`
	UpdatedAt time.Time `json:"updated_at" db:"updated_at"`
}

type DeploymentStore interface {
	CreateDeployment(ctx context.Context, d *Deployment) error
	GetDeployment(ctx context.Context, id string) (*Deployment, error)
	ListDeployments(ctx context.Context, limit, offset int) ([]*Deployment, error)
	UpdateDeploymentStatus(ctx context.Context, id string, status string) error
}

type Instance struct {
	ID              string    `json:"id" db:"id"`
	BootstrapToken  string    `json:"bootstrap_token" db:"bootstrap_token"`
	AccessToken     string    `json:"access_token" db:"access_token"`
	InstanceID      string    `json:"instance_id" db:"instance_id"`
	Issuer          string    `json:"issuer" db:"issuer"`
	Audience        string    `json:"audience" db:"audience"`
	RegisteredAt    time.Time `json:"registered_at" db:"registered_at"`
	LastInstalledAt time.Time `json:"last_installed_at" db:"last_installed_at"`
}

type InstanceStore interface {
	// GetInstance returns the current instance record, if any.
	GetInstance(ctx context.Context) (*Instance, error)
	// RegisterInstance persists the instance row on first registration.
	RegisterInstance(ctx context.Context, i *Instance) error
	UpdateLastInstalledAt(ctx context.Context) error
	SetBootstrapToken(ctx context.Context, token string) error
	GetBootstrapToken(ctx context.Context) (string, error)
	SetAccessToken(ctx context.Context, token string) error
	GetAccessToken(ctx context.Context) (string, error)
}

type RemoteObj struct {
	Url        string `json:"url" db:"url"`
	Branch     string `json:"branch" db:"branch"`
	CommitHash string `json:"commit_hash" db:"commit_hash"`
}

type Role string

type Runtime string

type RuntimeObj struct {
	Type    Runtime `json:"type" db:"type" validate:"required,oneof=static golang php python nodejs ruby dotnet java docker k3s custom"`
	Version string  `json:"version,omitempty" db:"version"`
}

type Service struct {
	ID             string            `json:"id" db:"id"`
	Name           string            `json:"name" db:"name"`
	Description    string            `json:"description" db:"description"`
	Source         string            `json:"source" db:"source"`
	Runtime        Runtime           `json:"runtime" db:"runtime"`
	RuntimeVersion string            `json:"runtime_version,omitempty" db:"runtime_version"`
	RunCmd         string            `json:"run_cmd,omitempty" db:"run_cmd"`
	BuildCmd       string            `json:"build_cmd,omitempty" db:"build_cmd"`
	Port           int               `json:"port"`
	WorkingDir     string            `json:"working_dir,omitempty" db:"working_dir"`
	StaticDir      string            `json:"static_dir,omitempty" db:"static_dir"`
	Image          string            `json:"image,omitempty" db:"image"`
	EnvVars        map[string]string `json:"env_vars,omitempty"`
	Status         string            `json:"status"`
	Remote         string            `json:"remote,omitempty" db:"remote_url"`
	Branch         string            `json:"branch" db:"remote_branch"`
	CommitHash     string            `json:"commit_hash" db:"remote_commit_hash"`
	DeploymentId   string            `json:"-" db:"deployment_id"`
	Blueprint      *Blueprint        `json:"blueprint,omitempty"`
	CreatedAt      time.Time         `json:"created_at" db:"created_at"`
	UpdatedAt      time.Time         `json:"updated_at" db:"updated_at"`
}

type ServiceStore interface {
	CreateService(ctx context.Context, svc *Service) (*Service, error)
	GetService(ctx context.Context, id string) (*Service, error)
	ListServices(ctx context.Context, limit, offset int) ([]*Service, error)
	UpdateService(ctx context.Context, svc *Service) error
}

type Status string

type TaskResult struct {
	ID     string `db:"id"`
	Status string `db:"status"`
	Result any    `db:"result"`
	Error  string `db:"error"`
}

type TaskResultStore interface {
	// ListUnsent returns all results that have not yet been marked as synced.
	ListUnsent(ctx context.Context) ([]*TaskResult, error)
	// SaveResults persists new task results as unsynced.
	SaveResults(ctx context.Context, results []*TaskResult) error
	// MarkSynced marks the given result IDs as synced.
	MarkSynced(ctx context.Context, ids []string) error
}

type User struct {
	ID        string    `json:"id" db:"id"`
	Email     string    `json:"email" db:"email"`
	Role      Role      `json:"role" db:"role"`
	CreatedAt time.Time `json:"created_at" db:"created_at"`
	UpdatedAt time.Time `json:"updated_at" db:"updated_at"`
}

type UserStore interface {
	FindOrCreateUser(email string, role Role) (*User, error)
	GetUserByEmail(ctx context.Context, email string) (*User, error)
	UpdateUserRole(ctx context.Context, email string, role Role) error
	HasOwner() (bool, error) // Returns true if owner exists
	GetRole(ctx context.Context, email string) (Role, error)
}