service

type Jwt interface {
	ValidateToken(tokenString string) (bool, *jwt.Token)
}

type LogEvent interface {
	Store(log v1.LogEvent)
	GetByProcessId(processId string, option v1.LogEventQueryOption) ([]string, int64)
	GetByProcessIdAndStepAndFootmark(processId string, step string, footmark string, claim int, option v1.LogEventQueryOption) ([]string, int64)
	GetByProcessIdAndStepAndClaim(processId string, step string, claim int, option v1.LogEventQueryOption) ([]v1.LogEvent, int64)
}

type Pipeline interface {
	GetByProcessId(processId string) v1.Pipeline
	GetStatusCount(companyId string, fromDate, toDate time.Time) v1.PipelineStatusCount
}

type Process interface {
	Store(process v1.Process)
	GetById(companyId, processId string) v1.Process
	GetByCompanyIdAndRepositoryIdAndAppName(companyId, repositoryId, appId string, option v1.ProcessQueryOption) ([]v1.Process, int64)
	GetByCompanyIdAndCommitId(companyId, commitId string, option v1.ProcessQueryOption) ([]v1.Process, int64)
	CountTodaysRanProcessByCompanyId(companyId string) int64
	CountProcessByCompanyIdAndDate(companyId string, from, to time.Time) int64
}

type ProcessEvent interface {
	Store(data v1.PipelineProcessEvent)
	GetByCompanyId(companyId string) map[string]interface{}
	GetByCompanyIdAndProcessId(companyId, processId string, option v1.ProcessQueryOption) ([]v1.PipelineProcessEvent, int64)
	DequeueByCompanyIdAndUserId(companyId, userId string) map[string]interface{}
	ReadEventByCompanyIdAndUserId(c chan map[string]interface{}, companyId, userId string)
}

type ProcessFootmark interface {
	Store(processFootmark v1.ProcessFootmark)
	GetByProcessId(processId string) []v1.ProcessFootmark
	GetByProcessIdAndStep(processId, step string) []v1.ProcessFootmark
	GetFootmarkByProcessIdAndStepAndFootmark(processId, step, footmark string) *v1.ProcessFootmark
}

type ProcessLifeCycleEvent interface {
	Store(events []v1.ProcessLifeCycleEvent)
	GetByProcessIdAndStep(processId, step string) v1.ProcessLifeCycleEvent
	PullNonInitializedAndAutoTriggerEnabledEventsByStepType(count int64, stepType string) []v1.ProcessLifeCycleEvent
	PullPausedAndAutoTriggerEnabledResourcesByAgentName(count int64, agent string) []v1.DeployableResource
	GetByProcessId(processId string) []v1.ProcessLifeCycleEvent
	UpdateClaim(companyId, processId, step, status string) error
	UpdateStatusesByTime(time time.Time)
}