wenpai
e9d28817fe
74 文件 14,082 处自动修复：空格→Tab 缩进、括号间距、 函数声明空格、前置自增、尾逗号等纯格式化改动。 零逻辑变更，php -l + token 级对比验证通过。 新增 phpcs.xml.dist / phpstan.neon.dist 项目配置。 Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
402 lines
8 KiB
PHP
402 lines
8 KiB
PHP
<?php
|
||
/**
|
||
* Bridge Server 客户端
|
||
*
|
||
* 与 wpbridge-server Go 服务端通信
|
||
*
|
||
* @package WPBridge
|
||
* @since 0.9.8
|
||
*/
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace WPBridge\Commercial;
|
||
|
||
use WPBridge\Core\Logger;
|
||
use WPBridge\Security\Validator;
|
||
|
||
// 防止直接访问
|
||
if ( ! defined( 'ABSPATH' ) ) {
|
||
exit;
|
||
}
|
||
|
||
/**
|
||
* BridgeClient 类
|
||
*/
|
||
class BridgeClient {
|
||
|
||
/**
|
||
* 服务端 URL
|
||
*
|
||
* @var string
|
||
*/
|
||
private string $server_url;
|
||
|
||
/**
|
||
* API Key
|
||
*
|
||
* @var string
|
||
*/
|
||
private string $api_key;
|
||
|
||
/**
|
||
* 请求超时（秒）
|
||
*
|
||
* @var int
|
||
*/
|
||
private int $timeout;
|
||
|
||
/**
|
||
* 构造函数
|
||
*
|
||
* @param string $server_url 服务端 URL
|
||
* @param string $api_key API Key
|
||
* @param int $timeout 请求超时（秒）
|
||
*/
|
||
public function __construct( string $server_url, string $api_key, int $timeout = 30 ) {
|
||
$server_url = rtrim( $server_url, '/' );
|
||
|
||
// H3/H4: 强制 HTTPS
|
||
if ( strpos( $server_url, 'http://' ) === 0 ) {
|
||
$server_url = 'https://' . substr( $server_url, 7 );
|
||
}
|
||
|
||
// M8: SSRF 防护 — 禁止内网地址
|
||
if ( ! Validator::is_valid_url( $server_url ) ) {
|
||
Logger::error(
|
||
'BridgeClient: 无效的 server_url（可能为内网地址）',
|
||
[
|
||
'url' => $server_url,
|
||
]
|
||
);
|
||
$server_url = '';
|
||
}
|
||
|
||
$this->server_url = $server_url;
|
||
$this->api_key = $api_key;
|
||
$this->timeout = $timeout;
|
||
}
|
||
|
||
/**
|
||
* 获取插件信息
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @return array|null
|
||
*/
|
||
public function get_plugin_info( string $slug ): ?array {
|
||
$response = $this->request( 'GET', "/api/v1/plugin/{$slug}" );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
Logger::error(
|
||
'Failed to get plugin info',
|
||
[
|
||
'slug' => $slug,
|
||
'error' => $response->get_error_message(),
|
||
]
|
||
);
|
||
return null;
|
||
}
|
||
|
||
return $response;
|
||
}
|
||
|
||
/**
|
||
* 获取下载 URL
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @return string|null
|
||
*/
|
||
public function get_download_url( string $slug ): ?string {
|
||
if ( empty( $this->server_url ) ) {
|
||
return null;
|
||
}
|
||
// 下载端点会返回重定向或直接代理
|
||
return $this->server_url . "/api/v1/download/{$slug}";
|
||
}
|
||
|
||
/**
|
||
* 列出所有供应商（需要认证）
|
||
*
|
||
* @return array
|
||
*/
|
||
public function list_vendors(): array {
|
||
$response = $this->request( 'GET', '/api/v1/admin/vendors', [], true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
Logger::error(
|
||
'Failed to list vendors',
|
||
[
|
||
'error' => $response->get_error_message(),
|
||
]
|
||
);
|
||
return [];
|
||
}
|
||
|
||
return $response ?? [];
|
||
}
|
||
|
||
/**
|
||
* 创建供应商（需要认证）
|
||
*
|
||
* @param array $data 供应商数据
|
||
* @return array
|
||
*/
|
||
public function create_vendor( array $data ): array {
|
||
$response = $this->request( 'POST', '/api/v1/admin/vendors', $data, true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => $response->get_error_message(),
|
||
];
|
||
}
|
||
|
||
return [
|
||
'success' => true,
|
||
'data' => $response,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 更新供应商（需要认证）
|
||
*
|
||
* @param int $id 供应商 ID
|
||
* @param array $data 供应商数据
|
||
* @return array
|
||
*/
|
||
public function update_vendor( int $id, array $data ): array {
|
||
$response = $this->request( 'PUT', "/api/v1/admin/vendors/{$id}", $data, true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => $response->get_error_message(),
|
||
];
|
||
}
|
||
|
||
return [
|
||
'success' => true,
|
||
'data' => $response,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 删除供应商（需要认证）
|
||
*
|
||
* @param int $id 供应商 ID
|
||
* @return array
|
||
*/
|
||
public function delete_vendor( int $id ): array {
|
||
$response = $this->request( 'DELETE', "/api/v1/admin/vendors/{$id}", [], true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => $response->get_error_message(),
|
||
];
|
||
}
|
||
|
||
return [
|
||
'success' => true,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 列出所有插件（需要认证）
|
||
*
|
||
* @return array
|
||
*/
|
||
public function list_plugins(): array {
|
||
$response = $this->request( 'GET', '/api/v1/admin/plugins', [], true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
Logger::error(
|
||
'Failed to list plugins',
|
||
[
|
||
'error' => $response->get_error_message(),
|
||
]
|
||
);
|
||
return [];
|
||
}
|
||
|
||
return $response ?? [];
|
||
}
|
||
|
||
/**
|
||
* 创建插件（需要认证）
|
||
*
|
||
* @param array $data 插件数据
|
||
* @return array
|
||
*/
|
||
public function create_plugin( array $data ): array {
|
||
$response = $this->request( 'POST', '/api/v1/admin/plugins', $data, true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => $response->get_error_message(),
|
||
];
|
||
}
|
||
|
||
return [
|
||
'success' => true,
|
||
'data' => $response,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 获取插件详情（需要认证）
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @return array|null
|
||
*/
|
||
public function get_plugin( string $slug ): ?array {
|
||
$response = $this->request( 'GET', "/api/v1/admin/plugins/{$slug}", [], true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return null;
|
||
}
|
||
|
||
return $response;
|
||
}
|
||
|
||
/**
|
||
* 更新插件（需要认证）
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @param array $data 插件数据
|
||
* @return array
|
||
*/
|
||
public function update_plugin( string $slug, array $data ): array {
|
||
$response = $this->request( 'PUT', "/api/v1/admin/plugins/{$slug}", $data, true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => $response->get_error_message(),
|
||
];
|
||
}
|
||
|
||
return [
|
||
'success' => true,
|
||
'data' => $response,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 删除插件（需要认证）
|
||
*
|
||
* @param string $slug 插件 slug
|
||
* @return array
|
||
*/
|
||
public function delete_plugin( string $slug ): array {
|
||
$response = $this->request( 'DELETE', "/api/v1/admin/plugins/{$slug}", [], true );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return [
|
||
'success' => false,
|
||
'message' => $response->get_error_message(),
|
||
];
|
||
}
|
||
|
||
return [
|
||
'success' => true,
|
||
];
|
||
}
|
||
|
||
/**
|
||
* 健康检查
|
||
*
|
||
* @return bool
|
||
*/
|
||
public function health_check(): bool {
|
||
$response = $this->request( 'GET', '/health' );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return false;
|
||
}
|
||
|
||
return isset( $response['status'] ) && $response['status'] === 'ok';
|
||
}
|
||
|
||
/**
|
||
* 发送请求
|
||
*
|
||
* @param string $method HTTP 方法
|
||
* @param string $endpoint API 端点
|
||
* @param array $data 请求数据
|
||
* @param bool $auth 是否需要认证
|
||
* @return array|\WP_Error
|
||
*/
|
||
private function request( string $method, string $endpoint, array $data = [], bool $auth = false ) {
|
||
$url = $this->server_url . $endpoint;
|
||
|
||
$args = [
|
||
'method' => $method,
|
||
'timeout' => $this->timeout,
|
||
'sslverify' => true,
|
||
'headers' => [
|
||
'Content-Type' => 'application/json',
|
||
'Accept' => 'application/json',
|
||
],
|
||
];
|
||
|
||
// 添加认证头
|
||
if ( $auth && ! empty( $this->api_key ) ) {
|
||
$args['headers']['X-API-Key'] = $this->api_key;
|
||
}
|
||
|
||
// 添加请求体
|
||
if ( ! empty( $data ) && in_array( $method, [ 'POST', 'PUT', 'PATCH' ], true ) ) {
|
||
$args['body'] = wp_json_encode( $data );
|
||
}
|
||
|
||
$response = wp_remote_request( $url, $args );
|
||
|
||
if ( is_wp_error( $response ) ) {
|
||
return $response;
|
||
}
|
||
|
||
$status_code = wp_remote_retrieve_response_code( $response );
|
||
$body = wp_remote_retrieve_body( $response );
|
||
|
||
// 处理 204 No Content
|
||
if ( $status_code === 204 ) {
|
||
return [];
|
||
}
|
||
|
||
// 处理错误状态码
|
||
if ( $status_code >= 400 ) {
|
||
$error_data = json_decode( $body, true );
|
||
$message = $error_data['message'] ?? $error_data['error'] ?? "HTTP {$status_code}";
|
||
return new \WP_Error( 'bridge_server_error', $message, [ 'status' => $status_code ] );
|
||
}
|
||
|
||
// 解析 JSON 响应
|
||
$decoded = json_decode( $body, true );
|
||
|
||
if ( json_last_error() !== JSON_ERROR_NONE ) {
|
||
return new \WP_Error( 'json_decode_error', 'Invalid JSON response' );
|
||
}
|
||
|
||
return $decoded;
|
||
}
|
||
|
||
/**
|
||
* 获取服务端 URL
|
||
*
|
||
* @return string
|
||
*/
|
||
public function get_server_url(): string {
|
||
return $this->server_url;
|
||
}
|
||
|
||
/**
|
||
* 检查是否已配置
|
||
*
|
||
* @return bool
|
||
*/
|
||
public function is_configured(): bool {
|
||
return ! empty( $this->server_url ) && ! empty( $this->api_key );
|
||
}
|
||
}
|
