core

type ApiKey struct {
	UserId  uuid.UUID `json:"userId"`
	KeyHash []byte    `json:"keyHash"`
}

type ApiKeyRepository interface {
	GetByUserId(userId uuid.UUID) ([]ApiKey, error)
	Create(userId uuid.UUID, keyHash []byte) error
}

type App struct {
	Id        uuid.UUID
	Name      string
	Namespace string
}

type AppRepository interface {
	Get(id uuid.UUID) (*App, error)
	GetByName(*NamespacedName) (*App, error)
	Create(app *App) error
	ListApps() ([]App, error)
}

type AppStatus struct {
	EnvironmentStatus []EnvironmentStatus
	// Deployments returns the whole deployment. We should probably use a different type here with less data, but we can't just pass
	// Deployment.Doc.Status as we also need the DeploymentName and the environment.
	Deployments []Deployment
}

type Deployment struct {
	DeploymentReservation
	DeploymentRecord
}

type DeploymentConfig struct {
	Name            string
	Namespace       string
	EnvironmentName string
	Docker          DeploymentDocker
	// TODO: Move to core and remove api/v1/model dependency
	App           *model.AppConfig
	Traffic       TrafficConfig
	ManualRollout bool
}

type DeploymentContext struct {
	DeploymentConfig  *DeploymentConfig
	EnvironmentConfig *EnvironmentConfig
	RiserRevision     int64
	Secrets           []SecretMeta
	ManualRollout     bool
}

type DeploymentDoc struct {
	Status  *DeploymentStatus   `json:"status,omitempty"`
	Traffic []TrafficConfigRule `json:"traffic"`
}

type DeploymentDocker struct {
	Tag string `json:"tag"`
}

type DeploymentRecord struct {
	Id              uuid.UUID
	ReservationId   uuid.UUID
	EnvironmentName string
	// RiserRevision is for tracking deployment changes and has no relation to a k8s deployment revision
	RiserRevision int64
	DeletedAt     *time.Time
	Doc           DeploymentDoc
}

type DeploymentRepository interface {
	Create(newDeployment *DeploymentRecord) error
	Delete(name *NamespacedName, envName string) error
	GetByReservation(reservationId uuid.UUID, envName string) (*Deployment, error)
	GetByName(name *NamespacedName, envName string) (*Deployment, error)
	FindByApp(appId uuid.UUID) ([]Deployment, error)
	UpdateStatus(name *NamespacedName, envName string, status *DeploymentStatus) error
	UpdateTraffic(name *NamespacedName, envName string, riserRevision int64, traffic TrafficConfig) error
	IncrementRevision(name *NamespacedName, envName string) (int64, error)
	RollbackRevision(name *NamespacedName, envName string, failedRevision int64) (int64, error)
}

type DeploymentReservation struct {
	Id    uuid.UUID
	AppId uuid.UUID
	Name  string
	// At the time of writing the namespace should never be different from the app's namespace as we do not allow a deployment
	// to be deployed to a different namespace than the app. This may change in the future
	Namespace string
}

type DeploymentReservationRepository interface {
	Create(reservation *DeploymentReservation) error
	GetByName(name *NamespacedName) (*DeploymentReservation, error)
}

type DeploymentRevisionStatus struct {
	Name                 string `json:"name"`
	AvailableReplicas    int32  `json:"availableReplicas"`
	DockerImage          string `json:"dockerImage"`
	RiserRevision        int64  `json:"riserRevision"`
	RevisionStatus       string `json:"revisionStatus"`
	RevisionStatusReason string `json:"revisionStatusReason"`
}

type DeploymentStatus struct {
	ObservedRiserRevision     int64                      `json:"observedRiserRevision"`
	LastUpdated               time.Time                  `json:"lastUpdated"`
	Revisions                 []DeploymentRevisionStatus `json:"revisions"`
	LatestReadyRevisionName   string                     `json:"latestReadyRevisionName"`
	LatestCreatedRevisionName string                     `json:"latestCreatedRevisionName"`
	Traffic                   []DeploymentTrafficStatus  `json:"traffic"`
}

type DeploymentTrafficStatus struct {
	Percent      *int64 `json:"percent,omitempty"`
	RevisionName string `json:"revisionName"`
	Tag          string `json:"tag,omitempty"`
}

type Environment struct {
	Name string
	Doc  EnvironmentDoc
}

type EnvironmentConfig struct {
	SealedSecretCert  []byte `json:"sealedSecretCert"`
	PublicGatewayHost string `json:"publicGatewayHost"`
}

type EnvironmentDoc struct {
	LastPing time.Time         `json:"lastPing"`
	Config   EnvironmentConfig `json:"config"`
}

type EnvironmentRepository interface {
	Get(name string) (*Environment, error)
	List() ([]Environment, error)
	Save(environment *Environment) error
}

type EnvironmentStatus struct {
	EnvironmentName string
	Healthy         bool
	Reason          string
}

type FakeApiKeyRepository struct {
	GetByUserIdFn   func(uuid.UUID) ([]ApiKey, error)
	CreateFn        func(uuid.UUID, []byte) error
	CreateCallCount int
}

type FakeAppRepository struct {
	GetFn              func(id uuid.UUID) (*App, error)
	GetCallCount       int
	GetByNameFn        func(*NamespacedName) (*App, error)
	GetByNameCallCount int
	CreateFn           func(app *App) error
	ListAppsFn         func() ([]App, error)
}

