さくらのAI Engineをコーディング支援AIとして活用する（on PhpStorm/Intellij）

Status code: 400
Error body:
{"error":{"message":"1 validation error:\n  {'type': 'value_error', 'loc': ('body',), 'msg': 'Value error, `tools` must not be an empty array. Either provide at least one tool or omit the field entirely.', 'input': {'messages': [{'content': 'Current date...

<?php
/**
 * さくらのAI Engine 向けローカルプロキシ
 *
 * JetBrains AI Assistant が送信する `"tools": []`（空配列）を除去して
 * upstream の vLLM に中継する。SSE ストリーミングをそのまま透過する。
 *
 * 起動:
 *   PHP_CLI_SERVER_WORKERS=4 php -S 127.0.0.1:8080 sakura-proxy.php
 *
 * IDE 側の Base URL:
 *   http://127.0.0.1:8080/v1
 */

declare(strict_types=1);

const UPSTREAM = 'https://api.ai.sakura.ad.jp';

/** モデル名の "openai/" などのプレフィックスを除去するか */
const STRIP_MODEL_PREFIX = true;

/** 標準エラー出力にリクエストの概要を出すか（php -S のコンソールに出る） */
const DEBUG = true;

set_time_limit(0);
ini_set('output_buffering', '0');
ini_set('zlib.output_compression', '0');
ini_set('implicit_flush', '1');
ob_implicit_flush(true);
while (ob_get_level() > 0) {
    ob_end_flush();
}

/**
 * 標準エラー出力にログを書く。
 */
function proxy_log(string $message): void
{
    if (!DEBUG) {
        return;
    }
    $fp = fopen('php://stderr', 'w');
    if ($fp !== false) {
        fwrite($fp, $message);
        fclose($fp);
    }
}

/**
 * リクエストヘッダから Authorization を取り出す。
 */
function incomingAuthHeader(): ?string
{
    if (!empty($_SERVER['HTTP_AUTHORIZATION'])) {
        return $_SERVER['HTTP_AUTHORIZATION'];
    }
    if (!empty($_SERVER['REDIRECT_HTTP_AUTHORIZATION'])) {
        return $_SERVER['REDIRECT_HTTP_AUTHORIZATION'];
    }
    if (function_exists('getallheaders')) {
        foreach (getallheaders() as $name => $value) {
            if (strcasecmp($name, 'Authorization') === 0) {
                return $value;
            }
        }
    }
    return null;
}

/**
 * リクエストボディを補正する。
 *
 * - 空の tools 配列を削除（削除時は tool_choice / parallel_tool_calls も落とす）
 * - モデル名のベンダープレフィックスを除去
 */
function normalizeBody(array $body): array
{
    if (array_key_exists('tools', $body)) {
        $tools = $body['tools'];
        if ($tools === null || (is_array($tools) && count($tools) === 0)) {
            unset($body['tools'], $body['tool_choice'], $body['parallel_tool_calls']);
            proxy_log("[proxy] removed empty tools\n");
        }
    }

    if (STRIP_MODEL_PREFIX && isset($body['model']) && is_string($body['model'])) {
        $original = $body['model'];
        // "preview/" はさくら側の正規のプレフィックスなので保持する
        if (!str_starts_with($original, 'preview/') && str_contains($original, '/')) {
            $body['model'] = substr($original, strrpos($original, '/') + 1);
            proxy_log("[proxy] model: {$original} -> {$body['model']}\n");
        }
    }

    return $body;
}

$method = $_SERVER['REQUEST_METHOD'] ?? 'GET';
$uri    = $_SERVER['REQUEST_URI'] ?? '/';
$url    = UPSTREAM . $uri;

proxy_log("[proxy] {$method} {$uri}\n");

$auth = incomingAuthHeader();
if ($auth === null) {
    http_response_code(401);
    header('Content-Type: application/json');
    echo json_encode(['error' => ['message' => 'Authorization header is missing', 'type' => 'proxy_error']]);
    exit;
}

$headers = [
    'Authorization: ' . $auth,
    'Accept: ' . ($_SERVER['HTTP_ACCEPT'] ?? 'application/json'),
];

$payload = null;

if ($method === 'POST' || $method === 'PUT' || $method === 'PATCH') {
    $raw         = file_get_contents('php://input') ?: '';
    $contentType = $_SERVER['CONTENT_TYPE'] ?? 'application/json';

    if (stripos($contentType, 'application/json') !== false) {
        $decoded = json_decode($raw, true);
        if (is_array($decoded)) {
            $payload = json_encode(normalizeBody($decoded), JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
        } else {
            // JSON として解釈できない場合はそのまま流す
            $payload = $raw;
        }
        $headers[] = 'Content-Type: application/json';
    } else {
        // multipart（音声の文字起こしなど）はそのまま透過
        $payload   = $raw;
        $headers[] = 'Content-Type: ' . $contentType;
    }
}

$ch = curl_init($url);

$headersSent = false;

curl_setopt_array($ch, [
    CURLOPT_CUSTOMREQUEST  => $method,
    CURLOPT_HTTPHEADER     => $headers,
    CURLOPT_RETURNTRANSFER => false,
    CURLOPT_CONNECTTIMEOUT => 15,
    CURLOPT_TIMEOUT        => 0,     // ストリーミングのため無制限
    CURLOPT_BUFFERSIZE     => 512,
    CURLOPT_HEADERFUNCTION => function ($ch, string $line) use (&$headersSent): int {
        $len     = strlen($line);
        $trimmed = trim($line);

        if ($trimmed === '') {
            return $len;
        }

        // ステータス行
        if (preg_match('#^HTTP/[\d.]+\s+(\d{3})#', $trimmed, $m) === 1) {
            http_response_code((int) $m[1]);
            $headersSent = true;
            return $len;
        }

        // 中継するヘッダのみホワイトリストで転送
        [$name, $value] = array_pad(explode(':', $trimmed, 2), 2, '');
        $name  = trim($name);
        $value = trim($value);

        if (in_array(strtolower($name), ['content-type', 'cache-control', 'x-request-id'], true)) {
            header("{$name}: {$value}");
        }

        return $len;
    },
    CURLOPT_WRITEFUNCTION  => function ($ch, string $chunk): int {
        echo $chunk;
        flush();
        return strlen($chunk);
    },
]);

if ($payload !== null) {
    curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);
}

curl_exec($ch);

if (curl_errno($ch) !== 0) {
    $message = curl_error($ch);
    proxy_log("[proxy] curl error: {$message}\n");
    if (!$headersSent) {
        http_response_code(502);
        header('Content-Type: application/json');
        echo json_encode(['error' => ['message' => $message, 'type' => 'proxy_error']]);
    }
}

curl_close($ch);

$ PHP_CLI_SERVER_WORKERS=4
$ php -S 127.0.0.1:8080 sakura-proxy.php