// Copyright 2022 Harness Inc. All rights reserved. // Use of this source code is governed by the Polyform Free Trial License // that can be found in the LICENSE.md file for this repository. package pipeline import ( "context" "fmt" "strings" "time" apiauth "github.com/harness/gitness/internal/api/auth" "github.com/harness/gitness/internal/api/usererror" "github.com/harness/gitness/internal/auth" "github.com/harness/gitness/types" "github.com/harness/gitness/types/check" "github.com/harness/gitness/types/enum" ) var ( // errPipelineRequiresParent if the user tries to create a pipeline without a parent space. errPipelineRequiresParent = usererror.BadRequest( "Parent space required - standalone pipelines are not supported.") ) type CreateInput struct { Description string `json:"description"` UID string `json:"uid"` DefaultBranch string `json:"default_branch"` ConfigPath string `json:"config_path"` } func (c *Controller) Create( ctx context.Context, session *auth.Session, repoRef string, in *CreateInput, ) (*types.Pipeline, error) { repo, err := c.repoStore.FindByRef(ctx, repoRef) if err != nil { return nil, fmt.Errorf("failed to find repo by ref: %w", err) } err = apiauth.CheckPipeline(ctx, c.authorizer, session, repo.Path, "", enum.PermissionPipelineEdit) if err != nil { return nil, fmt.Errorf("failed to authorize pipeline: %w", err) } if err := c.sanitizeCreateInput(in); err != nil { return nil, fmt.Errorf("failed to sanitize input: %w", err) } var pipeline *types.Pipeline now := time.Now().UnixMilli() pipeline = &types.Pipeline{ Description: in.Description, RepoID: repo.ID, UID: in.UID, Seq: 0, DefaultBranch: in.DefaultBranch, ConfigPath: in.ConfigPath, Created: now, Updated: now, Version: 0, } err = c.pipelineStore.Create(ctx, pipeline) if err != nil { return nil, fmt.Errorf("pipeline creation failed: %w", err) } return pipeline, nil } func (c *Controller) sanitizeCreateInput(in *CreateInput) error { if err := c.uidCheck(in.UID, false); err != nil { return err } in.Description = strings.TrimSpace(in.Description) if err := check.Description(in.Description); err != nil { return err } if in.DefaultBranch == "" { in.DefaultBranch = c.defaultBranch } return nil }