internal/fusefs/converters.go

@@ -0,0 +1,61 @@
+package fusefs
+
+import (
+	"go.arsenm.dev/infinitime"
+	"context"
+	"strconv"
+)
+
+func converterU8(ctx context.Context, in <-chan uint8) <-chan []byte {
+	out := make(chan []byte, 2)
+	go func() {
+		for {
+			select {
+			case <- ctx.Done():
+				return
+			case event := <-in:
+				out <- []byte(strconv.Itoa(int(event)) + "\n")
+			}
+		}
+	}()
+	return out
+}
+
+func converterU32(ctx context.Context, in <-chan uint32) <-chan []byte {
+	out := make(chan []byte, 2)
+	go func() {
+		for {
+			select {
+			case <- ctx.Done():
+				return
+			case event := <-in:
+				out <- []byte(strconv.Itoa(int(event)) + "\n")
+			}
+		}
+	}()
+	return out
+}
+
+func converterMotionValues(ctx context.Context, in <-chan infinitime.MotionValues) <-chan []byte {
+	out := make(chan []byte, 2)
+	go func() {
+		for {
+			select {
+			case <- ctx.Done():
+				return
+			case event := <-in:
+				out <- []byte(strconv.Itoa(int(event.X)) + " " + strconv.Itoa(int(event.Y)) + " " + strconv.Itoa(int(event.Z)) + "\n")
+			}
+		}
+	}()
+	return out
+}
+
+func converter1String(ctx context.Context, in string) <-chan []byte {
+	out := make(chan []byte, 2)
+	out <- []byte(in + "\n")
+	close(out)
+	return out
+}
+
+

internal/fusefs/fuse.go

@@ -10,13 +10,13 @@ import (
 	"github.com/hanwen/go-fuse/v2/fuse"
 	"io"
 	"bytes"
-	"strconv"
 )
 
 type ITProperty struct {
 	name string
 	Ino uint64
-	gen func() ([]byte, error)
+	oneshot bool
+	gen func(context.Context) (<-chan []byte, error)
 }
 
 
@@ -55,35 +55,40 @@ func BuildRootNode(dev *infinitime.Device) (*ITNode, error) {
 var properties = make([]ITProperty, 6)
 
 func BuildProperties(dev *infinitime.Device) {
-	properties[0] = ITProperty{"heartrate", 2,
-		func() ([]byte, error) {
-			ans, err := dev.HeartRate()
-			return []byte(strconv.Itoa(int(ans)) + "\n"), err
+	properties[0] = ITProperty{"heartrate", 2, true,
+		func(ctx context.Context) (<-chan []byte, error) {
+			ans, err := dev.WatchHeartRate(ctx)
+			return converterU8(ctx, ans), err
 	}}
-	properties[1] = ITProperty{"battery", 3,
-		func() ([]byte, error) {
-			ans, err := dev.BatteryLevel()
-			return []byte(strconv.Itoa(int(ans)) + "\n"), err
+	properties[1] = ITProperty{"battery", 3, true,
+		func(ctx context.Context) (<-chan []byte, error) {
+			ans, err := dev.WatchBatteryLevel(ctx)
+			return converterU8(ctx, ans), err
 	}}
-	properties[2] = ITProperty{"motion", 4,
-		func() ([]byte, error) {
-			ans, err := dev.Motion()
-			return []byte(strconv.Itoa(int(ans.X)) + " " + strconv.Itoa(int(ans.Y)) + " " + strconv.Itoa(int(ans.Z)) + "\n"), err
+	properties[2] = ITProperty{"motion", 4, true,
+		func(ctx context.Context) (<-chan []byte, error) {
+			ans, err := dev.WatchMotion(ctx)
+			return converterMotionValues(ctx, ans), err
 	}}
-	properties[3] = ITProperty{"stepcount", 6,
-		func() ([]byte, error) {
-			ans, err := dev.StepCount()
-			return []byte(strconv.Itoa(int(ans)) + "\n"), 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{"version", 7,
-		func() ([]byte, error) {
+	properties[4] = ITProperty{"stepcount", 6, true,
+		func(ctx context.Context) (<-chan []byte, error) {
+			ans, err := dev.WatchStepCount(ctx)
+			return converterU32(ctx, ans), err
+	}}
+	properties[5] = ITProperty{"version", 7, true,
+		func(ctx context.Context) (<-chan []byte, error) {
 			ans, err := dev.Version()
-			return []byte(ans + "\n"), err
+			return converter1String(ctx, ans), err
 	}}
-	properties[5] = ITProperty{"address", 8,
-		func() ([]byte, error) {
+	properties[6] = ITProperty{"address", 8, true,
+		func(ctx context.Context) (<-chan []byte, error) {
 			ans := dev.Address()
-			return []byte(ans + "\n"), nil
+			return converter1String(ctx, ans), nil
 	}}
 
 }
@@ -265,20 +270,18 @@ func (fh *bytesFileReadHandle) Read(ctx context.Context, dest []byte, off int64)
 }
 
 type sensorFileReadHandle struct {
-	content []byte
+	ch <-chan []byte
+	cancel context.CancelFunc
 }
 var _ fs.FileReader = (*sensorFileReadHandle)(nil)
 func (fh *sensorFileReadHandle) Read(ctx context.Context, dest []byte, off int64) (fuse.ReadResult, syscall.Errno) {
-	log.Info("Executing Read").Int("size", len(fh.content)).Send()
-	end := off + int64(len(dest))
-	if end > int64(len(fh.content)) {
-		end = int64(len(fh.content))
-	}
-	return fuse.ReadResultData(fh.content[off:end]), 0
+	content := <-fh.ch
+	return fuse.ReadResultData(content), 0
 }
 
 var _ fs.FileFlusher = (*sensorFileReadHandle)(nil)
 func (fh *sensorFileReadHandle) Flush(ctx context.Context) (errno syscall.Errno) {
+	fh.cancel()
 	return 0
 }
 
@@ -430,13 +433,15 @@ func (f *ITNode) Open(ctx context.Context, openFlags uint32) (fh fs.FileHandle,
 
 		for _, value := range properties {
 			if value.Ino == f.Ino {
-				ans, err := value.gen()
+				sub_ctx, cancel := context.WithCancel(ctx)
+				ans, err := value.gen(sub_ctx)
 				if err != nil {
 					return nil, 0, syscallErr(err)
 				}
 
 				fh = &sensorFileReadHandle{
-					content : ans,
+					ch: ans,
+					cancel : cancel,
 				}
 				return fh, fuse.FOPEN_DIRECT_IO, 0
 			}

internal/fusefs/unmount.go

@@ -1,15 +0,0 @@
-package fusefs
-
-import (
-	_ "unsafe"
-	"github.com/hanwen/go-fuse/v2/fuse"
-)
-
-func Unmount(mountPoint string) error {
-	return unmount(mountPoint, &fuse.MountOptions{DirectMount: false})
-}
-
-// Unfortunately, the FUSE library does not export its unmount function,
-// so this is required until that changes
-//go:linkname unmount github.com/hanwen/go-fuse/v2/fuse.unmount
-func unmount(mountPoint string, opts *fuse.MountOptions) error