Welcome to mirror list, hosted at ThFree Co, Russian Federation.

gitlab.com/gitlab-org/gitaly.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPatrick Steinhardt <psteinhardt@gitlab.com>2021-06-18 08:44:30 +0300
committerPatrick Steinhardt <psteinhardt@gitlab.com>2021-07-08 09:15:15 +0300
commitcd31493804ff9a173b5977dc92a2a42338a62960 (patch)
treecb09a64e767741586ec6c922f366e02f8b4ce790
parent353e85b66d2ef0eb9a65e3504ea789d05bd5a1ce (diff)
repository: Refactor `RemoveRepository()` for easier readability
This commit contains some preliminary refactorings to make the `RemoveRepository()` RPC follow best practices and make it a bit more readable. No functional changes are expected from this commit.
-rw-r--r--internal/gitaly/service/repository/remove.go18
1 files changed, 9 insertions, 9 deletions
diff --git a/internal/gitaly/service/repository/remove.go b/internal/gitaly/service/repository/remove.go
index 9fd43b63e..d40fca17a 100644
--- a/internal/gitaly/service/repository/remove.go
+++ b/internal/gitaly/service/repository/remove.go
@@ -11,34 +11,34 @@ import (
)
func (s *server) RemoveRepository(ctx context.Context, in *gitalypb.RemoveRepositoryRequest) (*gitalypb.RemoveRepositoryResponse, error) {
- path, err := s.locator.GetPath(in.Repository)
+ repo := in.GetRepository()
+
+ path, err := s.locator.GetPath(repo)
if err != nil {
return nil, helper.ErrInternal(err)
}
- storage, ok := s.cfg.Storage(in.GetRepository().GetStorageName())
+ storage, ok := s.cfg.Storage(repo.GetStorageName())
if !ok {
- return nil, helper.ErrInvalidArgumentf("storage %v not found", in.GetRepository().GetStorageName())
+ return nil, helper.ErrInvalidArgumentf("storage %v not found", repo.GetStorageName())
}
- base := filepath.Base(path)
-
tempDir := tempdir.TempDir(storage)
-
- if err = os.MkdirAll(tempDir, 0755); err != nil {
+ if err := os.MkdirAll(tempDir, 0755); err != nil {
return nil, helper.ErrInternal(err)
}
+ base := filepath.Base(path)
destDir := filepath.Join(tempDir, base+"+removed")
- if err = os.Rename(path, destDir); err != nil {
+ if err := os.Rename(path, destDir); err != nil {
if os.IsNotExist(err) {
return &gitalypb.RemoveRepositoryResponse{}, nil
}
return nil, helper.ErrInternal(err)
}
- if err = os.RemoveAll(destDir); err != nil {
+ if err := os.RemoveAll(destDir); err != nil {
return nil, helper.ErrInternal(err)
}