mirror of
https://github.com/MengMengCode/CLICD.git
synced 2026-08-08 06:24:44 +08:00
更新一键安装certbot脚本+增加更完整的webssh逻辑
This commit is contained in:
+12
-2
@@ -40,7 +40,7 @@ function clicd_MetaData()
|
||||
'DisplayName' => 'CLICD 对接模块 by 欢-Huan and ChatGPT 5.5 and DeepSeek V4',
|
||||
'APIVersion' => '1.1',
|
||||
'HelpDoc' => 'https://github.com/MengMengCode/CLICD',
|
||||
'version' => '1.0.10',
|
||||
'version' => '1.0.11',
|
||||
];
|
||||
}
|
||||
|
||||
@@ -365,7 +365,10 @@ function clicd_webssh_url($params, $ticket, $containerName)
|
||||
$host = parse_url($baseUrl, PHP_URL_HOST);
|
||||
$port = parse_url($baseUrl, PHP_URL_PORT);
|
||||
$wsBase = $scheme . '://' . $host . ($port ? ':' . $port : '');
|
||||
$wsUrl = $wsBase . '/api/ssh?container=' . rawurlencode((string)$containerName);
|
||||
$wsUrl = $wsBase
|
||||
. '/api/ssh?container=' . rawurlencode((string)$containerName)
|
||||
. '&container_name=' . rawurlencode((string)$containerName)
|
||||
. '&ticket=' . rawurlencode((string)$ticket);
|
||||
|
||||
$siteScheme = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https' : 'http';
|
||||
$siteHost = $_SERVER['HTTP_HOST'] ?? '';
|
||||
@@ -374,6 +377,7 @@ function clicd_webssh_url($params, $ticket, $containerName)
|
||||
return $handler
|
||||
. '?ws=' . rawurlencode($wsUrl)
|
||||
. '&protocol=' . rawurlencode('clicd-ticket.' . (string)$ticket)
|
||||
. '&ticket=' . rawurlencode((string)$ticket)
|
||||
. '&container=' . rawurlencode((string)$containerName);
|
||||
}
|
||||
|
||||
@@ -1419,7 +1423,13 @@ function clicd_ClientButton($params)
|
||||
|
||||
function clicd_webssh($params)
|
||||
{
|
||||
$container = [];
|
||||
$containerName = clicd_container_name($params);
|
||||
clicd_container_api_id($params, $container);
|
||||
if (!empty($container['name'])) {
|
||||
$containerName = (string)$container['name'];
|
||||
}
|
||||
|
||||
$res = clicd_request($params, '/api/v1/ssh-ticket', ['container_name' => $containerName], 'POST', 30);
|
||||
if (!clicd_success($res)) {
|
||||
return ['status' => 'error', 'msg' => clicd_message($res, 'WebSSH ticket create failed')];
|
||||
|
||||
@@ -2,8 +2,13 @@
|
||||
$ws = isset($_GET['ws']) ? (string)$_GET['ws'] : (isset($_GET['amp;ws']) ? (string)$_GET['amp;ws'] : '');
|
||||
$protocol = isset($_GET['protocol']) ? (string)$_GET['protocol'] : (isset($_GET['amp;protocol']) ? (string)$_GET['amp;protocol'] : '');
|
||||
$container = isset($_GET['container']) ? (string)$_GET['container'] : (isset($_GET['amp;container']) ? (string)$_GET['amp;container'] : '');
|
||||
$ticket = isset($_GET['ticket']) ? (string)$_GET['ticket'] : (isset($_GET['amp;ticket']) ? (string)$_GET['amp;ticket'] : '');
|
||||
|
||||
if ($ws === '' || $protocol === '') {
|
||||
if ($protocol === '' && $ticket !== '') {
|
||||
$protocol = 'clicd-ticket.' . $ticket;
|
||||
}
|
||||
|
||||
if ($ws === '') {
|
||||
http_response_code(400);
|
||||
header('Content-Type: text/plain; charset=utf-8');
|
||||
echo "Missing WebSSH parameters\n";
|
||||
@@ -64,6 +69,7 @@ if ($ws === '' || $protocol === '') {
|
||||
(function(){
|
||||
var wsUrl = <?php echo json_encode($ws, JSON_UNESCAPED_SLASHES); ?>;
|
||||
var protocol = <?php echo json_encode($protocol, JSON_UNESCAPED_SLASHES); ?>;
|
||||
var ticket = <?php echo json_encode($ticket, JSON_UNESCAPED_SLASHES); ?>;
|
||||
var term = document.getElementById('term');
|
||||
var state = document.getElementById('state');
|
||||
var modeSelect = document.getElementById('send-mode');
|
||||
@@ -189,8 +195,17 @@ if ($ws === '' || $protocol === '') {
|
||||
iostat.textContent = 'S' + sentCount + ' R' + recvCount + ' ' + stateText;
|
||||
}
|
||||
|
||||
function websocketProtocolValue(value) {
|
||||
value = String(value || '');
|
||||
return /^[!#$%&'*+\-.^_`|~0-9A-Za-z]+$/.test(value) ? value : '';
|
||||
}
|
||||
|
||||
try {
|
||||
socket = new WebSocket(wsUrl, protocol);
|
||||
var protocolValue = websocketProtocolValue(protocol);
|
||||
if (!protocolValue && ticket) {
|
||||
append('[WebSSH] 票据已通过 URL 参数传递,当前浏览器不会发送子协议。\n');
|
||||
}
|
||||
socket = protocolValue ? new WebSocket(wsUrl, protocolValue) : new WebSocket(wsUrl);
|
||||
socket.binaryType = 'arraybuffer';
|
||||
} catch (e) {
|
||||
setState('err', '\nWebSocket 创建失败:' + e.message + '\n');
|
||||
|
||||
Reference in New Issue
Block a user