#!/bin/bash

# --- 1. スクリプトの安全性の担保 ---


# -e: コマンドが失敗したら即座に終了


# -u: 未定義変数を使用したらエラー


# -o pipefail: パイプライン中の任意のコマンドが失敗したら終了ステータスを失敗にする

set -euo pipefail

# --- 2. 設定と定数 ---

readonly SCRIPT_NAME=$(basename "$0")
readonly LOCK_DIR="/var/tmp/${SCRIPT_NAME}.lock"
readonly API_ENDPOINT="https://api.example.com/v1/data"
readonly MAX_RETRIES=5

# --- 3. トラップ処理とロック管理 ---

# 処理が中断（SIGINT, SIGTERM）または終了（EXIT）する際にロックを解除する

cleanup() {

    # rmdirコマンドが失敗しても無視 (2>/dev/null)

    rmdir "$LOCK_DIR" 2>/dev/null
    local exit_code=$?
    if [[ $exit_code -ne 0 ]]; then
        echo "[INFO] ロックファイル ($LOCK_DIR) が見つかりませんでした。" >&2
    fi
}

# 異常終了時のトラップを設定。正常終了時は EXIT トラップで処理。

trap 'cleanup; echo "[ERROR] 異常終了またはシグナル受信により処理を中断しました。" >&2' SIGINT SIGTERM

# 多重起動チェック：ディレクトリ作成によるアトミックなロック

if ! mkdir "$LOCK_DIR" 2>/dev/null; then
    echo "[WARN] スクリプト ($SCRIPT_NAME) は既に実行中です。処理をスキップします (冪等な終了)。"
    exit 0
fi

# 正常終了時も必ずロックを解除するためのトラップ

trap 'cleanup; exit 0' EXIT


# --- 4. 堅牢なAPIリトライ処理関数 ---

# $1: JSONデータ

api_request_with_retry() {
    local json_data="$1"
    local attempt=1
    local http_status=0
    local response=""

    echo "[INFO] APIリクエストを開始します。"

    while [ $attempt -le $MAX_RETRIES ]; do
        echo "[INFO] 試行: $attempt / $MAX_RETRIES"

        # curl の実行


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


        # -S: エラー時に表示を強制


        # -L: リダイレクトを追跡


        # -w "%{http_code}": HTTPステータスコードを最後に表示


        # -o /dev/stderr: 通常の出力を標準エラー出力にリダイレクト


        # --max-time 30: 接続/処理の最大時間を30秒に設定


        # -H ... : Content-Typeヘッダ

        response=$(
            curl -sSL \
                --max-time 30 \
                -X POST "$API_ENDPOINT" \
                -H 'Content-Type: application/json' \
                -d "$json_data" \
                -w "%{http_code}" -o /dev/stderr
        )

        # HTTPステータスコードの分離

        http_status="${response: -3}"

        if [[ "$http_status" =~ ^2[0-9]{2}$ ]]; then
            echo "[SUCCESS] データが正常に送信されました (Status: $http_status)"

            # 応答JSONから必要なIDをjqで抽出 (例として、レスポンスボディが標準エラー出力にあるためここでは仮のダミー処理)

            local processed_id="DUMMY_ID_$(date +%s)"

            # 実際には、response bodyを別途ファイルに保存するか、


            # curlの-oを一時ファイルにして、そこからjqで読み込む。


            # 例：processed_id=$(cat /tmp/api_response.json | jq -r '.result.id')

            echo "[INFO] 処理ID: $processed_id"
            return 0 # 成功
        elif [[ "$http_status" =~ ^(4|5)[0-9]{2}$ ]]; then

            # 5xx (サーバーエラー) や 429 (レート制限) の場合にリトライ

            if [ $attempt -lt $MAX_RETRIES ]; then

                # 指数バックオフの計算 (例: 2^1=2s, 2^2=4s, 2^3=8s...)

                local delay=$(( 2 ** $attempt ))
                echo "[WARN] サーバーエラー (Status: $http_status)。$delay秒待機してリトライします。" >&2
                sleep "$delay"
            else
                echo "[CRITICAL] リトライ制限に達しました。処理を停止します (最終Status: $http_status)。" >&2
                return 1 # 失敗
            fi
        else
            echo "[CRITICAL] 予期せぬHTTPステータス: $http_status。処理を停止します。" >&2
            return 1 # 失敗
        fi

        attempt=$((attempt + 1))
    done
}


# --- 5. メイン処理の実行 ---

# 送信するダミーデータ (jqで生成または外部ファイルから読み込み)

INPUT_JSON=$(jq -n \
    --arg time "$(date -Iseconds)" \
    '{ "data_type": "event_log", "timestamp": $time, "payload": { "key": "value" } }'
)

# APIリクエストを実行

if api_request_with_retry "$INPUT_JSON"; then
    echo "[COMPLETE] すべての処理が成功しました。"
else

    # api_request_with_retry が 1 を返した場合、このスクリプトも非ゼロを返す

    exit 1
fi

[Unit]
Description=Robust API Synchronization Service
Requires=network-online.target
After=network-online.target

[Service]
Type=oneshot
User=batch_user
WorkingDirectory=/opt/scripts/
ExecStart=/bin/bash /opt/scripts/robust_api_sync.sh

# 失敗した場合、次のタイマーまで再試行しない (冪等性の維持のため)

Restart=on-failure 
StandardOutput=journal
StandardError=journal

[Install]
WantedBy=multi-user.target

# サービス名が api-sync.service の場合

journalctl -u api-sync.service --since "1 hour ago" -r

# リトライ処理中の WARN や CRITICAL エラーを確認


# CRITICALエラーで非ゼロ終了コード (exit 1) が確認できればOK