Delete empty trash dirs

Co-authored-by: Julian Koberg <jkoberg@owncloud.com>
Signed-off-by: Christian Richter <crichter@owncloud.com>

ocis/pkg/command/trash.go

@@ -0,0 +1,67 @@
+package command
+
+import (
+	"fmt"
+	"github.com/owncloud/ocis/v2/ocis/pkg/trash"
+
+	"github.com/owncloud/ocis/v2/ocis-pkg/config"
+	"github.com/owncloud/ocis/v2/ocis-pkg/config/configlog"
+	"github.com/owncloud/ocis/v2/ocis-pkg/config/parser"
+	"github.com/owncloud/ocis/v2/ocis/pkg/register"
+	"github.com/urfave/cli/v2"
+)
+
+func TrashCommand(cfg *config.Config) *cli.Command {
+	return &cli.Command{
+		Name:  "trash",
+		Usage: "ocis trash functionality",
+		Subcommands: []*cli.Command{
+			TrashPurgeOrphanedDirsCommand(cfg),
+		},
+		Before: func(c *cli.Context) error {
+			return configlog.ReturnError(parser.ParseConfig(cfg, true))
+		},
+		Action: func(_ *cli.Context) error {
+			fmt.Println("Read the docs")
+			return nil
+		},
+	}
+}
+
+func TrashPurgeOrphanedDirsCommand(cfg *config.Config) *cli.Command {
+	return &cli.Command{
+		Name:  "purge-orphaned-dirs",
+		Usage: "purge orphaned directories",
+		Flags: []cli.Flag{
+			&cli.StringFlag{
+				Name:     "basepath",
+				Aliases:  []string{"p"},
+				Usage:    "the basepath of the decomposedfs (e.g. /var/tmp/ocis/storage/users)",
+				Required: true,
+			},
+			&cli.BoolFlag{
+				Name:  "dry-run",
+				Usage: "do not delete anything, just print what would be deleted",
+				Value: true,
+			},
+		},
+		Action: func(c *cli.Context) error {
+			basePath := c.String("basepath")
+			if basePath == "" {
+				fmt.Println("basepath is required")
+				return cli.ShowCommandHelp(c, "consistency")
+			}
+
+			if err := trash.PurgeTrashOrphanedPaths(basePath, c.Bool("dry-run")); err != nil {
+				fmt.Println(err)
+				return err
+			}
+
+			return nil
+		},
+	}
+}
+
+func init() {
+	register.AddCommand(TrashCommand)
+}

ocis/pkg/trash/trash.go

@@ -0,0 +1,54 @@
+package trash
+
+import (
+	"errors"
+	"fmt"
+	"os"
+	"path/filepath"
+)
+
+const (
+	// _trashGlobPattern is the glob pattern to find all trash items
+	_trashGlobPattern = "storage/users/spaces/*/*/trash/*/*/*/*"
+)
+
+// PurgeTrashOrphanedPaths purges orphaned paths in the trash
+func PurgeTrashOrphanedPaths(p string, dryRun bool) error {
+	// we have all trash nodes in all spaces now
+	dirs, err := filepath.Glob(filepath.Join(p, _trashGlobPattern))
+	if err != nil {
+		return err
+	}
+
+	if len(dirs) == 0 {
+		return errors.New("no trash found. Double check storage path")
+	}
+
+	for _, d := range dirs {
+		if err := removeEmptyFolder(d, dryRun); err != nil {
+			return err
+		}
+	}
+	return nil
+}
+
+func removeEmptyFolder(path string, dryRun bool) error {
+	if dryRun {
+		f, err := os.ReadDir(path)
+		if err != nil {
+			return err
+		}
+		if len(f) < 1 {
+			fmt.Println("would remove", path)
+		}
+		return nil
+	}
+	if err := os.Remove(path); err != nil {
+		return nil
+	}
+	nd := filepath.Dir(path)
+	if filepath.Base(nd) == "trash" {
+		return nil
+	}
+	return removeEmptyFolder(nd, dryRun)
+}