start-observer.sh

#!/usr/bin/env bash
set -euo pipefail

# ==========================================
# 🧩 CONFIGURATION
# ==========================================
LEO_CDP_FOLDER="/build/cdp-instance"
BUILD_VERSION="v_0.9.0"

# Multiple router keys (space- or comma-separated)
HTTP_ROUTER_KEYS="datahub1 datahub2 datahub3"

JAR_MAIN="leo-observer-starter-${BUILD_VERSION}.jar"
JVM_PARAMS="-Xms256m -Xmx1500m -XX:+TieredCompilation -XX:+UseCompressedOops -XX:+DisableExplicitGC -XX:+UseNUMA -server"

LOG_DIR="${LEO_CDP_FOLDER}/logs"
MAX_LOG_DAYS=7  # keep compressed logs for 7 days

# ==========================================
# ⚙️ ENVIRONMENT PREP
# ==========================================
mkdir -p "$LOG_DIR"
cd "$LEO_CDP_FOLDER" || { echo "❌ Folder not found: $LEO_CDP_FOLDER"; exit 1; }

timestamp() {
  date '+%Y-%m-%d %H:%M:%S'
}

# ==========================================
# 🚀 MAIN LOOP — start 1 process per router key
# ==========================================
IFS=', ' read -r -a ROUTER_ARRAY <<< "$HTTP_ROUTER_KEYS"

for HTTP_ROUTER_KEY in "${ROUTER_ARRAY[@]}"; do
  LOG_FILE="${LOG_DIR}/observer-${HTTP_ROUTER_KEY}.log"

  echo "[$(timestamp)] === Restarting observer [$HTTP_ROUTER_KEY] ===" | tee -a "$LOG_FILE"

  # === LOG ROTATION ===
  if [ -f "$LOG_FILE" ]; then
    MOD_DATE=$(date -r "$LOG_FILE" +%Y-%m-%d)
    TODAY=$(date +%Y-%m-%d)
    if [ "$MOD_DATE" != "$TODAY" ]; then
      ARCHIVE="${LOG_FILE}.${MOD_DATE}.gz"
      echo "[$(timestamp)] Rotating old log → $ARCHIVE" | tee -a "$LOG_FILE"
      gzip -c "$LOG_FILE" > "$ARCHIVE"
      : > "$LOG_FILE"
    fi
  fi

  # Delete gzipped logs older than N days
  find "$LOG_DIR" -type f -name "observer-${HTTP_ROUTER_KEY}.log.*.gz" -mtime +${MAX_LOG_DAYS} -delete

  # === STOP EXISTING PROCESS ===
  PID=$(pgrep -f "java.*${HTTP_ROUTER_KEY}" || true)
  if [ -n "$PID" ]; then
    echo "[$(timestamp)] Stopping existing observer PID $PID..." | tee -a "$LOG_FILE"
    kill -15 "$PID" || true
    sleep 4
  fi

  # === START NEW PROCESS ===
  echo "[$(timestamp)] Starting observer [$HTTP_ROUTER_KEY]..." | tee -a "$LOG_FILE"
  nohup java $JVM_PARAMS -jar "$JAR_MAIN" "$HTTP_ROUTER_KEY" >> "$LOG_FILE" 2>&1 &
  NEW_PID=$!

  echo "[$(timestamp)] ✅ Observer [$HTTP_ROUTER_KEY] started (PID: $NEW_PID)" | tee -a "$LOG_FILE"
  echo "[$(timestamp)] --------------------------------------------" | tee -a "$LOG_FILE"
done

echo "[$(timestamp)] === All CDP Data Observer processes launched successfully ==="