repository

type GlobalPluginRepository interface {
	GetMetaDataForAllPlugins() ([]*PluginMetadata, error)
	GetMetaDataForPluginWithStageType(stageType int) ([]*PluginMetadata, error)
	GetMetaDataByPluginId(pluginId int) (*PluginMetadata, error)
	GetAllPluginTags() ([]*PluginTag, error)
	GetAllPluginTagRelations() ([]*PluginTagRelation, error)
	GetTagsByPluginId(pluginId int) ([]string, error)
	GetScriptDetailById(id int) (*PluginPipelineScript, error)
	GetScriptMappingDetailByScriptId(scriptId int) ([]*ScriptPathArgPortMapping, error)
	GetVariablesByStepId(stepId int) ([]*PluginStepVariable, error)
	GetStepsByPluginIds(pluginIds []int) ([]*PluginStep, error)
	GetExposedVariablesByPluginIdAndVariableType(pluginId int, variableType PluginStepVariableType) ([]*PluginStepVariable, error)
	GetExposedVariablesByPluginId(pluginId int) ([]*PluginStepVariable, error)
	GetExposedVariablesForAllPlugins() ([]*PluginStepVariable, error)
	GetConditionsByStepId(stepId int) ([]*PluginStepCondition, error)
	GetPluginByName(pluginName string) ([]*PluginMetadata, error)
	GetAllPluginMetaData() ([]*PluginMetadata, error)
	GetPluginStepsByPluginId(pluginId int) ([]*PluginStep, error)
	GetConditionsByPluginId(pluginId int) ([]*PluginStepCondition, error)
	GetPluginStageMappingByPluginId(pluginId int) (*PluginStageMapping, error)
	GetConnection() (dbConnection *pg.DB)

	SavePluginMetadata(pluginMetadata *PluginMetadata, tx *pg.Tx) (*PluginMetadata, error)
	SavePluginStageMapping(pluginStageMapping *PluginStageMapping, tx *pg.Tx) (*PluginStageMapping, error)
	SavePluginSteps(pluginStep *PluginStep, tx *pg.Tx) (*PluginStep, error)
	SavePluginPipelineScript(pluginPipelineScript *PluginPipelineScript, tx *pg.Tx) (*PluginPipelineScript, error)
	SavePluginStepVariables(pluginStepVariables *PluginStepVariable, tx *pg.Tx) (*PluginStepVariable, error)
	SavePluginStepConditions(pluginStepConditions *PluginStepCondition, tx *pg.Tx) (*PluginStepCondition, error)
	SavePluginTag(pluginTag *PluginTag, tx *pg.Tx) (*PluginTag, error)
	SavePluginTagRelation(pluginTagRelation *PluginTagRelation, tx *pg.Tx) (*PluginTagRelation, error)
	SavePluginTagInBulk(pluginTag []*PluginTag, tx *pg.Tx) error
	SavePluginTagRelationInBulk(pluginTagRelation []*PluginTagRelation, tx *pg.Tx) error

	UpdatePluginMetadata(pluginMetadata *PluginMetadata, tx *pg.Tx) error
	UpdatePluginStageMapping(pluginStageMapping *PluginStageMapping, tx *pg.Tx) error
	UpdatePluginSteps(pluginStep *PluginStep, tx *pg.Tx) error
	UpdatePluginPipelineScript(pluginPipelineScript *PluginPipelineScript, tx *pg.Tx) error
	UpdatePluginStepVariables(pluginStepVariables *PluginStepVariable, tx *pg.Tx) error
	UpdatePluginStepConditions(pluginStepConditions *PluginStepCondition, tx *pg.Tx) error
	UpdatePluginTag(pluginTag *PluginTag, tx *pg.Tx) error
	UpdatePluginTagRelation(pluginTagRelation *PluginTagRelation, tx *pg.Tx) error

	UpdateInBulkPluginSteps(pluginSteps []*PluginStep, tx *pg.Tx) error
	UpdateInBulkPluginStepVariables(pluginStepVariables []*PluginStepVariable, tx *pg.Tx) error
	UpdateInBulkPluginStepConditions(pluginStepConditions []*PluginStepCondition, tx *pg.Tx) error
}

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

type PluginMetadata struct {
	Id          int        `sql:"id,pk"`
	Name        string     `sql:"name"`
	Description string     `sql:"description"`
	Type        PluginType `sql:"type"`
	Icon        string     `sql:"icon"`
	Deleted     bool       `sql:"deleted, notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PluginPipelineScript struct {
	Id                       int                       `sql:"id,pk"`
	Script                   string                    `sql:"script"`
	StoreScriptAt            string                    `sql:"store_script_at"`
	Type                     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      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 PluginStageMapping struct {
	Id        int `sql:"id,pk"`
	PluginId  int `sql:"plugin_id"`
	StageType int `sql:"stage_type"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PluginStep struct {
	Id                  int            `sql:"id,pk"`
	PluginId            int            `sql:"plugin_id"` //id of plugin - parent of this step
	Name                string         `sql:"name"`
	Description         string         `sql:"description"`
	Index               int            `sql:"index"`
	StepType            PluginStepType `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"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PluginStepCondition struct {
	Id                  int                     `sql:"id,pk"`
	PluginStepId        int                     `sql:"plugin_step_id,notnull"`
	ConditionVariableId int                     `sql:"condition_variable_id,notnull"` //id of variable on which condition is written
	ConditionType       PluginStepConditionType `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 PluginStepConditionType string

type PluginStepType string

type PluginStepVariable struct {
	Id                        int                          `sql:"id,pk"`
	PluginStepId              int                          `sql:"plugin_step_id"`
	Name                      string                       `sql:"name"`
	Format                    PluginStepVariableFormatType `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              PluginStepVariableType       `sql:"variable_type"`
	ValueType                 PluginStepVariableValueType  `sql:"value_type"`
	PreviousStepIndex         int                          `sql:"previous_step_index,notnull"`
	VariableStepIndex         int                          `sql:"variable_step_index,notnull"`
	VariableStepIndexInPlugin int                          `sql:"variable_step_index_in_plugin,notnull"` // will contain stepIndex of variable in case of refPlugin
	ReferenceVariableName     string                       `sql:"reference_variable_name"`
	Deleted                   bool                         `sql:"deleted,notnull"`
	sql.AuditLog
	PluginMetadataId int `sql:"-"`
	// contains filtered or unexported fields
}

type PluginStepVariableFormatType string

type PluginStepVariableType string

type PluginStepVariableValueType string

type PluginTag struct {
	Id      int    `sql:"id,pk"`
	Name    string `sql:"name"`
	Deleted bool   `sql:"deleted, notnull"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PluginTagRelation struct {
	Id       int `sql:"id,pk"`
	TagId    int `sql:"tag_id"`
	PluginId int `sql:"plugin_id"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type PluginType string

type ScriptImagePullSecretType string

type ScriptMappingType string

type ScriptPathArgPortMapping struct {
	Id                  int               `sql:"id,pk"`
	TypeOfMapping       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"`
	sql.AuditLog
	// contains filtered or unexported fields
}

type ScriptType string