{"schema_version": "1.0", "article_type": "technical_guide", "target_audience": "SRE/DevOps Engineers", "tool_stack": ["jq", "bash", "curl"], "security_level": "High", "portability": "High"}

#!/usr/bin/env bash

# 堅牢なシェルスクリプトのための標準設定

set -euo pipefail  # 未定義変数、エラー、パイプライン失敗時に即座に終了
IFS=$'\n\t'        # スペース区切りの問題を回避

# --- 設定 ---

API_USER_ENDPOINT="https://api.example.com/users"
API_PERM_ENDPOINT="https://api.example.com/permissions"

# 認証トークンやAPIキー（環境変数から取得）

AUTH_TOKEN="${JSON_JOIN_API_KEY:?Error: JSON_JOIN_API_KEY environment variable not set}"

# 一時ファイルの設定

TMP_DIR=$(mktemp -d -t json-join-XXXXXX)
USER_JSON="${TMP_DIR}/users.json"
PERM_JSON="${TMP_DIR}/permissions.json"

# --- トラップ関数：エラー時および終了時のクリーンアップ ---

function cleanup {

    # 一時ディレクトリが存在し、かつ安全なパスであることを確認して削除

    if [[ -d "${TMP_DIR}" ]]; then
        rm -rf "${TMP_DIR}"
        echo "Cleaned up temporary directory: ${TMP_DIR}" >&2
    fi
}

# 終了時、中断時、エラー時にcleanupを実行

trap cleanup EXIT INT TERM

# --- データ取得関数 ---


# curlの堅牢化：リトライ、エラーチェック、進捗非表示

fetch_data() {
    local url=$1
    local output_file=$2
    local data_type=$3

    echo "Fetching ${data_type} data from ${url}..." >&2

    # -s: サイレント, -S: エラー時のみ表示, -L: リダイレクト追従, --fail: 4xx/5xxで非ゼロ終了


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

    if ! curl -sS -L --fail --retry 3 -H "Authorization: Bearer ${AUTH_TOKEN}" "${url}" -o "${output_file}"; then
        echo "ERROR: Failed to fetch ${data_type} data from ${url}" >&2
        exit 1
    fi

    # 取得したデータが有効なJSONであるかを jq で検証

    if ! jq empty < "${output_file}"; then
        echo "ERROR: Fetched file is not valid JSON: ${output_file}" >&2
        exit 1
    fi
    echo "${data_type} data fetched successfully." >&2
}

# --- メイン処理 ---

fetch_data "${API_USER_ENDPOINT}" "${USER_JSON}" "User"
fetch_data "${API_PERM_ENDPOINT}" "${PERM_JSON}" "Permission"

# jqによるJSON結合処理


# Goal: [


#   {


#     "id": 101,


#     "name": "Alice",


#     "permissions": ["read_s3", "write_ec2"]


#   },


#   ...


# ]

JQ_FILTER='

    # 1. Dataset B (Permissions)を読み込み、共通キー(user_id)をキーとしたルックアップマップ $perm_map を作成


    # 権限配列を user_id ごとにグループ化


    # reduce .[] as $item: 配列をイテレートし、初期オブジェクト {} に集約していく

    $perm_data | reduce .[] as $item ({}; 

        # $item.user_id をキーとして、既存の値に $item.permission を追加

        .[tostring($item.user_id)] += [$item.permission]
    ) as $perm_map
    |

    # 2. Dataset A (Users)を読み込み、マップを参照して結合

    .[] | 

    # .id を文字列に変換して $perm_map を参照（結合キーの型を合わせる）


    # // []: 該当キーがない場合、空の配列をデフォルト値として使用

    . + {
        "permissions": ($perm_map[tostring(.id)] // [])
    }
'

echo "Starting JSON join and reconstruction..." >&2

# jqの引数に一時ファイルを読み込ませ、結合を実行


# --slurpfile: 変数名 $perm_data にファイル全体を配列として読み込む


# USER_JSONを標準入力で受け取り、結果を標準出力へ出力

jq -c \
    --slurpfile perm_data "${PERM_JSON}" \
    "${JQ_FILTER}" \
    "${USER_JSON}"

echo "Processing complete. Joined JSON outputted to stdout." >&2

# 環境変数を設定（テスト目的のためダミー値を設定）

export JSON_JOIN_API_KEY="dummy_token_12345"

# スクリプトを実行し、最初の数行を確認

./join_and_reconstruct.sh | head -n 3 | jq .

[
  {
    "id": 101,
    "name": "Alice",
    "permissions": ["read_s3", "write_ec2"]
  },
  {
    "id": 102,
    "name": "Bob",
    "permissions": []
  }
]

# curlが失敗する状況をシミュレート


# 環境変数が未設定の場合

unset JSON_JOIN_API_KEY
./join_and_reconstruct.sh

# 標準エラー出力に以下のメッセージが出力される


# Error: JSON_JOIN_API_KEY environment variable not set


# Cleaned up temporary directory: /tmp/json-join-XXXXXX