gnh1201/caterpillar
1
0
Fork 0
mirror of https://github.com/gnh1201/caterpillar.git synced 2025-07-15 16:58:08 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update index.php

Browse Source
This commit is contained in:
Namhyeon Go 2024-02-26 14:50:20 +09:00 committed by GitHub
parent 05bc9ba978
commit ee40d26ace
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 41 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

71
index.php
View File

@ -57,6 +57,41 @@ function parse_headers($str) { // Parses HTTP headers into an array
return $headers; return $headers;
} }
function read_from_remote_server($remote_address, $remote_port, $conn = null, $buffer_size = 8192) {
$sock = fsockopen($remote_address, $remote_port, $error_code, $error_message, 1);
if (!$sock) {
$error = array(
"status" => 400,
"code" => $error_code,
"message" => $error_message
);
$buf = "HTTP/1.1 400 Bad Request\r\n\r\n" . jsonrpc2_error_encode($error);
if ($conn == null) {
echo $buf;
} else {
fwrite($conn, $buf);
}
} else {
$buf = null;
if ($conn != null) {
$buf = fgets($conn, $buffer_size);
fwrite($sock, $buf);
}
while (!feof($sock) && $buf !== false) {
$buf = fgets($sock, $buffer_size);
if ($conn == null) {
echo $buf;
} else {
fwrite($conn, $buf);
}
}
fclose($sock);
}
}
// stateless mode // stateless mode
function relay_request($params) { function relay_request($params) {
$buffer_size = $params['buffer_size']; $buffer_size = $params['buffer_size'];
@ -82,25 +117,7 @@ function relay_request($params) {
break; break;
default: default:
$fp = fsockopen($remote_address, $remote_port, $error_code, $error_message, 1); read_from_remote_server($remote_address, $remote_port, null, $buffer_size);
if (!$fp) {
$error = array(
"status" => 400,
"code" => $error_code,
"message" => $error_message
);
echo "HTTP/1.1 400 Bad Request\r\n\r\n" . jsonrpc2_error_encode($error);
} else {
fwrite($fp, $request_data);
$buf = null;
while (!feof($fp) && $buf !== false) {
$buf = fgets($fp, $buffer_size);
echo $buf;
}
fclose($fp);
}
} }
} }
@ -116,8 +133,8 @@ function relay_connect($params) {
$url = $params['url']; $url = $params['url'];
$datetime = $params['datetime']; // format: %Y-%m-%d %H:%M:%S.%f $datetime = $params['datetime']; // format: %Y-%m-%d %H:%M:%S.%f
$fp = fsockopen($client_address, $client_port, $error_code, $error_message, 1); $conn = fsockopen($client_address, $client_port, $error_code, $error_message, 1);
if (!$fp) { if (!$conn) {
$error = array( $error = array(
"status" => 400, "status" => 400,
"code" => $error_code, "code" => $error_code,
@ -125,15 +142,9 @@ function relay_connect($params) {
); );
echo "HTTP/1.1 400 Bad Request\r\n\r\n" . jsonrpc2_error_encode($error); echo "HTTP/1.1 400 Bad Request\r\n\r\n" . jsonrpc2_error_encode($error);
} else { } else {
fwrite($fp, jsonrpc2_result_encode(array("success" => true))); fwrite($conn, jsonrpc2_result_encode(array("success" => true)));
read_from_remote_server($remote_address, $remote_port, $conn, $buffer_size);
$buf = null; fclose($conn);
while (!feof($fp) && $buf !== false) {
$buf = fgets($fp, $buffer_size);
// todo
}
fclose($fp);
} }
} }