#!/bin/bash
# GENERE par Set-OPS (role client_journal). Ne pas editer a la main.
#
# SONDE « journaux » — les lignes SORTENT-ELLES vers Loki ?
#
# Contrat : docs/supervision-conception.md (API des greffons Nagios) — une ligne, 0/1/2.
# Mise en defaut PAR PARAMETRE : `client_journal_sonde_url` (port ferme).
set -uo pipefail

URL={{ client_journal_sonde_url }}
ETAT={{ client_journal_sonde_etat }}

corps=$(curl -s --max-time 10 "${URL}/metrics" 2>/dev/null)
if [[ -z "${corps}" ]]; then
  echo "Alloy ne repond pas sur ${URL} : impossible de savoir si les journaux partent."
  exit 2
fi

# CE QU'ALLOY A DU JETER. On somme tous les motifs : `ingester_error` (le collecteur
# refuse ou reste injoignable), `rate_limited`, `queue_is_full`… La distinction interesse
# le diagnostic, pas la question « des lignes sont-elles perdues ? ».
jetees=$(printf '%s\n' "${corps}" \
  | awk '/^loki_write_dropped_entries_total\{/ {s += $2} END {printf "%d", s+0}')
envoyees=$(printf '%s\n' "${corps}" \
  | awk '/^loki_write_sent_entries_total\{/ {s += $2} END {printf "%d", s+0}')

# LA MEMOIRE D'UN PASSAGE : sans elle, un compteur cumulatif ne dit pas QUAND.
#
# ET LE MOMENT DE LA LECTURE PRECEDENTE AVEC ELLE (2026-09-10). Sans horodatage, « depuis
# le dernier passage » est une fenetre de duree inconnue : la sonde a annonce une PERTE EN
# COURS sur deux machines alors que le delta reel etait nul — les lignes avaient ete
# perdues entre une lecture manuelle de la veille et la reparation intervenue depuis.
#
# Un ecart sans sa fenetre n'est pas une mesure, c'est un nombre. On garde donc les deux,
# et le message porte la duree.
precedent=0
precedent_a=0
if [[ -r "${ETAT}" ]]; then
  read -r precedent precedent_a < "${ETAT}" 2>/dev/null || true
fi
precedent=$(printf '%s' "${precedent:-0}" | tr -cd '0-9'); : "${precedent:=0}"
precedent_a=$(printf '%s' "${precedent_a:-0}" | tr -cd '0-9'); : "${precedent_a:=0}"
maintenant=$(date +%s)
printf '%s %s' "${jetees}" "${maintenant}" > "${ETAT}" 2>/dev/null || true

perf="envoyees=${envoyees} jetees=${jetees}"
nouvelles=$(( jetees - precedent ))
fenetre=$(( maintenant - precedent_a ))

# CE QUI ALERTE, C'EST LA CROISSANCE — PAS LA CICATRICE (2026-09-10).
#
# Le compteur d'Alloy est cumulatif : il ne redescend qu'au redemarrage du demon. Une
# machine qui a perdu onze mille lignes pendant que la frontiere etait fermee les portera
# donc pour toujours. Faire de ce total un AVERTISSEMENT, c'est condamner six machines sur
# sept a l'orange permanent — et une sonde toujours orange est une sonde qu'on cesse de
# lire, ce qui la rend pire qu'absente.
#
# La perte ANCIENNE n'est pas une cause d'action : elle est reparee, ou elle ne l'est pas,
# et c'est le delta qui le dit. Le total reste dans le texte et dans les metriques, la ou
# il sert au diagnostic sans crier.
if (( nouvelles > 0 )); then
  echo "PERTE EN COURS : ${nouvelles} ligne(s) jetees en ${fenetre} s (${jetees} au total). | ${perf}"
  exit 2
fi

# UN SILENCE COMPLET EST SUSPECT, LUI. Zero ligne expediee ET zero jetee ne veut pas dire
# « tout va bien » : ca veut dire qu'Alloy ne fait rien du tout — source mal ciblee,
# journal vide, composant non demarre. Ce cas-la merite d'etre vu.
if (( envoyees == 0 )); then
  echo "Alloy n'a expedie AUCUNE ligne : ni envoi, ni rejet — rien ne remonte. | ${perf}"
  exit 1
fi

# UN COMPTEUR QUI RECULE veut dire qu'Alloy a redemarre : ses compteurs repartent de zero.
# Ce n'est pas une perte, et le dire evite de chercher une panne la ou il y a eu un
# redemarrage.
if (( nouvelles < 0 )); then
  echo "Alloy a redemarre ; ${envoyees} ligne(s) expediees depuis, aucune perte nouvelle. | ${perf}"
  exit 0
fi

# UNE PREMIERE LECTURE N'A PAS DE FENETRE : rien a comparer. On rend l'etat, pas un verdict.
if (( precedent_a == 0 )); then
  echo "Premiere lecture : ${envoyees} ligne(s) expediees, ${jetees} jetees cumulees. | ${perf}"
  exit 0
fi

if (( jetees > 0 )); then
  echo "Journaux expedies ; aucune perte depuis ${fenetre} s (${jetees} jetees par le passe). | ${perf}"
  exit 0
fi
echo "Journaux expedies vers Loki, aucune ligne perdue. | ${perf}"
exit 0