itd/cmd/itctl/watch.go

package main

import (
	"encoding/json"
	"fmt"
	"os"

	"github.com/urfave/cli/v2"
)

func watchHeart(c *cli.Context) error {
	heartCh, cancel, err := client.WatchHeartRate()
	if err != nil {
		return err
	}

	catchSignal(cancel)

	for heartRate := range heartCh {
		if c.Bool("json") {
			json.NewEncoder(os.Stdout).Encode(
				map[string]uint8{"heartRate": heartRate},
			)
		} else if c.Bool("shell") {
			fmt.Printf("HEART_RATE=%d\n", heartRate)
		} else {
			fmt.Println(heartRate, "BPM")
		}
	}

	return nil
}

func watchBattLevel(c *cli.Context) error {
	battLevelCh, cancel, err := client.WatchBatteryLevel()
	if err != nil {
		return err
	}

	catchSignal(cancel)

	for battLevel := range battLevelCh {
		if c.Bool("json") {
			json.NewEncoder(os.Stdout).Encode(
				map[string]uint8{"battLevel": battLevel},
			)
		} else if c.Bool("shell") {
			fmt.Printf("BATTERY_LEVEL=%d\n", battLevel)
		} else {
			fmt.Printf("%d%%\n", battLevel)
		}
	}

	return nil
}

func watchStepCount(c *cli.Context) error {
	stepCountCh, cancel, err := client.WatchStepCount()
	if err != nil {
		return err
	}

	catchSignal(cancel)

	for stepCount := range stepCountCh {
		if c.Bool("json") {
			json.NewEncoder(os.Stdout).Encode(
				map[string]uint32{"stepCount": stepCount},
			)
		} else if c.Bool("shell") {
			fmt.Printf("STEP_COUNT=%d\n", stepCount)
		} else {
			fmt.Println(stepCount, "Steps")
		}
	}

	return nil
}

func watchMotion(c *cli.Context) error {
	motionCh, cancel, err := client.WatchMotion()
	if err != nil {
		return err
	}

	catchSignal(cancel)

	for motionVals := range motionCh {
		if c.Bool("json") {
			json.NewEncoder(os.Stdout).Encode(motionVals)
		} else if c.Bool("shell") {
			fmt.Printf(
				"X=%d\nY=%d\nZ=%d\n",
				motionVals.X,
				motionVals.Y,
				motionVals.Z,
			)
		} else {
			fmt.Println(motionVals)
		}
	}

	return nil
}