gnh1201/caterpillar
1
0
Fork 0
mirror of https://github.com/gnh1201/caterpillar.git synced 2025-03-12 17:05:16 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity
9ac4801118
caterpillar/assets/php/index.php

452 lines
14 KiB
PHP
Raw Normal View History

Create proxytest.php
2022-10-05 17:20:02 +00:00
<?php
Update index.php
2024-03-05 07:35:48 +00:00
/* index.php
* Caterpillar Worker on PHP
*
* Caterpillar Proxy - The simple and parasitic web proxy with spam filter
* Namhyeon Go (Catswords Research) <abuse@catswords.net>
* https://github.com/gnh1201/caterpillar
* Created at: 2022-10-06
* Updated at: 2024-03-05
*/
Create proxytest.php
2022-10-05 17:20:02 +00:00
Update index.php
2024-02-26 13:17:52 +00:00
define("PHP_HTTPPROXY_VERSION", "0.1.5");
Update index.php
2024-03-04 07:29:48 +00:00
define("DEFAULT_SOCKET_TIMEOUT", 1);
define("STATEFUL_SOCKET_TIMEOUT", 30);
define("MAX_EXECUTION_TIME", 0);
Update index.php, server.py
2022-11-25 12:37:34 +00:00
Update index.php
2024-02-20 02:46:26 +00:00
if (strpos($_SERVER['HTTP_USER_AGENT'], "php-httpproxy/") !== 0) {
Update index.php
2024-02-29 14:10:53 +00:00
exit('<!DOCTYPE html><html><head><title>It works!</title><meta charset="utf-8"></head><body><h1>It works!</h1><p><a href="https://github.com/gnh1201/caterpillar">Download the client</a></p><hr><p>php-httpproxy/' . PHP_HTTPPROXY_VERSION . ' (Server; PHP ' . phpversion() . '; Caterpillar; abuse@catswords.net)</p></body></html>');
Update proxytest.php
2022-10-07 04:48:58 +00:00
}
Update index.php
2024-03-04 07:29:48 +00:00
ini_set("default_socket_timeout", DEFAULT_SOCKET_TIMEOUT); // must be. because of `feof()` works
ini_set("max_execution_time", MAX_EXECUTION_TIME);
Create proxytest.php
2022-10-05 17:20:02 +00:00
Update index.php
2024-02-26 06:04:51 +00:00
function jsonrpc2_encode($method, $params, $id = '') {
Update index.php
2024-02-26 04:55:22 +00:00
$data = array(
"jsonrpc" => "2.0",
Update index.php
2024-02-26 06:04:51 +00:00
"method" => $method,
"params" => $params,
"id" => $id
Update index.php
2024-02-26 04:55:22 +00:00
);
return json_encode($data);
}
Update index.php
2024-02-26 06:04:51 +00:00
function jsonrpc2_result_encode($result, $id = '') {
Update index.php
2024-02-26 04:55:22 +00:00
$data = array(
"jsonrpc" => "2.0",
Update index.php
2024-02-26 06:04:51 +00:00
"result" => $result,
"id" => $id
Update index.php
2024-02-26 04:55:22 +00:00
);
return json_encode($data);
}
Update index.php
2024-02-26 06:04:51 +00:00
function jsonrpc2_error_encode($error, $id = '') {
Update index.php
2024-02-26 04:49:14 +00:00
$data = array(
"jsonrpc" => "2.0",
Update index.php
2024-02-26 06:04:51 +00:00
"error" => $error,
"id" => $id
Update index.php
2024-02-26 04:49:14 +00:00
);
return json_encode($data);
}
Update proxytest.php
2022-10-06 12:03:05 +00:00
function parse_headers($str) { // Parses HTTP headers into an array
Update proxytest.php
2022-10-06 12:48:49 +00:00
// https://stackoverflow.com/questions/16934409/curl-as-proxy-deal-with-https-connect-method
// https://stackoverflow.com/questions/12433958/how-to-parse-response-headers-in-php
Update proxytest.php
2022-10-06 12:03:05 +00:00
$headers = array();
Create proxytest.php
2022-10-05 17:20:02 +00:00
Update proxytest.php
2022-10-06 12:03:05 +00:00
$lines = preg_split("'\r?\n'", $str);
Update proxytest.php
2022-10-06 02:05:59 +00:00
Update proxytest.php
2022-10-06 12:03:05 +00:00
$first_line = array_shift($lines);
$headers['@method'] = explode(' ', $first_line);
Update proxytest.php
2022-10-06 02:39:40 +00:00
Update proxytest.php
2022-10-06 12:03:05 +00:00
foreach ($lines as $line) {
if (!preg_match('/^([^:]+):(.*)$/', $line, $out)) continue;
$headers[$out[1]] = trim($out[2]);
}
Create proxytest.php
2022-10-05 17:20:02 +00:00
Update proxytest.php
2022-10-06 12:03:05 +00:00
return $headers;
}
Create proxytest.php
2022-10-05 17:20:02 +00:00
Update index.php
2024-02-26 06:57:28 +00:00
function read_from_remote_server($remote_address, $remote_port, $scheme, $data = null, $conn = null, $buffer_size = 8192, $id = '') {
Update index.php
2024-02-26 05:52:50 +00:00
if (in_array($scheme, array("https", "ssl", "tls"))) {
$remote_address = "tls://" . $remote_address;
}
Update index.php
2024-03-04 07:29:48 +00:00
$sock = fsockopen($remote_address, $remote_port, $error_code, $error_message, DEFAULT_SOCKET_TIMEOUT);
Update index.php
2024-02-26 05:50:20 +00:00
if (!$sock) {
$error = array(
Update index.php
2024-02-26 06:44:38 +00:00
"status" => 502,
Update index.php
2024-02-26 05:50:20 +00:00
"code" => $error_code,
Update index.php
2024-02-26 13:06:55 +00:00
"message" => $error_message
Update index.php
2024-02-26 05:50:20 +00:00
);
if ($conn == null) {
Update index.php
2024-02-26 06:44:38 +00:00
echo jsonrpc2_error_encode($error, $id);
Update index.php
2024-02-26 05:50:20 +00:00
} else {
Update index.php
2024-02-26 13:06:55 +00:00
$buf = sprintf("HTTP/1.1 502 Bad Gateway\r\n\r\n");
Update index.php
2024-02-26 06:48:39 +00:00
$buf .= jsonrpc2_error_encode($error, $id);
Update index.php
2024-02-26 05:50:20 +00:00
fwrite($conn, $buf);
}
} else {
Update index.php
2024-02-26 06:57:28 +00:00
if ($conn == null) {
// send data
fwrite($sock, $data);
Update index.php
2024-02-26 05:50:20 +00:00
Update index.php
2024-02-26 06:57:28 +00:00
// receive data
$buf = null;
while (!feof($sock) && $buf !== false) {
$buf = fgets($sock, $buffer_size);
Update index.php
2024-02-26 05:50:20 +00:00
echo $buf;
Update index.php
2024-02-26 06:57:28 +00:00
}
} else {
// send data
$buf = null;
while (!feof($conn) && $buf !== false) {
$buf = fgets($conn, $buffer_size);
fwrite($sock, $buf);
}
// receive data
$buf = null;
while (!feof($sock) && $buf !== false) {
$buf = fgets($sock, $buffer_size);
Update index.php
2024-02-26 05:50:20 +00:00
fwrite($conn, $buf);
}
}
fclose($sock);
}
}
Update index.php
2024-02-25 17:51:08 +00:00
// stateless mode
Update index.php
2024-02-26 06:04:51 +00:00
function relay_request($params, $id = '') {
Update index.php
2024-02-26 04:49:14 +00:00
$buffer_size = $params['buffer_size'];
Update index.php
2024-02-26 05:12:57 +00:00
$request_data = base64_decode($params['request_data']);
$request_header = parse_headers($request_data);
$request_length = intval($params['request_length']);
Update index.php
2024-02-26 04:49:14 +00:00
$client_address = $params['client_address'];
$client_port = intval($params['client_port']);
$client_encoding = $params['client_encoding'];
$remote_address = $params['remote_address'];
$remote_port = intval($params['remote_port']);
$scheme = $params['scheme'];
$datetime = $params['datetime']; // format: %Y-%m-%d %H:%M:%S.%f
if (in_array($scheme, array("https", "ssl", "tls"))) {
$remote_address = "tls://" . $remote_address;
Update index.php
2024-02-25 17:51:08 +00:00
}
Update index.php
2024-02-26 04:49:14 +00:00
Update index.php
2024-02-26 05:12:57 +00:00
switch ($request_header['@method'][0]) {
Update index.php
2024-02-25 17:51:08 +00:00
case "CONNECT":
Update index.php
2024-02-26 06:44:38 +00:00
$error = array(
"status" => 405,
"code" => -1,
"message" => "Method Not Allowed"
);
echo jsonrpc2_error_encode($error, $id);
Update index.php
2024-02-25 17:51:08 +00:00
break;
Update index.php
2024-02-26 04:49:14 +00:00
Update index.php
2024-02-25 17:51:08 +00:00
default:
Update index.php
2024-02-26 06:57:28 +00:00
read_from_remote_server($remote_address, $remote_port, $scheme, $request_data, null, $buffer_size, $id);
Update index.php
2024-02-25 17:51:08 +00:00
}
Add HTTP decryption (stable)
2022-11-25 10:32:17 +00:00
}
Update index.php
2024-02-25 17:51:08 +00:00
// stateful mode
Update index.php
2024-02-26 06:04:51 +00:00
function relay_connect($params, $id = '') {
Update index.php
2024-02-26 04:49:14 +00:00
$buffer_size = $params['buffer_size'];
$client_address = $params['client_address'];
$client_port = intval($params['client_port']);
$client_encoding = $params['client_encoding'];
$remote_address = $params['remote_address'];
$remote_port = intval($params['remote_port']);
$scheme = $params['scheme'];
$datetime = $params['datetime']; // format: %Y-%m-%d %H:%M:%S.%f
Update index.php
2024-02-27 04:40:16 +00:00
$starttime = microtime(true);
Update index.php
2024-03-04 07:29:48 +00:00
$conn = fsockopen($client_address, $client_port, $error_code, $error_message, STATEFUL_SOCKET_TIMEOUT);
Update index.php
2024-02-26 05:50:20 +00:00
if (!$conn) {
Update index.php
2024-02-26 04:49:14 +00:00
$error = array(
Update index.php
2024-02-26 06:44:38 +00:00
"status" => 502,
Update index.php
2024-02-26 04:49:14 +00:00
"code" => $error_code,
Update index.php
2024-02-26 13:06:55 +00:00
"message" => $error_message,
"_params" => $params
Update index.php
2024-02-26 04:49:14 +00:00
);
Update index.php
2024-02-26 06:44:38 +00:00
echo jsonrpc2_error_encode($error, $id);
Update index.php
2024-02-26 04:49:14 +00:00
} else {
Update index.php
2024-02-27 04:40:16 +00:00
$stoptime = microtime(true);
$connection_speed = floor(($stoptime - $starttime) * 1000);
Update index.php
2024-02-26 07:27:49 +00:00
$data = jsonrpc2_encode("relay_accept", array(
Update index.php
2024-02-27 04:40:16 +00:00
"success" => true,
"connection_speed" => $connection_speed
Update index.php
2024-02-26 07:27:49 +00:00
), $id);
fwrite($conn, $data . "\r\n\r\n");
Update index.php
2024-02-26 06:57:28 +00:00
read_from_remote_server($remote_address, $remote_port, $scheme, null, $conn, $buffer_size, $id);
Update index.php
2024-02-26 05:50:20 +00:00
fclose($conn);
Update index.php
2024-02-26 04:49:14 +00:00
}
Update index.php
2024-02-25 17:51:08 +00:00
}
Update proxytest.php
2022-10-06 12:03:05 +00:00
Update index.php
2024-02-27 04:40:16 +00:00
function relay_mysql_connect($params) {
$hostname = $params['hostname'];
$username = $params['username'];
$password = $params['password'];
$database = $params['database'];
$port = array_key_exists('port', $params) ? intval($params['port']) : null;
Update index.php
2024-02-27 08:33:15 +00:00
$charset = array_key_exists('charset', $params) ? $params['charset'] : "utf8";
Update index.php
2024-02-27 04:40:16 +00:00
$mysqli = new mysqli($hostname, $username, $password, $database, $port);
if ($mysqli->connect_errno) {
return array(
"success" => false,
"error" => array(
"status" => 503,
"code" => $mysqli->connect_errno,
"message" => $mysqli->connect_error
)
);
} else {
Update index.php
2024-02-27 08:33:15 +00:00
$mysqli->set_charset($charset);
Update index.php
2024-02-27 04:40:16 +00:00
}
return array(
"success" => true,
"mysqli" => $mysqli,
"result" => array(
"status" => 200
)
);
}
function relay_mysql_query($params, $mysqli) {
$query = trim($params['query']);
$query_type = ""; // e.g., select, insert, update, delete
$pos = strpos($query, ' ');
if ($pos !== false) {
$query_type = strtolower(substr($query, 0, $pos));
}
Update index.php
2024-02-29 08:54:36 +00:00
$query_result = $mysqli->query($query);
Update index.php
2024-02-27 04:40:16 +00:00
if (!$mysqli->error) {
return array(
"success" => false,
"error" => array(
"status" => 503,
"code" => $msqli->errno,
"message" => $mysqli->error
)
);
}
Update index.php
2024-02-29 08:54:36 +00:00
$success = false;
$result = array(
"status" => 200
);
Update index.php
2024-02-29 07:36:05 +00:00
switch($query_type) {
case "select":
Update index.php
2024-02-29 08:54:36 +00:00
$success = true;
$result['data'] = mysqli_fetch_all($query_result, MYSQLI_ASSOC);
Update index.php
2024-02-29 07:36:05 +00:00
break;
case "insert":
Update index.php
2024-02-29 08:54:36 +00:00
$success = $query_result;
Update index.php
2024-02-29 09:39:43 +00:00
$result['last_id'] = @$mysqli->insert_id();
Update index.php
2024-02-29 07:36:05 +00:00
break;
default:
Update index.php
2024-02-29 08:54:36 +00:00
$success = $query_result;
Update index.php
2024-02-27 04:40:16 +00:00
}
return array(
Update index.php
2024-02-29 08:54:36 +00:00
"success" => $success,
"result" => $result
Update index.php
2024-02-27 04:40:16 +00:00
);
}
Update index.php
2024-02-27 05:52:52 +00:00
function relay_sendmail($params) {
$to = $params['to'];
$from = $params['from'];
$subject = $params['subject'];
$message = $params['message'];
$headers = 'From: ' . $from . "\r\n" .
Update index.php
2024-02-29 19:43:54 +00:00
'X-Mailer: php-httpproxy/' . PHP_HTTPPROXY_VERSION . ' (Server; PHP ' . phpversion() . '; Caterpillar)';
Update index.php
2024-02-29 07:36:05 +00:00
$sent = @mail($to, $subject, $message, $headers);
Update index.php
2024-02-27 05:52:52 +00:00
if (!$sent) {
$e = error_get_last();
return array(
"success" => false,
"error" => array(
"status" => 500,
"code" => $e['type'],
"message" => $e['message']
)
);
}
return array(
"success" => true,
"result" => array(
"status" => 200
)
);
}
Update index.php
2024-02-27 05:20:14 +00:00
function relay_get_version() {
Update index.php
2024-02-27 08:33:15 +00:00
return PHP_HTTPPROXY_VERSION;
Update index.php
2024-02-27 04:40:16 +00:00
}
Update index.php
2024-02-27 05:20:14 +00:00
function relay_get_phpversion() {
Update index.php
2024-02-27 08:33:15 +00:00
return phpversion();
Update index.php
2024-02-27 05:20:14 +00:00
}
function relay_get_loaded_extensions() {
Update index.php
2024-02-27 08:33:15 +00:00
return get_loaded_extensions();
Update index.php
2024-02-27 05:20:14 +00:00
}
Update index.php
2024-02-27 06:38:17 +00:00
function relay_dns_get_record($params) {
$hostname = $params['hostname'];
Update index.php
2024-02-27 06:50:24 +00:00
$data = dns_get_record($hostname);
if (!$data) {
return array(
"success" => false,
"error" => array(
"status" => 502,
"code" => -1,
"message" => $hostname . " is not found in DNS records"
)
Update index.php
2024-02-27 06:50:58 +00:00
);
Update index.php
2024-02-27 06:50:24 +00:00
}
return array(
"success" => true,
"result" => array(
"status" => 200,
"data" => $data
)
Update index.php
2024-02-27 06:50:58 +00:00
);
Update index.php
2024-02-27 06:38:17 +00:00
}
Update index.php
2024-02-27 06:27:08 +00:00
function relay_get_geolocation() {
$url = "https://ipapi.co/json/";
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
Update index.php
2024-02-27 08:21:27 +00:00
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 1);
Update index.php
2024-02-27 06:27:08 +00:00
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
$response = curl_exec($ch);
$error_code = curl_errno($ch);
if ($error_code) {
$error_message = curl_error($ch);
curl_close($ch);
return array(
"success" => false,
"error" => array(
"status" => 502,
"code" => $error_code,
"message" => $error_message
)
);
}
curl_close($ch);
$data = json_decode($response, true);
return array(
"success" => true,
"result" => array(
"status" => 200,
"data" => $data
)
);
}
Update index.php
2024-02-26 13:06:55 +00:00
function get_client_address() {
$client_address = '';
if (!empty($_SERVER['HTTP_CLIENT_IP'])) {
$client_address = $_SERVER['HTTP_CLIENT_IP'];
} elseif (!empty($_SERVER['HTTP_X_FORWARDED_FOR'])) {
$client_address = $_SERVER['HTTP_X_FORWARDED_FOR'];
} else {
$client_address = $_SERVER['REMOTE_ADDR'];
}
return array("client_address" => $client_address);
}
Update index.php
2024-02-27 04:40:16 +00:00
// parse a context
Update index.php
2024-02-29 14:10:53 +00:00
$context = json_decode(file_get_contents('php://input'), true);
Update index.php
2024-02-25 17:51:08 +00:00
Update index.php
2024-02-29 08:38:03 +00:00
// check is it JSON-RPC 2 (stateless)
Update index.php
2024-02-25 17:51:08 +00:00
if ($context['jsonrpc'] == "2.0") {
$method = $context['method'];
switch ($method) {
case "relay_request":
Update index.php
2024-02-26 06:04:51 +00:00
relay_request($context['params'], $context['id']); // stateless mode
Update index.php
2024-02-25 17:51:08 +00:00
break;
Update index.php
2024-02-26 13:06:55 +00:00
Update index.php
2024-02-25 17:51:08 +00:00
case "relay_connect":
Update index.php
2024-02-26 06:04:51 +00:00
relay_connect($context['params'], $context['id']); // stateful mode
Update index.php
2024-02-25 17:51:08 +00:00
break;
Update index.php
2024-02-26 13:06:55 +00:00
Update index.php
2024-02-27 04:40:16 +00:00
case "relay_mysql_query":
$result = relay_mysql_connect($context['params']);
if ($result['success']) {
$mysqli = $result['mysqli'];
$query_result = relay_mysql_query($context['params'], $mysqli);
if ($query_result['success']) {
echo jsonrpc2_result_encode($query_result['result'], $context['id']);
} else {
echo jsonrpc2_error_encode($query_result['error'], $context['id']);
}
} else {
echo jsonrpc2_error_encode($result['error'], $context['id']);
}
break;
Update index.php
2024-02-27 05:52:52 +00:00
case "relay_sendmail":
$result = relay_sendmail($context['params']);
if ($result['success']) {
echo jsonrpc2_result_encode($result['result'], $context['id']);
} else {
echo jsonrpc2_error_encode($result['error'], $context['id']);
}
break;
Update index.php
2024-02-27 05:20:14 +00:00
case "relay_get_version":
echo jsonrpc2_result_encode(relay_get_version(), $context['id']);
break;
case "relay_get_phpversion":
echo jsonrpc2_result_encode(relay_get_phpversion(), $context['id']);
break;
case "relay_get_loaded_extensions":
echo jsonrpc2_result_encode(relay_get_loaded_extensions(), $context['id']);
Update index.php
2024-02-27 04:40:16 +00:00
break;
Update index.php
2024-02-27 06:27:08 +00:00
Update index.php
2024-02-27 06:38:17 +00:00
case "relay_dns_get_record":
Update index.php
2024-02-27 06:50:24 +00:00
$result = relay_dns_get_record($context['params']);
if ($result['success']) {
echo jsonrpc2_result_encode($result['result'], $context['id']);
} else {
echo jsonrpc2_error_encode($result['error'], $context['id']);
}
Update index.php
2024-02-27 06:38:17 +00:00
break;
Update index.php
2024-02-27 06:27:08 +00:00
case "relay_get_geolocation":
Update index.php
2024-02-27 06:50:24 +00:00
$result = relay_get_geolocation();
Update index.php
2024-02-27 06:27:08 +00:00
if ($result['success']) {
echo jsonrpc2_result_encode($result['result'], $context['id']);
} else {
echo jsonrpc2_error_encode($result['error'], $context['id']);
}
break;
Update index.php
2024-02-27 04:40:16 +00:00
Update index.php
2024-02-26 13:06:55 +00:00
case "get_client_address":
echo jsonrpc2_result_encode(get_client_address(), $context['id']);
break;
Update index.php
2024-02-25 17:51:08 +00:00
}
Update index.php
2024-02-17 09:54:31 +00:00
}
Update index.php
2024-02-29 08:38:03 +00:00
Reference in New Issue Copy Permalink