#!/bin/bash


# スクリプト名: process_data.sh

# --- 1. 堅牢性設定 ---


# -e: コマンドが失敗した場合、即座にスクリプトを終了する。


# -u: 未定義の変数を使用した場合、エラーとしてスクリプトを終了する。


# -o pipefail: パイプライン中の任意のコマンドが失敗した場合、パイプライン全体を失敗とみなす。

set -euo pipefail

# --- 2. グローバル変数 ---

readonly SCRIPT_NAME=$(basename "$0")
readonly LOG_DIR="/var/log/${SCRIPT_NAME%.*}" # 例: /var/log/process_data
readonly TMP_DIR_PREFIX="${SCRIPT_NAME%.*}_tmp." # 一時ディレクトリのプレフィックス
TMP_WORK_DIR="" # 後でmktempで設定

# --- 3. クリーンアップ処理 (trap) ---


# EXITシグナルで実行され、スクリプト終了時に一時ファイルを削除する。


# エラー時も正常終了時も実行されるため、リソースリークを防ぐ。

cleanup() {

    # -d: ディレクトリのみを削除。


    # -f: エラーを無視して強制削除。


    # -r: 再帰的に削除。

    if [[ -n "$TMP_WORK_DIR" && -d "$TMP_WORK_DIR" ]]; then
        echo "$(date '+%Y-%m-%d %H:%M:%S') [INFO] Cleaning up temporary directory: $TMP_WORK_DIR"
        rm -rf "$TMP_WORK_DIR"
    fi
}
trap cleanup EXIT # EXITシグナルでcleanup関数を実行

# --- 4. ロギング関数 ---

log_message() {
    local level="$1"
    local message="$2"
    echo "$(date '+%Y-%m-%d %H:%M:%S') [$level] $message" | tee -a "${LOG_DIR}/${SCRIPT_NAME%.*}.log" >&2
}

# --- 5. メイン処理 ---

main() {

    # ログディレクトリの作成 (冪等性)

    mkdir -p "$LOG_DIR" || { log_message "ERROR" "Failed to create log directory: $LOG_DIR"; exit 1; }
    log_message "INFO" "Script started."

    # 一時ディレクトリの作成 (mktemp)


    # -d: ディレクトリを作成。


    # -t: 環境変数TMPDIRを使用。

    TMP_WORK_DIR=$(mktemp -d -t "$TMP_DIR_PREFIX"XXXXXXXX) || { log_message "ERROR" "Failed to create temporary directory."; exit 1; }
    log_message "INFO" "Temporary working directory created: $TMP_WORK_DIR"

    # APIキーなどの機密情報を安全に読み込む (例: 環境変数や秘密管理サービスから)


    # export API_KEY="your_api_key_here" # 本番では直接スクリプトに書かない


    # API_KEY="${API_KEY:-}" # 環境変数がない場合のエラーハンドリング


    # if [[ -z "$API_KEY" ]]; then


    #    log_message "ERROR" "API_KEY is not set."


    #    exit 1


    # fi

    # --- 6. curlとjqを利用したAPIデータ取得と処理 ---

    local API_ENDPOINT="https://api.example.com/data"
    local OUTPUT_FILE="$TMP_WORK_DIR/api_response.json"

    log_message "INFO" "Fetching data from API: $API_ENDPOINT"

    # curl: TLS/再試行/バックオフを考慮


    # --fail-with-body: HTTPエラー時に0以外の終了コードを返す（エラーボディは表示）


    # --retry 5: 最大5回リトライ


    # --retry-delay 3: リトライ間隔は3秒


    # --retry-max-time 30: リトライ合計時間は最大30秒


    # --connect-timeout 5: 接続タイムアウト5秒


    # --max-time 10: 最大転送時間10秒


    # --cacert /etc/ssl/certs/ca-certificates.crt: システムのCA証明書を利用したTLS検証 (Linux標準)


    # --silent --show-error: エラー時のみエラーメッセージを表示

    if ! curl --fail-with-body \
              --retry 5 --retry-delay 3 --retry-max-time 30 \
              --connect-timeout 5 --max-time 10 \
              --cacert /etc/ssl/certs/ca-certificates.crt \
              --silent --show-error \
              -X GET "${API_ENDPOINT}" \
              -o "$OUTPUT_FILE"; then
        log_message "ERROR" "Failed to fetch data from API: $API_ENDPOINT"
        exit 1
    fi
    log_message "INFO" "API data fetched and saved to $OUTPUT_FILE"

    # jq: JSONパースとエラー処理


    # .data[] | select(.status == "active"): .data配列からstatusがactiveの要素を抽出


    # -e: フィルター結果が空の場合、終了コード1を返す


    # -r: 生の文字列を出力

    if ! jq -e '.data[] | select(.status == "active") | .id' "$OUTPUT_FILE" > "$TMP_WORK_DIR/processed_ids.txt"; then
        if [[ $(jq '.data | length' "$OUTPUT_FILE") -eq 0 ]]; then
            log_message "WARN" "No data found in API response. JSON file might be empty or malformed."
        else
            log_message "ERROR" "Failed to process JSON data with jq. JSON might be malformed or no active items found."
            exit 1
        fi
    fi
    log_message "INFO" "Processed IDs saved to $TMP_WORK_DIR/processed_ids.txt"

    # --- 7. 主要ロジックの実行 (べき等性を考慮) ---


    # ここに取得したデータを使った具体的な処理を記述


    # 例: データベース更新、別サービスへの通知など


    # べき等性: 処理が複数回実行されても、システムの最終状態が同じになるように設計する。


    # 例: データベースにupsert（挿入または更新）操作を用いる、トランザクションを利用する、


    # 処理済みのIDを記録し重複実行を避ける、など。

    log_message "INFO" "Simulating main processing logic with processed IDs."
    while IFS= read -r id; do
        log_message "INFO" "Processing ID: $id"

        # 実際に何か処理を行うコマンド


        # process_record "$id" # 例

    done < "$TMP_WORK_DIR/processed_ids.txt"

    log_message "INFO" "Script finished successfully."
}

