1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
package storage
import (
"context"
"io"
"os"
"path"
grpc_logrus "github.com/grpc-ecosystem/go-grpc-middleware/logging/logrus"
log "github.com/sirupsen/logrus"
"gitlab.com/gitlab-org/gitaly/internal/helper"
"gitlab.com/gitlab-org/gitaly/internal/tempdir"
"gitlab.com/gitlab-org/gitaly/proto/go/gitalypb"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
)
func (s *server) DeleteAllRepositories(ctx context.Context, req *gitalypb.DeleteAllRepositoriesRequest) (*gitalypb.DeleteAllRepositoriesResponse, error) {
storageDir, err := helper.GetStorageByName(req.StorageName)
if err != nil {
return nil, status.Errorf(codes.InvalidArgument, "storage lookup failed: %v", err)
}
trashDir, err := tempdir.ForDeleteAllRepositories(req.StorageName)
if err != nil {
return nil, status.Errorf(codes.Internal, "create trash dir: %v", err)
}
dir, err := os.Open(storageDir)
if err != nil {
return nil, status.Errorf(codes.Internal, "open storage dir: %v", err)
}
defer dir.Close()
grpc_logrus.Extract(ctx).WithFields(log.Fields{
"trashDir": trashDir,
"storage": req.StorageName,
}).Warn("moving all repositories in storage to trash")
count := 0
for done := false; !done; {
dirents, err := dir.Readdir(100)
if err == io.EOF {
done = true
} else if err != nil {
return nil, status.Errorf(codes.Internal, "read storage dir: %v", err)
}
for _, d := range dirents {
if d.Name() == tempdir.GitalyDataPrefix {
continue
}
count++
if err := os.Rename(path.Join(storageDir, d.Name()), path.Join(trashDir, d.Name())); err != nil {
return nil, status.Errorf(codes.Internal, "move dir: %v", err)
}
}
}
grpc_logrus.Extract(ctx).WithFields(log.Fields{
"trashDir": trashDir,
"storage": req.StorageName,
"numDirectories": count,
}).Warn("directories moved to trash")
return &gitalypb.DeleteAllRepositoriesResponse{}, nil
}
|
