move main changes over to vizdesk

vizicist · Nov 25, 2023 · 90276e0 · 90276e0
1 parent e87792e
commit 90276e0
Show file tree

Hide file tree

Showing 10 changed files with 397 additions and 6 deletions.
diff --git a/cmd/palette_monitor/palette_monitor.go b/cmd/palette_monitor/palette_monitor.go
@@ -1,6 +1,7 @@
 package main
 
 import (
+	"context"
 	"flag"
 	"fmt"
 	"os/exec"
@@ -10,6 +11,8 @@ import (
 	"github.com/0xcafed00d/joystick"
 	"github.com/vizicist/palette/engine"
 
+	"github.com/reugn/go-quartz/quartz"
+
 	midi "gitlab.com/gomidi/midi/v2"
 	_ "gitlab.com/gomidi/midi/v2/drivers/rtmididrv" // autoregisters driver
 )
@@ -18,22 +21,67 @@ func main() {
 
 	engine.InitLog("monitor")
 
-	pcheck := flag.Bool("engine", true, "Check Engine")
+	// pcheck := flag.Bool("engine", true, "Check Engine")
 	pjsid := flag.Int("joystick", -1, "Joystick ID")
 
 	flag.Parse()
 
+	engine.LogInfo("HACK - palette_monitor is not checking engine")
+	/*
 	if *pcheck {
 		engine.LogInfo("monitor is checking the engine.")
 		go checkEngine()
 	} else {
 		engine.LogInfo("monitor is NOT checking the engine.")
 	}
+	*/
 
 	go joystickMonitor(*pjsid)
 
 	go midiMonitor("Logidy UMI3")
 
+	go scheduler()
+
+	select {}
+}
+
+func scheduler() {
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	// create scheduler
+	sched := quartz.NewStdScheduler()
+
+	// async start scheduler
+	sched.Start(ctx)
+
+	// create jobs
+	// "0 15 10 * * ?"          Fire at 10:15am every day
+	cronTrigger, _ := quartz.NewCronTrigger("0,15,30,45 * * * * *")
+	shellJob := quartz.NewShellJob("palette status")
+	fjob := quartz.NewFunctionJob(func(_ context.Context) (int, error) {
+		fmt.Printf("hi from function!\n")
+		return 0, nil
+	})
+
+	// request, _ := http.NewRequest(http.MethodGet, "https://worldtimeapi.org/api/timezone/utc", nil)
+	// curlJob := quartz.NewCurlJob(request)
+
+	// functionJob := quartz.NewFunctionJob(func(_ context.Context) (int, error) { return 42, nil })
+
+	// register jobs to scheduler
+	// sched.ScheduleJob(ctx, shellJob, cronTrigger)
+	sched.ScheduleJob(ctx, fjob, cronTrigger)
+	sched.ScheduleJob(ctx, shellJob, cronTrigger)
+	// sched.ScheduleJob(ctx, curlJob, quartz.NewSimpleTrigger(time.Second*7))
+	// sched.ScheduleJob(ctx, functionJob, quartz.NewSimpleTrigger(time.Second*5))
+
+	// stop scheduler
+	// sched.Stop()
+
+	// wait for all workers to exit
+	// sched.Wait(ctx)
+
 	select {}
 }
 

diff --git a/data/config/paramdefs.json b/data/config/paramdefs.json
@@ -198,6 +198,7 @@
 "engine.mmtt_xexpand": {"valuetype": "float", "min": "0.5", "max": "2.0",  "init": "1.25",	"comment": "#" },
 "engine.mmtt_yexpand": {"valuetype": "float", "min": "0.5", "max": "2.0",  "init": "1.25",	"comment": "#" },
 "engine.mmtt_zexpand": {"valuetype": "float", "min": "0.5", "max": "10.0",  "init": "4.0",	"comment": "#" },
+"engine.nats": {"valuetype":"bool", "min":"false", "max":"true", "init":"false", "comment":"#" },
 "engine.notifygui": {"valuetype":"bool", "min":"false", "max":"true", "init":"true", "comment":"#" },
 "engine.obspath": {"valuetype":"string", "min":"", "max":"", "init":"C:/Program Files/obs-studio/bin/64bit/obs64.exe", "comment":"# OBS executable path" },
 "engine.obsstream": {"valuetype":"bool", "min":"false", "max":"true", "init":"false", "comment":"# turn on OBS streaming" },

diff --git a/engine/engine.go b/engine/engine.go
@@ -76,6 +76,7 @@ func InitEngine() {
 	TheQuadPro = NewQuadPro()
 	TheMidiIO = NewMidiIO()
 	TheErae = NewErae()
+	TheNats = NewNats()
 
 	InitLogTypes()
 

diff --git a/engine/engineapi.go b/engine/engineapi.go
@@ -368,6 +368,15 @@ func (e *Engine) Set(name string, value string) (err error) {
 			TheProcessManager.processCheckSecs = f
 		}
 
+	case "engine.nats":
+		if !e.loading {
+			if IsTrueValue(value) {
+				TheNats.Connect()
+			} else {
+				TheNats.Disconnect()
+			}
+		}
+
 	case "engine.obsstream":
 		if !e.loading {
 			if IsTrueValue(value) {

diff --git a/engine/misc.go b/engine/misc.go
@@ -128,6 +128,11 @@ func ConfigDir() string {
 	return filepath.Join(PaletteDataPath(), "config")
 }
 
+func GetConfigFileData(filename string) ([]byte, error) {
+	path := ConfigFilePath(filename)
+	return os.ReadFile(path)
+}
+
 func ConfigFilePath(nm string) string {
 	return filepath.Join(ConfigDir(), nm)
 }
@@ -550,7 +555,7 @@ func ArchiveLogs() error {
 
 	err = ziplogs(logsdir, zippath)
 	if err != nil {
-		return fmt.Errorf("Archivelogs: err=%s", err)
+		return fmt.Errorf("archivelogs: err=%s", err)
 	} else {
 		// If archiving is successful, clear the logs
 		return ClearLogs()