手を動かして学ぶ！MCPステップバイステップ実践ガイド for Beginners – Vol.6 データをサーバーへ！MCPモデル情報の登録(POST)＆更新(PUT) #Python

# client.py (Vol.6 版)
import requests
import json # JSONを整形して表示するためにインポート
from requests.exceptions import JSONDecodeError

BASE_SERVER_URL = "http://127.0.0.1:5000/devices" # サーバーの基本URL

# display_device_info関数はVol.5から変更なし (ここでは省略、前回のコードを流用してください)
def display_device_info(device_info):
    """デバイス情報を整形して表示するヘルパー関数"""
    print(f"  モデル名: {device_info.get('modelName', '情報なし')}")
    print(f"  デバイスID: {device_info.get('deviceId', '情報なし')}")
    print(f"  設置場所: {device_info.get('location', '情報なし')}")

    status_info = device_info.get('status', {})
    if status_info:
        print("  ステータス:")
        for key, value in status_info.items():
            if isinstance(value, bool):
                print(f"    {key.replace('is', '').capitalize() if 'is' in key else key.capitalize()}: {'オン' if value else 'オフ'}")
            else:
                print(f"    {key.capitalize()}: {value} {device_info.get('status', {}).get('unit', '') if key == 'currentTemperature' or key == 'targetTemperature' or key == 'brightness' else ''}")
    else:
        print("  ステータス: 情報なし")

    if "supportedModes" in device_info and device_info["supportedModes"]:
        print(f"  対応モード: {', '.join(device_info['supportedModes'])}")
    if "supportedEvents" in device_info and device_info["supportedEvents"]:
        print(f"  対応イベント: {', '.join(device_info['supportedEvents'])}")
    print("-" * 30)

# get_specific_device_info関数はVol.5から変更なし (ここでは省略、前回のコードを流用してください)
def get_specific_device_info(device_id):
    target_url = f"{BASE_SERVER_URL}/{device_id}"
    print(f"\n--- MCPデバイスID '{device_id}' の情報を取得します ---")
    print(f"アクセスするURL: {target_url}")

    try:
        response = requests.get(target_url, timeout=5)

        if response.status_code == 200:
            device_data = response.json()
            print("--- 取得成功 ---")
            display_device_info(device_data)
        elif response.status_code == 404:
            try:
                error_data = response.json()
                print("--- 取得失敗 (404 Not Found) ---")
                print(f"  エラーメッセージ: {error_data.get('error', 'サーバーからのエラー詳細なし')}")
                print(f"  リクエストしたID: {error_data.get('requested_id', device_id)}")
            except JSONDecodeError:
                print("--- 取得失敗 (404 Not Found) ---")
                print(f"  サーバーからのエラーメッセージはJSON形式ではありませんでした。応答: {response.text[:200]}...")
        else:
            print(f"--- エラー (ステータスコード: {response.status_code}) ---")
            try:
                error_details = response.json()
                print("  サーバーからの詳細:")
                print(json.dumps(error_details, indent=2, ensure_ascii=False))
            except JSONDecodeError:
                print(f"  サーバーからの応答はJSON形式ではありませんでした。内容: {response.text[:200]}...")

    except requests.exceptions.ConnectionError:
        print(f"エラー: サーバー ({target_url}) への接続に失敗しました。サーバーが起動しているか確認してください。")
    except requests.exceptions.Timeout:
        print(f"エラー: サーバー ({target_url}) への接続がタイムアウトしました。")
    except JSONDecodeError:
        print(f"エラー: サーバーからの応答 ({target_url}) が正しいJSON形式ではありません。")
        if 'response' in locals() and response is not None:
             print(f"  応答内容(先頭200文字): {response.text[:200]}...")
    except requests.exceptions.RequestException as e:
        print(f"エラー: リクエスト中に問題が発生しました ({target_url}): {e}")


