@Blog

<?php

/**
 * Sakura AI Chat Completion APIと連携するためのクラス（さくらのAI Engine）
 */
class SakuraAiChatClient {
    private string $apiBase = "https://api.ai.sakura.ad.jp/v1/chat/completions";
    private string $token;
    private string $defaultModel = "gpt-oss-120b";

    /**
     * コンストラクタ
     *
     * @param string $token さくらのAI Engineの認証トークン
     */
    public function __construct(string $token) {
        $this->token = $token;
    }

    /**
     * チャットコンプリーションAPIを呼び出す
     *
     * @param string $query LLMに送るメッセージ（クエリ）
     * @param string|null $model 使用するモデル名（nullの場合はデフォルトモデルを使用）
     * @return string LLMからの応答メッセージの内容
     * @throws Exception APIリクエストまたはJSONデコードに失敗した場合
     */
    public function getCompletion(string $query, ?string $model = null): string {
        $model = $model ?? $this->defaultModel;

        $headers = [
            "Content-Type: application/json",
            "Authorization: Bearer " . $this->token,
        ];

        $messages = [
            ["role" => "user", "content" => $query]
        ];

        $data = [
            "model" => $model,
            "messages" => $messages
        ];

        // cURLを使用してPOSTリクエストを送信
        $ch = curl_init($this->apiBase);
        if ($ch === false) {
            throw new Exception("cURLの初期化に失敗しました。");
        }

        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // 実行結果を文字列で返す

        $response = curl_exec($ch);

        if ($response === false) {
            $error = curl_error($ch);
            curl_close($ch);
            throw new Exception("APIリクエストエラー: " . $error);
        }

        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($httpCode !== 200) {
            // エラー応答の場合
            throw new Exception("APIエラーが発生しました。HTTPステータスコード: " . $httpCode . " 応答: " . $response);
        }

        // JSON応答をデコード
        $responseData = json_decode($response, true);

        if (json_last_error() !== JSON_ERROR_NONE) {
            throw new Exception("JSONデコードエラー: " . json_last_error_msg() . " 応答: " . $response);
        }

        // 応答からメッセージの内容を抽出
        if (isset($responseData["choices"][0]["message"]["content"])) {
            return $responseData["choices"][0]["message"]["content"];
        } else {
            throw new Exception("API応答からメッセージの内容を取得できませんでした。応答: " . $response);
        }
    }
}