failj/ntspi-app
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change nginx.conf

Browse Source
This commit is contained in:
F4ilji
2026-01-22 13:38:34 +05:00
parent 8104d0b6cd
commit c4be035890
47 changed files with 8872 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
public/vikon_core/update/check_curl.php
+52
View File
@@ -0,0 +1,52 @@
<?php
function isCurlExists()
{
if (in_array('curl', get_loaded_extensions())) {
return true;
} else {
return false;
}
}
function checkCurl($url, $postFields = false)
{
$error = '';
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_ENCODING, "");
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
if (is_array($postFields)) {
curl_setopt($ch, CURLOPT_POST, true);
$postVars = "";
foreach ($postFields as $key => $value) {
$postVars .= $key . '=' . $value . '&';
}
$postVars = rtrim($postVars, '&');
curl_setopt($ch, CURLOPT_POSTFIELDS, $postVars);
}
curl_exec($ch);
if (curl_errno($ch) > 0 || curl_error($ch)) {
$error = 'Curl error code: ' . curl_errno($ch) . '. Error: ' . curl_error($ch);
}
curl_close($ch);
return $error;
}
if (!isCurlExists()) {
echo '<p class="alert alert-danger">
На Вашем сервере отсутствует расширение PHP для работы с cURL.<br>
Вам следует обратиться в службу технической поддержки Вашего хостинг-провайдера с просьбой
включить PHP расширение curl.
</p>';
} else {
if (($err = checkCurl($apiDomen)) || ($err = checkCurl($apiDomen, array('post' => 42)))) {
echo '<p class="alert alert-danger">
В процессе тестирования соединения с сервером обновлений, PHP расширение cURL вернуло
следующую ошибку:<br> ' . $err .
'</p>';
}
}
public/vikon_core/update/check_entry_point.php
+26
View File
@@ -0,0 +1,26 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
if (!isset($_GET['entry']) && filterEntry($_GET['entry'])) {
sendErrorResponse(422, 'Некорректный entry');
}
$entry = $_GET['entry'];
try {
$headers = array('Accept: application/json');
$result = remoteRequest($apiDomen . 'oauth2/checkEntryPoint?client_id=' . $clientId . '&entry_point=' . $entry, true, false, $headers);
if ($result->curlHasError) {
sendErrorResponse(500, 'Не удалось соединиться с сервером.' . $result->curlErrorTxt);
} else {
setResponseCode($result->code);
}
loadHeaders();
echo json_encode(array('success' => $result->responseBody->success));
} catch (Exception $e) {
sendErrorResponse(500, 'Не удалось проверить настройки безопасности.' . $e->getMessage());
}
public/vikon_core/update/check_filesystem.php
+74
View File
@@ -0,0 +1,74 @@
<?php
$updateDir = dirname(__FILE__);
$rootDir = dirname($updateDir);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
$errPrefix = 'Для запуска инструмента не удалось подтвердить подлинность вашего токена доступа. ';
if (!isset($_POST['access_token']) || !filterAccessToken($_POST['access_token'])) {
sendErrorResponse(422, $errPrefix . 'Токен доступа отсутствует или некорректен.');
}
$token = $_POST['access_token'];
try {
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$res = remoteRequest($apiDomen . 'pull_updates/checkAccessJson', true, false, $headers);
if ($res->curlHasError) {
sendErrorResponse(500, 'Ошибка CURL при выполнении запроса авторизации. ' . $errPrefix . $res->curlErrorTxt);
}
if ($res->code !== 200) {
$err = $errPrefix . (!empty($res->responseBody->message) ? $res->responseBody->message : 'Неизвестная ошибка.');
sendErrorResponse($res->code, $err);
}
Path::init($modulesByPathDeploy);
$payload = array(
'is_access_allowed' => true,
'err' => null
);
$message = isWritableRecrusive($rootDir);
if ($message) {
$payload['is_access_allowed'] = false;
$payload['err'] = $message;
}
loadHeaders();
setResponseCode(200);
echo json_encode(
array(
'success' => true,
'forward_code' => 200,
'payload' => $payload
)
);
die();
} catch (Exception $e) {
sendErrorResponse(500, $e->getMessage());
}
function isWritableRecrusive($dir)
{
$message = '';
if (is_dir($dir)) {
if (is_writable($dir)) {
$objects = scandir($dir);
foreach ($objects as $object) {
if ($object != "." && $object != "..") {
$objectPath = Path::join($dir, $object);
$message .= isWritableRecrusive($objectPath);
}
}
} else {
$message .= 'Отсутствуют права на запись: "' . htmlspecialchars($dir) . '"<br>';
}
} else {
if (!is_writable($dir)) {
$message .= 'Отсутствуют права на запись: "' . htmlspecialchars($dir) . '"<br>';
}
}
return $message;
}
public/vikon_core/update/cleaner.php
+59
View File
@@ -0,0 +1,59 @@
<?php
//todo new_core_after del
require_once dirname(__FILE__) . '/../internal/config.php';
require_once dirname(__FILE__) . '/../internal/helper.php';
require_once dirname(__FILE__) . '/../internal/filesystem.php';
if (!isset($_GET['is_access_remove_old_scripts_update'])) {
$isAccessRemoveOldScriptsUpdate = 0;
}
if (!in_array((int) $_GET['is_access_remove_old_scripts_update'], array(0, 1))) {
$isAccessRemoveOldScriptsUpdate = 0;
}
$isAccessRemoveOldScriptsUpdate = (int) $_GET['is_access_remove_old_scripts_update'];
Path::init($modulesByPathDeploy);
$vikonRootPath = Path::getCoreRootPath();
//remove executor
$executorPath = Path::join($vikonRootPath, Path::$executorFile);
if (!Filesystem::remove($executorPath, false)) {
sendErrorResponse(500, 'Ошибка при очистке ядра. Не удалось удалить исполняемый файл:' . $executorPath);
}
//fail
//vikon_core-latest
$vikonCoreLatestPath = Path::join($vikonRootPath, 'vikon_core-latest');
if (!Filesystem::remove($vikonCoreLatestPath, true)) {
sendErrorResponse(500, 'Ошибка при очистке ядра. Не удалось удалить исполняемый файл:' . $vikonCoreLatestPath);
}
//Удаляем старые скрипты в папке sveden/update
if ($isAccessRemoveOldScriptsUpdate) {
$svedenRoot = Path::getModuleRootPath(SVEDEN);
if (!file_exists($svedenRoot)) {
sendSuccessResponse('Временные файлы успешно удалены.');
}
$svedenFuncPath = Path::join($svedenRoot, 'update');
if (!file_exists($svedenFuncPath)) {
sendSuccessResponse('Временные файлы успешно удалены.');
}
$entriesFunc = Filesystem::safeScandir($svedenFuncPath);
if (!$entriesFunc) {
sendSuccessResponse('Временные файлы успешно удалены.');
}
$excludeEntries = array('index.php');
foreach ($entriesFunc as $entry) {
if (in_array($entry, $excludeEntries)) {
continue;
}
if (!Filesystem::remove(Path::join($svedenFuncPath, $entry), true, SVEDEN)) {
sendErrorResponse(500, 'Ошибка при очистке ядра. Не удалось удалить исполняемый файл:' . Path::join($svedenFuncPath, $entry));
}
}
}
sendSuccessResponse('Временные файлы успешно удалены.');
public/vikon_core/update/complete.php
Executable
+44
View File
@@ -0,0 +1,44 @@
<?php
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/config.php';
require_once $selfDir . '/../internal/helper.php';
$res = array();
$res['success'] = false;
if (!isset($_POST['access_token']) || !filterAccessToken($_POST['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
try {
$headers = array(
'Accept: application/json',
'Authorization: Bearer ' . $token = $_POST['access_token'],
);
$response = remoteRequest($apiDomen . 'pull_updates/assist/updateEndedSuccessByNewCoreJson', true, array(), $headers);
if (!$response->curlHasError) {
if (200 === $response->code) {
$resultBody = array(
'success' => true,
'forward_code' => 200,
);
} else {
$resultBody = array(
'success' => false,
'forward_code' => $response->code,
'message' => !empty($response->responseBody->message )
? $response->responseBody->message
: 'Неизвестная ошибка'
);
}
} else {
throw new RuntimeException( 'CURL ' . $response->curlErrorTxt);
}
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/cur_version.php
+1
View File
@@ -0,0 +1 @@
5.76.10.1
public/vikon_core/update/download_module_core.php
+239
View File
@@ -0,0 +1,239 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
if (!isset($_GET['access_token']) || !filterAccessToken($_GET['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
if (!isset($_GET['module_id']) || !filterInt($_GET['module_id'])) {
sendErrorResponse(422, 'Некорректный module_id');
}
$moduleId = (int)$_GET['module_id'];
$token = $_GET['access_token'];
Path::init($modulesByPathDeploy);
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
sendErrorResponse(422, 'Не верно передан параметр модуля');
}
$moduleFolder = $modulesByPathDeploy[$moduleId];
$foldersNeedStay = $allowedFoldersInCoreByModule[$moduleId];
$moduleRootPath = Path::getModuleRootPath($moduleId);
$flagFileOfModulePath = Path::join($moduleRootPath, '.vikon');
try {
if ($moduleId === ABITUR) {
$headers = array('Accept-Encoding: zip, gzip', 'Authorization: Bearer ' . $token);
$zipModuleCore = remoteRequest(
$apiDomen . 'pull_updates/generateEmptyModuleCore/' . $moduleId,
false,
false,
$headers
);
if ($zipModuleCore->curlHasError) {
throw new RuntimeException('CURL ' . $zipModuleCore->curlErrorTxt);
}
if ($zipModuleCore->code !== 200) {
$zipModuleCore->responseBody = json_decode($zipModuleCore->responseBody);
$err = 'Не удается скачать файл с обновлениями. ' . (!empty($zipModuleCore->responseBody->message)
? $zipModuleCore->responseBody->message
: 'Неизвестная ошибка');
sendErrorResponse($zipModuleCore->code, $err);
}
$zipModuleCore->responseBody = json_decode($zipModuleCore->responseBody);
if ($zipModuleCore->responseBody->success === true) {
moduleDirIsEmptyOrEx($moduleRootPath, $flagFileOfModulePath);
if (!Filesystem::safeMkdir($moduleRootPath, 0755, $moduleId)) {
$err = 'Ошибка при распаковке ядра модуля. Не удалось создать папку: ' . $moduleFolder;
sendErrorResponse(500, $err);
}
$filesDirectory = Path::join($moduleRootPath, 'files');
if (!Filesystem::safeMkdir($filesDirectory, 0755, $moduleId)) {
$err = 'Ошибка при распаковке ядра модуля. Не удалось создать папку: files';
sendErrorResponse(500, $err);
}
$msg = 'Ядро модуля "' . $moduleFolder . '" успешно обновлено и синхронизировано.';
if (!Filesystem::safeMkfile($flagFileOfModulePath, 0755)) {
throw new Exception('Не удалось записать служебную информацию в директорию: ' . $flagFileOfModulePath);
}
sendSuccessResponse($msg);
}
sendSuccessResponse('Неизвестная ошибка');
}
$headers = array('Accept-Encoding: zip, gzip', 'Authorization: Bearer ' . $token);
$zipModuleCore = remoteRequest(
$apiDomen . 'pull_updates/generateEmptyModuleCore/' . $moduleId,
false,
false,
$headers
);
if ($zipModuleCore->curlHasError) {
throw new RuntimeException('CURL ' . $zipModuleCore->curlErrorTxt);
}
if ($zipModuleCore->code != 200) {
$zipModuleCore->responseBody = json_decode($zipModuleCore->responseBody);
$err = 'Не удается скачать файл с обновлениями. ' . (!empty($zipModuleCore->responseBody->message)
? $zipModuleCore->responseBody->message
: 'Неизвестная ошибка');
sendErrorResponse($zipModuleCore->code, $err);
}
moduleDirIsEmptyOrEx($moduleRootPath, $flagFileOfModulePath);
$funcPath = Path::getFunctionalPath();
$filenameZip = Path::join($funcPath, $moduleFolder . '_core-latest.zip');
if (!Filesystem::removeZip($filenameZip, true)) {
$err = 'Ошибка при распаковке ядра модуля. Архив уже существует. Недостаточно прав для его удаления';
sendErrorResponse(500, $err);
}
$dlHandler = fopen($filenameZip, 'w');
if (!fwrite($dlHandler, $zipModuleCore->responseBody)) {
$err = 'Ошибка при распаковке ядра модуля. Не удалось записать архив. Проверьте права доступа и свободное место.';
sendErrorResponse(500, $err);
}
$unpackNewModuleCorePath = Path::join($funcPath, $moduleFolder);
if (!Filesystem::remove($unpackNewModuleCorePath, true)) {
$err = 'Ошибка при распаковке ядра модуля. Временая директория уже существует и не может быть удалена.';
sendErrorResponse(500, $err);
}
if (!unpackZip($filenameZip, $funcPath)) {
$err = 'Ошибка при распаковке ядра модуля. Проверьте права доступа и свободное место.';
sendErrorResponse(500, $err);
}
Filesystem::removeZip($filenameZip, false);
// перед синхронизацией убедимся что папка модуля вообще существует
if (!Filesystem::safeMkdir($moduleRootPath, 0755, $moduleId)) {
$err = 'Ошибка обновлении ядра модуля. Не удалось создать папку модуля: ' . $moduleFolder;
sendErrorResponse(500, $err);
}
$filesDirectory = Path::join($moduleRootPath, 'files');
if (!Filesystem::safeMkdir($filesDirectory, 0755, $moduleId)) {
$err = 'Ошибка обновлении ядра модуля. Не удалось создать папку в модуле: files';
sendErrorResponse(500, $err);
}
$entriesToSync = Filesystem::safeScandir($unpackNewModuleCorePath);
$serviceInfo = array('.vikon');
$failedEntryName = null;
foreach ($entriesToSync as $entryName) {
if (in_array($entryName, $serviceInfo)) {
continue;
}
$currentEntryPath = Path::join($moduleRootPath, $entryName);
$newEntryPath = Path::join($unpackNewModuleCorePath, $entryName);
$isFile = is_file($newEntryPath);
if (file_exists($currentEntryPath)) {
$newEntryPathWithNewPostfix = Path::join($moduleRootPath, $entryName . Path::$n_pstfx);
// try del
if (!Filesystem::remove($newEntryPathWithNewPostfix, true, $moduleId)) {
$failedEntryName = $entryName;
break;
}
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($newEntryPath, $newEntryPathWithNewPostfix, $moduleId)
: Filesystem::safeRenameFile($newEntryPath, $newEntryPathWithNewPostfix, $moduleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
$currentEntryPathWithOldPostfix = Path::join($moduleRootPath, $entryName . Path::$o_pstfx);
// try del
if (!Filesystem::remove($currentEntryPathWithOldPostfix, true, $moduleId)) {
$failedEntryName = $entryName;
break;
}
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($currentEntryPath, $currentEntryPathWithOldPostfix, $moduleId)
: Filesystem::safeRenameFile($currentEntryPath, $currentEntryPathWithOldPostfix, $moduleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($newEntryPathWithNewPostfix, $currentEntryPath, $moduleId)
: Filesystem::safeRenameFile($newEntryPathWithNewPostfix, $currentEntryPath, $moduleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
} else {
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($newEntryPath, $currentEntryPath, $moduleId)
: Filesystem::safeRenameFile($newEntryPath, $currentEntryPath, $moduleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
}
}
if ($failedEntryName !== null) {
if (!Filesystem::restoreUnitCoreAfterFail($moduleRootPath, $entriesToSync, $moduleId)) {
$err = 'Ошибка при синхронизации ядра модуля. Не удалось восстановить ядро после ошибки.';
sendErrorResponse(500, $err);
} else {
$err = 'Ошибка при синхронизации ядра модуля. Не удалось синхронизировать папку/файл: ' . $failedEntryName;
sendErrorResponse(500, $err);
}
}
Filesystem::remove($unpackNewModuleCorePath, true);
$successOrPath = Filesystem::cleanUnitCore($moduleRootPath, $foldersNeedStay, $moduleId);
if (is_string($successOrPath)) {
$err = 'Ошибка проверки целостности ядра модуля. Не удалось удалить папку: ' . $successOrPath;
sendErrorResponse(500, $err);
}
if (!$successOrPath) {
$err = 'Ошибка проверки целостности ядра модуля. Нет доступа к корневой папке ядра.';
sendErrorResponse(500, $err);
}
//todo new_core_after
if ($moduleId === SVEDEN) {
$updateDirModuleCore = Path::join($moduleRootPath, 'update');
$oldUpdateFile = Path::join($moduleRootPath, 'update', 'index.php');
Filesystem::safeMkdir($updateDirModuleCore, 0755, $moduleId);
Filesystem::safeMkfile($oldUpdateFile, 0755);
$protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off') ? 'https://' : 'http://';
$redirectPath = $locationOfVikonModules . 'vikon_core/update/index.php';
$redirectUrl = $protocol . $domenName . $redirectPath;
$indexContent = "<?php\n"
. "header('Location: " . $redirectUrl . "');\n"
. "exit;\n";
file_put_contents($oldUpdateFile, $indexContent);
}
if (!Filesystem::safeMkfile($flagFileOfModulePath, 0755)) {
throw new Exception('Не удалось записать служебную информацию в директорию: ' . $flagFileOfModulePath);
}
} catch (Exception $ex) {
sendErrorResponse(500, $ex->getMessage());
}
sendSuccessResponse('Ядро модуля "' . $moduleFolder . '" успешно обновлено и синхронизировано.');
public/vikon_core/update/get_access_token.php
+56
View File
@@ -0,0 +1,56 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
$res = array();
$res['success'] = false;
$codeSuccess = isset($_POST['code']) && filterAccessToken($_POST['code']);
$urlSuccess = isset($_POST['url']) && filterUrl($_POST['url']);
if (!$codeSuccess) {
sendErrorResponse(422, 'Некорректный авторизационный код');
}
if (!$urlSuccess) {
sendErrorResponse(422, 'Некорректный url выполнения запроса');
}
try {
$headers = array('Accept: application/json');
$data = remoteRequest($apiDomen . 'oauth2/authorize/token', true, array(
'code' => $_POST['code'],
'client_id' => $clientId,
'client_secret' => $clientSecret,
'redirect_uri' => $_POST['url'],
'grant_type' => 'authorization_code',
), $headers);
if ($data->curlHasError) {
$res['message'] = 'Не удалось соединиться с сервером.' . $data->curlErrorTxt;
setResponseCode(500);
} else {
if (isset($data->responseBody->access_token)) {
$res['access_token'] = $data->responseBody->access_token;
$res['refresh_token'] = $data->responseBody->refresh_token;
$res['success'] = true;
} else {
$message = '';
if (isset($data->responseBody->message)) {
$message = $data->responseBody->message;
} else {
$message = 'Ошибка при получении токена.';
}
$res['message'] = $message;
setResponseCode($data->code);
}
}
} catch (Exception $e) {
$res['message'] = 'Ошибка при получении ключа. ' . $e->getMessage();
setResponseCode(500);
}
loadHeaders();
echo json_encode($res);
public/vikon_core/update/get_module_version.php
+33
View File
@@ -0,0 +1,33 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
if (!isset($_GET['module_id']) || !filterInt($_GET['module_id'])) {
sendErrorResponse(422, 'Отсутствует идентификатор модуля или он указан некорректно');
}
$moduleId = (int) $_GET['module_id'];
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
sendErrorResponse(422, 'Не верно передан идентификатор модуля');
}
$tmpDir = Path::getTmpVersionPath();
$result = null;
$filePath = Path::join($tmpDir, $moduleId . '.json');
if (!file_exists($filePath) || !is_readable($filePath)) {
sendErrorResponse(422, 'Не получить файл с версией');
}
$json = @file_get_contents($filePath);
if ($json === false || $json === '') {
sendErrorResponse(422, 'Не удалось получить версию');
}
$data = @json_decode($json, true);
loadHeaders();
echo json_encode(array(
'success' => true,
'message' => '',
'forward_code' => 200,
'version' => isset($data['version']) ? htmlspecialchars($data['version']) : null
));
public/vikon_core/update/index.php
Executable
+226
View File
@@ -0,0 +1,226 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
header('Content-Type: text/html; charset=UTF-8');
$currentVersion = file_get_contents($updateDir . '/cur_version.php');
$showNewCoreInfo = isset($_GET['first_use_new_core']) && $_GET['first_use_new_core'] == '1';
?>
<!DOCTYPE html>
<html>
<head>
<meta http-equiv="Content-type" content="text/html;charset=UTF-8">
<meta http-equiv="Cache-Control" content="no-cache">
<meta charset="UTF-8">
<meta name="viewport" content="width=device-width, initial-scale=1.0">
<meta name="description" content="">
<meta name="author" content="">
<title>Полуавтоматическое обновление VIKON</title>
</head>
<body class="vikon-wrapper">
<input type="hidden" name="domen" value="<?php echo $domenName; ?>">
<input type="hidden" name="api_domen" value="<?php echo $apiDomen; ?>">
<input type="hidden" name="client_id" value="<?php echo $clientId; ?>">
<input type="hidden" name="current_version" value="<?php echo $currentVersion; ?>">
<div class="wrapper container">
<div class="main-wrapper">
<header class="header">
<div class="header-content">
<div class="header-logo vikon-logo" title="Vikon Logo">Vikon Logo</div>
<div class="header-title">Полуавтоматическое обновление VIKON</div>
</div>
<hr>
</header>
<div class="container-fluid">
<div class="form-group mb-4 d-flex justify-content-between">
<div>
<a href="/" class="btn btn-success">На главную</a>
<a href="#" class="btn btn-success" id="exit" style="display: none;">Выход</a>
</div>
<a href="https://db-nica.ru/rukovodstvo/selectFaq/43/132" target="_blank" class="btn btn-success help-button">Помощь</a>
</div>
<div class="alert alert-danger" id="message-container" style="display: none;"></div>
<div class="row" id="wait-load">
<div class="text-center">
<svg class="static-throbber" viewBox="0 0 50 50" style="width: 40px; height: 40px; margin-bottom: 10px;">
<circle class="path" cx="25" cy="25" r="20" fill="none" stroke-width="5" stroke="#007bff" />
</svg>
идет загрузка страницы
</div>
</div>
<div class="row" id="no-enter" style="display: none;">
<div class="col-sm-12 text-center">
<h3>Требуется вход</h3>
<div>
<button type="button" class="btn btn-success mb-3" id="enter-vikon">
Войти через VIKON
</button>
</div>
</div>
</div>
<?php if ($showNewCoreInfo) { ?>
<div class="row">
<div class="col-sm-12">
<div class="alert alert-info">
<p>
Переход на новую систему обновления успешно завершен! Для корректной работы системы, пожалуйста, <b>выполните полное обновление всех модулей</b>.
</p>
<p class="text-danger">Внимание! Директории модулей (/sveden, /abitur) являются точками синхронизации данных системы. Все их содержимое будет автоматически синхронизировано (перезаписано) данными из системы. Пожалуйста, убедитесь, что в этих папках нет личной информации или файлов, не относящихся к данным VIKON, чтобы избежать их потери.</p>
</div>
</div>
</div>
<?php } ?>
<div class="row" id="yes-enter" style="display: none;">
<div class="col-sm-6">
<h3>Текущая версия системы: <span class="badge bg-secondary"><?php echo $currentVersion; ?></span></h3>
<div class="settings-update" id="settings-update">
<div id="modules-container">
<!-- Модули будут вставлены здесь через JavaScript -->
</div>
<b>Настройки п/а обновления:</b>
<ul class="list-unstyled">
<li>
<div class="checkbox">
<input type="checkbox" name="is_resolve_domain" id="is_resolve_domain">
<label for="is_resolve_domain">
Использовать прямое подключение по IP-адресу к серверам VIKON
</label>
<span class="fas fa-question-circle"
data-bs-toggle="tooltip"
data-bs-placement="top"
title="Если в процессе работы у ПО не получается связаться с сервером (например, появляется сообщение об ошибке соединения), вы можете включить данную опцию. В этом режиме система будет подключаться напрямую к VIKON через IP-адрес.">
</span>
</div>
</li>
</ul>
</div>
<div class="d-none admin-mode-panel" id="admin-mode-panel">
<b>Дополнительные опции для администратора:</b>
<ul class="list-unstyled">
<li>
<div class="checkbox">
<input type="checkbox" name="no_core" id="no_core" value="no_core">
<label for="no_core">Не обновлять ядро</label>
</div>
</li>
<li>
<div class="checkbox">
<input type="checkbox" name="debug_mode" id="debug_mode" value="debug_mode">
<label for="debug_mode">Debug Mode</label>
</div>
</li>
</ul>
</div>
</div>
<div class="col-sm-6">
<h3>Наличие обновления: <span class="badge bg-warning" id="new-version">получение информации...</span></h3>
<div>
<button type="button" class="btn btn-success" id="start-update">Начать обновление</button>
</div>
<p class="alert alert-success" id="update-complete" style="display: none;"></p>
<p class="alert alert-danger" id="clear_tmp_error_layout" style="display: none;"></p>
<div class="row" id="progressbar-container" style="display: none;">
<div class="col-12">
<div class="progress">
<div id="progressbar" class="progress-bar progress-bar-striped progress-bar-animated"
role="progressbar" aria-valuenow="0" aria-valuemin="0" aria-valuemax="100"
style="width: 0;">
</div>
</div>
</div>
</div>
<div class="alert alert-info process-container" id="process-container" style="display: none;"></div>
</div>
</div>
</div>
<?php require_once $updateDir . '/check_curl.php'; ?>
</div>
<footer class="footer">
<hr>
<div class="text-center">
<p class="copyright">
Национальный фонд поддержки инноваций в сфере образования (НФПИ)
<br>
Copyright © 2013-<?php echo date('Y') ?>
</p>
</div>
</footer>
<script>
const CURRENT_VERSION = "<?php echo $currentVersion; ?>";
const ASSETS_BASE = "./../assets/";
let PATHNAME = window.location.pathname;
PATHNAME = PATHNAME.replace(/\/+$/, '');
PATHNAME = PATHNAME.replace(/\/index.php$/, '');
const getTargetContainer = (tag) => {
return document.getElementsByTagName(tag)[0] || document.documentElement;
};
const putStyle = (filename) => {
const head = getTargetContainer('head');
const link = document.createElement('link');
link.rel = 'stylesheet';
link.type = 'text/css';
link.href = `${PATHNAME}/${ASSETS_BASE}css/${filename}?v=${CURRENT_VERSION}`;
head.appendChild(link);
};
const loadScriptsSequentially = (filenames, index = 0) => {
return new Promise((resolve, reject) => {
if (index >= filenames.length) {
return resolve();
}
const filename = filenames[index];
const body = getTargetContainer('body');
const script = document.createElement('script');
script.src = `${PATHNAME}/${ASSETS_BASE}js/${filename}?v=${CURRENT_VERSION}`;
script.onload = () => {
loadScriptsSequentially(filenames, index + 1).then(resolve).catch(reject);
};
script.onerror = () => {
loadScriptsSequentially(filenames, index + 1).then(resolve).catch(reject);
};
body.appendChild(script);
});
};
const integrate = () => {
putStyle('update.css');
putStyle('vendor.css');
loadScriptsSequentially([
'vendor.js',
'update.js'
]).catch((е) => {
console.log('Не удалось динамически загрузить js-скрипты для работы полуавтоматического обновления')
});
};
integrate();
</script>
</div>
</body>
</html>
public/vikon_core/update/is_writable.php
+31
View File
@@ -0,0 +1,31 @@
<?php
$selfDir = dirname(__FILE__);
function isWritableR($dir)
{
$message = '';
if (is_dir($dir)) {
if (is_writable($dir)) {
$objects = scandir($dir);
foreach ($objects as $object) {
if ($object != "." && $object != "..") {
$message .= isWritableR($dir . DIRECTORY_SEPARATOR . $object);
}
}
} else {
$message .= 'Отсутствуют права на запись: "' . $dir . '"<br>';
}
} else if (!is_writable($dir)) {
$message .= 'Отсутствуют права на запись: "' . $dir . '"<br>';
}
return $message;
}
$messageSveden = '';
$root = dirname($selfDir);
if (file_exists($root)) {
$messageSveden = isWritableR($root);
}
if ($messageSveden) {
echo '<p class="alert alert-danger">' . $messageSveden . '</p>';
}
public/vikon_core/update/make_executor.php
+50
View File
@@ -0,0 +1,50 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
if (!isset($_GET['access_token']) || !filterAccessToken($_GET['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
$token = $_GET['access_token'];
$dlHandler = null;
try {
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$hasAccess = remoteRequest($apiDomen . 'pull_updates/checkAccessJson', true, false, $headers);
if ($hasAccess->curlHasError) {
throw new RuntimeException('CURL ' . $hasAccess->curlErrorTxt);
}
if ($hasAccess->code !== 200) {
$err = 'Не удается скачать файл с обновлениями. ' . (!empty($hasAccess->responseBody->message)
? $hasAccess->responseBody->message
: 'Неизвестная ошибка');
sendErrorResponse($hasAccess->code, $err);
}
if ($hasAccess->responseBody->success) {
$vikonRootPath = Path::getCoreRootPath();
$executorPath = Path::join($vikonRootPath, Path::$executorFile);
if (!Filesystem::remove($executorPath, false)) {
sendErrorResponse(500, 'Ошибка при генерации ядра. Не удалось удалить устаревший исполняемый скрипт: ' . $executorPath);
}
$srcForExecutorPath = Path::getSrcForExecutorPath();
$executorCode = file_get_contents($srcForExecutorPath);
if (!$executorCode || !Filesystem::safeMkfile($executorPath, 0755, $executorCode)) {
sendErrorResponse(500, 'Ошибка при генерации ядра. Не удалось создать исполняемый скрипт: ' . $executorPath);
}
sendSuccessResponse('');
}
} catch (Exception $ex) {
sendErrorResponse(500, $ex->getMessage());
}
if ($dlHandler) {
fclose($dlHandler);
}
public/vikon_core/update/purge.php
+69
View File
@@ -0,0 +1,69 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
if (!isset($_POST['access_token']) || !filterAccessToken($_POST['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
$token = $_POST['access_token'];
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$res = remoteRequest($apiDomen . 'pull_updates/checkAccessJson', true, false, $headers);
if ($res->curlHasError) {
sendErrorResponse(500, 'CURL ' . $res->curlErrorTxt);
}
if ($res->code !== 200) {
$err = 'Ошибка проверки подлинности токена. '
. (!empty($zipCore->responseBody->message) ? $zipCore->responseBody->message : 'Неизвестная ошибка');
sendErrorResponse($res->code, $err);
}
$isAccessRemoveOldScriptsUpdate = 0;
if (isset($_POST['is_access_remove_old_scripts_update']) && in_array((int) $_POST['is_access_remove_old_scripts_update'], array(0, 1))) {
$isAccessRemoveOldScriptsUpdate = (int) $_POST['is_access_remove_old_scripts_update'];
}
Path::init($modulesByPathDeploy);
$vikonRootPath = Path::getCoreRootPath();
//remove executor
$executorPath = Path::join($vikonRootPath, Path::$executorFile);
if (!Filesystem::remove($executorPath, false)) {
sendErrorResponse(500, 'Ошибка при очистке ядра. Не удалось удалить исполняемый файл:' . $executorPath);
}
//fail
$vikonCoreLatestPath = Path::join($vikonRootPath, 'vikon_core-latest');
if (!Filesystem::remove($vikonCoreLatestPath, true)) {
sendErrorResponse(500, 'Ошибка при очистке ядра. Не удалось удалить исполняемый файл:' . $vikonCoreLatestPath);
}
//todo new_core_after
//Удаляем старые скрипты в папке sveden/update
if ($isAccessRemoveOldScriptsUpdate) {
$svedenRoot = Path::getModuleRootPath(SVEDEN);
if (!file_exists($svedenRoot)) {
sendSuccessResponse('Временные файлы успешно удалены.');
}
$svedenFuncPath = Path::join($svedenRoot, 'update');
if (!file_exists($svedenFuncPath)) {
sendSuccessResponse('Временные файлы успешно удалены.');
}
$entriesFunc = Filesystem::safeScandir($svedenFuncPath);
if (!$entriesFunc) {
sendSuccessResponse('Временные файлы успешно удалены.');
}
$excludeEntries = array('index.php');
foreach ($entriesFunc as $entry) {
if (in_array($entry, $excludeEntries)) {
continue;
}
if (!Filesystem::remove(Path::join($svedenFuncPath, $entry), true, SVEDEN)) {
sendErrorResponse(500, 'Ошибка при очистке ядра. Не удалось удалить исполняемый файл:' . Path::join($svedenFuncPath, $entry));
}
}
}
sendSuccessResponse('Временные файлы успешно удалены.');
public/vikon_core/update/refresh_access_token.php
+50
View File
@@ -0,0 +1,50 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
if (!isset($_POST['refresh_token']) || !filterAccessToken($_POST['refresh_token'])) {
sendErrorResponse(422, 'Некорректный code');
}
$res = array();
$res['success'] = false;
$refreshToken = filterAccessToken($_POST['refresh_token']);
try {
$headers = array('Accept: application/json');
$data = remoteRequest($apiDomen . 'oauth2/RefreshToken', true, array(
'refresh_token' => $refreshToken,
'client_id' => $clientId,
'client_secret' => $clientSecret,
'grant_type' => 'refresh_token',
), $headers);
if ($data->curlHasError) {
$res['message'] = 'Не удалось соединиться с сервером.' . $data->curlErrorTxt;
setResponseCode(500);
} else {
if (isset($data->responseBody->access_token)) {
$res['access_token'] = $data->responseBody->access_token;
$res['refresh_token'] = $data->responseBody->refresh_token;
$res['success'] = true;
} else {
$message = '';
if (isset($data->responseBody->message)) {
$message = $data->responseBody->message;
} else {
$message = 'Ошибка при получении токена.';
}
$res['message'] = $message;
setResponseCode($data->code);
}
}
} catch (Exception $e) {
$res['message'] = 'Ошибка при обновлении ключа. ' . $e->getMessage();
setResponseCode(500);
}
loadHeaders();
echo json_encode($res);
public/vikon_core/update/request_generate_part.php
+44
View File
@@ -0,0 +1,44 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
if (!isset($_POST['access_token']) || !filterAccessToken($_POST['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
if (!isset($_POST['part']) || !filterPartName($_POST['part'])) {
sendErrorResponse(422, 'Некорректный part');
}
$token = $_POST['access_token'];
$part = $_POST['part'];
try {
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$post = array('part' => $part, 'is_new_core' => true);
$response = remoteRequest($apiDomen . 'pull_updates/generatePartByNewCoreJson', true, $post, $headers);
if (!$response->curlHasError) {
if (200 === $response->code) {
$resultBody = array(
'success' => true,
'operation_identity' => $response->responseBody->operation_identity,
'ttl' => $response->responseBody->ttl,
'forward_code' => 200,
);
} else {
$err = !empty($response->responseBody->message) ? $response->responseBody->message : 'Неизвестная ошибка';
sendErrorResponse($response->code, $err);
}
} else {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/request_new_file.php
+120
View File
@@ -0,0 +1,120 @@
<?php
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/config.php';
require_once $selfDir . '/../internal/helper.php';
require_once $selfDir . '/../internal/filesystem.php';
$token = filterAccessToken(isset($_POST['access_token']) ? (string) $_POST['access_token'] : '');
$moduleId = isset($_POST['moduleId']) ? filterInt($_POST['moduleId']) : null;
$dlHandler = null;
try {
Path::init($modulesByPathDeploy);
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
throw new RuntimeException('Не верно передан параметр модуля');
}
if (!$token) {
throw new RuntimeException('Некорректный access_token');
}
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$response = remoteRequest($filemanagerApiDomen . 'sync/getNewFileInfoByModule?moduleId=' . $moduleId, true, false, $headers);
if ($response->curlHasError) {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
if (
$response->code !== 200
|| !property_exists($response->responseBody, 'file_name')
|| !property_exists($response->responseBody, 'identity')
|| !property_exists($response->responseBody, 'dir_name')
) {
$msg = 'Не удалось получить информацию о файле, котрый требуется загрузить '
. tryExtractFmErrorMessage($response, '. ');
sendErrorResponse($response->code, $msg);
}
if ($response->responseBody->file_name === null && $response->responseBody->identity === null) {
$resultBody = array(
'success' => true,
'forward_code' => 200,
'done' => true,
);
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
die();
}
$fileIdentity = $response->responseBody->identity;
$filename = $response->responseBody->file_name;
$directory = $response->responseBody->dir_name;
if (!Filesystem::ensureValidDirectoryAndFileName($directory, $filename)) {
throw new RuntimeException('Некорректные параметры сохранения: недопустимое имя директории или файла.');
}
$headers = array('Accept-Encoding: zip, gzip', 'Authorization: Bearer ' . $token);
$binFile = remoteRequest(
$filemanagerApiDomen . 'sync/downloadFileBinary?identity=' . $fileIdentity,
false,
false,
$headers
);
if ($binFile->curlHasError) {
throw new RuntimeException('CURL ' . $binFile->curlErrorTxt);
}
if ($binFile->code !== 200) {
$binFile->responseBody = json_decode($binFile->responseBody);
$message = 'Не удается скачать файл ' . $filename . tryExtractFmErrorMessage($binFile, '. ');
sendErrorResponse($binFile->code, $message);
}
$fsPathDir = Path::getFsPathByModule($moduleId);
if ($directory !== null) {
$fsPathDir = Path::join($fsPathDir, $directory);
}
if (!Filesystem::safeMkdir($fsPathDir, 0775, $moduleId)) {
throw new RuntimeException('Не удалось создать папку "' . $fsPathDir . '" на вашем сервере');
}
$fsFilePath = Path::join($fsPathDir, $filename);
$dlHandler = fopen($fsFilePath, 'w');
if ($dlHandler == false || !fwrite($dlHandler, $binFile->responseBody)) {
throw new RuntimeException('Не удается записать файл ' . $fsFilePath . ' на диск', 500);
}
$headers = array('Authorization: Bearer ' . $token);
$response = remoteRequest(
$filemanagerApiDomen . 'sync/markNewFileAsLoaded?identity=' . $fileIdentity . '&moduleId=' . $moduleId,
true,
false,
$headers
);
if ($response->code !== 200) {
$message = 'Не удалось пометить файл' . $filename . ' как обновленный'
. tryExtractFmErrorMessage($response, '. ');
sendErrorResponse($response->code, $message);
}
$resultBody = array(
'success' => true,
'forward_code' => 200,
'message' => 'Файл ' . $filename . ' загружен',
'done' => false,
);
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
if ($dlHandler) {
fclose($dlHandler);
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/request_sync_file.php
+131
View File
@@ -0,0 +1,131 @@
<?php
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/config.php';
require_once $selfDir . '/../internal/helper.php';
require_once $selfDir . '/../internal/filesystem.php';
$token = filterAccessToken(isset($_POST['access_token']) ? (string) $_POST['access_token'] : '');
$fileIdentity = isset($_POST['fileIdentity']) && is_scalar($_POST['fileIdentity']) ? $_POST['fileIdentity'] : null;
$moduleId = isset($_POST['moduleId']) ? filterInt($_POST['moduleId']) : null;
$dlHandler = null;
Path::init($modulesByPathDeploy);
try {
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
throw new RuntimeException('Не верно передан параметр модуля');
}
if (!$token) {
throw new RuntimeException('Некорректный access_token');
}
if (!$fileIdentity) {
throw new RuntimeException('Передан невалидный идентификатор файла');
}
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$response = remoteRequest(
$filemanagerApiDomen . 'sync/getFileByIdentityInfo?identity=' . $fileIdentity,
true,
false,
$headers
);
if ($response->curlHasError) {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
if (
$response->code !== 200
|| !property_exists($response->responseBody, 'file_name')
|| !property_exists($response->responseBody, 'identity')
|| !property_exists($response->responseBody, 'dir_name')
) {
$resultBody = array(
'success' => false,
'forward_code' => $response->code == 200 ? 500 : $response->code,
'message' => (int) $response->code === 404
? 'Не удалось получить информацию об одном из синхронизируемых файлов. Файл был удален из системы после запуска процесса синхронизации. Перезапустите синхронизацию файлов.'
: 'Не удалось получить информацию о файле, котрый требуется загрузить ' . tryExtractFmErrorMessage($response, '. '),
'debug_identity' => $fileIdentity,
);
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
die();
}
$identity = $response->responseBody->identity;
$filename = $response->responseBody->file_name;
$directory = $response->responseBody->dir_name;
if (!Filesystem::ensureValidDirectoryAndFileName($directory, $filename)) {
throw new RuntimeException('Некорректные параметры сохранения: недопустимое имя директории или файла.');
}
$headers = array('Accept-Encoding: zip, gzip', 'Authorization: Bearer ' . $token);
$bin = remoteRequest(
$filemanagerApiDomen . 'sync/downloadFileBinaryForSync?identity=' . $identity . '&moduleId=' . $moduleId,
false,
false,
$headers
);
if ($bin->curlHasError) {
throw new RuntimeException('CURL ' . $bin->curlErrorTxt);
}
if ($bin->code !== 200) {
$bin->responseBody = json_decode($bin->responseBody);
$resultBody = array(
'success' => false,
'forward_code' => $bin->code,
'message' => 'Не удается скачать файл ' . $filename . tryExtractFmErrorMessage($bin, '. '),
'debug_identity' => $fileIdentity,
);
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
die();
}
$fsPathDir = Path::getFsPathByModule($moduleId);
if (!$fsPathDir) {
throw new RuntimeException('Неизвестная ошибка');
}
if ($directory !== null) {
$fsPathDir = Path::join($fsPathDir, $directory);
}
if (!Filesystem::safeMkdir($fsPathDir, 0775, $moduleId)) {
throw new RuntimeException('Не удалось создать папку "' . $fsPathDir . '" на вашем сервере');
}
$filePath = Path::join($fsPathDir, $filename);
$dlHandler = fopen($filePath, 'w');
if ($dlHandler === false) {
throw new RuntimeException('Не удается открыть файл для записи: ' . $filePath);
}
if (fwrite($dlHandler, $bin->responseBody) === false) {
throw new RuntimeException('Не удается записать файл на диск: ' . $filePath);
}
$resultBody = array(
'success' => true,
'forward_code' => 200,
'message' => 'Файл ' . $filename . ' загружен',
);
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
if ($dlHandler) {
fclose($dlHandler);
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/result_check_generate_part.php
+57
View File
@@ -0,0 +1,57 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
if (!isset($_POST['access_token']) || !filterAccessToken($_POST['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
if (!isset($_POST['operation_identity']) || !filter_var($_POST['operation_identity'], FILTER_SANITIZE_STRING)) {
sendErrorResponse(422, 'Некорректный operation_identity');
}
if (!isset($_POST['part']) || !filterPartName($_POST['part'])) {
sendErrorResponse(422, 'Некорректный part');
}
$token = $_POST['access_token'];
$operationIdentity = (string) $_POST['operation_identity'];
$part = $_POST['part'];
try {
$headers = array(
'Accept: application/json',
'Authorization: Bearer ' . $token,
);
$response = remoteRequest(
$apiDomen . 'pull_updates/checkPartGenerationByNewCoreResultJson?operation_identity=' . $operationIdentity . '&part=' . $part,
true,
false,
$headers
);
if (!$response->curlHasError) {
if ($response->code === 200) {
$resultBody = array(
'success' => true,
'forward_code' => 200,
);
} else {
$resultBody = array(
'success' => false,
'forward_code' => $response->code,
'message' => !empty($response->responseBody->message ) ? $response->responseBody->message : 'Неизвестная ошибка'
);
}
} else {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/result_download_part.php
+229
View File
@@ -0,0 +1,229 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
if (!isset($_POST['access_token']) || !filterAccessToken($_POST['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
if (!isset($_POST['operation_identity']) || !filter_var($_POST['operation_identity'], FILTER_SANITIZE_STRING)) {
sendErrorResponse(422, 'Некорректный operation_identity');
}
if (!isset($_POST['part']) || !filterPartName($_POST['part'])) {
sendErrorResponse(422, 'Некорректный part');
}
$dlHandler = null;
$token = $_POST['access_token'];
$operationIdentity = (string)$_POST['operation_identity'];
$part = $_POST['part'];
Path::init($modulesByPathDeploy);
try {
$headers = array(
'Authorization: Bearer ' . $token,
'Accept-Encoding: zip, gzip'
);
$response = remoteRequest(
$apiDomen . 'pull_updates/downloadPartByNewCoreResult?operation_identity=' . $operationIdentity . '&part=' . $part,
false,
false,
$headers
);
if (!$response->curlHasError) {
if ($response->code === 200) {
$curModuleId = 0;
foreach ($allowedFoldersInCoreByModule as $moduleId => $parts) {
if (is_array($parts) && in_array($part, $parts)) {
$curModuleId = $moduleId;
break;
}
}
$funcPath = Path::getFunctionalPath();
$filenameZip = Path::join($funcPath, $operationIdentity . '.zip');
if (!Filesystem::removeZip($filenameZip, true)) {
$err = 'Ошибка при распаковке раздела: "' . $part . '".'
. ' Базовый архив раздела уже существует, недостаточно прав для его удаления.';
sendErrorResponse(500, $err);
}
$dlHandler = fopen($filenameZip, 'w');
if (!fwrite($dlHandler, $response->responseBody)) {
$err = 'Ошибка при распаковке раздела: "' . $part . '".'
. ' Не удалось записать архив. Проверьте права доступа и свободное место.';
sendErrorResponse(500, $err);
}
$unpackPath = Path::join($funcPath, $part.'_part-latest');
if (!Filesystem::remove($unpackPath, true)) {
$err = 'Ошибка при распаковке раздела: "' . $part . '".'
. ' Временная директория уже существует и не может быть удалена.';
sendErrorResponse(500, $err);
}
if (!unpackZip($filenameZip, $unpackPath)) {
$err = 'Ошибка при распаковке раздела: ' . $part . '.'
. ' Проверьте права доступа и свободное место.';
sendErrorResponse(500, $err);
}
Filesystem::removeZip($filenameZip, false);
$errRepeir = 'Ошибка при синхронизации раздела. Не удалось восстановить часть: ' . $part;
$errSync = 'Ошибка при синхронизации раздела. Не удалось синхронизировать часть: ' . $part;
$rootModuleCore = Path::getModuleRootPath($curModuleId);
$pathCurFolderPart = Path::join($rootModuleCore, $part);
$excludedEntries = array();
if ('abitur' !== $part) {
$excludedEntries = $allowedFoldersInCoreByModule[$curModuleId];
$pathCurFolderPart = Path::join($rootModuleCore, $part);
if (file_exists($pathCurFolderPart)) {
$pathPartForSync = Path::join($unpackPath, $part);
$pathPartForSyncPostfixNew = Path::join($rootModuleCore, $part.Path::$n_pstfx);
if (!Filesystem::remove($pathPartForSyncPostfixNew, true, $curModuleId)) {
if (!Filesystem::restoreUnitCoreAfterFail($rootModuleCore, array($part), $curModuleId)) {
sendErrorResponse(500, $errRepeir);
}
}
if (!Filesystem::replaceWithRename($pathPartForSync, $pathPartForSyncPostfixNew, $curModuleId)) {
if (!Filesystem::restoreUnitCoreAfterFail($rootModuleCore, array($part), $curModuleId)) {
sendErrorResponse(500, $errRepeir);
}
sendErrorResponse(500, $errSync);
}
$pathCurFolderPartOldPostfix = Path::join($rootModuleCore, $part.Path::$o_pstfx);
if (!Filesystem::remove($pathCurFolderPartOldPostfix, true, $curModuleId)) {
if (!Filesystem::restoreUnitCoreAfterFail($rootModuleCore, array($part), $curModuleId)) {
sendErrorResponse(500, $errRepeir);
}
sendErrorResponse(500, $errSync);
}
if (!Filesystem::replaceWithRename($pathCurFolderPart, $pathCurFolderPartOldPostfix, $curModuleId)) {
if (!Filesystem::restoreUnitCoreAfterFail($rootModuleCore, array($part), $curModuleId)) {
sendErrorResponse(500, $errRepeir);
}
sendErrorResponse(500, $errSync);
}
if (!Filesystem::replaceWithRename($pathPartForSyncPostfixNew, $pathCurFolderPart, $curModuleId)) {
if (!Filesystem::restoreUnitCoreAfterFail($rootModuleCore, array($part), $curModuleId)) {
sendErrorResponse(500, $errRepeir);
}
sendErrorResponse(500, $errSync);
}
} else {
$pathPartForSync = Path::join($unpackPath, $part);
if (!Filesystem::replaceWithRename($pathPartForSync, $pathCurFolderPart, $curModuleId)) {
if (!Filesystem::restoreUnitCoreAfterFail($rootModuleCore, array($part), $curModuleId)) {
sendErrorResponse(500, $errRepeir);
}
sendErrorResponse(500, $errSync);
}
}
} else {
$pathCurFolderPart = $rootModuleCore;
$entrySyncFail = null;
$isRestoreFail = false;
$entriesToSync = Filesystem::safeScandir(Path::join($unpackPath, $part));
$excludedEntries = array_merge($entriesToSync, array('files', '.htaccess'));//todo подумать как от этого костыля отказаться
foreach ($entriesToSync as $entryName) {
$currentEntryPath = Path::join($pathCurFolderPart, $entryName);
$newEntryPath = Path::join($unpackPath, $part, $entryName);
$isFile = is_file($newEntryPath);
if (file_exists($currentEntryPath)) {
$newEntryPathWithNewPostfix = Path::join($pathCurFolderPart, $entryName.Path::$n_pstfx);
// try del
if (!Filesystem::remove($newEntryPathWithNewPostfix, true, $curModuleId)) {
$failedEntryName = $entryName;
break;
}
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($newEntryPath, $newEntryPathWithNewPostfix, $curModuleId)
: Filesystem::safeRenameFile($newEntryPath, $newEntryPathWithNewPostfix, $curModuleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
$currentEntryPathWithOldPostfix = Path::join($pathCurFolderPart, $entryName.Path::$o_pstfx);
// try del
if (!Filesystem::remove($currentEntryPathWithOldPostfix, true, $curModuleId)) {
$failedEntryName = $entryName;
break;
}
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($currentEntryPath, $currentEntryPathWithOldPostfix, $curModuleId)
: Filesystem::safeRenameFile($currentEntryPath, $currentEntryPathWithOldPostfix, $curModuleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($newEntryPathWithNewPostfix, $currentEntryPath, $curModuleId)
: Filesystem::safeRenameFile($newEntryPathWithNewPostfix, $currentEntryPath, $curModuleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
} else {
// try replace
$renameSuccess = !$isFile
? Filesystem::replaceWithRename($newEntryPath, $currentEntryPath, $curModuleId)
: Filesystem::safeRenameFile($newEntryPath, $currentEntryPath, $curModuleId);
if (!$renameSuccess) {
$failedEntryName = $entryName;
break;
}
}
}
}
Filesystem::remove($unpackPath, true);
$successOrPath = Filesystem::cleanUnitCore($rootModuleCore, $excludedEntries, $curModuleId);
if (is_string($successOrPath)) {
$err = 'Ошибка проверки целостности части. Не удалось удалить папку: ' . $successOrPath;
sendErrorResponse(500, $err);
}
if (!$successOrPath) {
$err = 'Ошибка проверки целостности части. Нет доступа к корневой папке части.';
sendErrorResponse(500, $err);
}
$resultBody = array('success' => true, 'forward_code' => 200, 'message' => 'Раздел ' . $part . ' успешно обновлен.');
} else {
$response->responseBody = json_decode($response->responseBody);
$resultBody = array(
'success' => false,
'forward_code' => $response->code,
'message' => !empty($response->responseBody->message ) ? $response->responseBody->message : 'неизвестная ошибка'
);
}
} else {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
if ($dlHandler != null) {
fclose($dlHandler);
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/src_executor.php
+132
View File
@@ -0,0 +1,132 @@
<?php
//скрипт запускается оносительно vikon_core
$vikonDir = dirname(__FILE__);
require_once $vikonDir . '/internal/config.php';
require_once $vikonDir . '/internal/helper.php';
require_once $vikonDir . '/internal/filesystem.php';
if (!isset($_GET['access_token']) || !filterAccessToken($_GET['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
$token = $_GET['access_token'];
$dlHandler = null;
try {
$headers = array('Accept-Encoding: zip, gzip', 'Authorization: Bearer ' . $token);
$zipCore = remoteRequest($apiDomen . 'pull_updates/generateEmptyCore', false, false, $headers);
if ($zipCore->curlHasError) {
throw new RuntimeException('CURL ' . $zipCore->curlErrorTxt);
}
if ($zipCore->code !== 200) {
$zipCore->responseBody = json_decode($zipCore->responseBody);
$err = 'Не удается скачать файл с обновлениями. ' . (!empty($zipCore->responseBody->message)
? $zipCore->responseBody->message
: 'Неизвестная ошибка');
sendErrorResponse($zipCore->code, $err);
}
$vikonFuncPath = Path::getCoreRootPath();
$vikonZipCorePath = Path::join($vikonFuncPath, 'vikon_core-latest.zip');
if (!Filesystem::removeZip($vikonZipCorePath, true)) {
$err = 'Ошибка при распаковке ядра. Архив уже существует. Недостаточно прав для его удаления';
sendErrorResponse(500, $err);
}
$dlHandler = fopen($vikonZipCorePath, 'w');
if (!fwrite($dlHandler, $zipCore->responseBody)) {
$err = 'Ошибка при распаковке ядра модуля. Не удалось записать архив. Проверьте права доступа и свободное место.';
sendErrorResponse(500, $err);
}
if ($dlHandler) {
fclose($dlHandler);
}
$vikonUnpackNewCorePath = Path::join($vikonFuncPath, 'vikon_core-latest');
if (!Filesystem::remove($vikonUnpackNewCorePath, true)) {
$err = 'Ошибка при распаковке ядра. Временная директория уже существует и не может быть удалена.';
sendErrorResponse(500, $err);
}
$unpackResult = unpackZip($vikonZipCorePath, $vikonUnpackNewCorePath);
if (!$unpackResult['success']) {
sendErrorResponse(500, 'Ошибка при распаковке ядра. Проверьте права доступа и свободное место.');
}
Filesystem::removeZip($vikonZipCorePath, false);
$vikonRootPath = Path::getCoreRootPath();
$pathToFoldersNewCore = Path::join($vikonUnpackNewCorePath, Path::$vikonCoreFolder);
$nameFoldersForSync = Filesystem::safeScandir($pathToFoldersNewCore);
$isRestoreFail = false;
$folderSyncFail = null;
foreach ($nameFoldersForSync as $nameFolderSync) {
$curFolder = Path::join($vikonRootPath, $nameFolderSync);
$pathToNewFolder = Path::join($vikonUnpackNewCorePath, Path::$vikonCoreFolder, $nameFolderSync);
if (file_exists($curFolder)) {
$pathToNewFolderPostfix = Path::join($vikonRootPath, $nameFolderSync . Path::$n_pstfx);
// try del vikon_core/assets_new
if (!Filesystem::remove($pathToNewFolderPostfix, true)) {
$folderSyncFail = $nameFolderSync;
break;
}
// try replace vikon_core/vikon_core-latest/vikon_core/assets -> vikon_core/assets_new
if (!Filesystem::replaceWithRename($pathToNewFolder, $pathToNewFolderPostfix)) {
$folderSyncFail = $nameFolderSync;
break;
}
$pathToOldFolderPostfix = Path::join($vikonRootPath, $nameFolderSync . Path::$o_pstfx);
// try del vikon_core/assets_old
if (!Filesystem::remove($pathToOldFolderPostfix, true)) {
$folderSyncFail = $nameFolderSync;
break;
}
// try replace vikon_core/assets -> vikon_core/assets_old
if (!Filesystem::replaceWithRename($curFolder, $pathToOldFolderPostfix)) {
$folderSyncFail = $nameFolderSync;
break;
}
// vikon_core/assets_new -> vikon_core/assets
if (!Filesystem::replaceWithRename($pathToNewFolderPostfix, $curFolder)) {
$folderSyncFail = $nameFolderSync;
break;
}
} else {
// try replace vikon_core/vikon_core-latest/vikon_core/assets -> vikon_core/assets
if (!Filesystem::replaceWithRename($pathToNewFolder, $curFolder)) {
$folderSyncFail = $nameFolderSync;
break;
}
}
}
//синхронизированные папки + временная папка с версиями
$allFoldersNeedCore = array_merge($nameFoldersForSync, array('tmp'));
if ($folderSyncFail !== null) {
if (!Filesystem::restoreUnitCoreAfterFail($vikonRootPath, $allFoldersNeedCore)) {
sendErrorResponse(500, 'Ошибка при синхронизации ядра. Не удалось восстановить ядро после ошибки.');
} else {
sendErrorResponse(500, 'Ошибка при синхронизации ядра. Не удалось синхронизировать папку: ' . $folderSyncFail);
}
}
$successOrPath = Filesystem::cleanUnitCore($vikonRootPath, $allFoldersNeedCore);
if (is_string($successOrPath)) {
sendErrorResponse(500, 'Ошибка проверки целостности ядра. Не удалось удалить папку: ' . $successOrPath);
}
if (!$successOrPath) {
sendErrorResponse(500, 'Ошибка проверки целостности ядра. Нет доступа к корневой папке ядра.');
}
} catch (Exception $ex) {
sendErrorResponse(500, $ex->getMessage());
}
sendSuccessResponse('Архив с базовыми обновлениями успешно загружен.');
public/vikon_core/update/start_sync_files.php
+74
View File
@@ -0,0 +1,74 @@
<?php
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/config.php';
require_once $selfDir . '/../internal/helper.php';
require_once $selfDir . '/../internal/filesystem.php';
$token = filterAccessToken(isset($_POST['access_token']) ? (string) $_POST['access_token'] : '');
$moduleId = isset($_POST['moduleId']) ? filterInt($_POST['moduleId']) : null;
$dlHandler = null;
Path::init($modulesByPathDeploy);
try {
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
throw new RuntimeException('Не верно передан параметр модуля');
}
if (!$token) {
throw new RuntimeException('Некорректный access_token');
}
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$response = remoteRequest($filemanagerApiDomen . 'sync/getUsedDirNamesByModule?moduleId=' . $moduleId, true, false, $headers);
if ($response->code !== 200) {
$msg = 'Не удалось инициировать процедуру синхронизации файлов' . tryExtractFmErrorMessage($response, '. ');
sendErrorResponse($response->code, $msg);
}
if (!property_exists($response->responseBody, 'directories') || !is_array($response->responseBody->directories)) {
throw new RuntimeException('Невалидный формат ответа при запросе используемых директорий');
}
$directories = $response->responseBody->directories;
$fsRootPath = Path::getFsPathByModule($moduleId);
if (!$fsRootPath) {
throw new RuntimeException('Неизвестная ошибка');
}
$dirObjects = Filesystem::safeScandir($fsRootPath);
if (false === $dirObjects) {
$msg = 'Не удалось просканировать папку: ' . $fsRootPath;
sendErrorResponse(500, $msg);
}
$flippedKnownDirectories = array_flip($directories);
foreach ($dirObjects as $objectName) {
$objectPath = Path::join($fsRootPath, $objectName);
if (
!array_key_exists($objectName, $flippedKnownDirectories)
&& is_dir($objectPath)
) {
if (is_link($fsRootPath)) {
throw new RuntimeException(
'В синхронизируемый директории находится ссылка'
. $objectPath
. ' , которая не может быть безопасно удалена'
);
}
Filesystem::remove($objectPath, true, $moduleId);
}
}
$resultBody = array(
'success' => true,
'forward_code' => 200,
'directories' => $directories,
);
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/status_generate_part.php
+50
View File
@@ -0,0 +1,50 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
if (!isset($_GET['access_token']) || !filterAccessToken($_GET['access_token'])) {
sendErrorResponse(422, 'Некорректный access_token');
}
if (!isset($_GET['operation_identity']) || !filter_var($_GET['operation_identity'], FILTER_SANITIZE_STRING)) {
sendErrorResponse(422, 'Некорректный operation_identity');
}
$operationIdentity = (string) $_GET['operation_identity'];
$token = $_GET['access_token'];
try {
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$response = remoteRequest(
$apiDomen . 'pull_updates/getStatusPartGenerationByNewCoreJson?operation_identity=' . $operationIdentity,
true,
false,
$headers
);
if (!$response->curlHasError) {
if (200 === $response->code) {
$resultBody = array(
'success' => true,
'status' => $response->responseBody->status,
'forward_code' => 200,
);
} else {
$resultBody = array(
'success' => false,
'forward_code' => $response->code,
'message' => !empty($response->responseBody->message ) ? $response->responseBody->message : 'неизвестная ошибка'
);
}
} else {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
} catch (Exception $ex) {
setResponseCode(!empty($response->code) ? $response->code : 500);
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/sync_root_dir.php
+109
View File
@@ -0,0 +1,109 @@
<?php
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/config.php';
require_once $selfDir . '/../internal/helper.php';
require_once $selfDir . '/../internal/filesystem.php';
$token = filterAccessToken(isset($_POST['access_token']) ? (string) $_POST['access_token'] : '');
//через jquery нельзя послать пустой массив, если это не json.
// json посылать не будем, похоже при некоторых настройках старых серверов есть проблемы с чтением raw-body через php://input($HTTP_RAW_POST_DATA)
$isHasSubDirs = isset($_POST['isHasSubDirs']) && is_numeric($_POST['isHasSubDirs'])
? (int) $_POST['isHasSubDirs']
: null;
$knownSubDirs = isset($_POST['knownSubDirs']) && is_array($_POST['knownSubDirs'])
? $_POST['knownSubDirs']
: array();
$moduleId = isset($_POST['moduleId']) ? filterInt($_POST['moduleId']) : null;
$dlHandler = null;
Path::init($modulesByPathDeploy);
try {
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
throw new RuntimeException('Не верно передан параметр модуля');
}
if (!$token) {
throw new RuntimeException('Некорректный access_token');
}
if (null === $isHasSubDirs || ($isHasSubDirs && !$knownSubDirs) || (!$isHasSubDirs && $knownSubDirs)) {
throw new RuntimeException('Не может быть обработано. Неверные параметры запроса.');
}
$fsDirPath = Path::getFsPathByModule($moduleId);
if (!$fsDirPath) {
throw new RuntimeException('Не удалось определить модуль');
}
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$response = remoteRequest($filemanagerApiDomen . 'sync/getFileNamesFromRootDirectoryByModule?moduleId=' . $moduleId, true, false, $headers);
if ($response->curlHasError) {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
if (
$response->code !== 200
|| !property_exists($response->responseBody, 'files')
|| !is_array($response->responseBody->files)
) {
$msg = 'Не удалось получить список файлов с файлового сервера'
. tryExtractFmErrorMessage($response, '. ');
sendErrorResponse($response->code, $msg);
}
$filesByNamesFromFm = array();
foreach ($response->responseBody->files as $row) {
$filesByNamesFromFm[(string) $row->n] = $row->i;
}
$response = null;
if (!Filesystem::safeMkdir($fsDirPath, 0775, $moduleId)) {
throw new RuntimeException('Не удалось создать папку "' . $fsDirPath . '" на вашем сервере');
}
$items = Filesystem::safeScandir($fsDirPath);
if (false === $items) {
$msg = 'Не удалось просканировать существующие файлы';
sendErrorResponse(500, $msg);
}
$existingItemsByNames = array();
foreach ($items as $fName) {
$existingItemsByNames[$fName] = null;
}
$knownSubDirsByNames = array_flip($knownSubDirs);
foreach ($existingItemsByNames as $dirItem => $_) {
$fsItemPath = Path::join($fsDirPath, $dirItem);
if ((array_key_exists($dirItem, $knownSubDirsByNames) && is_dir($fsItemPath))) {
unset($existingItemsByNames[$dirItem]);
continue;
}
if (!array_key_exists((string) $dirItem, $filesByNamesFromFm)) {
//удаляем только файлы, ненужные папки были удалены в start_sync_files
if (is_file($fsItemPath)) {
unlink($fsItemPath);
}
} else {
if (!filesize($fsItemPath)) {
unset($existingItemsByNames[$dirItem]);
}
}
}
$filesForSync = array();
foreach ($filesByNamesFromFm as $fileName => $identity) {
if (!array_key_exists($fileName, $existingItemsByNames)) {
$filesForSync[] = $identity;
}
}
$resultBody = array('success' => true, 'forward_code' => 200, 'files' => $filesForSync);
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/sync_sub_dir.php
+100
View File
@@ -0,0 +1,100 @@
<?php
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/config.php';
require_once $selfDir . '/../internal/helper.php';
require_once $selfDir . '/../internal/filesystem.php';
$dir = isset($_POST['dir']) && is_string($_POST['dir']) ? $_POST['dir'] : '';
$token = filterAccessToken(isset($_POST['access_token']) ? (string) $_POST['access_token'] : '');
$moduleId = isset($_POST['moduleId']) ? filterInt($_POST['moduleId']) : null;
$dlHandler = null;
Path::init($modulesByPathDeploy);
try {
if (!preg_match("/^[a-z]{3,4}$/", $dir)) {
throw new RuntimeException('Невалидное значение для синхронизируемой суб-директории');
}
if (!$token) {
throw new RuntimeException('Некорректный access_token');
}
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
throw new RuntimeException('Не верно передан параметр модуля');
}
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$url = $filemanagerApiDomen . 'sync/getFileNamesFromSubDirectoryByModule?dir=' . $dir . '&moduleId=' . $moduleId;
$response = remoteRequest($url, true, false, $headers);
if ($response->curlHasError) {
throw new RuntimeException('CURL ' . $response->curlErrorTxt);
}
if (
$response->code !== 200
|| !property_exists($response->responseBody, 'files')
|| !is_array($response->responseBody->files)
) {
$message = 'Не удалось получить список файлов с файлового сервера'
. tryExtractFmErrorMessage($response, '. ');
sendErrorResponse($response->code, $message);
}
$filesByNamesFromFm = array();
foreach ($response->responseBody->files as $row) {
$filesByNamesFromFm[(string) $row->n] = $row->i;
}
$response = null;
$fsDirPath = Path::getFsPathByModule($moduleId);
if (!$fsDirPath) {
throw new RuntimeException('Не удалось определить модуль');
}
$dirPath = Path::join($fsDirPath, $dir);
if (!Filesystem::safeMkdir($dirPath, 0775, $moduleId)) {
throw new RuntimeException('Не удалось создать папку "' . $dirPath . '" на вашем сервере');
}
$items = Filesystem::safeScandir($dirPath);
if (false === $items) {
$msg = 'Не удалось просканировать существующие файлы';
sendErrorResponse(500, $msg);
}
$existingItemsByNames = array();
foreach ($items as $fName) {
$existingItemsByNames[$fName] = null;
}
foreach ($existingItemsByNames as $subDirItem => $_) {
$filePath = Path::join($dirPath, $subDirItem);
if (!array_key_exists((string) $subDirItem, $filesByNamesFromFm)) {
if (is_dir($filePath)) {
Filesystem::remove($filePath, true);
} else {
unlink($filePath);
}
} else {
if (!filesize($filePath)) {
unset($existingItemsByNames[$subDirItem]);
}
}
}
$filesForSync = array();
foreach ($filesByNamesFromFm as $fileName => $identity) {
if (!array_key_exists($fileName, $existingItemsByNames)) {
$filesForSync[] = $identity;
}
}
$resultBody = array('success' => true, 'forward_code' => 200, 'files' => $filesForSync);
} catch (Exception $ex) {
$resultBody = array('success' => false, 'forward_code' => 500, 'message' => $ex->getMessage());
}
loadHeaders();
setResponseCode(200);
echo json_encode($resultBody);
public/vikon_core/update/update_module_version.php
+80
View File
@@ -0,0 +1,80 @@
<?php
$updateDir = dirname(__FILE__);
require_once $updateDir . '/../internal/config.php';
require_once $updateDir . '/../internal/helper.php';
require_once $updateDir . '/../internal/filesystem.php';
$token = null;
if (isset($_GET['access_token'])) { //todo new_core_after del GET
$token = $_GET['access_token'];
} elseif (isset($_POST['access_token'])) {
$token = $_POST['access_token'];
}
if ($token === null || !filterAccessToken($token)) {
sendErrorResponse(422, 'Токен доступа отсутствует или некорректен');
}
$moduleId = null;
if (isset($_GET['module_id'])) { //todo new_core_after del GET
$moduleId = $_GET['module_id'];
} elseif (isset($_POST['module_id'])) {
$moduleId = $_POST['module_id'];
}
if ($moduleId === null || !filterInt($moduleId)) {
sendErrorResponse(422, 'Отсутствует идентификатор модуля или он указан некорректно');
}
if (!in_array($moduleId, array(SVEDEN, ABITUR, VSOKO))) {
sendErrorResponse(422, 'Не верно передан идентификатор модуля');
}
$version = null;
if (array_key_exists('version', $_GET)) { //todo new_core_after del GET
$version = $_GET['version'];
} elseif (array_key_exists('version', $_POST)) {
$version = $_POST['version'];
}
if ($version !== null && !filterVersion($version)) {
sendErrorResponse(422, 'Передан невалидный параметр версии последнего обновления');
}
$headers = array('Accept: application/json', 'Authorization: Bearer ' . $token);
$res = remoteRequest($apiDomen . 'pull_updates/checkAccessJson', true, false, $headers);
if ($res->curlHasError) {
sendErrorResponse(500, 'CURL ' . $res->curlErrorTxt);
}
if ($res->code !== 200) {
$err = 'Ошибка проверки подлинности токена. '
. (!empty($res->responseBody->message) ? $res->responseBody->message : 'Неизвестная ошибка');
sendErrorResponse($res->code, $err);
}
try {
$tmpPath = Path::join(Path::getCoreRootPath(), 'tmp');
if (!Filesystem::safeMkdir($tmpPath, 0755)) {
throw new RuntimeException('Не удалось создать директорию "' . $tmpPath . '" на вашем сервере');
}
$moduleVersionsPath = Path::join($tmpPath, 'versions');
if (!Filesystem::safeMkdir($moduleVersionsPath, 0755)) {
throw new RuntimeException('Не удалось создать директорию "' . $moduleVersionsPath . '" на вашем сервере');
}
$moduleVersionFilePath = Path::join($moduleVersionsPath, $moduleId . '.json');
if (!Filesystem::remove($moduleVersionFilePath, false)) {
throw new RuntimeException('Не удалось удалить файл "' . $moduleVersionFilePath . '" на вашем сервере');
}
$json = json_encode(array('version' => $version));
if (!Filesystem::safeMkfile($moduleVersionFilePath, 0755, $json)) {
throw new Exception('Не удалось записать служебную информацию в директорию: ' . $moduleVersionFilePath);
}
} catch (Exception $ex) {
sendErrorResponse(500, $ex->getMessage());
}
sendSuccessResponse('');
public/vikon_core/update/vsoko_feedback.php
+77
View File
@@ -0,0 +1,77 @@
<?php
//todo new_core_after del file
$selfDir = dirname(__FILE__);
require_once $selfDir . '/../internal/helper.php';
require_once $selfDir . '/../internal/config.php';
$res = array();
$res['success'] = true;
$res['errorID'] = array();
$res['messages'] = array();
$name = $_POST['name'];
$email = $_POST['email'];
$message = $_POST['message'];
$consent = filter_var($_POST['consent'], FILTER_SANITIZE_NUMBER_INT);
if($consent != true){
$res['success'] = false;
$res['messages'][] = 'Не получено согласие на обработку персональных данных.';
$res['errorID'][] = 'consent';
}
$code = filter_var($_POST['captcha'], FILTER_SANITIZE_STRING);
session_start();
if (!isset($_SESSION['captcha']) || strtoupper(trim($_SESSION['captcha'])) != strtoupper(trim($code))) {
$res['success'] = false;
$res['errorID'][] = 'captcha';
$res['messages'][] = 'Неверный код с картинки.';
}
unset($_SESSION['captcha']);
if ($res['success']) {
$res['success'] = false;
$headers = array('Accept: application/json');
$data = remoteRequest($apiDomen . 'oauth2/ClientCredentials', true,
array(
'client_id' => $clientId,
'client_secret' => $clientSecret,
'grant_type' => 'client_credentials',
), $headers
);
if ($data->code == 200) {
if (isset($data->responseBody)) {
$accessToken = $data->responseBody->access_token;
try {
$data = remoteRequest($apiDomen . 'oauth-via-app/vsoko/feedbackSendMail?access_token='
. $accessToken .
'&name=' . urlencode($name) .
'&email=' . urlencode($email) .
'&message=' . urlencode($message)
);
if ($data->code == 200) {
$res['success'] = true;
} else {
sendErrorResponse($data->code, $data->responseBody->message);
}
} catch (Exception $e) {
$res['message'] = 'Ошибка. '.$e->getMessage();
}
} else {
$res['message'] = 'Ошибка ' . $data->responseBody->message;
}
} else {
$res['message'] = $data->responseBody->message;
}
}
loadHeaders();
echo json_encode($res);
public/vikon_core/update/zip_helper.php
Executable
+5451
View File
File diff suppressed because it is too large Load Diff