107 lines
11 KiB
PHP
107 lines
11 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
require dirname(__DIR__).'/bootstrap.php';
|
|
use PrelandAdmin\{Auth,Store,Config,Transport,Jobs,Sets,Problem,LinkBuilder,Notes,Copy,UtmPresets};
|
|
header('X-Content-Type-Options: nosniff');header('X-Frame-Options: DENY');header('Referrer-Policy: same-origin');header('Cache-Control: no-store');
|
|
$path=parse_url($_SERVER['REQUEST_URI']??'/',PHP_URL_PATH);
|
|
if(!str_starts_with((string)$path,'/api/')) {require dirname(__DIR__).'/views/dashboard.php';exit;}
|
|
header('Content-Type: application/json; charset=utf-8');
|
|
function reply(array $payload,int $status=200): never {http_response_code($status);echo json_encode(['ok'=>true]+$payload,JSON_UNESCAPED_UNICODE|JSON_UNESCAPED_SLASHES|JSON_THROW_ON_ERROR);exit;}
|
|
try {
|
|
Auth::session();$store=new Store();$auth=new Auth($store);$jobs=new Jobs($store);$sets=new Sets($store);$method=$_SERVER['REQUEST_METHOD']??'GET';$data=[];
|
|
if(!in_array($method,['GET','POST','DELETE','PUT'],true))throw new Problem('Метод не поддерживается.',405);
|
|
if($method!=='GET'){
|
|
$origin=$_SERVER['HTTP_ORIGIN']??'';
|
|
if($origin!=='' && strcasecmp((string)parse_url($origin,PHP_URL_HOST),(string)preg_replace('/:\d+$/','',$_SERVER['HTTP_HOST']??''))!==0)throw new Problem('Недопустимый источник запроса.',403);
|
|
if(!str_starts_with($_SERVER['CONTENT_TYPE']??'','multipart/form-data')){
|
|
if((int)($_SERVER['CONTENT_LENGTH']??0)>2097152)throw new Problem('Запрос слишком большой.',413);
|
|
$raw=file_get_contents('php://input',false,null,0,2097153);if(strlen($raw)>2097152)throw new Problem('Запрос слишком большой.',413);
|
|
if($raw!==''){$object=json_decode($raw,false,32,JSON_THROW_ON_ERROR);if(!$object instanceof stdClass)throw new Problem('Ожидался объект запроса.');$data=(array)$object;}
|
|
}else $data=$_POST;
|
|
}
|
|
if($path==='/api/login'&&$method==='POST'){
|
|
if(array_key_exists('remember',$data)&&!is_bool($data['remember']))throw new Problem('Поле «Запомнить меня» должно быть логическим значением.');
|
|
reply($auth->login((string)($data['username']??''),(string)($data['password']??''),$_SERVER['REMOTE_ADDR']??'unknown',$data['remember']??false));
|
|
}
|
|
$user=$auth->requireUser();
|
|
if($method!=='GET')$auth->csrf($_SERVER['HTTP_X_CSRF_TOKEN']??'');
|
|
if($path==='/api/logout'&&$method==='POST'){$auth->logout();reply([]);}
|
|
// Авторизация, idle timestamp и CSRF уже проверены; SSH/файловые операции
|
|
// не должны удерживать PHP session lock и блокировать соседние запросы.
|
|
session_write_close();
|
|
// Удаление и постановка заданий используют одну блокировку: транспорт нельзя
|
|
// удалить между проверкой существования подключения и записью задания.
|
|
$enqueue=static function(callable $create,array $selections)use($store){return $store->locked('targets',function()use($create,$selections,$store){foreach($selections as $selection){$id=is_array($selection)?($selection['id']??null):$selection;if(!is_string($id))throw new Problem('Некорректная цель задания.');$store->target($id);}return $create();});};
|
|
if($path==='/api/state'&&$method==='GET')reply(['csrf'=>$_SESSION['csrf'],'user'=>$user,'targets'=>$store->targets()]);
|
|
if($path==='/api/utm-notes'){
|
|
$notes=new Notes($store);
|
|
if($method==='GET'){
|
|
if($_GET)throw new Problem('Заметки UTM общие для всех доменов и не принимают параметры.');
|
|
reply(['notes'=>$notes->all()]);
|
|
}
|
|
if($method==='POST')reply(['note'=>$notes->save($data)]);
|
|
throw new Problem('Метод заметок UTM не поддерживается.',405);
|
|
}
|
|
if($path==='/api/link-builder'){
|
|
$builder=new LinkBuilder($store);
|
|
if($method==='GET'){
|
|
if(array_diff(array_keys($_GET),['target'])||!is_string($_GET['target']??null))throw new Problem('Укажите ID подключения конструктора ссылки.');
|
|
reply($builder->get($_GET['target']));
|
|
}
|
|
if($method==='POST'){
|
|
if(count($data)!==2||array_diff(array_keys($data),['target','selection'])||!is_string($data['target']??null)||!(($data['selection']??null) instanceof stdClass))throw new Problem('Передайте ID подключения и объект выбора конструктора ссылки.');
|
|
reply($builder->save($data['target'],get_object_vars($data['selection'])));
|
|
}
|
|
throw new Problem('Метод конструктора ссылки не поддерживается.',405);
|
|
}
|
|
if($path==='/api/targets'&&$method==='POST')reply(['target'=>$store->saveTarget((array)($data['target']??[]),isset($data['secret'])?(string)$data['secret']:null)]);
|
|
if($path==='/api/targets/visibility'&&$method==='POST'){
|
|
if(count($data)!==2||array_diff(array_keys($data),['id','hidden'])||!is_string($data['id']??null)||!is_bool($data['hidden']??null))throw new Problem('Передайте строковый ID и логическое значение hidden.');
|
|
reply(['targets'=>$store->setTargetVisibility($data['id'],$data['hidden'])]);
|
|
}
|
|
if($path==='/api/targets/order'&&$method==='POST'){
|
|
if(count($data)!==1||!is_array($data['ids']??null)||!array_is_list($data['ids']))throw new Problem('Передайте список строковых ID в поле ids.');
|
|
reply(['targets'=>$store->orderTargets($data['ids'])]);
|
|
}
|
|
if($path==='/api/targets'&&$method==='DELETE'){$store->deleteTarget((string)($data['id']??''));reply([]);}
|
|
if($path==='/api/targets/test'&&$method==='POST'){$id=(string)($data['id']??'');$t=$store->target($id);(new Transport($store,$t))->test();$store->verifyTarget($id,$t);reply(['message'=>'Пути, блокировка, чтение и права записи проверены.']);}
|
|
if($path==='/api/config'&&$method==='GET'){
|
|
$target=$store->target((string)($_GET['target']??''));$read=(new Transport($store,$target))->readConfig();$readAt=gmdate(DATE_ATOM);
|
|
reply(['config'=>$read['config'],'version'=>$read['version'],'read_at'=>$readAt,'warnings'=>[],'sets'=>$sets->list($target,$read['config'])]);
|
|
}
|
|
if($path==='/api/utm-presets'){
|
|
$presets=new UtmPresets($store);
|
|
if($method==='GET'){if($_GET)throw new Problem('Список наборов не привязан к доменам.');reply(['presets'=>$presets->all()]);}
|
|
if($method==='POST')reply(['preset'=>$presets->create($data)],201);
|
|
if($method==='DELETE'){if(count($data)!==1||!is_string($data['id']??null))throw new Problem('Передайте только ID набора.');$presets->delete($data['id']);reply([]);}
|
|
throw new Problem('Метод наборов не поддерживается.',405);
|
|
}
|
|
if($path==='/api/copy'){
|
|
if($method!=='POST')throw new Problem('Метод копирования не поддерживается.',405);
|
|
reply(['job'=>$enqueue(fn()=>(new Copy($store))->create($data),[])],202);
|
|
}
|
|
if($path==='/api/apply'&&$method==='POST'){$data['targets']=array_map(static fn($t)=>(array)$t,(array)($data['targets']??[]));$data['changes']=array_map(static fn($c)=>(array)$c,(array)($data['changes']??[]));reply(['job'=>$enqueue(fn()=>$jobs->create('apply',$data),$data['targets'])],202);}
|
|
if($path==='/api/jobs'&&$method==='GET')reply(isset($_GET['id'])?['job'=>$jobs->get((string)$_GET['id'])]:['jobs'=>$jobs->all()]);
|
|
if($path==='/api/jobs/retry'&&$method==='POST')reply(['job'=>$enqueue(fn()=>$jobs->retry((string)($data['id']??''),(array)($data['targets']??[])),(array)($data['targets']??[]))],202);
|
|
if($path==='/api/backups'&&$method==='GET'){$id=(string)($_GET['target']??'');$store->target($id);reply(['backups'=>$store->backups($id)]);}
|
|
if($path==='/api/restore'&&$method==='POST')reply(['job'=>$enqueue(fn()=>$jobs->create('restore',$data),[$data['target']??null])],202);
|
|
if($path==='/api/sets'&&$method==='GET'){$target=$store->target((string)($_GET['target']??''));$read=(new Transport($store,$target))->readConfig();reply(['sets'=>$sets->list($target,$read['config']),'version'=>$read['version']]);}
|
|
if($path==='/api/sets/upload'&&$method==='POST'){
|
|
if(($_FILES['file']['error']??UPLOAD_ERR_NO_FILE)!==UPLOAD_ERR_OK||!is_uploaded_file($_FILES['file']['tmp_name']))throw new Problem('ZIP не получен либо превышает лимит 64 МиБ.');
|
|
$number=Sets::number($data['number']??0);$prepared=$sets->prepareZip($_FILES['file']['tmp_name'],$number);
|
|
$targets=json_decode((string)($data['targets']??'[]'),true,16,JSON_THROW_ON_ERROR);
|
|
reply(['job'=>$enqueue(fn()=>$jobs->create('upload',['targets'=>$targets,'number'=>$number,'name'=>(string)($data['name']??''),'prepared'=>$prepared]),$targets)],202);
|
|
}
|
|
if(in_array($path,['/api/sets/check','/api/sets/register'],true)&&$method==='POST'){$data['number']=Sets::number($data['number']??0);reply(['job'=>$enqueue(fn()=>$jobs->create($path==='/api/sets/check'?'check':'register',$data),(array)($data['targets']??(isset($data['target'])?[$data['target']]:[])))],202);}
|
|
if(in_array($path,['/api/sets/name','/api/sets/delete'],true)&&$method==='POST'){$target=$store->target((string)($data['target']??''));$number=Sets::number($data['number']??0);if($path==='/api/sets/name')$sets->name($target,$number,(string)($data['name']??''));else $sets->delete($target,$number);reply([]);}
|
|
throw new Problem('Маршрут не найден.',404);
|
|
}catch(Problem $e){
|
|
// Запоздалый 401 (анонимный запрос, истечение сессии, ошибка входа) не должен
|
|
// подменять или удалять cookie более нового успешного входа. Истёкший backing
|
|
// Auth уже отзывает на сервере; явный logout возвращает 200 и очищает cookie.
|
|
if($e->status===401)header_remove('Set-Cookie');
|
|
http_response_code($e->status);echo json_encode(['ok'=>false,'error'=>$e->getMessage()],JSON_UNESCAPED_UNICODE|JSON_THROW_ON_ERROR);
|
|
}
|
|
catch(JsonException){http_response_code(400);echo json_encode(['ok'=>false,'error'=>'Некорректный JSON запроса.'],JSON_UNESCAPED_UNICODE);}
|
|
catch(Throwable){http_response_code(500);echo json_encode(['ok'=>false,'error'=>'Операция не выполнена. Проверьте доступность и повторите.'],JSON_UNESCAPED_UNICODE);}
|