/api/health/check

# Run health check on all wallets
curl "http://localhost:8080/api/health/check"

# Run health check on a specific wallet
curl "http://localhost:8080/api/health/check?wallet_path=Default"

# Poll for task completion (replace TASK_ID with actual ID)
curl "http://localhost:8080/api/system/tasks?id=TASK_ID"

# One-liner: start check and poll until done (bash)
TASK_ID=$(curl -s "http://localhost:8080/api/health/check" | python3 -c "import sys,json; print(json.load(sys.stdin)['task_id'])")
echo "Task: $TASK_ID"
while true; do
    STATUS=$(curl -s "http://localhost:8080/api/system/tasks?id=$TASK_ID")
    echo "$STATUS" | python3 -c "import sys,json; d=json.load(sys.stdin); print(f'{d.get(\"status\")}: {d.get(\"message\",\"\")}')"
    echo "$STATUS" | python3 -c "import sys,json; exit(0 if json.load(sys.stdin).get('status') in ('completed','failed') else 1)" && break
    sleep 3
done

package main

import (
    "encoding/json"
    "fmt"
    "io/ioutil"
    "net/http"
    "net/url"
    "time"
)

const ApiHost = "http://localhost:8080"

type HealthCheckResponse struct {
    Success bool   `json:"success"`
    TaskID  string `json:"task_id"`
    Message string `json:"message"`
}

type TaskStatus struct {
    TaskID   string                 `json:"task_id"`
    Status   string                 `json:"status"`
    Progress int                    `json:"progress"`
    Message  string                 `json:"message"`
    Data     map[string]interface{} `json:"data"`
}

func runHealthCheck(walletPath string) error {
    // Start health check
    reqURL := fmt.Sprintf("%s/api/health/check", ApiHost)
    if walletPath != "" {
        reqURL += "?wallet_path=" + url.QueryEscape(walletPath)
    }

    resp, err := http.Get(reqURL)
    if err != nil {
        return fmt.Errorf("request failed: %v", err)
    }
    defer resp.Body.Close()

    body, _ := ioutil.ReadAll(resp.Body)
    var result HealthCheckResponse
    json.Unmarshal(body, &result)

    if !result.Success {
        return fmt.Errorf("failed to start: %s", result.Message)
    }

    fmt.Printf("Started: %s (task: %s)\n", result.Message, result.TaskID)

    // Poll for completion
    for {
        time.Sleep(3 * time.Second)

        taskURL := fmt.Sprintf("%s/api/system/tasks?id=%s",
            ApiHost, url.QueryEscape(result.TaskID))
        taskResp, err := http.Get(taskURL)
        if err != nil {
            continue
        }

        taskBody, _ := ioutil.ReadAll(taskResp.Body)
        taskResp.Body.Close()

        var task TaskStatus
        json.Unmarshal(taskBody, &task)

        switch task.Status {
        case "completed":
            fmt.Println("Health check complete!")
            data, _ := json.MarshalIndent(task.Data, "", "  ")
            fmt.Println(string(data))
            return nil
        case "failed":
            return fmt.Errorf("health check failed: %s", task.Message)
        default:
            fmt.Printf("Progress: %d%% - %s\n", task.Progress, task.Message)
        }
    }
}

func main() {
    if err := runHealthCheck("Default"); err != nil {
        panic(err)
    }
}