repository

type PipelineStage struct {
	Id           int               `sql:"id,pk"`
	Name         string            `sql:"name"`
	Description  string            `sql:"description"`
	Type         PipelineStageType `sql:"type"`
	Deleted      bool              `sql:"deleted, notnull"`
	CiPipelineId int               `sql:"ci_pipeline_id"`
	CdPipelineId int               `sql:"cd_pipeline_id"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PipelineStageRepository interface {
	GetConnection() *pg.DB

	CreateCiStage(ciStage *PipelineStage) (*PipelineStage, error)
	UpdateCiStage(ciStage *PipelineStage) (*PipelineStage, error)
	MarkCiStageDeletedById(ciStageId int, updatedBy int32, tx *pg.Tx) error
	GetAllCiStagesByCiPipelineId(ciPipelineId int) ([]*PipelineStage, error)
	GetCiStageByCiPipelineIdAndStageType(ciPipelineId int, stageType PipelineStageType) (*PipelineStage, error)

	GetStepIdsByStageId(stageId int) ([]int, error)
	CreatePipelineStageStep(step *PipelineStageStep) (*PipelineStageStep, error)
	UpdatePipelineStageStep(step *PipelineStageStep) (*PipelineStageStep, error)
	MarkCiStageStepsDeletedByStageId(ciStageId int, updatedBy int32, tx *pg.Tx) error
	GetAllStepsByStageId(stageId int) ([]*PipelineStageStep, error)
	GetStepById(stepId int) (*PipelineStageStep, error)
	MarkStepsDeletedByStageId(stageId int) error
	MarkStepsDeletedExcludingActiveStepsInUpdateReq(activeStepIdsPresentInReq []int, stageId int) error

	CreatePipelineScript(pipelineScript *PluginPipelineScript) (*PluginPipelineScript, error)
	UpdatePipelineScript(pipelineScript *PluginPipelineScript) (*PluginPipelineScript, error)
	GetScriptIdsByStageId(stageId int) ([]int, error)
	MarkPipelineScriptsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
	GetScriptDetailById(id int) (*PluginPipelineScript, error)
	MarkScriptDeletedById(scriptId int) error

	MarkScriptMappingDeletedByScriptId(scriptId int) error
	CreateScriptMapping(mappings []ScriptPathArgPortMapping) error
	GetScriptMappingIdsByStageId(stageId int) ([]int, error)
	MarkPipelineScriptMappingsDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
	GetScriptMappingDetailByScriptId(scriptId int) ([]*ScriptPathArgPortMapping, error)
	CheckIfFilePathMappingExists(filePathOnDisk string, filePathOnContainer string, scriptId int) (bool, error)
	CheckIfCommandArgMappingExists(command string, arg string, scriptId int) (bool, error)
	CheckIfPortMappingExists(portOnLocal int, portOnContainer int, scriptId int) (bool, error)

	CreatePipelineStageStepVariables([]PipelineStageStepVariable, *pg.Tx) ([]PipelineStageStepVariable, error)
	UpdatePipelineStageStepVariables(variables []PipelineStageStepVariable, tx *pg.Tx) ([]PipelineStageStepVariable, error)
	GetVariableIdsByStageId(stageId int) ([]int, error)
	MarkPipelineStageStepVariablesDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
	GetVariablesByStepId(stepId int) ([]*PipelineStageStepVariable, error)
	GetVariableIdsByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType) ([]int, error)
	MarkVariablesDeletedByStepIdAndVariableType(stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error
	MarkVariablesDeletedExcludingActiveVariablesInUpdateReq(activeVariableIdsPresentInReq []int, stepId int, variableType PipelineStageStepVariableType, tx *pg.Tx) error

	CreatePipelineStageStepConditions([]PipelineStageStepCondition, *pg.Tx) ([]PipelineStageStepCondition, error)
	UpdatePipelineStageStepConditions(conditions []PipelineStageStepCondition, tx *pg.Tx) ([]PipelineStageStepCondition, error)
	GetConditionIdsByStageId(stageId int) ([]int, error)
	MarkPipelineStageStepConditionDeletedByIds(ids []int, updatedBy int32, tx *pg.Tx) error
	GetConditionsByStepId(stepId int) ([]*PipelineStageStepCondition, error)
	GetConditionsByVariableId(variableId int) ([]*PipelineStageStepCondition, error)
	GetConditionIdsByStepId(stepId int) ([]int, error)
	MarkConditionsDeletedByStepId(stepId int, tx *pg.Tx) error
	MarkConditionsDeletedExcludingActiveVariablesInUpdateReq(activeConditionIdsPresentInReq []int, stepId int, tx *pg.Tx) error
}

type PipelineStageRepositoryImpl struct {
	// contains filtered or unexported fields
}

type PipelineStageStep struct {
	Id                       int              `sql:"id,pk"`
	PipelineStageId          int              `sql:"pipeline_stage_id"`
	Name                     string           `sql:"name"`
	Description              string           `sql:"description"`
	Index                    int              `sql:"index"`
	StepType                 PipelineStepType `sql:"step_type"`
	ScriptId                 int              `sql:"script_id"`
	RefPluginId              int              `sql:"ref_plugin_id"` //id of plugin used as reference
	OutputDirectoryPath      []string         `sql:"output_directory_path" pg:",array"`
	DependentOnStep          string           `sql:"dependent_on_step"`
	Deleted                  bool             `sql:"deleted,notnull"`
	TriggerIfParentStageFail bool             `sql:"trigger_if_parent_stage_fail"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PipelineStageStepCondition struct {
	Id                  int                            `sql:"id,pk"`
	PipelineStageStepId int                            `sql:"pipeline_stage_step_id"`
	ConditionVariableId int                            `sql:"condition_variable_id"` //id of variable on which condition is written
	ConditionType       PipelineStageStepConditionType `sql:"condition_type"`
	ConditionalOperator string                         `sql:"conditional_operator"`
	ConditionalValue    string                         `sql:"conditional_value"`
	Deleted             bool                           `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PipelineStageStepConditionType string

type PipelineStageStepVariable struct {
	Id                        int                                 `sql:"id,pk"`
	PipelineStageStepId       int                                 `sql:"pipeline_stage_step_id"`
	Name                      string                              `sql:"name"`
	Format                    PipelineStageStepVariableFormatType `sql:"format"`
	Description               string                              `sql:"description"`
	IsExposed                 bool                                `sql:"is_exposed,notnull"`
	AllowEmptyValue           bool                                `sql:"allow_empty_value,notnull"`
	DefaultValue              string                              `sql:"default_value"`
	Value                     string                              `sql:"value"`
	VariableType              PipelineStageStepVariableType       `sql:"variable_type"`
	ValueType                 PipelineStageStepVariableValueType  `sql:"value_type"`
	PreviousStepIndex         int                                 `sql:"previous_step_index,type:integer"`
	VariableStepIndexInPlugin int                                 `sql:"variable_step_index_in_plugin,type:integer"`
	ReferenceVariableName     string                              `sql:"reference_variable_name,type:text"`
	ReferenceVariableStage    PipelineStageType                   `sql:"reference_variable_stage,type:text"`
	Deleted                   bool                                `sql:"deleted,notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PipelineStageStepVariableFormatType string

type PipelineStageStepVariableType string

type PipelineStageStepVariableValueType string

type PipelineStageType string

type PipelineStepType string

type PluginPipelineScript struct {
	Id                       int                                  `sql:"id,pk"`
	Script                   string                               `sql:"script"`
	StoreScriptAt            string                               `sql:"store_script_at"`
	Type                     repository.ScriptType                `sql:"type"`
	DockerfileExists         bool                                 `sql:"dockerfile_exists, notnull"`
	MountPath                string                               `sql:"mount_path"`
	MountCodeToContainer     bool                                 `sql:"mount_code_to_container,notnull"`
	MountCodeToContainerPath string                               `sql:"mount_code_to_container_path"`
	MountDirectoryFromHost   bool                                 `sql:"mount_directory_from_host,notnull"`
	ContainerImagePath       string                               `sql:"container_image_path"`
	ImagePullSecretType      repository.ScriptImagePullSecretType `sql:"image_pull_secret_type"`
	ImagePullSecret          string                               `sql:"image_pull_secret"`
	Deleted                  bool                                 `sql:"deleted, notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type ScriptPathArgPortMapping struct {
	Id                  int                          `sql:"id,pk"`
	TypeOfMapping       repository.ScriptMappingType `sql:"type_of_mapping"`
	FilePathOnDisk      string                       `sql:"file_path_on_disk"`
	FilePathOnContainer string                       `sql:"file_path_on_container"`
	Command             string                       `sql:"command"`
	Args                []string                     `sql:"args" pg:",array"`
	PortOnLocal         int                          `sql:"port_on_local"`
	PortOnContainer     int                          `sql:"port_on_container"`
	ScriptId            int                          `sql:"script_id"`
	Deleted             bool                         `sql:"deleted, notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}