add debug output

This commit is contained in:
Maxi Quoß
2023-01-29 21:20:30 +01:00
parent 18ef9f81c8
commit 969d1545b4
4 changed files with 8 additions and 0 deletions

View File

@@ -71,6 +71,7 @@ func RunPing(app *pocketbase.PocketBase) {
}(device) }(device)
} }
}) })
logger.Debug.Println("CronPing entries:", CronPing.Entries())
CronPing.Run() CronPing.Run()
} }
@@ -98,5 +99,6 @@ func RunWakeShutdown() {
}) })
} }
} }
logger.Debug.Println("CronWakeShutdown entries:", CronWakeShutdown.Entries())
CronWakeShutdown.Run() CronWakeShutdown.Run()
} }

View File

@@ -8,9 +8,11 @@ import (
"time" "time"
"github.com/pocketbase/pocketbase/models" "github.com/pocketbase/pocketbase/models"
"github.com/seriousm4x/upsnap/backend/logger"
) )
func ShutdownDevice(device *models.Record) error { func ShutdownDevice(device *models.Record) error {
logger.Debug.Println("shutdown triggered for", device.GetString("name"))
shutdown_cmd := device.GetString("shutdown_cmd") shutdown_cmd := device.GetString("shutdown_cmd")
if shutdown_cmd == "" { if shutdown_cmd == "" {
return fmt.Errorf("%s: no shutdown_cmd definded", device.GetString("name")) return fmt.Errorf("%s: no shutdown_cmd definded", device.GetString("name"))

View File

@@ -5,9 +5,11 @@ import (
"time" "time"
"github.com/pocketbase/pocketbase/models" "github.com/pocketbase/pocketbase/models"
"github.com/seriousm4x/upsnap/backend/logger"
) )
func WakeDevice(device *models.Record) error { func WakeDevice(device *models.Record) error {
logger.Debug.Println("wake triggered for", device.GetString("name"))
err := SendMagicPacket(device) err := SendMagicPacket(device)
if err != nil { if err != nil {
return err return err

View File

@@ -83,12 +83,14 @@ func StartPocketBase(distDirFS fs.FS) {
// using this outside App.OnBeforeServe() would not work // using this outside App.OnBeforeServe() would not work
App.OnModelAfterUpdate().Add(func(e *core.ModelEvent) error { App.OnModelAfterUpdate().Add(func(e *core.ModelEvent) error {
if e.Model.TableName() == "settings" { if e.Model.TableName() == "settings" {
logger.Debug.Println("restart CronPing")
for _, job := range cronjobs.CronPing.Entries() { for _, job := range cronjobs.CronPing.Entries() {
cronjobs.CronPing.Remove(job.ID) cronjobs.CronPing.Remove(job.ID)
} }
go cronjobs.RunPing(App) go cronjobs.RunPing(App)
} else if e.Model.TableName() == "devices" { } else if e.Model.TableName() == "devices" {
refreshDeviceList() refreshDeviceList()
logger.Debug.Println("restart CronWakeShutdown")
for _, job := range cronjobs.CronWakeShutdown.Entries() { for _, job := range cronjobs.CronWakeShutdown.Entries() {
cronjobs.CronWakeShutdown.Remove(job.ID) cronjobs.CronWakeShutdown.Remove(job.ID)
} }