# スクリプト実行

main "$@"

[Unit]
Description=Process external data periodically
Documentation=https://example.com/docs/process_data
Requires=network-online.target # ネットワーク接続が確立されるのを待つ
After=network-online.target

[Service]

# スクリプト実行ユーザーを限定し、rootでの実行を避ける

User=data-processor
Group=data-processor
WorkingDirectory=/opt/process_data # スクリプト実行時のカレントディレクトリ
ExecStart=/usr/local/bin/process_data.sh # スクリプトのフルパス
Type=exec
StandardOutput=journal # 標準出力をjournalctlに送信
StandardError=journal # 標準エラー出力をjournalctlに送信
Restart=on-failure # 失敗時にsystemdが自動的に再起動を試みる
RestartSec=300 # 5分後に再起動を試みる

# Environment="API_KEY=your_api_key" # 機密情報はSystemdのSecrets管理機能や別ファイルで管理推奨


# AmbientCapabilities=CAP_NET_RAW # 必要なパーミッションのみ付与


# PrivateTmp=true # サービス固有のプライベート一時ディレクトリを使用

[Unit]
Description=Run process_data.service daily at 3 AM
Requires=process_data.service # サービス本体に依存

[Timer]
OnCalendar=daily # 毎日実行
AccuracySec=1h   # 1時間程度のずれを許容 (システム負荷軽減)
Persistent=true  # タイマーが非アクティブな間に期限切れになった場合、次回起動時にすぐに実行

[Install]
WantedBy=timers.target # タイマーが起動時に有効になるように

# スクリプトを /usr/local/bin に配置

sudo cp process_data.sh /usr/local/bin/
sudo chmod +x /usr/local/bin/process_data.sh

# systemdユニットファイルを配置

sudo cp process_data.service /etc/systemd/system/
sudo cp process_data.timer /etc/systemd/system/

# systemd設定をリロード

sudo systemctl daemon-reload

# タイマーを有効化して起動

sudo systemctl enable process_data.timer
sudo systemctl start process_data.timer

# サービスが次回タイマー実行時に起動するよう有効化（直接起動はしない）

sudo systemctl enable process_data.service

# サービスのログを確認

journalctl -u process_data.service

# タイマーのログを確認

journalctl -u process_data.timer

# リアルタイムでログを追跡

journalctl -f -u process_data.service