marker/shuffle-cracked
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Further health fixes and frontend cleanup

Browse Source
This commit is contained in:
Frikky
2023-10-19 17:22:19 +02:00
parent 5a33135dd7
commit 74dfa09d4c
8 changed files with 174 additions and 185 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/go-app/main.go
+33 -4
View File
@@ -27,6 +27,9 @@ import (
"os/exec"
"path/filepath"
// import httptest
"net/http/httptest"
//"regexp"
"strings"
"time"
@@ -4025,7 +4028,7 @@ func runInitEs(ctx context.Context) {
jobret, err := newscheduler.Every(int(interval)).Seconds().NotImmediately().Run(job)
if err != nil {
log.Printf("[CRITICAL] Failed to schedule org: %s", err)
log.Printf("[ERROR] Failed to schedule org: %s", err)
} else {
log.Printf("[INFO] Started sync on interval %d for org %s (%s)", interval, org.Name, org.Id)
scheduledOrgs[org.Id] = jobret
@@ -4234,6 +4237,32 @@ func runInitEs(ctx context.Context) {
log.Printf("[INFO] Skipping download of extra API samples as %d were found", len(workflowapps))
}
if os.Getenv("SHUFFLE_HEALTHCHECK_DISABLED") != "true" {
healthcheckInterval := 15
log.Printf("[INFO] Starting healthcheck job every %d minute. Stats available on /api/v1/health/stats. Disable with SHUFFLE_HEALTHCHECK_DISABLED=true", healthcheckInterval)
job := func() {
// Prepare a fake http.responsewriter
resp := httptest.NewRecorder()
request := http.Request{}
// Add the "force=true" query to the fake request
request.URL, err = url.Parse("/api/v1/health/stats?force=true")
if err != nil {
log.Printf("[ERROR] Failed to parse test url for healthstats: %s", err)
}
shuffle.RunOpsHealthCheck(resp, &request)
}
_, err := newscheduler.Every(int(healthcheckInterval)).Minutes().Run(job)
if err != nil {
log.Printf("[ERROR] Failed to schedule healthcheck: %s", err)
} else {
log.Printf("[DEBUG] Successfully started healthcheck interval of %d minutes", healthcheckInterval)
}
}
log.Printf("[INFO] Finished INIT (ES)")
}
@@ -4731,9 +4760,9 @@ func runInit(ctx context.Context) {
jobret, err := newscheduler.Every(int(interval)).Seconds().NotImmediately().Run(job)
if err != nil {
log.Printf("[CRITICAL] Failed to schedule org: %s", err)
log.Printf("[ERROR] Failed to schedule org: %s", err)
} else {
log.Printf("Started sync on interval %d for org %s", interval, org.Name)
log.Printf("[INFO] Started sync on interval %d for org %s", interval, org.Name)
scheduledOrgs[org.Id] = jobret
}
}
@@ -5281,7 +5310,7 @@ func handleCloudSetup(resp http.ResponseWriter, request *http.Request) {
jobret, err := newscheduler.Every(int(interval)).Seconds().NotImmediately().Run(job)
if err != nil {
log.Printf("[CRITICAL] Failed to schedule org: %s", err)
log.Printf("[ERROR] Failed to schedule org: %s", err)
} else {
log.Printf("[INFO] Started sync on interval %d for org %s", interval, org.Name)
scheduledOrgs[org.Id] = jobret