diff --git a/installer/webui/test/reference/Main.body.html b/installer/webui/test/reference/Main.body.html
index 543d18d..3de17cd 100644
--- a/installer/webui/test/reference/Main.body.html
+++ b/installer/webui/test/reference/Main.body.html
@@ -18,13 +18,15 @@
diff --git a/installer/webui/test/reference/Vorpruefung.body.html b/installer/webui/test/reference/Vorpruefung.body.html
index 1666822..4875592 100644
--- a/installer/webui/test/reference/Vorpruefung.body.html
+++ b/installer/webui/test/reference/Vorpruefung.body.html
@@ -15,13 +15,15 @@
-
2Vorprüfung
+
+
+
3Vorprüfung
-
3Konfiguration
+
4Konfiguration
-
4Ausführung
+
5Ausführung
-
5Ergebnis
+
6Ergebnis
diff --git a/installer/webui/test/screen-preview.test.mjs b/installer/webui/test/screen-preview.test.mjs
index e8162a4..7ed6960 100644
--- a/installer/webui/test/screen-preview.test.mjs
+++ b/installer/webui/test/screen-preview.test.mjs
@@ -66,10 +66,28 @@ test('eine Komponente ohne Vorzustand ist neu', async () => {
test('Startet neu und Bleibt stehen folgen dem Plan (A17)', async () => {
const { screen } = await mount();
- assert.deepEqual(plain(screen.restart), ['energy-node-dashboard.service', 'tuya.service', 'automation.service']);
+ assert.deepEqual(plain(screen.restart), ['energy-node-dashboard.service', 'tuya.service']);
assert.equal(screen.keepNames, 'Systempakete · MQTT-Broker · Firewall · Tailscale · HTTPS über Caddy');
});
+test('nur Dienste mit Aenderung stehen unter Neustarts, "Alle neu starten" nimmt alle dazu', async () => {
+ const { screen } = await mount();
+ const units = plain(screen.restart);
+ assert.ok(units.includes('tuya.service'), 'geaenderter Dienst fehlt');
+ assert.ok(!units.includes('automation.service'), 'unveraenderter Dienst darf nicht neu starten');
+ screen.restartAll = true;
+ assert.ok(plain(screen.restart).includes('automation.service'), 'mit "alle" muss auch automation dabei sein');
+});
+
+test('start sendet restart_all nur, wenn der Schalter an ist', async () => {
+ const { screen, calls } = await mount();
+ await screen.start();
+ assert.equal(calls.find((call) => call.key === 'POST /api/run').body.restart_all, undefined);
+ screen.restartAll = true;
+ await screen.start();
+ assert.equal(calls.filter((call) => call.key === 'POST /api/run').pop().body.restart_all, true);
+});
+
test('der Funktionsumfang zeigt die Auswahl und einen neuen Dienst als aus', async () => {
const { screen } = await mount();
assert.deepEqual(plain(screen.serviceParts.map((part) => [part.type, part.name || '', part.on, part.isNew || false])), [
diff --git a/installer/webui/test/shell.test.mjs b/installer/webui/test/shell.test.mjs
index dd7c8bb..8bc21c0 100644
--- a/installer/webui/test/shell.test.mjs
+++ b/installer/webui/test/shell.test.mjs
@@ -272,3 +272,25 @@ test('ohne auto_prepare bleibt der erste Bildschirm des Dashboards die Vorschau'
const { shell } = await createShell({ bootstrap: DASHBOARD });
assert.equal(shell.screen, 'preview');
});
+
+test('das Vorbereiten hat im Stepper eine eigene Station statt unter Verbindung mitzulaufen', async () => {
+ const { shell } = await createShell({ bootstrap: Object.assign({}, BOOT, { package: {} }) });
+ shell.screen = 'prepare';
+ const items = shell.stepperParts.filter((part) => part.item);
+ assert.deepEqual(plain(items.map((item) => item.key)), ['connect', 'prepare', 'precheck', 'configure', 'run', 'result']);
+ assert.equal(items[0].done, true, 'Verbindung liegt hinter dem Vorbereiten');
+ assert.equal(items[1].cls, 'st-item active');
+});
+
+test('ein Wirt ohne Paketauswahl und ohne auto_prepare zeigt keine Vorbereiten-Station', async () => {
+ const { shell } = await createShell();
+ const items = shell.stepperParts.filter((part) => part.item);
+ assert.equal(items.some((item) => item.key === 'prepare'), false);
+});
+
+test('beim Dashboard mit auto_prepare steht das Vorbereiten als eigene, aktive Station vor der Vorschau', async () => {
+ const { shell } = await createShell({ bootstrap: Object.assign({}, DASHBOARD, { auto_prepare: true }) });
+ const items = shell.stepperParts.filter((part) => part.item);
+ assert.deepEqual(plain(items.map((item) => item.key)), ['prepare', 'preview', 'run', 'result']);
+ assert.equal(items[0].cls, 'st-item active');
+});
diff --git a/scripts/bootstrap/CHANGELOG.md b/scripts/bootstrap/CHANGELOG.md
index f490c90..d8b2f95 100644
--- a/scripts/bootstrap/CHANGELOG.md
+++ b/scripts/bootstrap/CHANGELOG.md
@@ -1,6 +1,6 @@
# Changelog
-## v0.1.8 (2026-09-21)
+## v0.1.9 (2026-09-22)
### Features
@@ -10,6 +10,9 @@
- **installer:** hide dashboard tabs for deselected optional services (#31) (59f2d40)
- **installer:** add the dashboard's local self-update path (Plan D) (#33) (e50d236)
- **dashboard:** download the newest release bundle from the redeploy page (#44) (245b277)
+- **bootstrap:** add the rule that decides which service units restart (5405aca)
+- **bootstrap:** restart a service unit only when its version or library changed (440f113)
+- **installer:** show per service which units restart in the preview (e2464cb)
### Fixes
diff --git a/scripts/bootstrap/VERSION b/scripts/bootstrap/VERSION
index da14730..549f177 100644
--- a/scripts/bootstrap/VERSION
+++ b/scripts/bootstrap/VERSION
@@ -1 +1 @@
-v0.1.8
+v0.1.9
diff --git a/scripts/bootstrap/lib/restart_rule.py b/scripts/bootstrap/lib/restart_rule.py
new file mode 100644
index 0000000..8950966
--- /dev/null
+++ b/scripts/bootstrap/lib/restart_rule.py
@@ -0,0 +1,82 @@
+#!/usr/bin/env python3
+"""Entscheidet, ob eine Dienst-Unit nach einem Update neu starten muss.
+
+Eine Stelle fuer die Regel: die Dienstschritte (service_step.sh) fragen sie
+zur Laufzeit, plan.sh fuer die Vorschau des Installers. Das Go-Gegenstueck im
+Dashboard (dashboard/internal/updaterhost/restart.go) wird gegen dieselbe
+Fallliste geprueft (scripts/bootstrap/testdata/restart_cases.json).
+
+Antworten:
+ "" kein Neustart noetig
+ "all" EN_RESTART=all: der Betreiber will alle Dienste neu starten
+ "first" kein installiertes Manifest oder der Dienst steht nicht darin
+ "unknown" eine Version fehlt (aelteres Manifest): im Zweifel neu starten
+ "version" die Version des Dienstes hat sich geaendert
+ "library" eine gemeinsame Bibliothek hat sich geaendert, die er importiert
+"""
+import json
+import os
+import pathlib
+import sys
+
+# Bibliothek -> Dienstverzeichnisse, die sie importieren. None = alle Dienste.
+# test_restart_rule.py haelt diese Tabelle gegen die echten Imports.
+LIBRARY_USERS = {
+ "energy_node_common": None,
+ "battery_soc_core": {"battery_soc"},
+}
+
+
+def _step(manifest, step_id):
+ for step in (manifest or {}).get("steps") or []:
+ if str(step.get("id")) == str(step_id):
+ return step
+ return None
+
+
+def restart_reason(candidate, installed, step_id, restart_all=False):
+ if restart_all:
+ return "all"
+ if not isinstance(candidate, dict):
+ return "unknown"
+ if not isinstance(installed, dict):
+ return "first"
+ new = _step(candidate, step_id)
+ if new is None:
+ return ""
+ old = _step(installed, step_id)
+ if old is None:
+ return "first"
+ if not old.get("version") or not new.get("version"):
+ return "unknown"
+ if old["version"] != new["version"]:
+ return "version"
+ old_components = installed.get("components") or {}
+ new_components = candidate.get("components") or {}
+ for name, users in LIBRARY_USERS.items():
+ version = new_components.get(name)
+ if version and old_components.get(name) != version and (users is None or new.get("dir") in users):
+ return "library"
+ return ""
+
+
+def _load(path):
+ try:
+ return json.loads(pathlib.Path(path).read_text(encoding="utf-8"))
+ except (OSError, ValueError):
+ return None
+
+
+def main(argv):
+ bundle_dir, state_dir, step_id = argv[1:4]
+ reason = restart_reason(
+ _load(pathlib.Path(bundle_dir) / "manifest.json"),
+ _load(pathlib.Path(state_dir) / "installed-manifest.json"),
+ step_id,
+ os.environ.get("EN_RESTART") == "all",
+ )
+ print(reason)
+
+
+if __name__ == "__main__":
+ main(sys.argv)
diff --git a/scripts/bootstrap/lib/service_step.sh b/scripts/bootstrap/lib/service_step.sh
index fac3e18..e4f5024 100644
--- a/scripts/bootstrap/lib/service_step.sh
+++ b/scripts/bootstrap/lib/service_step.sh
@@ -25,6 +25,13 @@ service_step_is_artefact() {
esac
}
+# Muss diese Unit neu starten? Die Regel steht in restart_rule.py (eine
+# Stelle fuer Schritt, Vorschau und Dashboard). Leere Antwort = nein.
+service_restart_reason() {
+ python3 "${SERVICE_STEP_LIB_DIR}/restart_rule.py" \
+ "${EN_BUNDLE_DIR}" "${EN_STATE_DIR}" "$1"
+}
+
# Achtung: step_fail beendet den Prozess. Das ist gewollt - jedes NN-*.sh
# ruft service_step genau einmal und hat danach nichts mehr zu tun.
service_step() {
@@ -82,15 +89,19 @@ service_step() {
"${EN_ROOT}/etc/systemd/system/${unit}" || { rm -f "${rendered}"; step_fail SERVICE_UNIT_FAILED; }
rm -f "${rendered}"
"${SUDO[@]}" systemctl daemon-reload
- # enable + restart statt enable --now: --now startet nur eine gestoppte
- # Unit. Bei einem Update laeuft sie schon mit dem alten Python-Code im
- # Speicher und muss neu starten. restart startet eine gestoppte Unit
- # ebenfalls, der Ablauf ist also fuer Erstinstallation und Update derselbe.
- # Der Koerper laeuft nur einmal je Bundle-Version (step_done), das ist
- # also ein Neustart je Update, nicht je Lauf.
+ # enable statt enable --now, und restart nur, wenn die Regel es verlangt:
+ # ein Update laesst laufende Dienste in Ruhe, die sich nicht geaendert haben
+ # (restart_rule.py). Eine gestoppte Unit wird immer gestartet - restart tut
+ # das ebenfalls, ein Lauf ist also fuer Erstinstallation und Update derselbe.
+ # Der Koerper laeuft nur einmal je Bundle-Version (step_done).
+ local reason
+ reason="$(service_restart_reason "${id}")"
"${SUDO[@]}" systemctl enable "${unit}" || step_fail SERVICE_START_FAILED
- "${SUDO[@]}" systemctl restart "${unit}" || step_fail SERVICE_START_FAILED
-
- step_log "Dienst ${dir} eingerichtet (${unit})."
+ if [[ -n "${reason}" ]] || ! "${SUDO[@]}" systemctl is-active --quiet "${unit}"; then
+ "${SUDO[@]}" systemctl restart "${unit}" || step_fail SERVICE_START_FAILED
+ step_log "Dienst ${dir} eingerichtet und neu gestartet (${unit}, ${reason:-war nicht aktiv})."
+ else
+ step_log "Dienst ${dir} eingerichtet (${unit}), unveraendert - kein Neustart."
+ fi
step_ok
}
diff --git a/scripts/bootstrap/plan.sh b/scripts/bootstrap/plan.sh
index 6fe18b4..cbe334d 100755
--- a/scripts/bootstrap/plan.sh
+++ b/scripts/bootstrap/plan.sh
@@ -7,8 +7,9 @@
# Komponente von/nach. Gibt JSON aus und KEINE ##STEP-Marker - dies ist kein
# Schritt, sondern ein Bericht.
set -euo pipefail
+SCRIPT_LIB_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)/lib"
# shellcheck source=scripts/bootstrap/lib/step.sh
-source "$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)/lib/step.sh"
+source "${SCRIPT_LIB_DIR}/step.sh"
if [[ ! -f "${EN_BUNDLE_DIR}/manifest.json" ]]; then
printf 'FEHLER BUNDLE_MANIFEST_MISSING\n'
@@ -19,6 +20,7 @@ EN_STATE_DIR="${EN_STATE_DIR}" \
EN_BUNDLE_DIR="${EN_BUNDLE_DIR}" \
EN_BUNDLE_VERSION="${EN_BUNDLE_VERSION}" \
EN_SELECTION="${EN_SELECTION}" \
+EN_PLAN_LIB_DIR="${SCRIPT_LIB_DIR}" \
python3 <<'PY'
import json, os, pathlib, sys
@@ -26,8 +28,19 @@ state = pathlib.Path(os.environ["EN_STATE_DIR"])
bundle = pathlib.Path(os.environ["EN_BUNDLE_DIR"])
version = os.environ["EN_BUNDLE_VERSION"]
+sys.path.insert(0, os.environ["EN_PLAN_LIB_DIR"])
+import restart_rule
+
manifest = json.loads((bundle / "manifest.json").read_text(encoding="utf-8"))
+installed_doc = None
+_installed_path = state / "installed-manifest.json"
+if _installed_path.is_file():
+ try:
+ installed_doc = json.loads(_installed_path.read_text(encoding="utf-8"))
+ except ValueError:
+ installed_doc = None
+
# Auswahl: fehlende Datei oder nicht genannter Schritt = gewaehlt.
selection = {}
sel_path = pathlib.Path(os.environ["EN_SELECTION"])
@@ -59,6 +72,12 @@ for entry in manifest.get("steps", []):
for extra in ("service_id", "dir", "unit"):
if entry.get(extra):
item[extra] = entry[extra]
+ if entry.get("dir"):
+ old = next((s for s in (installed_doc or {}).get("steps") or [] if str(s.get("id")) == step_id), None)
+ item["von"] = (old or {}).get("version")
+ item["nach"] = entry.get("version")
+ if state_name == "pending":
+ item["restart"] = restart_rule.restart_reason(manifest, installed_doc, step_id)
steps.append(item)
# von: das Manifest des zuletzt vollstaendig angewandten Bundles. Diese
diff --git a/scripts/bootstrap/testdata/restart_cases.json b/scripts/bootstrap/testdata/restart_cases.json
new file mode 100644
index 0000000..4271bf1
--- /dev/null
+++ b/scripts/bootstrap/testdata/restart_cases.json
@@ -0,0 +1,60 @@
+[
+ {"name": "restart all wins over everything",
+ "candidate": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {"energy_node_common": "v0.4.5"}},
+ "installed": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {"energy_node_common": "v0.4.5"}},
+ "step_id": "82", "restart_all": true, "want": "all"},
+
+ {"name": "no installed manifest means first install",
+ "candidate": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {}},
+ "installed": null, "step_id": "82", "restart_all": false, "want": "first"},
+
+ {"name": "service missing from the installed manifest is new",
+ "candidate": {"steps": [{"id": "84", "dir": "trucki", "version": "v0.4.0"}], "components": {}},
+ "installed": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {}},
+ "step_id": "84", "restart_all": false, "want": "first"},
+
+ {"name": "same version, same libraries: no restart",
+ "candidate": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {"energy_node_common": "v0.4.5", "battery_soc_core": "v0.1.9"}},
+ "installed": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {"energy_node_common": "v0.4.5", "battery_soc_core": "v0.1.9"}},
+ "step_id": "83", "restart_all": false, "want": ""},
+
+ {"name": "changed service version restarts that service",
+ "candidate": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.3"}], "components": {}},
+ "installed": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {}},
+ "step_id": "83", "restart_all": false, "want": "version"},
+
+ {"name": "installed manifest from before per-service versions is unknown",
+ "candidate": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {}},
+ "installed": {"steps": [{"id": "83", "dir": "shelly"}], "components": {}},
+ "step_id": "83", "restart_all": false, "want": "unknown"},
+
+ {"name": "candidate without a version is unknown",
+ "candidate": {"steps": [{"id": "83", "dir": "shelly"}], "components": {}},
+ "installed": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {}},
+ "step_id": "83", "restart_all": false, "want": "unknown"},
+
+ {"name": "energy_node_common changed restarts every service",
+ "candidate": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {"energy_node_common": "v0.4.6"}},
+ "installed": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {"energy_node_common": "v0.4.5"}},
+ "step_id": "83", "restart_all": false, "want": "library"},
+
+ {"name": "battery_soc_core changed restarts battery_soc",
+ "candidate": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {"battery_soc_core": "v0.2.0"}},
+ "installed": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {"battery_soc_core": "v0.1.9"}},
+ "step_id": "82", "restart_all": false, "want": "library"},
+
+ {"name": "battery_soc_core changed leaves other services alone",
+ "candidate": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {"battery_soc_core": "v0.2.0"}},
+ "installed": {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {"battery_soc_core": "v0.1.9"}},
+ "step_id": "83", "restart_all": false, "want": ""},
+
+ {"name": "library missing from the installed manifest counts as changed",
+ "candidate": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {"battery_soc_core": "v0.1.9"}},
+ "installed": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {}},
+ "step_id": "82", "restart_all": false, "want": "library"},
+
+ {"name": "step not in the candidate needs no restart",
+ "candidate": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {}},
+ "installed": {"steps": [{"id": "82", "dir": "battery_soc", "version": "v0.4.0"}], "components": {}},
+ "step_id": "99", "restart_all": false, "want": ""}
+]
diff --git a/scripts/build/lib/wheels.sh b/scripts/build/lib/wheels.sh
index c788beb..b27e330 100644
--- a/scripts/build/lib/wheels.sh
+++ b/scripts/build/lib/wheels.sh
@@ -127,6 +127,12 @@ build_local_wheels() {
version="$(tr -d '[:space:]' < "${repo_root}/libs/${lib}/VERSION")"
version="${version#v}"
+ # dist/ may not exist yet on a checkout that has never built a wheel
+ # locally before -- find on a missing directory fails, and pipefail
+ # would otherwise carry that failure into the assignment below and kill
+ # the script under set -e without printing anything (the real error is
+ # thrown away by 2>/dev/null).
+ mkdir -p "${dist}"
cached="$(find "${dist}" -maxdepth 1 -name "${lib}-${version}-*.whl" 2>/dev/null | head -n 1)"
if [[ -n "${cached}" ]]; then
echo "Wiederverwendet: $(basename "${cached}")"
diff --git a/scripts/tests/test_bootstrap_plan.sh b/scripts/tests/test_bootstrap_plan.sh
index e940885..8838d74 100755
--- a/scripts/tests/test_bootstrap_plan.sh
+++ b/scripts/tests/test_bootstrap_plan.sh
@@ -20,7 +20,7 @@ cat > "$bundle/manifest.json" <<'JSON'
{ "id": "40", "optional": true, "default": true },
{ "id": "50", "optional": false },
{ "id": "81", "optional": true, "default": true, "service_id": "apsystems",
- "dir": "apsystems_ez1", "unit": "apsystems-ez1.service" }
+ "dir": "apsystems_ez1", "unit": "apsystems-ez1.service", "version": "v0.4.1" }
]
}
JSON
@@ -32,7 +32,7 @@ mkdir -p "$EN_STATE_DIR/steps"
printf 'bundle=v0.2.0\n' > "$EN_STATE_DIR/steps/10" # erledigt
printf 'bundle=v0.1.0\n' > "$EN_STATE_DIR/steps/50" # altes Bundle -> offen
printf '{"steps":{"40":false}}\n' > "$EN_SELECTION"
-printf '{"version":"v0.1.0","components":{"dashboard":"v0.6.0"}}\n' \
+printf '{"version":"v0.1.0","components":{"dashboard":"v0.6.0"},"steps":[{"id":"81","dir":"apsystems_ez1","version":"v0.4.0"}]}\n' \
> "$EN_STATE_DIR/installed-manifest.json"
out="$(bash "$script")"
@@ -51,6 +51,15 @@ get() { python3 -c 'import json,sys; d=json.load(sys.stdin); print(eval(sys.argv
[ "$(get 'd["components"]["dashboard"]["nach"]')" = "v0.6.1" ] || fail "nach falsch" "$out"
[ "$(get 'd["components"]["services"]["von"]')" = "None" ] || fail "unbekanntes von nicht null" "$out"
+python3 - "$out" <<'PY' || fail "Vorschau meldet den Neustart des Dienstes falsch"
+import json, sys
+steps = {s["id"]: s for s in json.loads(sys.argv[1])["steps"]}
+apsystems = steps["81"]
+assert apsystems["von"] == "v0.4.0" and apsystems["nach"] == "v0.4.1", apsystems
+assert apsystems["restart"] == "version", apsystems
+assert "restart" not in steps["50"], steps["50"] # kein Dienstschritt
+PY
+
# --- ohne installed-manifest.json ist jedes von null ----------------------
rm -f "$EN_STATE_DIR/installed-manifest.json"
out="$(bash "$script")"
diff --git a/scripts/tests/test_bootstrap_service_step.sh b/scripts/tests/test_bootstrap_service_step.sh
index d74ccd0..516c9f4 100755
--- a/scripts/tests/test_bootstrap_service_step.sh
+++ b/scripts/tests/test_bootstrap_service_step.sh
@@ -12,6 +12,11 @@ fail() { echo "FAIL: $1"; [ -n "${2:-}" ] && printf '%s\n' "$2"; exit 1; }
mkdir -p "$tmp/bin"
cat > "$tmp/bin/systemctl" <<'SH'
#!/usr/bin/env bash
+# is-active fragt nur; es steht nicht im Protokoll. UNIT_ACTIVE=1 = laeuft.
+if [ "$1" = is-active ]; then
+ [ "${UNIT_ACTIVE:-0}" = 1 ]
+ exit $?
+fi
printf 'systemctl %s\n' "$*" >> "$SYSTEMCTL_LOG"
SH
chmod +x "$tmp/bin/systemctl"
@@ -102,4 +107,50 @@ set -e
[ "$rc" -eq 1 ] || fail "fehlende Quelle nicht gemeldet" "$rc"
grep -q '^##STEP 81 fail SERVICE_SOURCE_MISSING$' <<<"$out" || fail "falscher Code" "$out"
+# --- Neustart nur, wenn sich der Dienst geaendert hat ---------------------
+manifest() { #
+ printf '{"version":"v1.0.0","components":{"energy_node_common":"%s"},"steps":[{"id":"81","dir":"demo","version":"%s"}]}\n' "$2" "$1"
+}
+manifest v0.4.0 v0.4.5 > "$bundle/manifest.json"
+mkdir -p "$tmp/state"
+manifest v0.4.0 v0.4.5 > "$tmp/state/installed-manifest.json"
+restarts() { grep -c 'systemctl restart demo.service' "$SYSTEMCTL_LOG" || true; }
+
+# unveraendert und laeuft: kein Neustart, die Unit wird trotzdem eingerichtet
+rm -rf "$tmp/state/steps"; : > "$SYSTEMCTL_LOG"
+out="$(UNIT_ACTIVE=1 run)"
+grep -q '^##STEP 81 ok$' <<<"$out" || fail "unveraenderter Dienst: kein ok" "$out"
+[ "$(restarts)" = 0 ] || fail "unveraenderter, laufender Dienst wurde neu gestartet" "$(cat "$SYSTEMCTL_LOG")"
+grep -qx 'systemctl enable demo.service' "$SYSTEMCTL_LOG" || fail "Unit nicht aktiviert"
+grep -qi 'kein Neustart' <<<"$out" || fail "kein Hinweis auf den ausgebliebenen Neustart" "$out"
+
+# unveraendert, aber gestoppt: wird gestartet
+rm -rf "$tmp/state/steps"; : > "$SYSTEMCTL_LOG"
+UNIT_ACTIVE=0 run >/dev/null
+[ "$(restarts)" = 1 ] || fail "gestoppter Dienst wurde nicht gestartet" "$(cat "$SYSTEMCTL_LOG")"
+
+# neue Dienstversion: Neustart
+manifest v0.4.1 v0.4.5 > "$bundle/manifest.json"
+rm -rf "$tmp/state/steps"; : > "$SYSTEMCTL_LOG"
+UNIT_ACTIVE=1 run >/dev/null
+[ "$(restarts)" = 1 ] || fail "geaenderter Dienst wurde nicht neu gestartet" "$(cat "$SYSTEMCTL_LOG")"
+
+# gemeinsame Bibliothek geaendert: Neustart trotz gleicher Dienstversion
+manifest v0.4.0 v0.4.6 > "$bundle/manifest.json"
+rm -rf "$tmp/state/steps"; : > "$SYSTEMCTL_LOG"
+UNIT_ACTIVE=1 run >/dev/null
+[ "$(restarts)" = 1 ] || fail "Bibliotheksaenderung fuehrte nicht zum Neustart" "$(cat "$SYSTEMCTL_LOG")"
+
+# EN_RESTART=all erzwingt den Neustart
+manifest v0.4.0 v0.4.5 > "$bundle/manifest.json"
+rm -rf "$tmp/state/steps"; : > "$SYSTEMCTL_LOG"
+EN_RESTART=all UNIT_ACTIVE=1 run >/dev/null
+[ "$(restarts)" = 1 ] || fail "EN_RESTART=all startete nicht neu" "$(cat "$SYSTEMCTL_LOG")"
+
+# ohne installiertes Manifest (Erstinstallation): Start
+rm -f "$tmp/state/installed-manifest.json"
+rm -rf "$tmp/state/steps"; : > "$SYSTEMCTL_LOG"
+UNIT_ACTIVE=1 run >/dev/null
+[ "$(restarts)" = 1 ] || fail "Erstinstallation startete nicht" "$(cat "$SYSTEMCTL_LOG")"
+
echo "OK: $(basename "$0")"
diff --git a/scripts/tests/test_build_wheels.sh b/scripts/tests/test_build_wheels.sh
index 354641d..eb89fc0 100755
--- a/scripts/tests/test_build_wheels.sh
+++ b/scripts/tests/test_build_wheels.sh
@@ -99,4 +99,38 @@ set -e
[ "$rc" -ne 0 ] || fail "pip-Fehler nicht weitergereicht"
grep -qi 'kein Wheel' <<<"$out" || fail "Meldung nennt das Problem nicht" "$out"
+# --- build_local_wheels auf einem frischen Checkout ohne dist/ -----------
+# find auf einem fehlenden Verzeichnis schlaegt fehl; unter set -e/pipefail
+# darf das cached=$(find ...) nicht das ganze Skript stumm abbrechen (es tat
+# das vor dem Fix, weil 2>/dev/null die einzige Fehlermeldung verschluckte).
+repo="$tmp/repo"
+mkdir -p "$repo/libs/energy_node_common" "$repo/libs/battery_soc_core"
+(cd "$repo" && git init -q)
+printf 'v1.2.3\n' > "$repo/libs/energy_node_common/VERSION"
+printf 'v0.1.0\n' > "$repo/libs/battery_soc_core/VERSION"
+cat > "$tmp/bin/fakepip" <<'SH'
+#!/usr/bin/env bash
+printf 'pip %s\n' "$*" >> "$PIP_LOG"
+if [ "$1" = wheel ]; then
+ src="$2" dir=""
+ shift
+ while [ $# -gt 0 ]; do
+ case "$1" in --wheel-dir) dir="$2"; shift 2 ;; *) shift ;; esac
+ done
+ name="$(basename "$src")"
+ version="$(tr -d '[:space:]' < "$src/VERSION")"; version="${version#v}"
+ : > "$dir/${name}-${version}-py3-none-any.whl"
+fi
+exit "${PIP_RC:-0}"
+SH
+chmod +x "$tmp/bin/fakepip"
+: > "$PIP_LOG"
+# make_bundle.sh selbst laeuft mit set -euo pipefail - das muss hier auch
+# gelten, sonst prueft der Test nicht denselben Fehlerpfad (ein einfacher
+# "source; call" ohne -e haette den Bug nicht gezeigt).
+out="$(cd "$repo" && bash -c 'set -euo pipefail; source "$1"; shift; "$@"' _ "$lib" build_local_wheels "$tmp/localwheels" 2>&1)" \
+ || fail "build_local_wheels brach auf einem Checkout ohne dist/ stumm ab" "$out"
+[ -d "$repo/libs/energy_node_common/dist" ] || fail "dist/ wurde nicht angelegt"
+grep -q 'Baue energy_node_common 1.2.3' <<<"$out" || fail "Bauhinweis fehlt" "$out"
+
echo "OK: $(basename "$0")"
diff --git a/scripts/tests/test_restart_rule.py b/scripts/tests/test_restart_rule.py
new file mode 100644
index 0000000..e4e78f1
--- /dev/null
+++ b/scripts/tests/test_restart_rule.py
@@ -0,0 +1,56 @@
+"""Table test for scripts/bootstrap/lib/restart_rule.py and a drift guard for
+its library map against what the services really import."""
+import json
+import pathlib
+import re
+import subprocess
+import sys
+
+REPO = pathlib.Path(__file__).resolve().parents[2]
+LIB = REPO / "scripts" / "bootstrap" / "lib"
+CASES = json.loads((REPO / "scripts" / "bootstrap" / "testdata" / "restart_cases.json").read_text(encoding="utf-8"))
+
+sys.path.insert(0, str(LIB))
+import restart_rule # noqa: E402
+
+
+def test_every_case_in_the_table():
+ for case in CASES:
+ got = restart_rule.restart_reason(case["candidate"], case["installed"], case["step_id"], case["restart_all"])
+ assert got == case["want"], case["name"]
+
+
+def test_cli_reads_manifests_and_env(tmp_path):
+ bundle, state = tmp_path / "bundle", tmp_path / "state"
+ bundle.mkdir()
+ state.mkdir()
+ (bundle / "manifest.json").write_text(json.dumps(
+ {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.3"}], "components": {}}))
+ (state / "installed-manifest.json").write_text(json.dumps(
+ {"steps": [{"id": "83", "dir": "shelly", "version": "v0.4.2"}], "components": {}}))
+
+ def run(env=None):
+ out = subprocess.run([sys.executable, str(LIB / "restart_rule.py"), str(bundle), str(state), "83"],
+ capture_output=True, text=True, check=True, env=env)
+ return out.stdout.strip()
+
+ assert run({"PATH": "/usr/bin"}) == "version"
+ assert run({"PATH": "/usr/bin", "EN_RESTART": "all"}) == "all"
+ (state / "installed-manifest.json").unlink()
+ assert run({"PATH": "/usr/bin"}) == "first"
+ (bundle / "manifest.json").write_text("not json")
+ assert run({"PATH": "/usr/bin"}) == "unknown"
+
+
+def test_library_map_matches_the_services_imports():
+ """battery_soc_core is imported by battery_soc only; every service imports
+ energy_node_common. A new importer must be added to LIBRARY_USERS."""
+ importers = {"battery_soc_core": set(), "energy_node_common": set()}
+ for path in (REPO / "services").glob("*/*.py"):
+ text = path.read_text(encoding="utf-8")
+ for lib in importers:
+ if re.search(r"^\s*(from|import)\s+%s\b" % lib, text, re.M):
+ importers[lib].add(path.parent.name)
+ assert importers["battery_soc_core"] == restart_rule.LIBRARY_USERS["battery_soc_core"]
+ assert restart_rule.LIBRARY_USERS["energy_node_common"] is None, "every service restarts for it"
+ assert importers["energy_node_common"], "no service imports energy_node_common any more?"
diff --git a/scripts/tests/test_updater.sh b/scripts/tests/test_updater.sh
index d5edd7a..f8b513f 100755
--- a/scripts/tests/test_updater.sh
+++ b/scripts/tests/test_updater.sh
@@ -52,6 +52,7 @@ if [ -z "$user" ] || [ -z "$pwfile" ] || [ ! -f "$pwfile" ]; then
echo "##STEP 20 fail MOSQUITTO_ARGS_MISSING"; exit 1
fi
echo "Broker eingerichtet, Benutzer $user."
+echo "EN_RESTART=${EN_RESTART:-unset}"
echo "##STEP 20 ok"
SH
cat > "$fixture/bootstrap/50-python-deps.sh" <<'SH'
@@ -275,4 +276,15 @@ printf '%s\n' '{"bundle_version":"1.5.0","mode":"redeploy","steps":["60"]}' > "$
if run_updater "$job_f"; then fail "invalid pinned target accepted"; fi
grep -q '"code":"TARGET_INVALID"' "$job_f/status.json" || fail "expected TARGET_INVALID: $(cat "$job_f/status.json")"
+# --- restart_all im Auftrag setzt EN_RESTART=all fuer die Schritte ---------
+job8="$tmp/job8"
+stage_job "$job8" '{"bundle_version":"1.5.0","mode":"redeploy","restart_all":true,"steps":["20"]}'
+run_updater "$job8"
+grep -q 'EN_RESTART=all' "$job8/log" || fail "restart_all kam nicht bei den Schritten an" "$(cat "$job8/log")"
+
+job9="$tmp/job9"
+stage_job "$job9" '{"bundle_version":"1.5.0","mode":"redeploy","steps":["20"]}'
+run_updater "$job9"
+grep -q 'EN_RESTART=unset' "$job9/log" || fail "EN_RESTART ohne restart_all gesetzt" "$(cat "$job9/log")"
+
echo "OK"
diff --git a/services/tuya_mqtt/CHANGELOG.md b/services/tuya_mqtt/CHANGELOG.md
index 91004d3..1204c53 100644
--- a/services/tuya_mqtt/CHANGELOG.md
+++ b/services/tuya_mqtt/CHANGELOG.md
@@ -8,7 +8,7 @@
### Fixes
-- **tuya:** retry once on a stale persistent socket before reporting offline (41e9f55)
+- **tuya:** retry once on a stale persistent socket before reporting offline (#47) (1dfc8bd)
## v0.3.2 (2026-09-15)