neofs-lens: add fstree cleanup-tmp command

Add command to cleaning up temporary files in FSTree by path.

Ref #2291.

Signed-off-by: Andrey Butusov <[email protected]>

CHANGELOG.md

@@ -12,6 +12,7 @@ Changelog for NeoFS Node
 - For `neofs-cli container create`, add `--global-name` flag, that sets name attribute as the value of `__NEOFS__NAME` 
 attribute, which is used for container domain name in NNS contracts (#2954)
 - Clean up temporary files in FSTree on start (#2967)
+- `neofs-lens fstree cleanup-tmp` command (#2967)
 
 ### Fixed
 - Do not search for tombstones when handling their expiration, use local indexes instead (#2929)

cmd/neofs-lens/internal/fstree/cleanup.go

@@ -0,0 +1,30 @@
+package fstree
+
+import (
+ common "github.com/nspcc-dev/neofs-node/cmd/neofs-lens/internal"
+ "github.com/spf13/cobra"
+)
+
+var cleanupCMD = &cobra.Command{
+ Use: "cleanup-tmp",
+ Short: "Clean up tmp files in FSTree",
+ Long: "Clean up temporary files in FSTree",
+ Args: cobra.NoArgs,
+ RunE: cleanupFunc,
+}
+
+func init() {
+ common.AddComponentPathFlag(cleanupCMD, &vPath)
+}
+
+func cleanupFunc(cmd *cobra.Command, _ []string) error {
+ fst, err := openFSTree()
+ if err != nil {
+ return err
+ }
+ defer fst.Close()
+
+ cmd.Println("Cleaning up tmp files in FSTree")
+
+ return fst.CleanUpTmp()
+}

cmd/neofs-lens/internal/fstree/root.go

@@ -0,0 +1,47 @@
+package fstree
+
+import (
+ "fmt"
+
+ "github.com/nspcc-dev/neofs-node/pkg/local_object_storage/blobstor/compression"
+ "github.com/nspcc-dev/neofs-node/pkg/local_object_storage/blobstor/fstree"
+ "github.com/spf13/cobra"
+)
+
+var (
+ vPath string
+)
+
+// Root defines root command for operations with FSTree.
+var Root = &cobra.Command{
+ Use: "fstree",
+ Short: "Operations with a FSTree",
+}
+
+func init() {
+ Root.AddCommand(cleanupCMD)
+}
+
+// openFSTree open and returns read-only fstree.FSTree located in vPath.
+func openFSTree() (*fstree.FSTree, error) {
+ fst := fstree.New(
+ fstree.WithPath(vPath),
+ fstree.WithPerm(0400),
+ )
+
+ var compressCfg compression.Config
+
+ err := compressCfg.Init()
+ if err != nil {
+ return nil, fmt.Errorf("failed to init compression config: %w", err)
+ }
+
+ fst.SetCompressor(&compressCfg)
+
+ err = fst.Open(true)
+ if err != nil {
+ return nil, fmt.Errorf("failed to open FSTree: %w", err)
+ }
+
+ return fst, nil
+}

cmd/neofs-lens/root.go

@@ -4,6 +4,7 @@ import (
  "os"
 
  "github.com/nspcc-dev/neofs-node/cmd/internal/cmderr"
+ "github.com/nspcc-dev/neofs-node/cmd/neofs-lens/internal/fstree"
  "github.com/nspcc-dev/neofs-node/cmd/neofs-lens/internal/meta"
  "github.com/nspcc-dev/neofs-node/cmd/neofs-lens/internal/object"
  "github.com/nspcc-dev/neofs-node/cmd/neofs-lens/internal/peapod"
@@ -44,6 +45,7 @@ func init() {
  writecache.Root,
  storage.Root,
  object.Root,
+ fstree.Root,
  gendoc.Command(command),
  )
 }