nocd

type PipeLog struct {
	ID         uint
	StartedAt  time.Time
	StoppedAt  time.Time
	Pipeline   Pipeline
	PipelineID uint
	Pusher     string
	Log        string
	Status     int
}

type PipeLogService interface {
	Create(plog *PipeLog) error
	Update(plog *PipeLog) error
	LastServerLog(sid uint) PipeLog
	LastPipelineLog(pid uint) PipeLog
	UserLogs(uid uint, page, size int64) ([]PipeLog, int64)
	Pipeline(log *PipeLog) error
	GetByUID(uid, lid uint) (PipeLog, error)
	GetByID(lid uint) (PipeLog, error)
	Logs(status int, page, size int64) ([]PipeLog, int64)
	LastLogs(num uint) []PipeLog
}

type Pipeline struct {
	ID           uint   `form:"id" binding:"min=0"`
	Name         string `form:"name" binding:"required,min=1,max=12"`
	Branch       string `form:"branch" binding:"required,alphanum,min=1,max=30"`
	Events       string
	EventsSlice  []string `gorm:"-" form:"events[]" binding:"required,min=1"`
	Shell        string   `form:"shell" binding:"required,min=3,max=1000"`
	UserID       uint
	User         User       `form:"-" binding:"-"`
	ServerID     uint       `form:"server" binding:"required,min=1"`
	Server       Server     `form:"-" binding:"-"`
	RepositoryID uint       `form:"repo" binding:"required,min=1"`
	Repository   Repository `form:"-" binding:"-"`
	PipeLog      []PipeLog  `form:"-" binding:"-"`
}

type PipelineService interface {
	Create(p *Pipeline) error
	Update(p *Pipeline) error
	Delete(pid uint) error
	RepoPipelines(r *Repository) []Pipeline
	UserPipelines(u *User) []Pipeline
	UserPipeline(uid, pid uint) (Pipeline, error)
	GetPipelinesByRidAndEventAndBranch(rid uint, event string, branch string) ([]Pipeline, error)
	Server(p *Pipeline) error
	User(p *Pipeline) error
}

type Repository struct {
	ID       uint `form:"id"`
	UserID   uint
	User     User `form:"-" binding:"-"`
	Secret   string
	Name     string     `form:"name" binding:"required,min=1,max=12"`
	Platform int        `form:"platform" binding:"required,min=1,max=4"`
	Pipeline []Pipeline `form:"-" binding:"-"`
}

type RepositoryService interface {
	Create(repo *Repository) error
	Update(repo *Repository) error
	Delete(rid uint) error
	GetRepoByUser(user *User) []Repository
	GetRepoByID(id uint) (Repository, error)
	GetRepoByUserAndID(user *User, id uint) (Repository, error)
}

type Running struct {
	Finish     chan bool
	Closed     bool
	Log        *PipeLog
	RunningLog []string
}

type Server struct {
	ID        uint `form:"id" binding:"min=0"`
	UserID    uint
	User      User       `form:"-" binding:"-"`
	Pipelines []Pipeline `form:"-" binding:"-"`
	Name      string     `form:"name" binding:"required,min=1,max=12"`
	Address   string     `form:"address" binding:"required,address,min=1,max=30"`
	Port      int        `form:"port" binding:"required,min=1"`
	Login     string     `form:"login" binding:"required,alphanum,min=1,max=30"`
	Status    int
}

type ServerService interface {
	CreateServer(s *Server) error
	DeleteServer(sid uint) error
	UpdateServer(s *Server) error
	GetServersByUser(user *User) []Server
	GetServersByUserAndSid(user *User, sid uint) (Server, error)
}

type Stats struct {
	UserCount     int64
	ServerCount   int64
	PipelineCount int64
	RepoCount     int64
	RunningCount  int64
	PipeLogCount  int64
	Update        time.Time
}

type User struct {
	gorm.Model
	//用户GitHubID
	GID        uint `gorm:"unique_index"`
	GName      string
	GLogin     string
	Pubkey     string
	PrivateKey string
	//Server酱推送Key
	Sckey        string       `form:"sckey" binding:"alphanum,min=20"`
	PushSuccess  bool         `form:"push_success" binding:"exists"`
	Servers      []Server     `form:"-"`
	Repositories []Repository `form:"-"`
	Pipelines    []Pipeline   `form:"-"`
	IsBlocked    bool
	IsAdmin      bool
	// 用户Token
	Token string
}

type UserService interface {
	UserByGID(gid int64) (*User, error)
	Create(u *User) error
	Update(u *User) error
	Verify(uid, token string) (*User, error)
	Users(page, size int64) ([]*User, int64)
}