service

type HttpClient interface {
	Post(url string, header map[string]string, body []byte) error
	Get(url string, header map[string]string) ([]byte, error)
}

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

type K8s interface {
	GetSecret(name, namespace string) (corev1.Secret, error)
	GetConfigMap(name, namespace string) (corev1.ConfigMap, error)
	GetPodListByProcessId(namespace, processId string, option v1.PodListGetOption) *corev1.PodList
	WaitAndGetInitializedPods(companyId, namespace, processId, step string, stepType string, claim int) *corev1.PodList
	FollowContainerLifeCycle(companyId, namespace, podName, containerName, step, processId string, stepType enums.STEP_TYPE, claim int)
	GetContainerLog(namespace, podName, containerName string, taskRunLabel map[string]string) (io.ReadCloser, error)
	RequestContainerLog(namespace string, podName string, containerName string) *rest.Request
	CreatePersistentVolumeClaim(source corev1.PersistentVolumeClaim) error
	InitPersistentVolumeClaim(step v1.Step, label map[string]string, processId string) corev1.PersistentVolumeClaim
	DeletePersistentVolumeClaimByProcessId(processId string) error
}

type LogEvent interface {
	Store(log v1.LogEvent)
	GetByProcessId(processId string, option v1.LogEventQueryOption) ([]string, int64)
	Listen(subject v1.Subject)
}

type Observer interface {
	Listen(subject v1.Subject)
}

type Pipeline interface {
	BuildProcessLifeCycleEvents(url, revision string, pipeline v1.Pipeline) error
	LoadArgs(pipeline v1.Pipeline)
	LoadEnvs(pipeline v1.Pipeline)
	SetInputResource(url, revision string, pipeline v1.Pipeline)
	Build(url, revision string, pipeline v1.Pipeline)
	PostOperations(step string, stepType enums.STEP_TYPE, pipeline v1.Pipeline, claim int)
	GetLogsByProcessId(processId string, option v1.LogEventQueryOption) ([]string, int64)
	ReadEventByCompanyId(c chan map[string]interface{}, processId string)
	ApplyBuildSteps()
	ApplyIntermediarySteps()
	ApplyJenkinsJobSteps()
	ApplyBuildCancellationSteps()
	PostOperationsForBuildPack(step string, stepType enums.STEP_TYPE, pipeline v1.Pipeline, claim int)
	FollowContainerLogs(pipeline Pipeline)
}

type ProcessEvent interface {
	Store(data v1.ProcessEvent)
	GetByCompanyId(companyId string) map[string]interface{}
	DequeueByCompanyId(companyId string) map[string]interface{}
	Listen(subject v1.Subject)
}

type ProcessLifeCycleEvent interface {
	PullBuildEvents() []v1.ProcessLifeCycleEvent
	PullIntermediaryStepsEvents() []v1.ProcessLifeCycleEvent
	PullBuildCancellingEvents() []v1.ProcessLifeCycleEvent
	PullJenkinsJobStepsEvents() []v1.ProcessLifeCycleEvent
	Listen(subject v1.Subject)
}

type Step interface {
	SetInput(url, revision string)
	SetArgs(k8s K8s)
	SetEnvs(k8s K8s)
}

type Tekton interface {
	InitPipelineResources(step v1.Step, label map[string]string, processId string) (input v1alpha1.PipelineResource, output []v1alpha1.PipelineResource, err error)
	InitTask(step v1.Step, label map[string]string, processId string) (v1alpha1.Task, error)
	InitTaskRun(step v1.Step, label map[string]string, processId string) (v1alpha1.TaskRun, error)
	CreatePipelineResource(v1alpha1.PipelineResource) error
	CreateTask(v1alpha1.Task) error
	CreateTaskRun(v1alpha1.TaskRun) error
	DeletePipelineResourceByProcessId(processId string) error
	DeletePipelineResources(pipelineResourcesList []string) error
	DeleteTaskByProcessId(processId string) error
	DeleteTasks(taskList []string) error
	DeletePipelineByProcessId(processId string) error
	DeletePipelineRunByProcessId(processId string) error
	DeleteTaskRunByProcessId(processId string) error
	DeleteTaskRuns(taskRunsList []string) error
	PurgeByProcessId(processId string)
	GetTaskRun(name string, waitUntilTaskRunIsCompleted bool) (*v1alpha1.TaskRun, error)
	GetPipelineRun(companyId, name, id, stepType string, waitUntilPipelineRunIsCompleted bool, podList corev1.PodList, claim int) (*v1beta1.PipelineRun, error)
	CreatePipeline(pipeline v1beta1.Pipeline) error
	InitPipeline(step v1.Step, label map[string]string, processId string) v1beta1.Pipeline
	CreatePipelineRun(pipelineRun v1beta1.PipelineRun) error
	InitPipelineRun(step v1.Step, label map[string]string, processId string) (v1beta1.PipelineRun, error)
}