mirror of
https://github.com/lkddi/Xboard.git
synced 2026-04-03 18:40:52 +08:00
434 lines
14 KiB
PHP
434 lines
14 KiB
PHP
<?php
|
||
|
||
namespace App\Models;
|
||
|
||
use Illuminate\Database\Eloquent\Model;
|
||
use Illuminate\Database\Eloquent\Relations\BelongsTo;
|
||
use Illuminate\Database\Eloquent\Relations\HasMany;
|
||
use Illuminate\Support\Facades\Cache;
|
||
use App\Utils\CacheKey;
|
||
use App\Utils\Helper;
|
||
use App\Models\User;
|
||
use Illuminate\Database\Eloquent\Casts\Attribute;
|
||
|
||
/**
|
||
* App\Models\Server
|
||
*
|
||
* @property int $id
|
||
* @property string $name 节点名称
|
||
* @property string $type 服务类型
|
||
* @property string $host 主机地址
|
||
* @property string|int $port 端口
|
||
* @property int|null $server_port 服务器端口
|
||
* @property array|null $group_ids 分组IDs
|
||
* @property array|null $route_ids 路由IDs
|
||
* @property array|null $tags 标签
|
||
* @property string|null $show 是否显示
|
||
* @property string|null $allow_insecure 是否允许不安全
|
||
* @property string|null $network 网络类型
|
||
* @property int|null $parent_id 父节点ID
|
||
* @property float|null $rate 倍率
|
||
* @property int|null $sort 排序
|
||
* @property array|null $protocol_settings 协议设置
|
||
* @property int $created_at
|
||
* @property int $updated_at
|
||
*
|
||
* @property-read Server|null $parent 父节点
|
||
* @property-read \Illuminate\Database\Eloquent\Collection<int, StatServer> $stats 节点统计
|
||
*
|
||
* @property-read int|null $last_check_at 最后检查时间（Unix时间戳）
|
||
* @property-read int|null $last_push_at 最后推送时间（Unix时间戳）
|
||
* @property-read int $online 在线用户数
|
||
* @property-read int $is_online 是否在线（1在线 0离线）
|
||
* @property-read string $available_status 可用状态描述
|
||
* @property-read string $cache_key 缓存键
|
||
* @property string|null $ports 端口范围
|
||
* @property string|null $password 密码
|
||
* @property int|null $u 上行流量
|
||
* @property int|null $d 下行流量
|
||
* @property int|null $total 总流量
|
||
*/
|
||
class Server extends Model
|
||
{
|
||
public const TYPE_HYSTERIA = 'hysteria';
|
||
public const TYPE_VLESS = 'vless';
|
||
public const TYPE_TROJAN = 'trojan';
|
||
public const TYPE_VMESS = 'vmess';
|
||
public const TYPE_TUIC = 'tuic';
|
||
public const TYPE_SHADOWSOCKS = 'shadowsocks';
|
||
public const TYPE_ANYTLS = 'anytls';
|
||
public const TYPE_SOCKS = 'socks';
|
||
public const TYPE_NAIVE = 'naive';
|
||
public const TYPE_HTTP = 'http';
|
||
public const TYPE_MIERU = 'mieru';
|
||
public const STATUS_OFFLINE = 0;
|
||
public const STATUS_ONLINE_NO_PUSH = 1;
|
||
public const STATUS_ONLINE = 2;
|
||
|
||
public const CHECK_INTERVAL = 300; // 5 minutes in seconds
|
||
|
||
private const CIPHER_CONFIGURATIONS = [
|
||
'2022-blake3-aes-128-gcm' => [
|
||
'serverKeySize' => 16,
|
||
'userKeySize' => 16,
|
||
],
|
||
'2022-blake3-aes-256-gcm' => [
|
||
'serverKeySize' => 32,
|
||
'userKeySize' => 32,
|
||
],
|
||
'2022-blake3-chacha20-poly1305' => [
|
||
'serverKeySize' => 32,
|
||
'userKeySize' => 32,
|
||
]
|
||
];
|
||
|
||
public const TYPE_ALIASES = [
|
||
'v2ray' => self::TYPE_VMESS,
|
||
'hysteria2' => self::TYPE_HYSTERIA,
|
||
];
|
||
|
||
public const VALID_TYPES = [
|
||
self::TYPE_HYSTERIA,
|
||
self::TYPE_VLESS,
|
||
self::TYPE_TROJAN,
|
||
self::TYPE_VMESS,
|
||
self::TYPE_TUIC,
|
||
self::TYPE_SHADOWSOCKS,
|
||
self::TYPE_ANYTLS,
|
||
self::TYPE_SOCKS,
|
||
self::TYPE_NAIVE,
|
||
self::TYPE_HTTP,
|
||
self::TYPE_MIERU,
|
||
];
|
||
|
||
protected $table = 'v2_server';
|
||
|
||
protected $guarded = ['id'];
|
||
protected $casts = [
|
||
'group_ids' => 'array',
|
||
'route_ids' => 'array',
|
||
'tags' => 'array',
|
||
'protocol_settings' => 'array',
|
||
'last_check_at' => 'integer',
|
||
'last_push_at' => 'integer',
|
||
'created_at' => 'timestamp',
|
||
'updated_at' => 'timestamp'
|
||
];
|
||
|
||
private const PROTOCOL_CONFIGURATIONS = [
|
||
self::TYPE_TROJAN => [
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false],
|
||
'server_name' => ['type' => 'string', 'default' => null],
|
||
'network' => ['type' => 'string', 'default' => null],
|
||
'network_settings' => ['type' => 'array', 'default' => null]
|
||
],
|
||
self::TYPE_VMESS => [
|
||
'tls' => ['type' => 'integer', 'default' => 0],
|
||
'network' => ['type' => 'string', 'default' => null],
|
||
'rules' => ['type' => 'array', 'default' => null],
|
||
'network_settings' => ['type' => 'array', 'default' => null],
|
||
'tls_settings' => ['type' => 'array', 'default' => null]
|
||
],
|
||
self::TYPE_VLESS => [
|
||
'tls' => ['type' => 'integer', 'default' => 0],
|
||
'tls_settings' => ['type' => 'array', 'default' => null],
|
||
'flow' => ['type' => 'string', 'default' => null],
|
||
'network' => ['type' => 'string', 'default' => null],
|
||
'network_settings' => ['type' => 'array', 'default' => null],
|
||
'reality_settings' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false],
|
||
'server_port' => ['type' => 'string', 'default' => null],
|
||
'server_name' => ['type' => 'string', 'default' => null],
|
||
'public_key' => ['type' => 'string', 'default' => null],
|
||
'private_key' => ['type' => 'string', 'default' => null],
|
||
'short_id' => ['type' => 'string', 'default' => null]
|
||
]
|
||
]
|
||
],
|
||
self::TYPE_SHADOWSOCKS => [
|
||
'cipher' => ['type' => 'string', 'default' => null],
|
||
'obfs' => ['type' => 'string', 'default' => null],
|
||
'obfs_settings' => ['type' => 'array', 'default' => null]
|
||
],
|
||
self::TYPE_HYSTERIA => [
|
||
'version' => ['type' => 'integer', 'default' => 2],
|
||
'bandwidth' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'up' => ['type' => 'integer', 'default' => null],
|
||
'down' => ['type' => 'integer', 'default' => null]
|
||
]
|
||
],
|
||
'obfs' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'open' => ['type' => 'boolean', 'default' => false],
|
||
'type' => ['type' => 'string', 'default' => 'salamander'],
|
||
'password' => ['type' => 'string', 'default' => null]
|
||
]
|
||
],
|
||
'tls' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'server_name' => ['type' => 'string', 'default' => null],
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false]
|
||
]
|
||
]
|
||
],
|
||
self::TYPE_TUIC => [
|
||
'version' => ['type' => 'integer', 'default' => 5],
|
||
'congestion_control' => ['type' => 'string', 'default' => 'cubic'],
|
||
'alpn' => ['type' => 'array', 'default' => ['h3']],
|
||
'udp_relay_mode' => ['type' => 'string', 'default' => 'native'],
|
||
'tls' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'server_name' => ['type' => 'string', 'default' => null],
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false]
|
||
]
|
||
]
|
||
],
|
||
self::TYPE_ANYTLS => [
|
||
'padding_scheme' => [
|
||
'type' => 'array',
|
||
'default' => [
|
||
"stop=8",
|
||
"0=30-30",
|
||
"1=100-400",
|
||
"2=400-500,c,500-1000,c,500-1000,c,500-1000,c,500-1000",
|
||
"3=9-9,500-1000",
|
||
"4=500-1000",
|
||
"5=500-1000",
|
||
"6=500-1000",
|
||
"7=500-1000"
|
||
]
|
||
],
|
||
'tls' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'server_name' => ['type' => 'string', 'default' => null],
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false]
|
||
]
|
||
]
|
||
],
|
||
self::TYPE_SOCKS => [
|
||
'tls' => ['type' => 'integer', 'default' => 0],
|
||
'tls_settings' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false]
|
||
]
|
||
]
|
||
],
|
||
self::TYPE_NAIVE => [
|
||
'tls' => ['type' => 'integer', 'default' => 0],
|
||
'tls_settings' => ['type' => 'array', 'default' => null]
|
||
],
|
||
self::TYPE_HTTP => [
|
||
'tls' => ['type' => 'integer', 'default' => 0],
|
||
'tls_settings' => [
|
||
'type' => 'object',
|
||
'fields' => [
|
||
'allow_insecure' => ['type' => 'boolean', 'default' => false]
|
||
]
|
||
]
|
||
],
|
||
self::TYPE_MIERU => [
|
||
'transport' => ['type' => 'string', 'default' => 'tcp'],
|
||
'multiplexing' => ['type' => 'string', 'default' => 'MULTIPLEXING_LOW']
|
||
]
|
||
];
|
||
|
||
private function castValueWithConfig($value, array $config)
|
||
{
|
||
if ($value === null && $config['type'] !== 'object') {
|
||
return $config['default'] ?? null;
|
||
}
|
||
|
||
return match ($config['type']) {
|
||
'integer' => (int) $value,
|
||
'boolean' => (bool) $value,
|
||
'string' => (string) $value,
|
||
'array' => (array) $value,
|
||
'object' => is_array($value) ?
|
||
$this->castSettingsWithConfig($value, $config['fields']) :
|
||
$config['default'] ?? null,
|
||
default => $value
|
||
};
|
||
}
|
||
|
||
private function castSettingsWithConfig(array $settings, array $configs): array
|
||
{
|
||
$result = [];
|
||
foreach ($configs as $key => $config) {
|
||
$value = $settings[$key] ?? null;
|
||
$result[$key] = $this->castValueWithConfig($value, $config);
|
||
}
|
||
return $result;
|
||
}
|
||
|
||
public function getProtocolSettingsAttribute($value)
|
||
{
|
||
$settings = json_decode($value, true) ?? [];
|
||
$configs = self::PROTOCOL_CONFIGURATIONS[$this->type] ?? [];
|
||
return $this->castSettingsWithConfig($settings, $configs);
|
||
}
|
||
|
||
public function setProtocolSettingsAttribute($value)
|
||
{
|
||
if (is_string($value)) {
|
||
$value = json_decode($value, true);
|
||
}
|
||
|
||
$configs = self::PROTOCOL_CONFIGURATIONS[$this->type] ?? [];
|
||
$castedSettings = $this->castSettingsWithConfig($value ?? [], $configs);
|
||
|
||
$this->attributes['protocol_settings'] = json_encode($castedSettings);
|
||
}
|
||
|
||
public function generateShadowsocksPassword(User $user): string
|
||
{
|
||
if ($this->type !== self::TYPE_SHADOWSOCKS) {
|
||
return $user->uuid;
|
||
}
|
||
|
||
|
||
$cipher = data_get($this, 'protocol_settings.cipher');
|
||
if (!$cipher || !isset(self::CIPHER_CONFIGURATIONS[$cipher])) {
|
||
return $user->uuid;
|
||
}
|
||
|
||
$config = self::CIPHER_CONFIGURATIONS[$cipher];
|
||
// Use parent's created_at if this is a child node
|
||
$serverCreatedAt = $this->parent_id ? $this->parent->created_at : $this->created_at;
|
||
$serverKey = Helper::getServerKey($serverCreatedAt, $config['serverKeySize']);
|
||
$userKey = Helper::uuidToBase64($user->uuid, $config['userKeySize']);
|
||
return "{$serverKey}:{$userKey}";
|
||
}
|
||
|
||
public static function normalizeType(string $type): string
|
||
{
|
||
return strtolower(self::TYPE_ALIASES[$type] ?? $type);
|
||
}
|
||
|
||
public static function isValidType(string $type): bool
|
||
{
|
||
return in_array(self::normalizeType($type), self::VALID_TYPES, true);
|
||
}
|
||
|
||
public function getAvailableStatusAttribute(): int
|
||
{
|
||
$now = time();
|
||
if (!$this->last_check_at || ($now - self::CHECK_INTERVAL) >= $this->last_check_at) {
|
||
return self::STATUS_OFFLINE;
|
||
}
|
||
if (!$this->last_push_at || ($now - self::CHECK_INTERVAL) >= $this->last_push_at) {
|
||
return self::STATUS_ONLINE_NO_PUSH;
|
||
}
|
||
return self::STATUS_ONLINE;
|
||
}
|
||
|
||
public function parent(): BelongsTo
|
||
{
|
||
return $this->belongsTo(self::class, 'parent_id', 'id');
|
||
}
|
||
|
||
public function stats(): HasMany
|
||
{
|
||
return $this->hasMany(StatServer::class, 'server_id', 'id');
|
||
}
|
||
|
||
public function groups()
|
||
{
|
||
return ServerGroup::whereIn('id', $this->group_ids)->get();
|
||
}
|
||
|
||
public function routes()
|
||
{
|
||
return ServerRoute::whereIn('id', $this->route_ids)->get();
|
||
}
|
||
|
||
/**
|
||
* 最后检查时间访问器
|
||
*/
|
||
protected function lastCheckAt(): Attribute
|
||
{
|
||
return Attribute::make(
|
||
get: function () {
|
||
$type = strtoupper($this->type);
|
||
$serverId = $this->parent_id ?: $this->id;
|
||
return Cache::get(CacheKey::get("SERVER_{$type}_LAST_CHECK_AT", $serverId));
|
||
}
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 最后推送时间访问器
|
||
*/
|
||
protected function lastPushAt(): Attribute
|
||
{
|
||
return Attribute::make(
|
||
get: function () {
|
||
$type = strtoupper($this->type);
|
||
$serverId = $this->parent_id ?: $this->id;
|
||
return Cache::get(CacheKey::get("SERVER_{$type}_LAST_PUSH_AT", $serverId));
|
||
}
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 在线用户数访问器
|
||
*/
|
||
protected function online(): Attribute
|
||
{
|
||
return Attribute::make(
|
||
get: function () {
|
||
$type = strtoupper($this->type);
|
||
$serverId = $this->parent_id ?: $this->id;
|
||
return Cache::get(CacheKey::get("SERVER_{$type}_ONLINE_USER", $serverId)) ?? 0;
|
||
}
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 是否在线访问器
|
||
*/
|
||
protected function isOnline(): Attribute
|
||
{
|
||
return Attribute::make(
|
||
get: function () {
|
||
return (time() - 300 > $this->last_check_at) ? 0 : 1;
|
||
}
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 缓存键访问器
|
||
*/
|
||
protected function cacheKey(): Attribute
|
||
{
|
||
return Attribute::make(
|
||
get: function () {
|
||
return "{$this->type}-{$this->id}-{$this->updated_at}-{$this->is_online}";
|
||
}
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 服务器密钥访问器
|
||
*/
|
||
protected function serverKey(): Attribute
|
||
{
|
||
return Attribute::make(
|
||
get: function () {
|
||
if ($this->type === self::TYPE_SHADOWSOCKS) {
|
||
return Helper::getServerKey($this->created_at, 16);
|
||
}
|
||
return null;
|
||
}
|
||
);
|
||
}
|
||
}
|