236 lines
7.6 KiB
PHP
236 lines
7.6 KiB
PHP
<?php
|
|
mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);
|
|
include("../../../cibuild_db.php");
|
|
function openDb(){
|
|
if (! defined('database::SERVER')) return null;
|
|
try{
|
|
$db=new mysqli(database::SERVER, database::USER, database::PASS,database::DB);
|
|
#$db->query("SET CHARACTER SET 'utf8'");
|
|
return $db;
|
|
}catch (Exception $e){
|
|
error_log("openDB error $e");
|
|
}
|
|
return null;
|
|
}
|
|
function safeName($name)
|
|
{
|
|
return preg_replace('[^0-9_a-zA-Z.-]', '', $name);
|
|
}
|
|
function replaceVars($str, $vars)
|
|
{
|
|
foreach ($vars as $n => &$v) {
|
|
$str = str_replace("#" . $n . "#", $v, $str);
|
|
}
|
|
return $str;
|
|
}
|
|
if (!function_exists('getallheaders')) {
|
|
function getallheaders()
|
|
{
|
|
$headers = [];
|
|
foreach ($_SERVER as $name => $value) {
|
|
if (substr($name, 0, 5) == 'HTTP_') {
|
|
$headers[str_replace(' ', '-', ucwords(strtolower(str_replace('_', ' ', substr($name, 5)))))] = $value;
|
|
}
|
|
}
|
|
return $headers;
|
|
}
|
|
}
|
|
function addVars(&$vars,$names,$defaults=null){
|
|
foreach ($names as $n){
|
|
$v=null;
|
|
if (! isset($_REQUEST[$n])){
|
|
if ($defaults == null || ! isset($defaults[$n])) throw new Exception("missing parameter $n");
|
|
$v=$defaults[$n];
|
|
}
|
|
else{
|
|
$v=safeName($_REQUEST[$n]);
|
|
}
|
|
$vars[$n]=$v;
|
|
}
|
|
return $vars;
|
|
}
|
|
|
|
function curl_exec_follow(/*resource*/ $ch, /*int*/ &$maxredirect = null) {
|
|
$mr = $maxredirect === null ? 5 : intval($maxredirect);
|
|
#echo("###handling redirects $mr\n");
|
|
if (ini_get('open_basedir') == '' && ini_get('safe_mode' == 'Off') && false) {
|
|
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, $mr > 0);
|
|
curl_setopt($ch, CURLOPT_MAXREDIRS, $mr);
|
|
} else {
|
|
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, false);
|
|
if ($mr > 0) {
|
|
$newurl = curl_getinfo($ch, CURLINFO_EFFECTIVE_URL);
|
|
$rch = curl_copy_handle($ch);
|
|
curl_setopt($rch, CURLOPT_HEADER, true);
|
|
#curl_setopt($rch, CURLOPT_NOBODY, true);
|
|
curl_setopt($rch, CURLOPT_FORBID_REUSE, false);
|
|
curl_setopt($rch, CURLOPT_RETURNTRANSFER, true);
|
|
do {
|
|
#echo("###trying $newurl\n");
|
|
curl_setopt($rch, CURLOPT_URL, $newurl);
|
|
curl_setopt($ch, CURLOPT_URL, $newurl);
|
|
$header = curl_exec($rch);
|
|
if (curl_errno($rch)) {
|
|
$code = 0;
|
|
} else {
|
|
$code = curl_getinfo($rch, CURLINFO_HTTP_CODE);
|
|
#echo("###code=$code\n");
|
|
if ($code == 301 || $code == 302) {
|
|
preg_match('/Location:(.*?)\n/', $header, $matches);
|
|
$newurl = trim(array_pop($matches));
|
|
} else {
|
|
if ($code >= 300){
|
|
trigger_error("HTTP error $code");
|
|
}
|
|
$code = 0;
|
|
}
|
|
}
|
|
} while ($code && --$mr);
|
|
curl_close($rch);
|
|
if (!$mr) {
|
|
if ($maxredirect === null) {
|
|
trigger_error('Too many redirects. When following redirects, libcurl hit the maximum amount.', E_USER_WARNING);
|
|
} else {
|
|
$maxredirect = 0;
|
|
}
|
|
return false;
|
|
}
|
|
curl_setopt($ch, CURLOPT_URL, $newurl);
|
|
}
|
|
}
|
|
curl_setopt(
|
|
$ch,
|
|
CURLOPT_HEADERFUNCTION,
|
|
function ($curl, $header) {
|
|
header($header);
|
|
return strlen($header);
|
|
}
|
|
);
|
|
curl_setopt(
|
|
$ch,
|
|
CURLOPT_WRITEFUNCTION,
|
|
function ($curl, $body) {
|
|
echo $body;
|
|
return strlen($body);
|
|
}
|
|
);
|
|
header('Access-Control-Allow-Origin:*');
|
|
return curl_exec($ch);
|
|
}
|
|
|
|
function getFwHeaders($aheaders=null){
|
|
$headers=getallheaders();
|
|
$FWHDR = ['User-Agent'];
|
|
$outHeaders = array();
|
|
foreach ($FWHDR as $k) {
|
|
if (isset($headers[$k])) {
|
|
array_push($outHeaders, "$k: $headers[$k]");
|
|
}
|
|
}
|
|
if ($aheaders != null){
|
|
foreach ($aheaders as $hk => $hv){
|
|
array_push($outHeaders,"$hk: $hv");
|
|
}
|
|
}
|
|
return $outHeaders;
|
|
}
|
|
function getJson($url,$headers=null,$doThrow=false,$jsonData=null){
|
|
$curl = curl_init();
|
|
curl_setopt($curl, CURLOPT_URL,$url);
|
|
curl_setopt($curl,CURLOPT_RETURNTRANSFER, true);
|
|
$outHeaders=getFwHeaders($headers);
|
|
if ($jsonData != null){
|
|
$json=json_encode($jsonData);
|
|
array_push($outHeaders,"Content-Type: application/json");
|
|
array_push($outHeaders,"Content-length: ".strlen($json));
|
|
curl_setopt($curl, CURLOPT_POSTFIELDS,$json);
|
|
}
|
|
curl_setopt($curl, CURLOPT_HTTPHEADER, $outHeaders);
|
|
$response = curl_exec($curl);
|
|
$httpcode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
|
|
#echo("curl exec for $url:$response:$httpcode\n");
|
|
if($e = curl_error($curl)) {
|
|
curl_close($curl);
|
|
if ($doThrow) throw new Exception($e);
|
|
return array('error'=>$e);
|
|
} else {
|
|
if ($httpcode >= 300){
|
|
curl_close($curl);
|
|
if ($doThrow) throw new Exception("HTTP error $httpcode");
|
|
return array('error'=>"HTTP code ".$httpcode);
|
|
}
|
|
curl_close($curl);
|
|
return json_decode($response, true);
|
|
}
|
|
}
|
|
class HTTPErrorException extends Exception{
|
|
public $code=0;
|
|
public function __construct($c,$text){
|
|
parent::__construct($text);
|
|
$this->code=$c;
|
|
}
|
|
};
|
|
function proxy_impl($url, $timeout=30,$headers=null,$num = 5)
|
|
{
|
|
$nexturl=$url;
|
|
while ($num > 0 && $nexturl != null) {
|
|
$num--;
|
|
$code=0;
|
|
$ch = curl_init($nexturl);
|
|
$nexturl=null;
|
|
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, false);
|
|
curl_setopt($ch, CURLOPT_TIMEOUT,$timeout);
|
|
if ($headers != null){
|
|
curl_setopt($ch,CURLOPT_HTTPHEADER,$headers);
|
|
}
|
|
curl_setopt(
|
|
$ch,
|
|
CURLOPT_HEADERFUNCTION,
|
|
function ($curl, $header) use(&$nexturl,&$code){
|
|
#echo ("###header:$header\n");
|
|
if ($code == 0){
|
|
$code = curl_getinfo($curl, CURLINFO_HTTP_CODE);
|
|
}
|
|
#echo ("???code=$code\n");
|
|
if ($code == 301 || $code == 302) {
|
|
if(preg_match('/[Ll]ocation:(.*?)\n/', $header, $matches)){
|
|
$nexturl = trim(array_pop($matches));
|
|
#echo("???nexturl=$nexturl\n");
|
|
}
|
|
}
|
|
if ($code != 0 && $code < 300){
|
|
header($header);
|
|
}
|
|
return strlen($header);
|
|
}
|
|
);
|
|
curl_setopt(
|
|
$ch,
|
|
CURLOPT_WRITEFUNCTION,
|
|
function ($curl, $body) use(&$code) {
|
|
if ($code != 0 && $code < 300){
|
|
#echo ("### body part " . strlen($body)."\n");
|
|
echo $body;
|
|
return strlen($body);
|
|
}
|
|
return false;
|
|
}
|
|
);
|
|
$rs = curl_exec($ch);
|
|
#echo ("###code=$code\n");
|
|
curl_close($ch);
|
|
if ($nexturl == null){
|
|
if ($code != 200) throw new HTTPErrorException($code,"HTTP status $code");
|
|
return true;
|
|
}
|
|
}
|
|
throw new HTTPErrorException(500,"too many redirects");
|
|
}
|
|
|
|
function proxy($url)
|
|
{
|
|
header('Access-Control-Allow-Origin:*');
|
|
return proxy_impl($url,30,getFwHeaders());
|
|
}
|
|
|
|
?>
|