# get_all_device_infos関数はVol.5から変更なし (ここでは省略、前回のコードを流用してください)
def get_all_device_infos():
    target_url = BASE_SERVER_URL # これは /devices エンドポイント
    print(f"\n--- 全てのMCPデバイス情報を取得します ---")
    print(f"アクセスするURL: {target_url}")
    try:
        response = requests.get(target_url, timeout=5)
        response.raise_for_status() # 200番台以外ならエラーを発生

        data = response.json()
        devices = data.get("devices", [])
        if devices:
            print(f"--- 取得成功 (全 {len(devices)} デバイス) ---")
            for device in devices:
                display_device_info(device)
        else:
            print("デバイス情報が見つかりませんでした。")

    except requests.exceptions.ConnectionError:
        print(f"エラー: サーバー ({target_url}) への接続に失敗しました。")
    except requests.exceptions.Timeout:
        print(f"エラー: サーバー ({target_url}) からの応答がタイムアウトしました。")
    except requests.exceptions.HTTPError as e:
        print(f"エラー: HTTPエラーが発生しました。ステータスコード: {e.response.status_code}")
        try:
            error_details = e.response.json()
            print(f"  サーバーからの詳細: {json.dumps(error_details, indent=2, ensure_ascii=False)}")
        except JSONDecodeError:
            print(f"  サーバーからの応答はJSON形式ではありませんでした。内容: {e.response.text[:200]}...")
    except JSONDecodeError:
        print(f"エラー: サーバーからの応答 ({target_url}) が正しいJSON形式ではありません。")
        if 'response' in locals() and response is not None:
             print(f"  応答内容(先頭200文字): {response.text[:200]}...")
    except requests.exceptions.RequestException as e:
        print(f"エラー: リクエスト中に予期せぬ問題が発生しました ({target_url}): {e}")


def add_new_device(device_data):
    """新しいデバイス情報をサーバーに登録する (POST)"""
    target_url = BASE_SERVER_URL # POST先は /devices
    print(f"\n--- 新しいデバイスを登録します ---")
    print(f"送信先URL: {target_url}")
    print(f"送信データ:")
    print(json.dumps(device_data, indent=2, ensure_ascii=False))

    try:
        response = requests.post(target_url, json=device_data, timeout=5)

        if response.status_code == 201: # 201 Created
            print("--- 登録成功 (201 Created) ---")
            new_device = response.json()
            display_device_info(new_device)
        elif response.status_code == 409: # 409 Conflict (deviceId重複など)
            error_data = response.json()
            print("--- 登録失敗 (409 Conflict) ---")
            print(f"  エラーメッセージ: {error_data.get('error', 'サーバーからのエラー詳細なし')}")
            print(f"  競合したID: {error_data.get('deviceId', '情報なし')}")
        elif response.status_code == 400: # 400 Bad Request (データ不備など)
            error_data = response.json()
            print("--- 登録失敗 (400 Bad Request) ---")
            print(f"  エラーメッセージ: {error_data.get('error', 'サーバーからのエラー詳細なし')}")
        else:
            print(f"--- エラー (ステータスコード: {response.status_code}) ---")
            try:
                error_details = response.json()
                print("  サーバーからの詳細:")
                print(json.dumps(error_details, indent=2, ensure_ascii=False))
            except JSONDecodeError:
                print(f"  サーバーからの応答はJSON形式ではありませんでした。内容: {response.text[:200]}...")
    
    except requests.exceptions.ConnectionError:
        print(f"エラー: サーバー ({target_url}) への接続に失敗しました。")
    except requests.exceptions.Timeout:
        print(f"エラー: サーバー ({target_url}) への接続がタイムアウトしました。")
    except requests.exceptions.RequestException as e:
        print(f"エラー: リクエスト中に問題が発生しました ({target_url}): {e}")


