fix: create worker to add data when computer is offline
This commit is contained in:
parent
d918100c2e
commit
e97b271bd7
2 changed files with 22 additions and 0 deletions
21
internal/worker/computer.go
Normal file
21
internal/worker/computer.go
Normal file
|
|
@ -0,0 +1,21 @@
|
||||||
|
package worker
|
||||||
|
|
||||||
|
import (
|
||||||
|
"backend/internal/model"
|
||||||
|
"backend/internal/service"
|
||||||
|
"log/slog"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
func StartComputerWorker() {
|
||||||
|
slog.Info("Starting computer worker...")
|
||||||
|
|
||||||
|
for range time.Tick(1 * time.Minute) {
|
||||||
|
if !service.ComputerData.Online {
|
||||||
|
service.AddComputerData(model.ComputerWebSocketMessage{
|
||||||
|
Cpu: 0,
|
||||||
|
Ram: 0,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
@ -4,6 +4,7 @@ import "os"
|
||||||
|
|
||||||
func StartWorkers() {
|
func StartWorkers() {
|
||||||
go StartLastFMWorker()
|
go StartLastFMWorker()
|
||||||
|
go StartComputerWorker()
|
||||||
if os.Getenv("UPTIME_KUMA_ENABLED") == "true" {
|
if os.Getenv("UPTIME_KUMA_ENABLED") == "true" {
|
||||||
go StartStatusWorker()
|
go StartStatusWorker()
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue