3 Commits

Author SHA1 Message Date
184378ae57 fleet: one-shot homelab health snapshot (containers, disks, units)
status across configured hosts via read-only commands (claude-docker
wrapper on the Pi5, local docker/systemctl here). Stable table +
findings list, exit 0/2/1, CI job containers skipped, unreachable
hosts become findings. Parsers unit-tested; smoked against the real
fleet (19 genuine findings). Spec: doc/tool-parity.md 4.2.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_011KikHkfCiC3yELbsMN8fT9
2026-08-07 01:02:06 +02:00
f8bfa71f5f ci/tasks/readme: register notifyr, svg-maker, waitfor, cronr, giteactl
All checks were successful
release-tools / build-release (push) Successful in 5m1s
release.yml TOOLS + BIN cases, VS Code build/test tasks, README table,
plan.md milestone 5, tool-parity build-order status.

Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>
Claude-Session: https://claude.ai/code/session_011KikHkfCiC3yELbsMN8fT9
2026-08-07 00:56:47 +02:00
6b4f1441ac Merge dev/giteactl: giteactl v1 2026-08-07 00:48:46 +02:00
10 changed files with 684 additions and 32 deletions

View File

@@ -20,7 +20,7 @@ jobs:
- name: Detektera ändrade tools
id: changed
run: |
TOOLS="pixel-sprite-maker mesh-tool bitmap-font-maker sfx-maker hitbox-tool"
TOOLS="pixel-sprite-maker mesh-tool bitmap-font-maker sfx-maker hitbox-tool notifyr svg-maker waitfor cronr giteactl"
BEFORE="${{ github.event.before }}"
CHANGED=""
if [ "${{ github.event_name }}" = "workflow_dispatch" ] \
@@ -59,6 +59,11 @@ jobs:
bitmap-font-maker) BIN=fontc ;;
sfx-maker) BIN=sfxc ;;
hitbox-tool) BIN=hitbox ;;
notifyr) BIN=notifyr ;;
svg-maker) BIN=svgc ;;
waitfor) BIN=waitfor ;;
cronr) BIN=cronr ;;
giteactl) BIN=giteactl ;;
*) echo "okänt tool $t"; exit 1 ;;
esac
echo "=== $t ($BIN) ==="
@@ -88,6 +93,11 @@ jobs:
bitmap-font-maker) BIN=fontc ;;
sfx-maker) BIN=sfxc ;;
hitbox-tool) BIN=hitbox ;;
notifyr) BIN=notifyr ;;
svg-maker) BIN=svgc ;;
waitfor) BIN=waitfor ;;
cronr) BIN=cronr ;;
giteactl) BIN=giteactl ;;
esac
TAG="$t-latest"
BODY="$t (binär: $BIN) - rullande bygge från senaste master. Commit: ${{ github.sha }}. Arkitekturer: linux x64 + arm64 (Pi5)."

218
.vscode/tasks.json vendored
View File

@@ -5,87 +5,261 @@
"label": "build pixel-sprite-maker",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/spritec .",
"options": { "cwd": "${workspaceFolder}/pixel-sprite-maker" },
"options": {
"cwd": "${workspaceFolder}/pixel-sprite-maker"
},
"group": "build",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "build mesh-tool",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/mesht .",
"options": { "cwd": "${workspaceFolder}/mesh-tool" },
"options": {
"cwd": "${workspaceFolder}/mesh-tool"
},
"group": "build",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "build bitmap-font-maker",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/fontc .",
"options": { "cwd": "${workspaceFolder}/bitmap-font-maker" },
"options": {
"cwd": "${workspaceFolder}/bitmap-font-maker"
},
"group": "build",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "test bitmap-font-maker",
"type": "shell",
"command": "go test ./...",
"options": { "cwd": "${workspaceFolder}/bitmap-font-maker" },
"options": {
"cwd": "${workspaceFolder}/bitmap-font-maker"
},
"group": "test",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "build sfx-maker",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/sfxc .",
"options": { "cwd": "${workspaceFolder}/sfx-maker" },
"options": {
"cwd": "${workspaceFolder}/sfx-maker"
},
"group": "build",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "test sfx-maker",
"type": "shell",
"command": "go test ./...",
"options": { "cwd": "${workspaceFolder}/sfx-maker" },
"options": {
"cwd": "${workspaceFolder}/sfx-maker"
},
"group": "test",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "build hitbox-tool",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/hitbox .",
"options": { "cwd": "${workspaceFolder}/hitbox-tool" },
"options": {
"cwd": "${workspaceFolder}/hitbox-tool"
},
"group": "build",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "test hitbox-tool",
"type": "shell",
"command": "go test ./...",
"options": { "cwd": "${workspaceFolder}/hitbox-tool" },
"options": {
"cwd": "${workspaceFolder}/hitbox-tool"
},
"group": "test",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "test pixel-sprite-maker",
"type": "shell",
"command": "go test ./...",
"options": { "cwd": "${workspaceFolder}/pixel-sprite-maker" },
"options": {
"cwd": "${workspaceFolder}/pixel-sprite-maker"
},
"group": "test",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "test mesh-tool",
"type": "shell",
"command": "go test ./...",
"options": { "cwd": "${workspaceFolder}/mesh-tool" },
"options": {
"cwd": "${workspaceFolder}/mesh-tool"
},
"group": "test",
"problemMatcher": ["$go"]
"problemMatcher": [
"$go"
]
},
{
"label": "build notifyr",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/notifyr .",
"options": {
"cwd": "${workspaceFolder}/notifyr"
},
"group": "build",
"problemMatcher": [
"$go"
]
},
{
"label": "test notifyr",
"type": "shell",
"command": "go test ./...",
"options": {
"cwd": "${workspaceFolder}/notifyr"
},
"group": "test",
"problemMatcher": [
"$go"
]
},
{
"label": "build svg-maker",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/svgc .",
"options": {
"cwd": "${workspaceFolder}/svg-maker"
},
"group": "build",
"problemMatcher": [
"$go"
]
},
{
"label": "test svg-maker",
"type": "shell",
"command": "go test ./...",
"options": {
"cwd": "${workspaceFolder}/svg-maker"
},
"group": "test",
"problemMatcher": [
"$go"
]
},
{
"label": "build waitfor",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/waitfor .",
"options": {
"cwd": "${workspaceFolder}/waitfor"
},
"group": "build",
"problemMatcher": [
"$go"
]
},
{
"label": "test waitfor",
"type": "shell",
"command": "go test ./...",
"options": {
"cwd": "${workspaceFolder}/waitfor"
},
"group": "test",
"problemMatcher": [
"$go"
]
},
{
"label": "build cronr",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/cronr .",
"options": {
"cwd": "${workspaceFolder}/cronr"
},
"group": "build",
"problemMatcher": [
"$go"
]
},
{
"label": "test cronr",
"type": "shell",
"command": "go test ./...",
"options": {
"cwd": "${workspaceFolder}/cronr"
},
"group": "test",
"problemMatcher": [
"$go"
]
},
{
"label": "build giteactl",
"type": "shell",
"command": "go build -trimpath -ldflags '-s -w' -o build/giteactl .",
"options": {
"cwd": "${workspaceFolder}/giteactl"
},
"group": "build",
"problemMatcher": [
"$go"
]
},
{
"label": "test giteactl",
"type": "shell",
"command": "go test ./...",
"options": {
"cwd": "${workspaceFolder}/giteactl"
},
"group": "test",
"problemMatcher": [
"$go"
]
},
{
"label": "build",
"dependsOn": ["build pixel-sprite-maker", "build mesh-tool", "build bitmap-font-maker", "build sfx-maker", "build hitbox-tool"],
"dependsOn": [
"build pixel-sprite-maker",
"build mesh-tool",
"build bitmap-font-maker",
"build sfx-maker",
"build hitbox-tool",
"build notifyr",
"build svg-maker",
"build waitfor",
"build cronr",
"build giteactl"
],
"dependsOrder": "parallel",
"group": { "kind": "build", "isDefault": true },
"group": {
"kind": "build",
"isDefault": true
},
"problemMatcher": []
}
]

View File

@@ -13,18 +13,25 @@ agent understands the result without opening an image viewer.
| [`bitmap-font-maker/`](bitmap-font-maker/) | `fontc` | Turns `.font` text files (pixel glyph grids, proportional widths) into font atlases (PNG + JSON metrics) and renders text strings to PNG or the terminal. |
| [`sfx-maker/`](sfx-maker/) | `sfxc` | Synthesizes retro game sound effects (sfxr-style) from `.sfx` text presets to 16-bit WAV: waves, envelope, pitch slides, vibrato, arpeggio, filters. Deterministic, with built-in presets (jump, coin, laser…). |
| [`hitbox-tool/`](hitbox-tool/) | `hitbox` | Scans sprite sheet PNGs and writes per-frame collision boxes as JSON from the alpha channel. Understands the spritec sheet naming convention including upscaled sheets. |
| [`notifyr/`](notifyr/) | `notifyr` | Sends **and reads** notifications on the homelab ntfy bus — alert a human, or check what the infra has been complaining about. |
| [`svg-maker/`](svg-maker/) | `svgc` | Builds SVG graphics from `.svgd` text descriptions (shapes, text, groups, color vars) with terminal preview, measurements and out-of-canvas warnings. Display via agent-helm: `helmd share out.svg`. |
| [`waitfor/`](waitfor/) | `waitfor` | Blocks until a shell condition holds (exit 0 + optional regex match) — replaces hand-rolled poll loops. `--then` hook composes with notifyr. |
| [`cronr/`](cronr/) | `cronr` | Recurring/one-shot jobs as systemd user timers that survive session exit and reboot. add/list/run/logs/rm, schedules validated by systemd-analyze. |
| [`giteactl/`](giteactl/) | `giteactl` | Gitea Actions runs, job logs (API/web/ssh+zstd fallback), `wait` (block until green) and `wait-quiet` (the "serialize heavy builds" rule), release assets. |
Each tool has its own folder, its own README with the full format/CLI
reference, its own tests and its own dev branch (`dev/<tool>`).
## Planned: agent-capability & homelab-admin tools
## Agent-capability & homelab-admin tools
[`doc/tool-parity.md`](doc/tool-parity.md) compares Gemini CLI's
[`doc/tool-parity.md`](doc/tool-parity.md) compares the Google agent's
built-in tools with Claude Code's, and specs the CLI tools that close
the gaps (`notifyr`, `giteactl`, `waitfor`, `cronr`, `fleet`,
`envaudit`, `reghelper`, `pagepub`, `nbcell`, `wtreectl`, `fanout`) so
any agent gets the same capabilities via `run_shell_command`. Build
order and rationale live there and in [`doc/plan.md`](doc/plan.md).
the gaps so any agent gets the same capabilities via its shell tool.
Built so far: `notifyr`, `waitfor`, `cronr`, `giteactl`, `svgc`
(2026-08-07). Still on the list: `fleet`, `envaudit`, `reghelper`,
`pagepub`, `nbcell`, `wtreectl`, `fanout`. Build order and rationale
live there and in [`doc/plan.md`](doc/plan.md). Agy finds the tools
through the `agent-tools` skill in `~/.gemini/config/skills/`.
## Building

View File

@@ -27,6 +27,12 @@ master/main. Only tools whose folders changed get rebuilt.
multi-view rendering, measurements and watertightness checks.
3. ✅ Per-tool VS Code build tasks → `<tool>/build/`.
4. ✅ CI: changed-tool detection + per-tool rolling releases.
5. ✅ 2026-08-07: agent-capability batch 1 — `notifyr` (ntfy
send/read), `waitfor` (block on condition), `cronr` (systemd user
timers), `giteactl` (CI runs/logs/wait/wait-quiet/releases) and
`svgc` (`svg-maker/`: .svgd → SVG for agent-helm, Björns direkta
önskemål). Alla smoke-testade mot riktig infra; agy-integration
via `agent-tools`-skill + AGENTS.md i `~/.gemini/config/`.
## Roadmap / expansion ideas (not agreed yet)

View File

@@ -289,9 +289,14 @@ binaries), same philosophy — don't duplicate those here.
## 5. Suggested build order
1. `notifyr` — smallest, everything else composes with it, ntfy already runs.
2. `giteactl` — removes the biggest daily friction (CI logs + build serialization).
3. `waitfor` + `cronr` — turns both agents into unattended operators.
1. `notifyr` — smallest, everything else composes with it, ntfy already runs. *(built 2026-08-07)*
2. `giteactl` — removes the biggest daily friction (CI logs + build serialization). *(built 2026-08-07; private repos need an API token in the config)*
3. `waitfor` + `cronr` — turns both agents into unattended operators. *(built 2026-08-07)*
4. `fleet` — replaces the hand-rolled health loops in every runbook.
5. `envaudit`, `reghelper`, `pagepub`, `nbcell`, `wtreectl` — as needed.
6. `fanout` — only if a concrete multi-agent need shows up.
Also built 2026-08-07 (outside this list, Björns direct request):
`svgc` (`svg-maker/`) — SVG graphics from text, displayed in
agent-helm via `helmd share`. Agy integration: the `agent-tools`
skill + a tools section in `~/.gemini/config/AGENTS.md`.

60
fleet/README.md Normal file
View File

@@ -0,0 +1,60 @@
# fleet — one-shot homelab health snapshot
Replaces the hand-rolled `ssh pi5-claude sudo claude-docker ps …`
loops from every runbook with a single command that checks **all
hosts**: container states, disk fill and failed systemd units.
Read-only by construction — it only runs `ps`/`df`/`systemctl` through
the read-only claude-docker wrapper, so it needs no new permissions.
From [`doc/tool-parity.md`](../doc/tool-parity.md) §4.2.
## Usage
```
fleet status [--host NAME] # all hosts, or one
```
```
== pi5 ==
containers: 54/58 healthy
disk / 81% used, 82G free
disk /srv/storage1 58% used, 1.2T free
failed units: 0 system, 0 user
...
19 finding(s):
pi5: container dozzle: exited (Exited (0) 5 months ago)
brasse-linux01: failed unit: cpupower-gui.service
```
| Exit | Meaning |
|------|---------|
| 0 | everything healthy |
| 2 | findings printed (unhealthy/exited containers, disk ≥ warn %, failed units) |
| 1 | error (unknown host, config problem) |
Output is a stable text table — an agent can diff it between runs.
Unreachable hosts become findings, not crashes. Gitea Actions'
transient job containers are skipped.
## Config
`~/.config/fleet/config.json`, created on first run (`FLEET_CONFIG`
overrides):
```json
{
"disk_warn_pct": 85,
"hosts": [
{"name": "pi5", "ssh": "pi5-claude", "docker_cmd": "sudo claude-docker", "df_targets": "/ /srv/storage1", "user_units": false},
{"name": "brasse-linux01", "ssh": "", "docker_cmd": "docker", "df_targets": "/ /home", "user_units": true}
]
}
```
`ssh: ""` means run locally. Add hosts by appending entries.
## Build & test
```bash
go test ./...
go build -o build/fleet .
```

118
fleet/check/check.go Normal file
View File

@@ -0,0 +1,118 @@
// Package check parses the health data fleet collects (docker ps,
// df, systemctl --failed) into stable rows and findings an agent can
// diff between runs.
package check
import (
"fmt"
"strconv"
"strings"
)
// Container is one row of docker ps output.
type Container struct {
Name string
State string // running, exited, restarting, ...
Status string // "Up 2 hours (healthy)", "Exited (1) 3 days ago"
Image string
}
// Healthy reports whether the container looks fine: running, and not
// flagged unhealthy.
func (c Container) Healthy() bool {
return c.State == "running" && !strings.Contains(c.Status, "unhealthy")
}
// ParseDockerPS parses `docker ps -a --format
// "{{.Names}}\t{{.State}}\t{{.Status}}\t{{.Image}}"`. CI job
// containers (Gitea Actions workers) are transient and skipped.
func ParseDockerPS(out string) []Container {
var rows []Container
for _, line := range strings.Split(out, "\n") {
line = strings.TrimSpace(line)
if line == "" {
continue
}
parts := strings.Split(line, "\t")
if len(parts) < 4 {
continue
}
if strings.HasPrefix(parts[0], "GITEA-ACTIONS-TASK-") {
continue
}
rows = append(rows, Container{Name: parts[0], State: parts[1], Status: parts[2], Image: parts[3]})
}
return rows
}
// Mount is one row of df output.
type Mount struct {
Target string
UsedPct int
Avail string
}
// ParseDF parses `df -h --output=target,pcent,avail`.
func ParseDF(out string) []Mount {
var rows []Mount
for i, line := range strings.Split(out, "\n") {
fields := strings.Fields(line)
if i == 0 || len(fields) < 3 { // header
continue
}
pct, err := strconv.Atoi(strings.TrimSuffix(fields[1], "%"))
if err != nil {
continue
}
rows = append(rows, Mount{Target: fields[0], UsedPct: pct, Avail: fields[2]})
}
return rows
}
// ParseFailedUnits parses `systemctl --failed --no-legend --plain`
// into unit names.
func ParseFailedUnits(out string) []string {
var units []string
for _, line := range strings.Split(out, "\n") {
fields := strings.Fields(strings.TrimPrefix(strings.TrimSpace(line), "● "))
if len(fields) == 0 {
continue
}
u := fields[0]
if strings.Contains(u, ".") {
units = append(units, u)
}
}
return units
}
// Finding is one thing worth attention.
type Finding struct {
Host string
Text string
}
func (f Finding) String() string { return f.Host + ": " + f.Text }
// Evaluate turns parsed data into findings. diskWarnPct is the fill
// grade that counts as a problem.
func Evaluate(host string, containers []Container, mounts []Mount, failedSys, failedUser []string, diskWarnPct int) []Finding {
var out []Finding
for _, c := range containers {
if !c.Healthy() {
out = append(out, Finding{host, fmt.Sprintf("container %s: %s (%s)", c.Name, c.State, c.Status)})
}
}
for _, m := range mounts {
if m.UsedPct >= diskWarnPct {
out = append(out, Finding{host, fmt.Sprintf("disk %s at %d%% (%s left)", m.Target, m.UsedPct, m.Avail)})
}
}
for _, u := range failedSys {
out = append(out, Finding{host, "failed unit: " + u})
}
for _, u := range failedUser {
out = append(out, Finding{host, "failed user unit: " + u})
}
return out
}

78
fleet/check/check_test.go Normal file
View File

@@ -0,0 +1,78 @@
package check
import (
"strings"
"testing"
)
const psOut = `GITEA-ACTIONS-TASK-120-WORKFLOW-x running Up 2 minutes catthehacker/ubuntu:act-latest
helm-hub running Up 58 minutes localhost:5000/helmd:latest
gitea-d running Up 27 hours (healthy) gitea/gitea:1.24
deluge exited Exited (1) 3 days ago linuxserver/deluge
kuma running Up 4 days (unhealthy) louislam/uptime-kuma:1`
func TestParseDockerPS(t *testing.T) {
rows := ParseDockerPS(psOut)
if len(rows) != 4 {
t.Fatalf("got %d rows, want 4 (CI worker skipped)", len(rows))
}
if rows[0].Name != "helm-hub" || !rows[0].Healthy() {
t.Errorf("helm-hub should be healthy: %+v", rows[0])
}
for _, r := range rows {
switch r.Name {
case "deluge":
if r.Healthy() {
t.Error("exited container marked healthy")
}
case "kuma":
if r.Healthy() {
t.Error("unhealthy container marked healthy")
}
}
}
}
const dfOut = `Mounted on Use% Avail
/ 81% 82G
/srv/storage1 58% 1.2T`
func TestParseDF(t *testing.T) {
rows := ParseDF(dfOut)
if len(rows) != 2 || rows[0].Target != "/" || rows[0].UsedPct != 81 || rows[1].Avail != "1.2T" {
t.Errorf("df parse wrong: %+v", rows)
}
}
func TestParseFailedUnits(t *testing.T) {
units := ParseFailedUnits("● backup.service loaded failed failed Nightly backup\nfoo.timer loaded failed failed X\n\n")
if len(units) != 2 || units[0] != "backup.service" || units[1] != "foo.timer" {
t.Errorf("failed units: %v", units)
}
if len(ParseFailedUnits("")) != 0 {
t.Error("empty output should give no units")
}
}
func TestEvaluate(t *testing.T) {
findings := Evaluate("pi5",
ParseDockerPS(psOut),
ParseDF(dfOut),
[]string{"backup.service"}, nil, 80)
var text []string
for _, f := range findings {
text = append(text, f.String())
}
joined := strings.Join(text, "\n")
for _, want := range []string{"deluge", "kuma", "disk / at 81%", "backup.service"} {
if !strings.Contains(joined, want) {
t.Errorf("findings missing %q:\n%s", want, joined)
}
}
if strings.Contains(joined, "storage1") {
t.Error("58% disk should not be a finding at threshold 80")
}
if len(findings) != 4 {
t.Errorf("got %d findings, want 4", len(findings))
}
}

3
fleet/go.mod Normal file
View File

@@ -0,0 +1,3 @@
module gitea.brasse-pc.eu/brasse/agent-tools/fleet
go 1.24

191
fleet/main.go Normal file
View File

@@ -0,0 +1,191 @@
// fleet takes a one-shot health snapshot of the homelab: container
// states, disk fill and failed systemd units per host — the loop every
// runbook used to hand-roll, done once and properly. Read-only by
// construction. See doc/tool-parity.md §4.2.
package main
import (
"encoding/json"
"flag"
"fmt"
"os"
"os/exec"
"path/filepath"
"strings"
"time"
"gitea.brasse-pc.eu/brasse/agent-tools/fleet/check"
)
var version = "dev"
const usage = `fleet - one-shot homelab health snapshot
Usage:
fleet status [--host NAME] [--all] containers, disks, failed units
fleet version
Exit codes: 0 = everything healthy, 2 = findings, 1 = error.
Hosts come from ~/.config/fleet/config.json (created on first run;
FLEET_CONFIG overrides). Default: the Pi5 through the read-only
claude-docker wrapper, and this workstation locally. All commands are
read-only (ps/df/systemctl status) — mutations stay in the supervised
tmux flow.
`
type host struct {
Name string `json:"name"`
SSH string `json:"ssh"` // ssh host alias, "" = run locally
DockerCmd string `json:"docker_cmd"` // e.g. "sudo claude-docker" or "docker"
DFTargets string `json:"df_targets"` // space-separated mount points
UserUnits bool `json:"user_units"` // also check systemctl --user --failed
}
type config struct {
DiskWarnPct int `json:"disk_warn_pct"`
Hosts []host `json:"hosts"`
}
func defaultConfig() *config {
return &config{
DiskWarnPct: 85,
Hosts: []host{
{Name: "pi5", SSH: "pi5-claude", DockerCmd: "sudo claude-docker", DFTargets: "/ /srv/storage1", UserUnits: false},
{Name: "brasse-linux01", SSH: "", DockerCmd: "docker", DFTargets: "/ /home", UserUnits: true},
},
}
}
func configPath() string {
if p := os.Getenv("FLEET_CONFIG"); p != "" {
return p
}
dir, err := os.UserConfigDir()
if err != nil {
dir = "."
}
return filepath.Join(dir, "fleet", "config.json")
}
func loadConfig() *config {
cfg := defaultConfig()
path := configPath()
data, err := os.ReadFile(path)
if os.IsNotExist(err) {
if err := os.MkdirAll(filepath.Dir(path), 0o755); err == nil {
out, _ := json.MarshalIndent(cfg, "", " ")
os.WriteFile(path, append(out, '\n'), 0o600)
fmt.Fprintf(os.Stderr, "fleet: created %s\n", path)
}
return cfg
}
if err == nil {
json.Unmarshal(data, cfg)
}
return cfg
}
func main() {
if len(os.Args) < 2 {
fmt.Print(usage)
os.Exit(2)
}
switch os.Args[1] {
case "status":
cmdStatus(os.Args[2:])
case "version", "--version", "-v":
fmt.Println("fleet", version)
case "help", "--help", "-h":
fmt.Print(usage)
default:
die("unknown command %q — run 'fleet help'", os.Args[1])
}
}
// run executes a read-only command locally or over ssh, with a
// timeout so one dead host cannot hang the snapshot.
func run(h host, cmdline string) (string, error) {
var c *exec.Cmd
if h.SSH != "" {
c = exec.Command("ssh", "-o", "ConnectTimeout=10", h.SSH, cmdline)
} else {
c = exec.Command("sh", "-c", cmdline)
}
done := make(chan struct{})
var out []byte
var err error
go func() { out, err = c.CombinedOutput(); close(done) }()
select {
case <-done:
case <-time.After(45 * time.Second):
c.Process.Kill()
return "", fmt.Errorf("timeout")
}
return string(out), err
}
func cmdStatus(args []string) {
fs := flag.NewFlagSet("status", flag.ExitOnError)
hostFilter := fs.String("host", "", "only this host (default: all)")
fs.Parse(args)
cfg := loadConfig()
var allFindings []check.Finding
checked := 0
for _, h := range cfg.Hosts {
if *hostFilter != "" && h.Name != *hostFilter {
continue
}
checked++
fmt.Printf("== %s ==\n", h.Name)
psOut, err := run(h, h.DockerCmd+` ps -a --format '{{.Names}}\t{{.State}}\t{{.Status}}\t{{.Image}}'`)
if err != nil {
fmt.Printf(" docker: UNREACHABLE (%v)\n", err)
allFindings = append(allFindings, check.Finding{Host: h.Name, Text: "docker unreachable: " + strings.TrimSpace(psOut)})
}
containers := check.ParseDockerPS(psOut)
up := 0
for _, c := range containers {
if c.Healthy() {
up++
}
}
fmt.Printf(" containers: %d/%d healthy\n", up, len(containers))
dfOut, _ := run(h, "df -h --output=target,pcent,avail "+h.DFTargets)
mounts := check.ParseDF(dfOut)
for _, m := range mounts {
fmt.Printf(" disk %-16s %3d%% used, %s free\n", m.Target, m.UsedPct, m.Avail)
}
sysOut, _ := run(h, "systemctl --failed --no-legend --plain")
failedSys := check.ParseFailedUnits(sysOut)
var failedUser []string
if h.UserUnits {
userOut, _ := run(h, "systemctl --user --failed --no-legend --plain")
failedUser = check.ParseFailedUnits(userOut)
}
fmt.Printf(" failed units: %d system, %d user\n", len(failedSys), len(failedUser))
allFindings = append(allFindings, check.Evaluate(h.Name, containers, mounts, failedSys, failedUser, cfg.DiskWarnPct)...)
}
if checked == 0 {
die("no host named %q in the config", *hostFilter)
}
if len(allFindings) == 0 {
fmt.Println("\nall healthy")
return
}
fmt.Printf("\n%d finding(s):\n", len(allFindings))
for _, f := range allFindings {
fmt.Println(" " + f.String())
}
os.Exit(2)
}
func die(format string, args ...interface{}) {
fmt.Fprintf(os.Stderr, "fleet: "+format+"\n", args...)
os.Exit(1)
}