#!/usr/bin/env bash


# my_data_processor.sh: 外部APIからデータを取得し処理するスクリプト

# -----------------------------------------------------------------------------


# スクリプトの安全な実行設定


# -----------------------------------------------------------------------------


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


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


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

set -euo pipefail

# -----------------------------------------------------------------------------


# 一時ディレクトリの管理


# -----------------------------------------------------------------------------


# 一時ディレクトリを作成し、スクリプト終了時に必ず削除する

TMP_DIR=$(mktemp -d -t my_app_processor_XXXXXX)

# mktemp -d の計算量: O(1) (ファイルシステム操作に依存)


# メモリ条件: 非常に小さい (ディレクトリパス文字列のみ)

trap 'echo "INFO: Cleaning up temporary directory: $TMP_DIR" && rm -rf "$TMP_DIR"' EXIT HUP INT TERM

echo "INFO: Temporary directory created: $TMP_DIR"

# -----------------------------------------------------------------------------


# 設定変数


# -----------------------------------------------------------------------------

API_URL="${API_ENDPOINT:-http://localhost:8080/data}"
OUTPUT_FILE="${TMP_DIR}/processed_data.json"

# CA_BUNDLE_PATH="/etc/ssl/certs/my_custom_ca.pem" # 必要に応じてカスタムCA証明書を指定

# -----------------------------------------------------------------------------


# curlによるAPI呼び出しとjqによるJSON処理


# -----------------------------------------------------------------------------

echo "INFO: Fetching data from API: $API_URL"

# curlの入出力:


#   入力: API_URL


#   出力: JSONデータ (標準出力)


# curlの前提:


#   - ネットワーク接続


#   - API_URLが有効であること


# curlの計算量: O(N) (Nは受信データサイズ、ネットワーク速度に依存)


# curlのメモリ条件: O(N) (Nは受信データサイズ、バッファリングに依存)

#


# オプション詳細:


# --silent: プログレスバーやエラーメッセージ以外を表示しない


# --show-error: エラー発生時にエラーメッセージを表示する


# --fail: HTTPステータスコードが200番台以外の場合、エラーとする


# --retry 5: 失敗時に最大5回リトライ


# --retry-delay 3: リトライ間の待ち時間を3秒に設定


# --max-time 30: 処理全体のタイムアウトを30秒に設定


# --connect-timeout 5: 接続確立のタイムアウトを5秒に設定


# --output -: 出力を標準出力に送る


# --cacert "$CA_BUNDLE_PATH": 必要に応じてCA証明書バンドルを指定し、TLS検証を強化

if ! curl \
    --silent \
    --show-error \
    --fail \
    --retry 5 \
    --retry-delay 3 \
    --max-time 30 \
    --connect-timeout 5 \
    "${API_URL}" \
    | jq --compact-output '.[] | select(.status == "active") | {id, name, value: (.data.value * 1.2)}' > "$OUTPUT_FILE"; then
    echo "ERROR: Failed to fetch or process data from API." >&2
    exit 1
fi

# jqの入出力:


#   入力: curlからのJSONデータ (標準入力)


#   出力: 変換されたJSONデータ (標準出力)


# jqの前提:


#   - 入力が有効なJSON形式であること


# jqの計算量: O(N) (Nは入力JSONのサイズ、フィルターの複雑さに依存)


# jqのメモリ条件: O(N) (Nは入力JSONのサイズ、特に大きな配列やオブジェクトの場合)

echo "INFO: Data successfully processed and saved to: $OUTPUT_FILE"

# -----------------------------------------------------------------------------


# 後処理（例: 処理結果を別のシステムに送信、データベースに保存など）


# -----------------------------------------------------------------------------


# ここにべき等性を考慮した処理を追加する。


# 例: ファイルが既に存在する場合はスキップ、またはタイムスタンプで最新かチェック。


# rsync -av "$OUTPUT_FILE" "/path/to/destination/"

echo "INFO: Script finished successfully."

# /etc/systemd/system/my_data_processor.service

[Unit]
Description=My Data Processor Service
Documentation=https://example.com/docs/my_data_processor
After=network-online.target # ネットワークが利用可能になった後に起動
Wants=network-online.target

[Service]
Type=exec

# ExecStartでbashスクリプトを実行


# スクリプトの絶対パスを指定すること

ExecStart=/usr/local/bin/my_data_processor.sh

# 実行ユーザーとグループを指定し、root権限での実行を避ける


# サービス専用のユーザー（例: myappuser）を作成し、そのユーザーで実行するのがベストプラクティス

User=myappuser
Group=myappuser

# 作業ディレクトリを指定

WorkingDirectory=/opt/my_app

# 環境変数を指定

Environment="API_ENDPOINT=https://api.example.com/v1/data"

# スクリプトが予期せず終了した場合、5秒待ってから再起動

Restart=on-failure
RestartSec=5s

# 一時ディレクトリを分離し、/tmpや/var/tmpへの書き込みを制限

PrivateTmp=true

# ファイルシステムを読み取り専用でマウントし、意図しない書き込みを防止

ProtectSystem=full
ProtectHome=true

# サービスが新しい権限を取得するのを防ぐ

NoNewPrivileges=true

# 利用できるシステムコールを最小限に制限（詳細な知識が必要）


# SystemCallFilter=...


# プロセスに割り当てるCPUやメモリのリソースを制限


# CPUShares=100


# MemoryLimit=256M

[Install]

# サービスをmulti-user.targetの一部として起動できるようにする

WantedBy=multi-user.target

# /etc/systemd/system/my_data_processor.timer

[Unit]
Description=Run My Data Processor every 30 minutes

# サービスユニットの後にタイマーユニットを起動


# UnitとTimerの連携を明確にするため

After=my_data_processor.service

[Timer]

# systemd起動後すぐに一度実行（必要であれば）


# OnBootSec=1min


# 30分ごとにサービスを起動

OnCalendar=*:0/30

# 持続的タイマー: systemdがダウンしている間に経過した時間を考慮して、起動時に実行

Persistent=true

# タイマーの精度を上げる（デフォルトは1分）

AccuracySec=1s

[Install]

# タイマーをmulti-user.targetの一部として起動できるようにする

WantedBy=timers.target