type FakeDeploymentRepository struct {
	CreateFn                   func(newDeployment *DeploymentRecord) error
	CreateCallCount            int
	DeleteFn                   func(name *NamespacedName, envName string) error
	DeleteCallCount            int
	GetByNameFn                func(name *NamespacedName, envName string) (*Deployment, error)
	GetByReservationFn         func(reservationId uuid.UUID, envName string) (*Deployment, error)
	GetByReservationCallCount  int
	FindByAppFn                func(uuid.UUID) ([]Deployment, error)
	IncrementRevisionFn        func(name *NamespacedName, envName string) (int64, error)
	IncrementRevisionCallCount int
	RollbackRevisionFn         func(name *NamespacedName, envName string, failedRevision int64) (int64, error)
	UpdateStatusFn             func(name *NamespacedName, envName string, status *DeploymentStatus) error
	UpdateStatusCallCount      int
	UpdateTrafficFn            func(name *NamespacedName, envName string, riserRevision int64, traffic TrafficConfig) error
	UpdateTrafficCallCount     int
}

type FakeDeploymentReservationRepository struct {
	CreateFn        func(reservation *DeploymentReservation) error
	CreateCallCount int
	GetByNameFn     func(name *NamespacedName) (*DeploymentReservation, error)
}

type FakeEnvironmentRepository struct {
	GetFn         func(string) (*Environment, error)
	GetCallCount  int
	ListFn        func() ([]Environment, error)
	ListCallCount int
	SaveFn        func(*Environment) error
	SaveCallCount int
}

type FakeNamespaceRepository struct {
	CreateFn     func(namespace *Namespace) error
	GetFn        func(namespaceName string) (*Namespace, error)
	GetCallCount int
	ListFn       func() ([]Namespace, error)
}

type FakeSecretMetaRepository struct {
	CommitFn                 func(*SecretMeta) error
	CommitCallCount          int
	SaveFn                   func(*SecretMeta) (int64, error)
	SaveCallCount            int
	ListByAppInEnvironmentFn func(*NamespacedName, string) ([]SecretMeta, error)
}

type FakeUserRepository struct {
	GetByApiKeyFn    func(keyHash []byte) (*User, error)
	GetByUsernameFn  func(username string) (*User, error)
	CreateFn         func(newUser *NewUser) error
	CreateCallCount  int
	GetActiveCountFn func() (int, error)
}

type Namespace struct {
	Name string
}

type NamespaceRepository interface {
	Create(namespace *Namespace) error
	Get(namespaceName string) (*Namespace, error)
	List() ([]Namespace, error)
}

type NamespacedName struct {
	Name      string
	Namespace string
}

type NewUser struct {
	Id       uuid.UUID
	Username string
}

type ResourceFile struct {
	Name     string `json:"name"`
	Contents []byte `json:"contents"`
	Delete   bool   `json:"delete,omitempty"`
}

type RuntimeConfig struct {
	BootstrapApikey          string `split_words:"true"`
	BindAddress              string `split_words:"true" default:":8000"`
	DeveloperMode            bool   `split_words:"true"`
	GitUrl                   string `split_words:"true" required:"true"`
	GitDir                   string `split_words:"true" default:"/tmp/riser/git/"`
	GitBranch                string `split_words:"true" default:"master"`
	GitUsername              string `split_words:"true"`
	GitPassword              string `split_words:"true"`
	PostgresUrl              string `split_words:"true" default:"postgres://postgres.riser-system.svc.cluster.local/riserdb?sslmode=disable&connect_timeout=3"`
	PostgresUsername         string `split_words:"true" required:"true"`
	PostgresPassword         string `split_words:"true" required:"true"`
	PostgresMigrateOnStartup bool   `split_words:"true" default:"true"`
}

type SecretMeta struct {
	Name            string
	App             *NamespacedName
	EnvironmentName string
	Revision        int64
}

type SecretMetaRepository interface {
	// Commit commits a secretmeta at the specified revision. This is an acknowledgement that the secret has been committed to the underlying
	// resource (e.g. the git state repo)
	Commit(secretMeta *SecretMeta) error
	// Save saves the secret meta and returns a new revision. It is up to the caller to modify the secretMeta with the new revision.
	// Important: You must call r.Commit to validate that the object has been committed. Uncommitted secrets are not applied to deployments
	Save(secretMeta *SecretMeta) (revision int64, err error)
	ListByAppInEnvironment(appName *NamespacedName, envName string) ([]SecretMeta, error)
}

type StatusProblem struct {
	Count   int    `json:"count"`
	Message string `json:"message"`
}

type TrafficConfig []TrafficConfigRule

type TrafficConfigRule struct {
	RiserRevision int64  `json:"riserRevision"`
	RevisionName  string `json:"revisionName"`
	Percent       int    `json:"percent"`
}

type User struct {
	Id       uuid.UUID
	Username string
	Doc      UserDoc
}

type UserDoc struct {
	Created time.Time `json:"created"`
}

type UserRepository interface {
	GetByApiKey(keyHash []byte) (*User, error)
	GetByUsername(username string) (*User, error)
	Create(newUser *NewUser) error
	GetActiveCount() (int, error)
}

type ValidationError struct {
	Message string
	// ValidationError represents the validation error that ocurred. See the API errorHandler for how this is returned to the client.
	ValidationError error
	// contains filtered or unexported fields
}