schnutibox/pkg/run/run.go

package run

import (
	"github.com/rs/zerolog/log"
	"github.com/spf13/cobra"
	"go.xsfx.dev/schnutibox/internal/config"
	"go.xsfx.dev/schnutibox/pkg/mpc"
	"go.xsfx.dev/schnutibox/pkg/rfid"
	"go.xsfx.dev/schnutibox/pkg/web"
)

func Run(cmd *cobra.Command, args []string) {
	log.Info().Msg("starting the RFID reader")

	idChan := make(chan string)
	r := rfid.NewRFID(config.Cfg, idChan)

	if err := r.Run(); err != nil {
		log.Fatal().Err(err).Msg("could not start RFID reader")
	}

	// Stating watcher.
	mpc.Watcher()

	go func() {
		var id string

		for {
			// Wating for a scanned tag.
			id = <-idChan
			logger := log.With().Str("id", id).Logger()
			logger.Info().Msg("received id")

			// Check of stop tag was detected.
			if id == config.Cfg.Meta.Stop {
				logger.Info().Msg("stopping")

				if err := mpc.Stop(logger); err != nil {
					logger.Error().Err(err).Msg("could not stop")
				}

				if err := mpc.Clear(logger); err != nil {
					logger.Error().Err(err).Msg("could not clear")
				}

				continue
			}

			// Check if there is a track for the ID.
			tracks, ok := config.Cfg.Tracks[id]
			if !ok {
				logger.Error().Msg("could not find track for ID")

				continue
			}

			// Try to play track.
			if err := mpc.Play(logger, id, tracks.Name, tracks.Uris); err != nil {
				logger.Error().Err(err).Msg("could not play track")
			}
		}
	}()

	// Running web interface. Blocking.
	web.Run(cmd, args)
}