def update_device_info(device_id, updated_data):
    """既存のデバイス情報を更新する (PUT)"""
    target_url = f"{BASE_SERVER_URL}/{device_id}" # PUT先は /devices/{device_id}
    print(f"\n--- デバイスID '{device_id}' の情報を更新します ---")
    print(f"送信先URL: {target_url}")
    print(f"送信データ:")
    print(json.dumps(updated_data, indent=2, ensure_ascii=False))

    try:
        response = requests.put(target_url, json=updated_data, timeout=5)

        if response.status_code == 200: # 200 OK
            print("--- 更新成功 (200 OK) ---")
            device_info = response.json()
            # warningが含まれているかチェック (app.pyのdeviceIdミスマッチ警告用)
            if "warning" in device_info:
                print(f"  サーバーからの警告: {device_info['warning']}")
                display_device_info(device_info.get("updated_device", {}))
            else:
                display_device_info(device_info)
        elif response.status_code == 404: # 404 Not Found
            error_data = response.json()
            print("--- 更新失敗 (404 Not Found) ---")
            print(f"  エラーメッセージ: {error_data.get('error', 'サーバーからのエラー詳細なし')}")
            print(f"  リクエストしたID: {error_data.get('requested_id', device_id)}")
        elif response.status_code == 400: # 400 Bad Request
            error_data = response.json()
            print("--- 更新失敗 (400 Bad Request) ---")
            print(f"  エラーメッセージ: {error_data.get('error', 'サーバーからのエラー詳細なし')}")
        else:
            print(f"--- エラー (ステータスコード: {response.status_code}) ---")
            try:
                error_details = response.json()
                print("  サーバーからの詳細:")
                print(json.dumps(error_details, indent=2, ensure_ascii=False))
            except JSONDecodeError:
                print(f"  サーバーからの応答はJSON形式ではありませんでした。内容: {response.text[:200]}...")

    except requests.exceptions.ConnectionError:
        print(f"エラー: サーバー ({target_url}) への接続に失敗しました。")
    except requests.exceptions.Timeout:
        print(f"エラー: サーバー ({target_url}) への接続がタイムアウトしました。")
    except requests.exceptions.RequestException as e:
        print(f"エラー: リクエスト中に問題が発生しました ({target_url}): {e}")


if __name__ == '__main__':
    print("MCPクライアント (Vol.6) を実行します。")

    # --- 1. まず現在の全デバイス情報を取得 ---
    get_all_device_infos()

    # --- 2. 新しいデバイスを登録してみる ---
    new_smart_speaker = {
        "modelName": "Smart Speaker S500",
        "deviceId": "SPEAKER-004-D", # 新しいユニークなID
        "location": "Kitchen",
        "status": {"volume": 50, "isPlaying": False, "isActive": True},
        "supportedModes": ["play", "pause", "volume_control"]
    }
    add_new_device(new_smart_speaker)

    # --- 3. 登録されたか確認するために、再度全デバイス情報を取得 ---
    get_all_device_infos()

    # --- 4. 既存のデバイス (LIGHT-002-B) の情報を更新してみる ---
    updated_light_info = {
        "modelName": "Smart Light L200 (Upgraded)", # モデル名を少し変更
        "deviceId": "LIGHT-002-B", # IDは同じ
        "location": "Bedroom (Study Corner)", # 場所を変更
        "status": {"brightness": 60, "color": "cool_white", "unit": "percent", "isActive": True}, # ステータスも変更
        "supportedModes": ["on", "off", "dim", "color_change"] # 対応モードも追加
    }
    update_device_info("LIGHT-002-B", updated_light_info)
    
    # --- 5. 更新されたか確認するために、該当デバイスの情報を個別に取得 ---
    get_specific_device_info("LIGHT-002-B")

    # --- 6. 存在しないデバイスIDで更新を試みる ---
    non_existent_device_update = {
        "modelName": "Phantom Device",
        "deviceId": "NON-EXISTENT-001",
        "location": "Nowhere",
        "status": {"isActive": False}
    }
    update_device_info("NON-EXISTENT-001", non_existent_device_update)

    # --- 7. 同じdeviceIdで再度POSTを試みる (エラーになるはず) ---
    add_new_device(new_smart_speaker) # SPEAKER-004-D は既に登録済みのはず