github/drone
5
0
Fork 0
mirror of https://github.com/harness/drone.git synced 2025-05-04 16:52:22 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: [PIPE-24894]: Restrict lifecycle operations for reserved repo identifiers (#3426)

Browse Source 
* feat: [PIPE-24894]: Restrict lifecycle operations for reserved repo identifiers
This commit is contained in:
Karan Saraswat 2025-02-13 12:01:53 +00:00 committed by Harness
parent 13f6558ca3
commit f85b6c45c3
6 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
app/api/controller/repo/archive.go
View File

@ -36,6 +36,10 @@ func (c *Controller) Archive(
return err
}
if err = c.repoCheck.LifecycleRestriction(ctx, session, repo); err != nil {
return err
}
return c.git.Archive(ctx, git.ArchiveParams{
ReadParams: git.CreateReadParams(repo),
ArchiveParams: params,

2
app/api/controller/repo/check.go
View File

@ -18,10 +18,12 @@ import (
"context"
"github.com/harness/gitness/app/auth"
"github.com/harness/gitness/types"
)
// Check defines the interface for adding extra checks during repository operations.
type Check interface {
// Create allows adding extra check during create repo operations
Create(ctx context.Context, session *auth.Session, in *CreateInput) error
LifecycleRestriction(ctx context.Context, session *auth.Session, repo *types.RepositoryCore) error
}

5
app/api/controller/repo/no_op_checks.go
View File

@ -18,6 +18,7 @@ import (
"context"
"github.com/harness/gitness/app/auth"
"github.com/harness/gitness/types"
)
var _ Check = (*NoOpRepoChecks)(nil)
@ -32,3 +33,7 @@ func NewNoOpRepoChecks() *NoOpRepoChecks {
func (c *NoOpRepoChecks) Create(_ context.Context, _ *auth.Session, _ *CreateInput) error {
return nil
}
func (c *NoOpRepoChecks) LifecycleRestriction(_ context.Context, _ *auth.Session, _ *types.RepositoryCore) error {
return nil
}

4
app/api/controller/repo/purge.go
View File

@ -46,6 +46,10 @@ func (c *Controller) Purge(
return err
}
if err = c.repoCheck.LifecycleRestriction(ctx, session, repo.Core()); err != nil {
return err
}
log.Ctx(ctx).Info().
Int64("repo.id", repo.ID).
Str("repo.path", repo.Path).

4
app/api/controller/repo/restore.go
View File

@ -50,6 +50,10 @@ func (c *Controller) Restore(
return nil, fmt.Errorf("access check failed: %w", err)
}
if err = c.repoCheck.LifecycleRestriction(ctx, session, repo.Core()); err != nil {
return nil, err
}
if repo.Deleted == nil {
return nil, usererror.BadRequest("cannot restore a repo that hasn't been deleted")
}

4
app/api/controller/repo/soft_delete.go
View File

@ -50,6 +50,10 @@ func (c *Controller) SoftDelete(
return nil, fmt.Errorf("access check failed: %w", err)
}
if err = c.repoCheck.LifecycleRestriction(ctx, session, repoCore); err != nil {
return nil, err
}
repo, err := c.repoStore.Find(ctx, repoCore.ID)
if err != nil {
return nil, fmt.Errorf("failed to find the repo by ID: %w", err)