create namespaceNode

Author: JojiiOfficial

dmfs/dmfsRoot.go

@@ -10,18 +10,18 @@ import (
 	"github.com/hanwen/go-fuse/v2/fs"
 )
 
-type dmanagerRoot struct {
+type rootNode struct {
 	fs.Inode
 }
 
 // implement the interfaces
-var _ = (fs.NodeOnAdder)((*dmanagerRoot)(nil))
-var _ = (fs.NodeRenamer)((*dmanagerRoot)(nil))
-var _ = (fs.NodeRmdirer)((*dmanagerRoot)(nil))
+var _ = (fs.NodeOnAdder)((*rootNode)(nil))
+var _ = (fs.NodeRenamer)((*rootNode)(nil))
+var _ = (fs.NodeRmdirer)((*rootNode)(nil))
 
 // OnAdd is called on mounting the file system. Use it to populate
 // the file system tree.
-func (root *dmanagerRoot) OnAdd(ctx context.Context) {
+func (root *rootNode) OnAdd(ctx context.Context) {
 	root.debug("Init files")
 
 	err := data.loadUserAttributes()
@@ -39,40 +39,22 @@ func (root *dmanagerRoot) OnAdd(ctx context.Context) {
 
 		// Create namespace folder
 		if nsp == nil {
-			nsp = root.Inode.NewInode(ctx, &fs.Inode{}, fs.StableAttr{
+			nsp = root.Inode.NewInode(ctx, &namespaceNode{
+				namespace: nsName,
+				groups:    namespace.Groups,
+			}, fs.StableAttr{
 				Mode: syscall.S_IFDIR,
 			})
-			root.AddChild(nsName, nsp, true)
-		}
-
-		// Use a no_group folder for files
-		// not associated to a groud
-		if len(namespace.Groups) == 0 {
-			namespace.Groups = []string{"no_group"}
-		}
 
-		// Add groups to namespace
-		for _, group := range namespace.Groups {
-			gp := nsp.GetChild(group)
-			if gp == nil {
-				gp = nsp.NewInode(ctx, &groupInode{
-					group:     group,
-					namespace: namespace.Name,
-				}, fs.StableAttr{
-					Mode: syscall.S_IFDIR,
-				})
-
-				nsp.AddChild(group, gp, true)
-			}
+			root.AddChild(nsName, nsp, true)
 		}
 	}
 
 	root.debug("Init files success")
-
 }
 
-// Unlink if virtual file was unlinked
-func (root *dmanagerRoot) Rmdir(ctx context.Context, name string) syscall.Errno {
+// Delete Namespace if virtual file was unlinked
+func (root *rootNode) Rmdir(ctx context.Context, name string) syscall.Errno {
 	namespace := addNSName(name, data.libdm.Config)
 
 	// wait 2 seconds to ensure, user didn't cancel
@@ -91,12 +73,12 @@ func (root *dmanagerRoot) Rmdir(ctx context.Context, name string) syscall.Errno
 	return 0
 }
 
-// Rename if virtual file was renamed
-func (root *dmanagerRoot) Rename(ctx context.Context, name string, newParent fs.InodeEmbedder, newName string, flags uint32) syscall.Errno {
+// Rename namespace if virtual file was renamed
+func (root *rootNode) Rename(ctx context.Context, name string, newParent fs.InodeEmbedder, newName string, flags uint32) syscall.Errno {
 	// Don't rename default ns
 	if name == "default" {
 		fmt.Println("Can't rename default namespace!")
-		return syscall.EACCES
+		return syscall.EPERM
 	}
 
 	// Get real namespace names
@@ -115,7 +97,7 @@ func (root *dmanagerRoot) Rename(ctx context.Context, name string, newParent fs.
 	return 0
 }
 
-func (root *dmanagerRoot) debug(arg ...interface{}) {
+func (root *rootNode) debug(arg ...interface{}) {
 	if data.mounter.Debug {
 		fmt.Println(arg...)
 	}

dmfs/fsGroup.go

@@ -12,8 +12,9 @@ import (
 type groupInode struct {
 	fs.Inode
 
-	namespace string
-	group     string
+	namespace            string
+	group                string
+	isNoGroupPlaceholder bool
 }
 
 var _ = (fs.NodeOnAdder)((*groupInode)(nil))
@@ -22,6 +23,7 @@ func (groupInode *groupInode) OnAdd(ctx context.Context) {
 	groupAdd := []string{groupInode.group}
 
 	if len(groupAdd) == 1 && groupAdd[0] == "no_group" {
+		groupInode.isNoGroupPlaceholder = true
 		groupAdd = []string{}
 	}
 

dmfs/fsNamespace.go

@@ -0,0 +1,56 @@
+package dmfs
+
+import (
+	"context"
+	"syscall"
+	"time"
+
+	"github.com/hanwen/go-fuse/v2/fs"
+)
+
+type namespaceNode struct {
+	fs.Inode
+
+	namespace string
+	groups    []string
+}
+
+var _ = (fs.NodeOnAdder)((*namespaceNode)(nil))
+var _ = (fs.NodeRmdirer)((*namespaceNode)(nil))
+
+func (nsNode *namespaceNode) OnAdd(ctx context.Context) {
+	// Use a no_group folder for files
+	// not associated to a groud
+	if len(nsNode.groups) == 0 {
+		nsNode.groups = []string{"no_group"}
+	}
+
+	// Add groups to namespace
+	for _, group := range nsNode.groups {
+		gp := nsNode.GetChild(group)
+		if gp == nil {
+			gp = nsNode.NewInode(ctx, &groupInode{
+				group:     group,
+				namespace: nsNode.namespace,
+			}, fs.StableAttr{
+				Mode: syscall.S_IFDIR,
+			})
+
+			nsNode.AddChild(group, gp, true)
+		}
+	}
+}
+
+// Delete group if vfile was removed
+func (nsNode *namespaceNode) Rmdir(ctx context.Context, name string) syscall.Errno {
+	// wait 2 seconds to ensure, user didn't cancel
+	select {
+	case <-ctx.Done():
+		return syscall.ECANCELED
+	case <-time.After(2 * time.Second):
+	}
+
+	// TODO do delete request
+
+	return 0
+}

dmfs/mount.go

@@ -54,7 +54,7 @@ func (mounter *Mounter) Mount() {
 	initData()
 
 	// Create the fs
-	root := &dmanagerRoot{}
+	root := &rootNode{}
 
 	var err error