Surface ILM policy validation errors in highstate

Fail 4xx ILM PUTs immediately (retry 429/5xx/connect), print the
Elasticsearch reason in the salt summary, and retry the load on the
next highstate via /opt/so/state/esilm.txt when the last run failed.

Fixes https://github.com/Security-Onion-Solutions/sos/issues/277

.github/DISCUSSION_TEMPLATE/3-0.yml

@@ -14,6 +14,7 @@ body:
         - 3.2.0
         - 3.3.0
         - 3.4.0
+        - 3.5.0
         - Other (please provide detail below)
     validations:
       required: true

DOWNLOAD_AND_VERIFY_ISO.md

@@ -1,17 +1,17 @@
-### 3.3.0-20260911 ISO image released on 2026/09/11
+### 3.4.0-20261102 ISO image released on 2026/11/02
 
 
 ### Download and Verify
 
-3.3.0-20260911 ISO image:  
-https://download.securityonion.net/file/securityonion/securityonion-3.3.0-20260911.iso
+3.4.0-20261102 ISO image:  
+https://download.securityonion.net/file/securityonion/securityonion-3.4.0-20261102.iso
  
-MD5: 12B18433D3A2198A185892FF79CF638F  
-SHA1: 2B3C2E1FA7A78ED1F956E7EDCC12E32593C14EEE  
-SHA256: 0938C73B76CE30EC9E4394D312C79EA7CAC721B6818541697279A6221F7D870D  
+MD5: FB0380AE996E175D6CC7E7A35D8CC178  
+SHA1: D8960F1DA352710BCA209773BF0B3AE8791D0D1B  
+SHA256: DFC4C87668836852A328EC7A0B755C8C1511FF0E43D423DEE23047A95F676D99  
 
 Signature for ISO image:  
-https://github.com/Security-Onion-Solutions/securityonion/raw/3/main/sigs/securityonion-3.3.0-20260911.iso.sig
+https://github.com/Security-Onion-Solutions/securityonion/raw/3/main/sigs/securityonion-3.4.0-20261102.iso.sig
 
 Signing key:  
 https://raw.githubusercontent.com/Security-Onion-Solutions/securityonion/3/main/KEYS  
