set -uo pipefail

PM="/shared/projects/zion-pm"

OUT="$PM/state/outbox.json"

mapfile -t APPROVED < <(jq -r '.history[] | select(.decision=="approved" and (.executed|not)) | .id' "$OUT" 2>/dev/null)

[ "${#APPROVED[@]}" -eq 0 ] && { echo "[pm] nothing approved to flush"; exit 0; }

for OID in "${APPROVED[@]}"; do

  KIND=$(jq -r --arg id "$OID" '.history[] | select(.id==$id) | .kind' "$OUT")

  HAND="$PM/hands/execute-$KIND.sh"

  if [ -x "$HAND" ] || [ -f "$HAND" ]; then

    echo "[pm] executing $OID via $HAND"

    PM_APPROVED=1 bash "$HAND" "$OID" "$OUT" && STATUS="executed" || STATUS="failed"

  else

    echo "[pm] no hand for kind='$KIND' (item $OID). Wire hands/execute-$KIND.sh. Left for manual."

    STATUS="needs_hand"

  fi

  python3 - "$OUT" "$OID" "$STATUS" <<'PY'

import json,sys,time

path,oid,status=sys.argv[1:4]

o=json.load(open(path))

for h in o["history"]:

    if h["id"]==oid:

        h["executed"]=True; h["exec_status"]=status; h["executed_at"]=time.strftime("%Y-%m-%dT%H:%M:%S")

json.dump(o,open(path,"w"),indent=2)

PY

done