sergio/takana

1#!/usr/bin/env bash
2# cosecha-cron.sh — el LATIDO de la granja: recoger + sembrar, en bucle, sin agente ni tokens.
3#
4# QUÉ HACE cada ciclo, por cada worker vivo en scripts/farm/.fleet:
5#   1. SIEMBRA (sube): rsync de código + recetas laptop→worker (el laptop es canónico; si autoré
6#      recetas nuevas —p.ej. openrc— el worker las empieza a moler sin que yo intervenga).
7#   2. RECOGE (baja): rsync del store sellado worker→laptop (CAS ⇒ merge seguro, sin conflicto).
8#   3. Regenera el GRAFO DE ESTADO (build-state.json + build-state-kde.json) desde el store ya
9#      cosechado, y commitea SÓLO esos ficheros firmes. El `git log` de docs/state/ ES el avance
10#      que el humano ve y sigue (huecos, fallos, qué se selló entre dos ciclos).
11#
12# LO QUE **NO** HACE (a propósito): NO promueve incoming-kde→recipes/ canónico (esa es decisión de
13# clasificación humana — "el hub clasifica", ver granja-promote-colisiones) ni firma el índice. Sólo
14# captura al store del laptop y deja el veredicto para la mañana. Idempotente y re-corrible.
15#
16# INFINITO: vive en el crontab hasta que lo saques (`crontab -e`, borrar la línea cosecha-cron).
17# Robusto a worker-ausente: si el dead-man ya mató al worker (cola seca ⇒ €0), el paso 1/2 falla
18# suave, se loguea y igual regenera+commitea el estado local. NO relanza workers (eso gasta €;
19# es decisión explícita con farm-up).
20#
21# Uso:    scripts/farm/cosecha-cron.sh                 # un ciclo (lo que dispara el cron)
22#         */30 * * * * cd /home/sergio/hammer && scripts/farm/cosecha-cron.sh >>work/cosecha-cron.log 2>&1
23# Env:    SSH_KEY (def ~/.ssh/github5), REMOTE (def /opt/hammer), NO_COMMIT=1 (regenera pero no commitea)
24set -uo pipefail
25
26ROOT="$(cd "$(dirname "$0")/../.." && pwd)"
27cd "$ROOT"
28
29# LOCK (2026-07-22): el latido ya no viene sólo del crontab — `latido.sh` lo lanza desde la sesión
30# porque el laptop arranca a veces con arje-zero y a veces con OpenRC, y cronie sólo existe en uno
31# de los dos. Con dos disparadores posibles, dos ciclos pueden solaparse: ambos hacen rsync sobre el
32# mismo store y, peor, `git commit`+`push` a la vez (index.lock, o un push que pisa al otro). El lock
33# va ACÁ y no en el llamador para que valga venga de donde venga: cron, latido o a mano.
34# -n = no esperar: si ya hay un ciclo corriendo, este sobra (el próximo tick recoge lo mismo).
35LOCKFILE="${LOCKFILE:-$ROOT/work/.cosecha-cron.lock}"
36mkdir -p "$(dirname "$LOCKFILE")"
37exec 9>"$LOCKFILE"
38if ! flock -n 9; then
39  echo "── $(date -u +%FT%TZ) cosecha-cron: ya hay un ciclo en curso ⇒ salgo (no me solapo)"
40  exit 0
41fi
42
43SSH_KEY="${SSH_KEY:-$HOME/.ssh/github5}"
44REMOTE="${REMOTE:-/opt/hammer}"
45FLEET="$ROOT/scripts/farm/.fleet"
46HAMMER="${HAMMER:-$ROOT/target/release/hammer}"
47# Workers efímeros reciclan IPs ⇒ no fijar known_hosts (hub-and-spoke, worker sin secretos).
48SSH="ssh -i $SSH_KEY -o UserKnownHostsFile=/dev/null -o StrictHostKeyChecking=no -o BatchMode=yes -o LogLevel=ERROR -o ConnectTimeout=15"
49
50ts() { date -u +%FT%TZ; }
51echo "── $(ts) cosecha-cron arranca"
52
53if [ ! -s "$FLEET" ]; then
54  echo "   flota vacía (scripts/farm/.fleet) — nada que cosechar este ciclo"
55else
56  while read -r name ip; do
57    [ -n "${name:-}" ] || continue
58    echo "==> $name ($ip)"
59    # 1. SIEMBRA: código + recetas laptop→worker (--delete: el laptop manda; nunca toca work/store/target).
60    if rsync -az --delete -e "$SSH" \
61        --exclude /work --exclude /store --exclude '/store-*' --exclude /target \
62        --exclude /dist --exclude /.dev-fs --exclude /.git --exclude /.scratch \
63        --exclude '*.png' --exclude '/content*' \
64        ./ "root@$ip:$REMOTE/" 2>&1 | tail -2; then
65      echo "   siembra ✓"
66    else
67      echo "   ⚠ siembra falló (worker ausente/idle-muerto?) — sigo con el siguiente"
68      continue
69    fi
70    # 2. RECOGE: store sellado worker→laptop (CAS, merge seguro).
71    if rsync -az -e "$SSH" "root@$ip:$REMOTE/store/" "$ROOT/store/" 2>&1 | tail -2; then
72      echo "   cosecha ✓"
73    else
74      echo "   ⚠ cosecha falló — sigo"
75    fi
76  done < "$FLEET"
77fi
78
79# 3. Regenerar el grafo de estado desde el store ya cosechado (usa el hammer del laptop, que tiene
80# el subcomando `hash`). Barato (~14s cada uno). El corpus canónico y el frente KDE, por separado.
81echo "==> regenerando grafo de estado"
82if [ -x "$HAMMER" ]; then
83  scripts/build-state.py >/dev/null 2>&1 && echo "   build-state.json ✓" || echo "   ⚠ build-state.py falló"
84  scripts/build-state.py --kde >/dev/null 2>&1 && echo "   build-state-kde.json ✓" || echo "   ⚠ build-state.py --kde falló"
85else
86  echo "   ⚠ sin binario hammer en $HAMMER — no regenero estado"
87fi
88
89# 4. Commitear SÓLO el estado firme (el avance que el humano sigue). Recetas nuevas que YO autoré se
90# commitean aparte, a mano, para no meter autoría a medias en un commit de cron.
91if [ "${NO_COMMIT:-}" != "1" ]; then
92  git add docs/state/build-state.json docs/state/build-state-kde.json 2>/dev/null || true
93  if ! git diff --cached --quiet 2>/dev/null; then
94    git commit -q -m "estado: cosecha granja $(ts) — avance del árbol KDE" 2>/dev/null \
95      && { git push -q origin main 2>/dev/null && echo "==> estado commiteado+pusheado" \
96           || echo "==> estado commiteado (push falló, reintenta próximo ciclo)"; }
97  else
98    echo "==> sin cambios de estado este ciclo"
99  fi
100fi
101echo "── $(ts) cosecha-cron fin"