fuse.go

@@ -11,15 +11,7 @@ import (
 
 func startFUSE(ctx context.Context, dev *infinitime.Device) error {
 	// This is where we'll mount the FS
-	err := os.MkdirAll(k.String("fuse.mountpoint"), 0755)
-	if err != nil && !os.IsExist(err) {
-		return err
-	}
-
-	// Ignore the error because nothing might be mounted on the mountpoint
-	_ = fusefs.Unmount(k.String("fuse.mountpoint"))
-
-
+	os.Mkdir(k.String("fuse.mountpoint"), 0755)
 	root, err := fusefs.BuildRootNode(dev)
 	if err != nil {
 		log.Error("Building root node failed").

internal/fusefs/fuse.go

@@ -15,7 +15,6 @@ import (
 type ITProperty struct {
 	name string
 	Ino uint64
-	oneshot bool
 	gen func(context.Context) (<-chan []byte, error)
 }
 
@@ -55,37 +54,32 @@ func BuildRootNode(dev *infinitime.Device) (*ITNode, error) {
 var properties = make([]ITProperty, 6)
 
 func BuildProperties(dev *infinitime.Device) {
-	properties[0] = ITProperty{"heartrate", 2, true,
+	properties[0] = ITProperty{"heartrate", 2,
 		func(ctx context.Context) (<-chan []byte, error) {
 			ans, err := dev.WatchHeartRate(ctx)
 			return converterU8(ctx, ans), err
 	}}
-	properties[1] = ITProperty{"battery", 3, true,
+	properties[1] = ITProperty{"battery", 3,
 		func(ctx context.Context) (<-chan []byte, error) {
 			ans, err := dev.WatchBatteryLevel(ctx)
 			return converterU8(ctx, ans), err
 	}}
-	properties[2] = ITProperty{"motion", 4, true,
+	properties[2] = ITProperty{"motion", 4,
 		func(ctx context.Context) (<-chan []byte, error) {
 			ans, err := dev.WatchMotion(ctx)
 			return converterMotionValues(ctx, ans), err
 	}}
-	properties[3] = ITProperty{"motion", 5, true,
-		func(ctx context.Context) (<-chan []byte, error) {
-			ans, err := dev.WatchMotion(ctx)
-			return converterMotionValues(ctx, ans), err
-	}}
-	properties[4] = ITProperty{"stepcount", 6, true,
+	properties[3] = ITProperty{"stepcount", 5,
 		func(ctx context.Context) (<-chan []byte, error) {
 			ans, err := dev.WatchStepCount(ctx)
 			return converterU32(ctx, ans), err
 	}}
-	properties[5] = ITProperty{"version", 7, true,
+	properties[4] = ITProperty{"version", 6,
 		func(ctx context.Context) (<-chan []byte, error) {
 			ans, err := dev.Version()
 			return converter1String(ctx, ans), err
 	}}
-	properties[6] = ITProperty{"address", 8, true,
+	properties[5] = ITProperty{"address", 7,
 		func(ctx context.Context) (<-chan []byte, error) {
 			ans := dev.Address()
 			return converter1String(ctx, ans), nil
@@ -103,7 +97,7 @@ func (n *ITNode) Readdir(ctx context.Context) (fs.DirStream, syscall.Errno) {
 		// root folder
 		r := make([]fuse.DirEntry, 2)
 		r[0] = fuse.DirEntry{
-			Name: "info",
+			Name: "device",
 			Ino:  0,
 			Mode: fuse.S_IFDIR,
 		}
@@ -115,7 +109,7 @@ func (n *ITNode) Readdir(ctx context.Context) (fs.DirStream, syscall.Errno) {
 		return fs.NewListDirStream(r), 0
 
 	case 1:
-		// info folder
+		// device folder
 		r := make([]fuse.DirEntry, 6)
 		for ind, value := range properties {
 			r[ind] = fuse.DirEntry{
@@ -128,7 +122,7 @@ func (n *ITNode) Readdir(ctx context.Context) (fs.DirStream, syscall.Errno) {
 		return fs.NewListDirStream(r), 0
 
 	case 2:
-		// on info
+		// on device
 		files, err := myfs.ReadDir(n.path)
 		if err != nil {
 			log.Error("FUSE ReadDir failed").Str("path", n.path).Err(err).Send()
@@ -185,7 +179,7 @@ func (n *ITNode) Lookup(ctx context.Context, name string, out *fuse.EntryOut) (*
 	switch n.kind {
 	case 0:
 		// root folder
-		if name == "info" {
+		if name == "device" {
 			stable := fs.StableAttr{
 				Mode: fuse.S_IFDIR,
 				Ino: uint64(0),
@@ -203,7 +197,7 @@ func (n *ITNode) Lookup(ctx context.Context, name string, out *fuse.EntryOut) (*
 			return child, 0
 		}
 	case 1:
-		// info folder
+		// device folder
 		for _, value := range properties {
 			if value.name == name {
 				stable := fs.StableAttr{