#!/usr/bin/env bash

# --- 堅牢性設定 ---

set -euo pipefail # E: エラー発生時即時終了, U: 未定義変数禁止, O pipefail: パイプライン中のエラーを捕捉

# readonly: 定数として変数を保護

readonly API_ENDPOINT="https://api.internal.example.com/system/metrics"
readonly LOG_FILE="/var/log/hawk_metrics_processor.log"

# mktempで安全かつ予測不可能な一時ファイルを作成


# 一時ファイルは必ずローカルに定義する

readonly TMP_DATA=$(mktemp 2>/dev/null || mktemp -t 'hawk_json') 

# --- クリーンアップとエラーハンドリング ---

cleanup() {
    local exit_code=$?

    # 一時ファイルを安全に削除

    if [ -f "$TMP_DATA" ]; then
        rm -f "$TMP_DATA" || { echo "Warning: Failed to remove $TMP_DATA." 1>&2; }
    fi

    # ログ出力

    if [ $exit_code -ne 0 ]; then
        echo "$(date '+%Y-%m-%d %H:%M:%S') [FATAL] Script failed with exit code $exit_code." >> "$LOG_FILE"
    else
        echo "$(date '+%Y-%m-%d %H:%M:%S') [INFO] Processing finished successfully." >> "$LOG_FILE"
    fi

    # trapの解除（再実行防止）

    trap - EXIT
}

# 実行終了(EXIT)、中断(INT)、強制終了(TERM)時にcleanupを呼び出す

trap cleanup EXIT INT TERM

echo "$(date '+%Y-%m-%d %H:%M:%S') [INFO] Starting data ingestion." >> "$LOG_FILE"

# 1. データ取得と一時ファイル保存 (cURL)


# -s: サイレントモード


# -S: エラー時にメッセージを表示 (サイレントモードと併用し、エラー報告を確実にする)


# -f: HTTPステータスが4xxまたは5xxの場合、非ゼロ終了コードで終了


# -L: リダイレクトをフォロー

if ! curl -sS -f -L "$API_ENDPOINT" -o "$TMP_DATA"; then
    echo "ERROR: API data retrieval failed. Check connection or endpoint." 1>&2
    exit 1
fi

# 2. JSON処理とTSV変換 (jq)


# .data[] をイテレートし、statusが"SUCCESS"のレコードのみを選択。


# id, status, latency_ms（数値化）を配列として構築し、@tsvフィルターでタブ区切り文字列に変換。

echo "--- Metrics Processing Report ($(date '+%Y-%m-%d')) ---"

jq -r '.data[] | 
      select(.status == "SUCCESS") | 
      [.id, .status, (.latency_ms | tonumber)] | @tsv' "$TMP_DATA" | \

# 3. 集計とレポート整形 (awk)


# FS="\t": 入力フィールドセパレータをタブに設定

awk 'BEGIN { 
        FS="\t"; 
        count=0; 
        sum_latency=0; 
        print "ID\tLatency(ms)"; 
        print "-----------------------"
     }
     { 

        # $3が数値（Latency）

        count++; 
        sum_latency += $3; 
        print $1 "\t" $3 
     }
     END { 
        avg_latency = (count > 0 ? sum_latency / count : 0);
        print "-----------------------";
        print "Total Success Records:", count;
        printf "Average Latency: %.2f ms\n", avg_latency;
     }' | tee -a "$LOG_FILE"

# teeにより標準出力とログファイルの両方に出力される。

# スクリプトを実行

bash hawk_processor.sh

# 成功時の標準出力例（ログファイルにも同様に出力）

--- Metrics Processing Report (2024-05-18) ---
ID  Latency(ms)
-----------------------
1001    25.4
1005    18.9
-----------------------
Total Success Records: 2
Average Latency: 22.15 ms

# ログファイルを直接確認

tail -n 5 /var/log/hawk_metrics_processor.log

# (例: API接続失敗時)


# 2024-05-18 10:30:05 [FATAL] Script failed with exit code 1.