@@ -25,22 +25,22 @@ wget https://raw.githubusercontent.com/Security-Onion-Solutions/securityonion/3/
 
 Download the signature file for the ISO:  
 ```
-wget https://github.com/Security-Onion-Solutions/securityonion/raw/3/main/sigs/securityonion-3.3.0-20260911.iso.sig
+wget https://github.com/Security-Onion-Solutions/securityonion/raw/3/main/sigs/securityonion-3.4.0-20261102.iso.sig
 ```
 
 Download the ISO image:  
 ```
-wget https://download.securityonion.net/file/securityonion/securityonion-3.3.0-20260911.iso
+wget https://download.securityonion.net/file/securityonion/securityonion-3.4.0-20261102.iso
 ```
 
 Verify the downloaded ISO image using the signature file:  
 ```
-gpg --verify securityonion-3.3.0-20260911.iso.sig securityonion-3.3.0-20260911.iso
+gpg --verify securityonion-3.4.0-20261102.iso.sig securityonion-3.4.0-20261102.iso
 ```
 
 The output should show "Good signature" and the Primary key fingerprint should match what's shown below:
 ```
-gpg: Signature made Fri 11 Sep 2026 11:23:56 AM EDT using RSA key ID FE507013
+gpg: Signature made Sat 31 Oct 2026 09:27:50 AM EDT using RSA key ID FE507013
 gpg: Good signature from "Security Onion Solutions, LLC <info@securityonionsolutions.com>"
 gpg: WARNING: This key is not certified with a trusted signature!
 gpg:          There is no indication that the signature belongs to the owner.

VERSION

@@ -1 +1 @@
-3.4.0
+3.5.0

salt/elasticfleet/manager.sls

@@ -112,17 +112,6 @@ so-elastic-fleet-addon-integrations:
       - http: wait_for_so-kibana
       - cmd: so-elasticsearch-templates-after-fleet-packages
 
-so-elastic-fleet-transforms-manage:
-  cmd.run:
-    - name: /usr/sbin/so-elastic-fleet-transforms-manage
-    - require:
-      - http: wait_for_so-kibana
-      - file: elasticfleet_sbin
-      - cmd: so-elastic-fleet-package-upgrade
-      - cmd: so-elastic-fleet-integration-upgrade
-      - cmd: so-elastic-fleet-integrations
-      - cmd: so-elastic-fleet-addon-integrations
-
 {% if ELASTICFLEETMERGED.config.defend_filters.enable_auto_configuration %}
 so-elastic-defend-manage-filters-file-watch:
   cmd.run:

salt/elasticfleet/tools/sbin/so-elastic-fleet-transforms-manage

@@ -1,225 +0,0 @@
-#!/bin/bash
-#
-# Copyright Security Onion Solutions LLC and/or licensed to Security Onion Solutions LLC under one
-# or more contributor license agreements. Licensed under the Elastic License 2.0 as shown at
-# https://securityonion.net/license; you may not use this file except in compliance with the
-# Elastic License 2.0.
-#
-# 1. List transforms (source/dest come from the transform config).
-# 2. List enabled Fleet package policies.
-# 3. Unused packages: count only those source/dest indices, then stop and
-#    delete empty dests. --after-install skips the counts and stops unused.
-
-. /usr/sbin/so-common
-. /usr/sbin/so-elastic-fleet-common
-
-PIVOT_PREFIX='logs-elasticsearch.index_pivot-default-'
-STATE_FILE=/opt/so/state/esfleet_stopped_transforms.json
-DRY_RUN=false
-AFTER_INSTALL=false
-
-usage() {
-    echo "Usage: $0 [--dry-run] [--after-install]" >&2
-    exit 1
-}
-
-while [[ $# -gt 0 ]]; do
-    case "$1" in
-        --dry-run) DRY_RUN=true ;;
-        --after-install) AFTER_INSTALL=true ;;
-        -h|--help) usage ;;
-        *) usage ;;
-    esac
-    shift
-done
-
-es() {
-    so-elasticsearch-query "$@" --fail --retry 2 --retry-delay 3
-}
-
-skip() {
-    echo "Warning: $1; skipping transform cleanup." >&2
-    exit 0
-}
-
-run() {
-    local desc=$1
-    shift
-    if [[ "$DRY_RUN" == true ]]; then
-        echo "[dry-run] $desc"
-        return 0
-    fi
-    echo "$desc"
-    es "$@" >/dev/null
-}
-
-uri() {
-    jq -rn --arg id "$1" '$id|@uri'
-}
-
-in_use_packages() {
-    local page=1 collected=0 count total resp packages='[]'
-    while true; do
-        resp=$(fleet_api "package_policies?perPage=100&page=$page") || return 1
-        jq -e '(.items | type == "array") and (.total | type == "number")' <<<"$resp" >/dev/null || return 1
-        packages=$(jq -c --argjson acc "$packages" '
-            $acc + [.items[]
-              | select(.enabled == true)
-              | select(([.policy_ids[]?, .policy_id] | map(select(. != null and . != "")) | length) > 0)
-              | .package.name
-              | select(. != null and . != "")]' <<<"$resp")
-        count=$(jq '.items | length' <<<"$resp")
-        total=$(jq '.total' <<<"$resp")
-        collected=$((collected + count))
-        [[ "$count" -eq 0 || "$collected" -ge "$total" ]] && break
-        page=$((page + 1))
-        [[ "$page" -gt 100 ]] && return 1
-    done
-    [[ "$collected" -eq "$total" ]] || return 1
-    jq -c 'unique' <<<"$packages"
-}
-
-# Page into files: a full transform list exceeds ARG_MAX.
-page_es() {
-    local path=$1 outfile=$2 from=0 size=1000 count got page_len
-    echo '[]' > "$outfile"
-    while true; do
-        es "${path}?from=${from}&size=${size}" > "$WORKDIR/page.json" || return 1
-        jq -e '(.count | type == "number") and (.transforms | type == "array")' "$WORKDIR/page.json" >/dev/null || return 1
-        count=$(jq -r '.count' "$WORKDIR/page.json")
-        jq -c --slurpfile page "$WORKDIR/page.json" '. + ($page[0].transforms // [])' "$outfile" > "$WORKDIR/next.json" || return 1
-        mv "$WORKDIR/next.json" "$outfile"
-        got=$(jq 'length' "$outfile")
-        page_len=$(jq '.transforms | length' "$WORKDIR/page.json")
-        [[ "$page_len" -eq 0 || "$got" -ge "$count" ]] && break
-        from=$((from + size))
-        [[ "$from" -gt 100000 ]] && return 1
-    done
-    [[ "$got" -eq "$count" ]]
-}
-
-load_transforms() {
-    page_es "_transform" "$WORKDIR/tf-configs.json" || return 1
-    page_es "_transform/_stats" "$WORKDIR/tf-stats.json" || return 1
-    jq -c --slurpfile stats "$WORKDIR/tf-stats.json" --arg pivot "$PIVOT_PREFIX" '
-        ($stats[0] | map({key: .id, value: .state}) | from_entries) as $states
-        | [.[] | {
-            id,
-            package: (._meta.package.name // null),
-            state: ($states[.id] // "unknown"),
-            dest: (.dest.index // null),
-            create_time: (.create_time // null),
-            source: (.source.index | if type == "array" then . elif type == "string" then [.] else [] end),
-            pivot: (.id | startswith($pivot)),
-            latest: ((.latest != null) or ((.dest.index // "") | contains("_latest")))
-          }
-          | select(.pivot or .latest)
-        ]' "$WORKDIR/tf-configs.json" > "$WORKDIR/transforms.json"
-}
-
-doc_count() {
-    local pattern=$1 count
-    count=$(es "${pattern}/_count?ignore_unavailable=true" | jq -er '.count') || return 1
-    [[ "$count" =~ ^[0-9]+$ ]] || return 1
-    echo "$count"
-}
-
-status "Elastic Fleet transform cleanup (after_install=$AFTER_INSTALL dry_run=$DRY_RUN)"
-
-WORKDIR=$(mktemp -d)
-trap 'rm -rf "$WORKDIR"' EXIT
-
-load_transforms || skip "Elasticsearch transforms could not be retrieved in full"
-IN_USE=$(in_use_packages) || skip "Fleet package policies could not be retrieved in full"
-jq -e 'length > 0' <<<"$IN_USE" >/dev/null || skip "no enabled Fleet package policies are assigned to an agent policy"
-
-STATE=$(jq -c '{stopped: ((.stopped | objects) // {}), user_started: ((.user_started | arrays) // [])}' "$STATE_FILE" 2>/dev/null)
-jq -e '.stopped and .user_started' <<<"$STATE" >/dev/null 2>&1 || STATE='{"stopped":{},"user_started":[]}'
-
-# Same create_time but running again: operator started it after we stopped it.
-STATE=$(jq -c --slurpfile t "$WORKDIR/transforms.json" '
-    ($t[0] | map({key: .id, value: .}) | from_entries) as $cur
-    | (.stopped | to_entries | map(select($cur[.key] != null and $cur[.key].create_time == .value))) as $tracked
-    | {
-        stopped: ($tracked | map(select($cur[.key].state == "stopped")) | from_entries),
-        user_started: ((.user_started + [$tracked[] | select($cur[.key].state | IN("started", "indexing")) | .key])
-                       | unique | map(select($cur[.] != null and ($cur[.].state | IN("stopped", "failed") | not))))
-      }' <<<"$STATE")
-
-# Unused = latest/pivot with a package, not on a policy, not operator-started.
-# Pivot is always unused (see so-elastic-fleet-package-upgrade).
-jq -c --argjson inuse "$IN_USE" --argjson state "$STATE" '
-    def unused:
-      if .pivot then true
-      elif .package == null then false
-      elif (.id | IN($state.user_started[]?)) then false
-      elif (.package | IN($inuse[]?)) then false
-      else true
-      end;
-    {
-      unused: [.[] | select(unused)],
-      start: [.[] | select(.package != null and (.state | IN("stopped", "failed"))
-                           and ($state.stopped[.id] != null) and (.pivot | not)
-                           and (.package | IN($inuse[]?)))]
-    }' "$WORKDIR/transforms.json" > "$WORKDIR/split.json"
-
-jq -c '.unused' "$WORKDIR/split.json" > "$WORKDIR/unused.json"
-
-if [[ "$AFTER_INSTALL" == true ]]; then
-    jq -c '[.[] | select(.state | IN("started", "indexing", "failed"))]' "$WORKDIR/unused.json" > "$WORKDIR/stop.json"
-else
-    echo '{}' > "$WORKDIR/counts.json"
-    while IFS= read -r pattern; do
-        [[ -n "$pattern" ]] || continue
-        n=$(doc_count "$pattern") || skip "could not count documents in $pattern"
-        jq -c --arg p "$pattern" --argjson n "$n" '. + {($p): $n}' "$WORKDIR/counts.json" > "$WORKDIR/counts-next.json"
-        mv "$WORKDIR/counts-next.json" "$WORKDIR/counts.json"
-    done < <(jq -r '[.[].dest | select(. != null and . != "")] + [.[].source[]?] | unique | .[]' "$WORKDIR/unused.json")
-
-    jq -c --slurpfile c "$WORKDIR/counts.json" '
-        ($c[0] // {}) as $n
-        | [.[] | select(.state | IN("started", "indexing", "failed"))
-             | select((if .dest == null or .dest == "" then 0 else ($n[.dest] // 0) end) == 0)
-             | select(([.source[]? | $n[.] // 0] | add // 0) == 0)]' \
-        "$WORKDIR/unused.json" > "$WORKDIR/stop.json"
-fi
-
-echo "in_use=$(jq -r 'join(",")' <<<"$IN_USE") unused=$(jq 'length' "$WORKDIR/unused.json") stop=$(jq 'length' "$WORKDIR/stop.json") start=$(jq '.start | length' "$WORKDIR/split.json") dry_run=$DRY_RUN"
-
-while IFS= read -r id; do
-    [[ -n "$id" ]] || continue
-    force=
-    jq -e --arg id "$id" '.[] | select(.id == $id and .state == "failed")' "$WORKDIR/stop.json" >/dev/null && force='&force=true'
-    if run "stop transform $id" "_transform/$(uri "$id")/_stop?wait_for_completion=true&timeout=60s${force}" -XPOST; then
-        [[ "$DRY_RUN" == true ]] && continue
-        ct=$(jq -c --arg id "$id" '.[] | select(.id == $id) | .create_time' "$WORKDIR/stop.json")
-        STATE=$(jq -c --arg id "$id" --argjson ct "$ct" '.stopped[$id] = $ct | .user_started -= [$id]' <<<"$STATE")
-    fi
-done < <(jq -r '.[].id' "$WORKDIR/stop.json")
-
-while IFS= read -r id; do
-    [[ -n "$id" ]] || continue
-    if run "start transform $id" "_transform/$(uri "$id")/_start" -XPOST; then
-        [[ "$DRY_RUN" == false ]] && STATE=$(jq -c --arg id "$id" 'del(.stopped[$id])' <<<"$STATE")
-    fi
-done < <(jq -r '.start[].id' "$WORKDIR/split.json")
-
-if [[ "$DRY_RUN" == false ]]; then
-    mkdir -p "$(dirname "$STATE_FILE")"
-    tmp=$(mktemp "${STATE_FILE}.XXXXXX") && printf '%s\n' "$STATE" > "$tmp" && mv -f "$tmp" "$STATE_FILE"
-fi
-
-DELETED=0
-while IFS= read -r dest; do
-    [[ -n "$dest" ]] || continue
-    if [[ "$DRY_RUN" == true ]]; then
-        echo "[dry-run] delete empty transform destination $dest"
-        DELETED=$((DELETED + 1))
-        continue
-    fi
-    n=$(doc_count "$dest") || continue
-    [[ "$n" -eq 0 ]] || continue
-    run "delete empty transform destination $dest" "$(uri "$dest")" -XDELETE && DELETED=$((DELETED + 1))
-done < <(jq -r '.[].dest | select(. != null and . != "")' "$WORKDIR/stop.json" | sort -u)
-
-echo "stopped=$(jq -r '.stopped | length' <<<"$STATE") user_started=$(jq -r '.user_started | length' <<<"$STATE") dests_removed=$DELETED"

salt/elasticfleet/tools/sbin_jinja/so-elastic-fleet-optional-integrations-load

@@ -137,7 +137,6 @@ def needs($sub;$autoup;$excluded;$inuse):
             done
             # cleanup any temp files for chunked package install
             rm -f ${pkg_filename}_*.json $BULK_INSTALL_PACKAGE_LIST
-            /usr/sbin/so-elastic-fleet-transforms-manage --after-install || echo "Warning: transform cleanup after package install failed; highstate will retry."
         else
             echo "Elastic integrations don't appear to need installation/updating..."
         fi

salt/elasticsearch/cluster.sls

@@ -107,6 +107,12 @@ so-elasticsearch-system-indices-patch:
       - file: so-elasticsearch-system-indices-patch-script
 {%  endif %}
 
+so-elasticsearch-ilm-policy-reload:
+  file.absent:
+    - name: /opt/so/state/esilm.txt
+    - onchanges:
+      - file: so-elasticsearch-ilm-policy-load-script
+
 # heavynodes will only load ILM policies for SO managed indices. (Indicies defined in elasticsearch/defaults.yaml)
 so-elasticsearch-ilm-policy-load:
   cmd.run:
@@ -115,8 +121,9 @@ so-elasticsearch-ilm-policy-load:
     - require:
       - docker_container: so-elasticsearch
       - file: so-elasticsearch-ilm-policy-load-script
-    - onchanges:
-      - file: so-elasticsearch-ilm-policy-load-script
+      - http: wait_for_so-elasticsearch
+      - file: so-elasticsearch-ilm-policy-reload
+    - unless: test -f /opt/so/state/esilm.txt
 
 so-elasticsearch-templates-reload:
   file.absent:

salt/elasticsearch/tools/sbin_jinja/so-elasticsearch-ilm-policy-load

@@ -7,11 +7,17 @@
 . /usr/sbin/so-common
 
 MAX_JOBS=${MAX_ILM_JOBS:-10}
+ILM_STATEFILE=/opt/so/state/esilm.txt
+rm -f "$ILM_STATEFILE"
 
+check_elasticsearch_responsive
+
+ILM_TMP_DIR=$(mktemp -d)
+trap 'rm -rf "$ILM_TMP_DIR"' EXIT
 # Lock used to serialize block writes so concurrent jobs never interleave their output.
-ILM_OUTPUT_LOCK=$(mktemp)
-ILM_FAIL_FILE=$(mktemp)
-trap 'rm -f "$ILM_OUTPUT_LOCK" "$ILM_FAIL_FILE"' EXIT
+ILM_OUTPUT_LOCK="$ILM_TMP_DIR/output.lock"
+ILM_FAIL_FILE="$ILM_TMP_DIR/failed"
+touch "$ILM_FAIL_FILE"
 
 # Policies are loaded concurrently (up to MAX_JOBS at a time) for speed. Each policy's block is
 # printed the moment its curl returns, so output appears in COMPLETION ORDER, not the order
@@ -20,13 +26,30 @@ echo "Loading ILM policies concurrently; output below appears in completion orde
 echo
 
 put_policy() {
-  local desc="$1" policyname="$2" data="$3" result rc=0
-  if ! result=$(curl -K /opt/so/conf/elasticsearch/curl.config -s -k -L --fail \
-    -X PUT "https://localhost:9200/_ilm/policy/${policyname}" \
-    -H 'Content-Type: application/json' -d"${data}" 2>&1); then
-    rc=1
-  elif ! jq -e '.acknowledged == true' <<<"$result" >/dev/null 2>&1; then
-    rc=1
+  local desc="$1" policyname="$2" data="$3" rc=1 attempt out http_code body result reason tmpdata
+  tmpdata=$(mktemp "$ILM_TMP_DIR/${policyname}.XXXXXX.json")
+  printf '%s' "$data" >"$tmpdata"
+
+  for attempt in 1 2 3; do
+    out=$(so-elasticsearch-query "_ilm/policy/${policyname}" -d@"${tmpdata}" -XPUT -w '\n%{http_code}' 2>/dev/null)
+    http_code=${out##*$'\n'} body=${out%$'\n'*}
+
+    if [[ "$http_code" == 200 ]] && jq -e '.acknowledged == true' <<<"$body" >/dev/null 2>&1; then
+      rc=0
+      break
+    fi
+    # 429 = ES rejected/throttled (may succeed later); other 4xx will not
+    [[ "$http_code" == 4?? && "$http_code" != 429 ]] && break
+    (( attempt < 3 )) && sleep 3
+  done
+
+  if (( rc == 0 )); then
+    result='{"acknowledged":true}'
+  else
+    result=${body:-"HTTP ${http_code:-000}"}
+    # flatten tabs/newlines so the TAB fail-file stays one record
+    reason=$(jq -r '(if (.error|type) == "object" then (.error.reason // .error.type) elif (.error|type) == "string" then .error else empty end) // empty | tostring | gsub("[\t\r\n]+"; " ")' <<<"$body" 2>/dev/null)
+    reason="HTTP ${http_code:-000}${reason:+: ${reason}}"
   fi
 
   # curl above ran in parallel; serialize just this block write so concurrent jobs never interleave.
@@ -34,7 +57,7 @@ put_policy() {
     flock 200
     printf 'Setting up %s policy...\n%s\n\n' "${desc}" "${result}"
     if (( rc != 0 )); then
-      printf '%s\n' "${policyname}" >>"$ILM_FAIL_FILE"
+      printf '%s\t%s\n' "${policyname}" "${reason}" >>"$ILM_FAIL_FILE"
     fi
   } 200>>"${ILM_OUTPUT_LOCK}"
 
@@ -82,10 +105,15 @@ wait || true
 
 if [[ -s "$ILM_FAIL_FILE" ]]; then
   echo "ERROR: Failed to load ILM policy(s):"
-  while read -r POLICY; do
-    echo " - $POLICY"
+  while IFS=$'\t' read -r POLICY REASON; do
+    if [[ -n "$REASON" ]]; then
+      echo " - ${POLICY}: ${REASON}"
+    else
+      echo " - ${POLICY}"
+    fi
   done < "$ILM_FAIL_FILE"
   exit 1
 else
   echo "Successfully loaded all ILM policies."
+  touch "$ILM_STATEFILE"
 fi