Similar blocks of code found in 4 locations. Consider refactoring.
func (d *pipelinerunDAO) GetLatestSuccessByClusterID(ctx context.Context, clusterID uint) (*models.Pipelinerun, error) {
var pipelinerun models.Pipelinerun
result := d.db.WithContext(ctx).Raw(common.PipelinerunGetLatestSuccessByClusterID, clusterID).Scan(&pipelinerun)
if result.Error != nil {
return nil, herrors.NewErrGetFailed(herrors.PipelinerunInDB, result.Error.Error())
Similar blocks of code found in 4 locations. Consider refactoring.
func (d *pipelinerunDAO) GetByID(ctx context.Context, pipelinerunID uint) (*models.Pipelinerun, error) {
var pr models.Pipelinerun
result := d.db.WithContext(ctx).Raw(common.PipelinerunGetByID, pipelinerunID).Scan(&pr)
if result.Error != nil {
return nil, herrors.NewErrGetFailed(herrors.PipelinerunInDB, result.Error.Error())
Similar blocks of code found in 4 locations. Consider refactoring.
func (d *pipelinerunDAO) GetByCIEventID(ctx context.Context, ciEventID string) (*models.Pipelinerun, error) {
var pr models.Pipelinerun
result := d.db.WithContext(ctx).Raw(common.PipelinerunGetByCIEventID, ciEventID).Scan(&pr)
if result.Error != nil {
return nil, herrors.NewErrGetFailed(herrors.PipelinerunInDB, result.Error.Error())
Similar blocks of code found in 4 locations. Consider refactoring.
func (d *pipelinerunDAO) GetFirstCanRollbackPipelinerun(ctx context.Context,
clusterID uint) (*models.Pipelinerun, error) {
var pipelinerun models.Pipelinerun
result := d.db.WithContext(ctx).Raw(common.PipelinerunGetFirstCanRollbackByClusterID, clusterID).Scan(&pipelinerun)
Similar blocks of code found in 5 locations. Consider refactoring.
func (d *pipelinerunDAO) Create(ctx context.Context, pipelinerun *models.Pipelinerun) (*models.Pipelinerun, error) {
result := d.db.WithContext(ctx).Create(pipelinerun)
if result.Error != nil {
return nil, herrors.NewErrInsertFailed(herrors.PipelinerunInDB, result.Error.Error())
Similar blocks of code found in 2 locations. Consider refactoring.
func (d *pipelinerunDAO) DeleteByClusterID(ctx context.Context, clusterID uint) error {
result := d.db.WithContext(ctx).Exec(common.PipelinerunDeleteByClusterID, clusterID)
if result.Error != nil {
return herrors.NewErrDeleteFailed(herrors.PipelinerunInDB, result.Error.Error())
Similar blocks of code found in 2 locations. Consider refactoring.
func (d *pipelinerunDAO) DeleteByID(ctx context.Context, pipelinerunID uint) error {
result := d.db.WithContext(ctx).Exec(common.PipelinerunDeleteByID, pipelinerunID)
if result.Error != nil {
return herrors.NewErrDeleteFailed(herrors.PipelinerunInDB, result.Error.Error())
There are no issues that match your filters.