core

type ApiKey struct {
	Id      int    `json:"id"`
	UserId  int    `json:"userId"`
	KeyHash []byte `json:"keyHash"`
}

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

type App struct {
	Name string
	// TODO: Consider a name that better describes the intent (e.g. "guardid" or something)
	Hashid AppId
}

type AppId []byte

type AppRepository interface {
	Get(name string) (*App, error)
	Create(app *App) error
	ListApps() ([]App, error)
}

type AppStatus struct {
	StageStatuses []StageStatus
	// 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 Stage.
	Deployments []Deployment
}

type Deployment struct {
	Name      string
	StageName string
	AppName   string
	// RiserGeneration is for tracking deployment changes and has no relation to a k8s Deployment generation
	RiserGeneration int64
	Doc             DeploymentDoc
}

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

type DeploymentContext struct {
	Deployment      *DeploymentConfig
	Stage           *StageConfig
	RiserGeneration int64
	SecretNames     []string
	ManualRollout   bool
}

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

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

type DeploymentRepository interface {
	Create(newDeployment *Deployment) error
	FindByApp(appName string) ([]Deployment, error)
	Get(name, stageName string) (*Deployment, error)
	UpdateStatus(name, stageName string, status *DeploymentStatus) error
	UpdateTraffic(name, stageName string, riserGeneration int64, traffic TrafficConfig) error
	IncrementGeneration(name, stageName string) (int64, error)
	RollbackGeneration(name, stageName string, failedGeneration int64) (int64, error)
}

type DeploymentRevisionStatus struct {
	Name                string          `json:"name"`
	AvailableReplicas   int32           `json:"availableReplicas"`
	DockerImage         string          `json:"dockerImage"`
	RiserGeneration     int64           `json:"riserGeneration"`
	RolloutStatus       string          `json:"rolloutStatus"`
	RolloutStatusReason string          `json:"rolloutStatusReason"`
	Problems            []StatusProblem `json:"problems"`
}

type DeploymentStatus struct {
	ObservedRiserGeneration   int64                      `json:"observedRiserGeneration"`
	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 FakeApiKeyRepository struct {
	GetByUserIdFn   func(int) ([]ApiKey, error)
	CreateFn        func(int, []byte) (int, error)
	CreateCallCount int
}

type FakeAppRepository struct {
	GetFn        func(string) (*App, error)
	GetCallCount int
	CreateFn     func(app *App) error
	ListAppsFn   func() ([]App, error)
}

type FakeDeploymentRepository struct {
	CreateFn                     func(newDeployment *Deployment) error
	CreateCallCount              int
	GetFn                        func(name, stageName string) (*Deployment, error)
	GetCallCount                 int
	FindByAppFn                  func(string) ([]Deployment, error)
	IncrementGenerationFn        func(name, stageName string) (int64, error)
	IncrementGenerationCallCount int
	RollbackGenerationFn         func(name, stageName string, failedGeneration int64) (int64, error)
	UpdateStatusFn               func(name, stageName string, status *DeploymentStatus) error
	UpdateStatusCallCount        int
	UpdateTrafficFn              func(name, stageName string, riserGeneration int64, traffic TrafficConfig) error
	UpdateTrafficCallCount       int
}

type FakeSecretMetaRepository struct {
	SaveFn        func(*SecretMeta) error
	SaveCallCount int
	FindByStageFn func(string, string) ([]SecretMeta, error)
}

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

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

type Namespace struct {
	Name  string
	Stage string
}

type NewUser struct {
	Username string
}

type ResourceFile struct {
	Name     string `json:"name"`
	Contents []byte `json:"contents"`
}

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"`
	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 {
	AppName    string
	StageName  string
	SecretName string
	Doc        SecretMetaDoc
}

type SecretMetaDoc struct {
	LastUpdated time.Time `json:"lastUpdated"`
}

type SecretMetaRepository interface {
	Save(secretMeta *SecretMeta) error
	FindByStage(appName string, stageName string) ([]SecretMeta, error)
}

type Stage struct {
	Name string
	Doc  StageDoc
}

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

type StageDoc struct {
	LastPing time.Time   `json:"lastPing"`
	Config   StageConfig `json:"config"`
}

type StageRepository interface {
	Get(name string) (*Stage, error)
	List() ([]Stage, error)
	Save(stage *Stage) error
}

type StageStatus struct {
	StageName string
	Healthy   bool
	Reason    string
}

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

type TrafficConfig []TrafficConfigRule

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

type User struct {
	Id       int
	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) (int, 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
}