diff options
author | Patrick Steinhardt <psteinhardt@gitlab.com> | 2021-06-18 08:44:30 +0300 |
---|---|---|
committer | Patrick Steinhardt <psteinhardt@gitlab.com> | 2021-07-08 09:15:15 +0300 |
commit | cd31493804ff9a173b5977dc92a2a42338a62960 (patch) | |
tree | cb09a64e767741586ec6c922f366e02f8b4ce790 | |
parent | 353e85b66d2ef0eb9a65e3504ea789d05bd5a1ce (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.go | 18 |
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) } |