#!/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.
precedent=0
[[ -r "${ETAT}" ]] && precedent=$(cat "${ETAT}" 2>/dev/null | tr -cd '0-9')
: "${precedent:=0}"
printf '%s' "${jetees}" > "${ETAT}" 2>/dev/null || true

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

if (( nouvelles > 0 )); then
  echo "PERTE EN COURS : ${nouvelles} ligne(s) de journal jetees depuis le dernier passage (${jetees} au total). | ${perf}"
  exit 2
fi
# UN COMPTEUR QUI RECULE veut dire qu'Alloy a redemarre — ses compteurs repartent de
# zero. Ce n'est pas une perte, c'est une remise a zero, et la dire pour ce qu'elle est
# evite de chercher une panne la ou il y a eu un redemarrage.
if (( nouvelles < 0 )); then
  echo "Alloy a redemarre (compteurs remis a zero) ; ${jetees} ligne(s) jetees depuis. | ${perf}"
  exit 1
fi
if (( jetees > 0 )); then
  echo "Journaux expedies ; ${jetees} ligne(s) perdues par le passe, plus rien depuis. | ${perf}"
  exit 1
fi
echo "Journaux expedies vers Loki, aucune ligne perdue. | ${perf}"
exit 0