138 lines
3.3 KiB
Go
138 lines
3.3 KiB
Go
// backend\tasks_status.go
|
|
|
|
package main
|
|
|
|
import (
|
|
"encoding/json"
|
|
"net/http"
|
|
"strings"
|
|
"sync"
|
|
)
|
|
|
|
type CleanupTaskState struct {
|
|
Running bool `json:"running"`
|
|
Text string `json:"text,omitempty"`
|
|
Error string `json:"error,omitempty"`
|
|
}
|
|
|
|
type RegenerateAssetsTaskState struct {
|
|
Running bool `json:"running"`
|
|
File string `json:"file,omitempty"`
|
|
Text string `json:"text,omitempty"`
|
|
Error string `json:"error,omitempty"`
|
|
}
|
|
|
|
type TasksStatusResponse struct {
|
|
GenerateAssets AssetsTaskState `json:"generateAssets"`
|
|
RegenerateAssets RegenerateAssetsTaskState `json:"regenerateAssets"`
|
|
Cleanup CleanupTaskState `json:"cleanup"`
|
|
AnyRunning bool `json:"anyRunning"`
|
|
}
|
|
|
|
var (
|
|
cleanupTaskMu sync.Mutex
|
|
cleanupTaskState CleanupTaskState
|
|
|
|
regenerateAssetsTaskMu sync.Mutex
|
|
regenerateAssetsTaskState RegenerateAssetsTaskState
|
|
)
|
|
|
|
func snapshotRegenerateAssetsTaskState() RegenerateAssetsTaskState {
|
|
regenerateAssetsTaskMu.Lock()
|
|
st := regenerateAssetsTaskState
|
|
regenerateAssetsTaskMu.Unlock()
|
|
return st
|
|
}
|
|
|
|
func setRegenerateAssetsTaskRunning(file, text string) {
|
|
regenerateAssetsTaskMu.Lock()
|
|
regenerateAssetsTaskState = RegenerateAssetsTaskState{
|
|
Running: true,
|
|
File: strings.TrimSpace(file),
|
|
Text: strings.TrimSpace(text),
|
|
Error: "",
|
|
}
|
|
regenerateAssetsTaskMu.Unlock()
|
|
}
|
|
|
|
func setRegenerateAssetsTaskDone(file, text string) {
|
|
regenerateAssetsTaskMu.Lock()
|
|
regenerateAssetsTaskState = RegenerateAssetsTaskState{
|
|
Running: false,
|
|
File: strings.TrimSpace(file),
|
|
Text: strings.TrimSpace(text),
|
|
Error: "",
|
|
}
|
|
regenerateAssetsTaskMu.Unlock()
|
|
}
|
|
|
|
func setRegenerateAssetsTaskError(file, errText string) {
|
|
regenerateAssetsTaskMu.Lock()
|
|
regenerateAssetsTaskState = RegenerateAssetsTaskState{
|
|
Running: false,
|
|
File: strings.TrimSpace(file),
|
|
Text: "",
|
|
Error: strings.TrimSpace(errText),
|
|
}
|
|
regenerateAssetsTaskMu.Unlock()
|
|
}
|
|
|
|
func snapshotCleanupTaskState() CleanupTaskState {
|
|
cleanupTaskMu.Lock()
|
|
st := cleanupTaskState
|
|
cleanupTaskMu.Unlock()
|
|
return st
|
|
}
|
|
|
|
func setCleanupTaskRunning(text string) {
|
|
cleanupTaskMu.Lock()
|
|
cleanupTaskState = CleanupTaskState{
|
|
Running: true,
|
|
Text: strings.TrimSpace(text),
|
|
Error: "",
|
|
}
|
|
cleanupTaskMu.Unlock()
|
|
}
|
|
|
|
func setCleanupTaskDone(text string) {
|
|
cleanupTaskMu.Lock()
|
|
cleanupTaskState = CleanupTaskState{
|
|
Running: false,
|
|
Text: strings.TrimSpace(text),
|
|
Error: "",
|
|
}
|
|
cleanupTaskMu.Unlock()
|
|
}
|
|
|
|
func setCleanupTaskError(errText string) {
|
|
cleanupTaskMu.Lock()
|
|
cleanupTaskState = CleanupTaskState{
|
|
Running: false,
|
|
Text: "",
|
|
Error: strings.TrimSpace(errText),
|
|
}
|
|
cleanupTaskMu.Unlock()
|
|
}
|
|
|
|
func tasksStatusHandler(w http.ResponseWriter, r *http.Request) {
|
|
if r.Method != http.MethodGet {
|
|
http.Error(w, "Nur GET erlaubt", http.StatusMethodNotAllowed)
|
|
return
|
|
}
|
|
|
|
assets := getGenerateAssetsTaskStatus()
|
|
regenerate := snapshotRegenerateAssetsTaskState()
|
|
cleanup := snapshotCleanupTaskState()
|
|
|
|
resp := TasksStatusResponse{
|
|
GenerateAssets: assets,
|
|
RegenerateAssets: regenerate,
|
|
Cleanup: cleanup,
|
|
AnyRunning: assets.Running || regenerate.Running || cleanup.Running,
|
|
}
|
|
|
|
w.Header().Set("Content-Type", "application/json")
|
|
w.Header().Set("Cache-Control", "no-store")
|
|
_ = json.NewEncoder(w).Encode(resp)
|
|
}
|