feat(vikon): remove broken VikonIntegration container - starting fresh

This commit is contained in:
F4ilji
2026-07-04 12:40:41 +05:00
parent 67b9aae961
commit 47aac647ac
20 changed files with 1 additions and 2563 deletions
@@ -1,57 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Actions\Auth;
use App\Containers\VikonIntegration\Tasks\CallVikonApiTask;
/**
* Action: Authenticate with Vikon using authorization code
*
* Exchanges OAuth2 authorization code for access_token and refresh_token.
* Replaces old vikon_core/get_access_token.php with proper error handling.
*/
class AuthenticateVikonAction
{
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
private readonly string $clientId,
private readonly ?string $clientSecret,
) {}
/**
* Exchange authorization code for tokens
*
* @param string $code Authorization code from Vikon OAuth
* @param string $redirectUri Current URL for validation
* @return array{access_token: string, refresh_token: string}
* @throws \RuntimeException
*/
public function run(string $code, string $redirectUri): array
{
if (empty($this->clientSecret)) {
throw new \RuntimeException(
'VIKON_CLIENT_SECRET не настроен. Обратитесь к администратору.'
);
}
$response = $this->callVikonApiTask->post('oauth2/authorize/token', [
'code' => $code,
'client_id' => $this->clientId,
'client_secret' => $this->clientSecret,
'redirect_uri' => $redirectUri,
'grant_type' => 'authorization_code',
], [], 'auth');
$body = $response->json();
if (!isset($body['access_token']) || !isset($body['refresh_token'])) {
throw new \RuntimeException(
'Authentication failed: ' . ($body['message'] ?? 'Unknown error')
);
}
return [
'access_token' => $body['access_token'],
'refresh_token' => $body['refresh_token'],
];
}
}
@@ -1,156 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Actions\Updates;
use App\Containers\VikonIntegration\Tasks\CallVikonApiTask;
use App\Containers\VikonIntegration\Tasks\ValidateVikonTokenTask;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Facades\Log;
/**
* Action: Check if user has access to Vikon updates
*
* Verifies access_token and checks permissions for update operations.
* Replaces old vikon_core/check_filesystem.php authorization check.
*/
class CheckVikonAccessAction
{
public function __construct(
private readonly ValidateVikonTokenTask $validateTokenTask,
private readonly CallVikonApiTask $callVikonApiTask,
private readonly string $publicPath,
) {}
/**
* Check if user has valid access and filesystem is writable
*
* @param string $accessToken User's access token
* @return array{has_access: bool, error: ?string, permissions: array, writable_paths: array}
*/
public function run(string $accessToken): array
{
// Step 1: Validate token
$isValid = $this->validateTokenTask->run($accessToken);
if (!$isValid) {
return [
'has_access' => false,
'error' => 'Токен доступа недействителен или истёк. Пожалуйста, выполните повторную авторизацию.',
'permissions' => [],
'writable_paths' => [],
];
}
// Step 2: Check update permissions
try {
$response = $this->callVikonApiTask->getWithToken(
'pull_updates/checkAccessJson',
$accessToken
);
$body = $response->json();
if (!isset($body['success']) || !$body['success']) {
return [
'has_access' => false,
'error' => 'Нет прав на обновление. Обратитесь к администратору VIKON.',
'permissions' => [],
'writable_paths' => [],
];
}
// Extract permissions from response
$permissions = $body['additional_access_flags'] ?? [];
// Step 3: Check filesystem writability (recursive, like old check_filesystem.php)
$writablePaths = $this->checkWritablePaths();
$nonWritablePaths = $this->findNonWritablePaths($this->publicPath);
if (!empty($nonWritablePaths)) {
Log::warning('Vikon access: non-writable paths detected', [
'paths' => $nonWritablePaths,
]);
return [
'has_access' => false,
'error' => 'Отсутствуют права на запись в следующие директории: ' . implode(', ', array_slice($nonWritablePaths, 0, 5)) . '. Обратитесь к администратору сервера.',
'permissions' => $permissions,
'writable_paths' => $writablePaths,
'non_writable_paths' => $nonWritablePaths,
];
}
return [
'has_access' => true,
'error' => null,
'permissions' => $permissions,
'writable_paths' => $writablePaths,
];
} catch (\Throwable $e) {
Log::error('Vikon access check failed', [
'error' => $e->getMessage(),
]);
return [
'has_access' => false,
'error' => 'Не удалось проверить права доступа: ' . $e->getMessage(),
'permissions' => [],
'writable_paths' => [],
];
}
}
/**
* Check which module directories are writable
*/
private function checkWritablePaths(): array
{
$modules = config('vikon.modules', []);
$writable = [];
foreach ($modules as $moduleId => $moduleConfig) {
$modulePath = $this->publicPath . '/' . $moduleConfig['path'];
$isWritable = is_writable($modulePath);
$writable[] = [
'module_id' => $moduleId,
'path' => $moduleConfig['path'],
'writable' => $isWritable,
];
}
return $writable;
}
/**
* Recursively find non-writable paths (like old isWritableRecrusive)
*
* Limits depth to 3 levels to avoid performance issues on large directories.
*/
private function findNonWritablePaths(string $path, int $depth = 0): array
{
$nonWritable = [];
if ($depth > 3) {
return $nonWritable;
}
if (!is_dir($path)) {
return $nonWritable;
}
if (!is_writable($path)) {
$nonWritable[] = str_replace(base_path() . '/', '', $path);
return $nonWritable;
}
$entries = File::directories($path);
foreach ($entries as $entry) {
$nonWritable = array_merge(
$nonWritable,
$this->findNonWritablePaths($entry, $depth + 1)
);
}
return $nonWritable;
}
}
@@ -1,64 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Actions\Updates;
use App\Containers\VikonIntegration\Tasks\CallVikonApiTask;
/**
* Action: Check for available Vikon module updates
*
* Replaces old vikon_core/get_module_version.php
*/
class CheckVikonVersionAction
{
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
private readonly string $currentVersion,
) {}
/**
* Get current version and check for updates
*
* @param string $accessToken Valid Vikon access token
* @return array{current_version: string, has_update: bool, latest_version: ?string}
*/
public function run(string $accessToken): array
{
try {
$response = $this->callVikonApiTask->getWithToken(
'pull_updates/getLatestVersion',
$accessToken
);
$body = $response->json();
$latestVersion = $body['version'] ?? null;
$hasUpdate = $latestVersion && version_compare($latestVersion, $this->currentVersion, '>');
return [
'current_version' => $this->currentVersion,
'has_update' => $hasUpdate,
'latest_version' => $latestVersion,
];
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::warning('Vikon version check failed', [
'error' => $e->getMessage(),
]);
return [
'current_version' => $this->currentVersion,
'has_update' => false,
'latest_version' => null,
'error' => 'Не удалось проверить наличие обновлений',
];
}
}
/**
* Get current version without checking for updates
*/
public function getCurrentVersion(): string
{
return $this->currentVersion;
}
}
@@ -1,434 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Actions\Updates;
use App\Containers\VikonIntegration\Tasks\CallVikonApiTask;
use App\Containers\VikonIntegration\Tasks\ExtractZipArchiveTask;
use App\Containers\VikonIntegration\Tasks\ManageModuleFilesTask;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Facades\Log;
/**
* Action: Download and install module core update
*
* Replaces old vikon_core/download_module_core.php with:
* - Secure HTTP (SSL enabled)
* - Zip Slip protection
* - Atomic file operations with rollback
* - Proper error handling
*/
class DownloadModuleUpdateAction
{
private const NEW_SUFFIX = '_new';
private const OLD_SUFFIX = '_old';
/**
* Allowed file extensions for module updates
*
* Only static files are allowed - NO executable scripts
* This prevents RCE via malicious ZIP uploads from Vikon API
*/
private const ALLOWED_EXTENSIONS = [
// Documents
'pdf', 'doc', 'docx', 'xls', 'xlsx', 'ppt', 'pptx', 'txt', 'rtf', 'odt', 'ods', 'odp',
// Web
'html', 'htm', 'css', 'js', 'json', 'xml', 'map',
// Images
'png', 'jpg', 'jpeg', 'gif', 'svg', 'svgz', 'webp', 'ico', 'bmp', 'tiff', 'tif',
// Fonts
'woff', 'woff2', 'ttf', 'eot', 'otf',
// Archives (for internal use only)
'zip', 'rar', '7z', 'gz', 'tar',
// Vikon-specific
'vikon',
];
/**
* Dangerous file extensions that MUST be blocked
* Even if Vikon sends them, they will be rejected
*/
private const BLOCKED_EXTENSIONS = [
// PHP
'php', 'php3', 'php4', 'php5', 'php7', 'php8', 'phps', 'phtml',
// Other server-side scripts
'asp', 'aspx', 'jsp', 'jspx', 'cfm', 'cfc',
// Server configs
'htaccess', 'htpasswd', 'conf', 'config',
// Scripts
'pl', 'py', 'pyc', 'pyo', 'rb', 'cgi', 'sh', 'bash', 'bat', 'cmd', 'exe', 'com',
// PowerShell
'ps1', 'psm1', 'psd1',
// Node/JS runtime (JS allowed as static, but not server-side)
'mjs', 'cjs', 'ts',
// Compiled
'so', 'dll', 'exe', 'bin', 'class',
];
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
private readonly ExtractZipArchiveTask $extractZipTask,
private readonly array $modulesConfig,
private readonly string $storagePath,
private readonly string $basePath,
) {}
/**
* Download and install module update
*
* @param int $moduleId Module ID (1, 2, 6)
* @param string $accessToken Valid Vikon access token
* @return string Success message
* @throws \RuntimeException
*/
public function run(int $moduleId, string $accessToken): string
{
$moduleConfig = $this->getModuleConfig($moduleId);
$modulePath = $this->basePath . '/' . $moduleConfig['path'];
$tempPath = $this->storagePath . '/temp/' . $moduleConfig['path'];
try {
// Step 1: Download module core ZIP
Log::info('Vikon update: downloading module core', ['module_id' => $moduleId]);
$zipContent = $this->callVikonApiTask->downloadWithToken(
'pull_updates/generateEmptyModuleCore/' . $moduleId,
$accessToken
);
// Step 2: Prepare temp directory
$this->prepareTempDirectory($tempPath);
// Step 3: Write ZIP to temp file
$zipFile = $tempPath . '/module_core.zip';
$writeResult = file_put_contents($zipFile, $zipContent);
if ($writeResult === false) {
throw new \RuntimeException('Не удалось записать архив обновления. Проверьте права доступа.');
}
// Step 4: Extract with Zip Slip protection
$this->extractZipTask->run($zipFile, $tempPath);
// Step 5: Validate file types BEFORE syncing to module directory
$blockedFiles = $this->validateFileTypes($tempPath);
if (!empty($blockedFiles)) {
throw new \RuntimeException(
'Обнаружены запрещённые типы файлов: ' . implode(', ', $blockedFiles) .
'. Обновление отклонено в целях безопасности.'
);
}
// Step 6: Remove vikon_core directory from archive (we use Laravel-based updater)
$vikonCorePath = $tempPath . '/vikon_core';
if (File::isDirectory($vikonCorePath)) {
Log::info('Vikon update: removing vikon_core from archive (using Laravel updater instead)');
File::deleteDirectory($vikonCorePath);
}
// Step 7: Clean up ZIP
File::delete($zipFile);
// Step 7: Sync extracted files to module directory
$this->syncModuleFiles($tempPath, $modulePath, $moduleConfig['path']);
// Step 8: Clean module - remove files/folders not in allowed list (like old cleanUnitCore)
$this->cleanModuleDirectory($modulePath, $moduleConfig['allowed_folders']);
// Step 9: Create .vikon flag file
$this->createVikonFlag($modulePath);
// Step 9: Cleanup temp
File::deleteDirectory($tempPath);
Log::info('Vikon update: module core updated successfully', ['module_id' => $moduleId]);
return 'Ядро модуля "' . $moduleConfig['name'] . '" успешно обновлено.';
} catch (\Throwable $e) {
// Rollback on error
$this->rollback($modulePath, $moduleConfig['path']);
Log::error('Vikon update: failed', [
'module_id' => $moduleId,
'error' => $e->getMessage(),
]);
throw new \RuntimeException('Ошибка обновления модуля: ' . $e->getMessage());
}
}
/**
* Get module configuration
*
* @throws \RuntimeException
*/
private function getModuleConfig(int $moduleId): array
{
if (!isset($this->modulesConfig[$moduleId])) {
throw new \RuntimeException('Неизвестный идентификатор модуля');
}
return $this->modulesConfig[$moduleId];
}
/**
* Prepare temporary directory for extraction
*/
private function prepareTempDirectory(string $path): void
{
if (File::exists($path)) {
File::deleteDirectory($path);
}
File::makeDirectory($path, 0755, true, true);
}
/**
* Sync extracted files to module directory with atomic operations
*
* Strategy:
* 1. Rename current file/dir to _old
* 2. Move new file/dir to current location
* 3. If error occurs, rollback from _old
*/
private function syncModuleFiles(string $sourcePath, string $targetPath, string $moduleFolder): void
{
$entries = File::directories($sourcePath);
$files = File::files($sourcePath);
$failedEntries = [];
// Process directories
foreach ($entries as $entry) {
$entryName = basename($entry);
$currentPath = $targetPath . '/' . $entryName;
$newPath = $sourcePath . '/' . $entryName;
try {
$this->syncDirectory($newPath, $currentPath, $targetPath);
} catch (\Throwable $e) {
$failedEntries[] = $entryName;
Log::error('Vikon update: failed to sync directory', [
'entry' => $entryName,
'error' => $e->getMessage(),
]);
}
}
// Process files
foreach ($files as $file) {
$fileName = basename($file);
$currentPath = $targetPath . '/' . $fileName;
$newPath = $sourcePath . '/' . $fileName;
try {
$this->syncFile($newPath, $currentPath, $targetPath);
} catch (\Throwable $e) {
$failedEntries[] = $fileName;
Log::error('Vikon update: failed to sync file', [
'entry' => $fileName,
'error' => $e->getMessage(),
]);
}
}
if (!empty($failedEntries)) {
throw new \RuntimeException(
'Не удалось синхронизировать: ' . implode(', ', $failedEntries)
);
}
}
/**
* Sync single directory with atomic rename
*/
private function syncDirectory(string $newPath, string $currentPath, string $basePath): void
{
if (File::exists($currentPath)) {
// Rename current to _old
$oldPath = $currentPath . self::OLD_SUFFIX;
if (File::exists($oldPath)) {
File::deleteDirectory($oldPath);
}
File::move($currentPath, $oldPath);
}
// Move new to current
File::copyDirectory($newPath, $currentPath);
}
/**
* Sync single file with atomic rename
*/
private function syncFile(string $newPath, string $currentPath, string $basePath): void
{
if (File::exists($currentPath)) {
// Rename current to _old
$oldPath = $currentPath . self::OLD_SUFFIX;
if (File::exists($oldPath)) {
File::delete($oldPath);
}
rename($currentPath, $oldPath);
}
// Move new to current
copy($newPath, $currentPath);
}
/**
* Create .vikon flag file in module directory
*/
private function createVikonFlag(string $modulePath): void
{
$flagPath = $modulePath . '/.vikon';
if (!File::exists($flagPath)) {
File::put($flagPath, date('Y-m-d H:i:s'));
}
}
/**
* Clean module directory - remove files/folders not in allowed list
*
* Replaces old Filesystem::cleanUnitCore()
* After sync, removes any files/directories that are not in the allowed_folders list
*/
private function cleanModuleDirectory(string $modulePath, array $allowedFolders): void
{
$entries = File::directories($modulePath);
foreach ($entries as $entry) {
$entryName = basename($entry);
if (in_array($entryName, $allowedFolders, true)) {
continue;
}
// Skip symlinks
if (is_link($entry)) {
Log::warning('Vikon update: skipping symlink during cleanup', [
'path' => $entry,
]);
continue;
}
Log::info('Vikon update: removing disallowed directory', [
'directory' => $entryName,
]);
File::deleteDirectory($entry);
}
// Also check files at root level
$files = File::files($modulePath);
foreach ($files as $file) {
$fileName = basename($file);
if (in_array($fileName, $allowedFolders, true)) {
continue;
}
// Skip .vikon flag and .htaccess
if (in_array($fileName, ['.vikon', '.htaccess'], true)) {
continue;
}
Log::info('Vikon update: removing disallowed file', [
'file' => $fileName,
]);
File::delete($file);
}
}
/**
* Validate all extracted files against allowed/blocked extensions
*
* This is a security measure to prevent RCE via malicious ZIP from Vikon API.
* Even if Vikon sends PHP/ASP files, they will be rejected here.
*
* @return array List of blocked file paths
*/
private function validateFileTypes(string $extractPath): array
{
$blockedFiles = [];
$this->scanDirectoryForBlockedFiles($extractPath, $blockedFiles);
return $blockedFiles;
}
/**
* Recursively scan directory for blocked file types
*/
private function scanDirectoryForBlockedFiles(string $directory, array &$blockedFiles): void
{
// Check files
$files = File::files($directory);
foreach ($files as $file) {
$extension = strtolower(pathinfo($file, PATHINFO_EXTENSION));
$relativePath = str_replace(base_path() . '/', '', $file);
if (in_array($extension, self::BLOCKED_EXTENSIONS, true)) {
$blockedFiles[] = $relativePath;
}
}
// Recurse into subdirectories
$dirs = File::directories($directory);
foreach ($dirs as $dir) {
$this->scanDirectoryForBlockedFiles($dir, $blockedFiles);
}
}
/**
* Rollback failed update from _old backups
*/
private function rollback(string $modulePath, string $moduleFolder): void
{
Log::warning('Vikon update: rolling back failed update', [
'module' => $moduleFolder,
]);
// Restore directories
$dirs = File::directories($modulePath);
foreach ($dirs as $dir) {
$dirName = basename($dir);
$oldPath = $dir . self::OLD_SUFFIX;
if (File::exists($oldPath)) {
try {
// Remove failed new version
File::deleteDirectory($dir);
// Restore old version
File::move($oldPath, $dir);
} catch (\Throwable $e) {
Log::error('Vikon update: rollback failed for directory', [
'entry' => $dirName,
'error' => $e->getMessage(),
]);
}
}
}
// Restore files
$files = File::files($modulePath);
foreach ($files as $file) {
$fileName = basename($file);
$oldPath = $file . self::OLD_SUFFIX;
if (File::exists($oldPath)) {
try {
// Remove failed new version
File::delete($file);
// Restore old version
rename($oldPath, $file);
} catch (\Throwable $e) {
Log::error('Vikon update: rollback failed for file', [
'entry' => $fileName,
'error' => $e->getMessage(),
]);
}
}
}
}
}
@@ -1,176 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Actions\Updates;
use App\Containers\VikonIntegration\Tasks\CallVikonApiTask;
use App\Containers\VikonIntegration\Tasks\ManageModuleFilesTask;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Facades\Log;
/**
* Action: Synchronize module files with Vikon file manager
*
* Replaces old vikon_core/start_sync_files.php and sync_root_dir.php
* with proper error handling and secure HTTP.
*/
class SyncModuleFilesAction
{
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
private readonly array $modulesConfig,
private readonly string $basePath,
) {}
/**
* Initialize file sync for module
*
* @param int $moduleId Module ID (1, 2, 6)
* @param string $accessToken Valid Vikon access token
* @return array{directories: array, files_to_sync: array}
* @throws \RuntimeException
*/
public function run(int $moduleId, string $accessToken): array
{
$moduleConfig = $this->getModuleConfig($moduleId);
$modulePath = $this->basePath . '/' . $moduleConfig['path'];
$filesPath = $modulePath . '/files';
// Step 1: Get directories list from Vikon file manager
$response = $this->callVikonApiTask->getWithToken(
'sync/getUsedDirNamesByModule?moduleId=' . $moduleId,
$accessToken,
'filemanager'
);
$body = $response->json();
if (!isset($body['directories']) || !is_array($body['directories'])) {
throw new \RuntimeException('Невалидный ответ от файлового сервера');
}
$directories = $body['directories'];
// Step 2: Remove unknown directories
$this->cleanUnknownDirectories($filesPath, $directories, $modulePath);
// Step 3: Get files that need to be synced
$filesToSync = $this->getFilesToSync($filesPath, $moduleId, $accessToken);
return [
'directories' => $directories,
'files_to_sync' => $filesToSync,
];
}
/**
* Get module configuration
*
* @throws \RuntimeException
*/
private function getModuleConfig(int $moduleId): array
{
if (!isset($this->modulesConfig[$moduleId])) {
throw new \RuntimeException('Неизвестный идентификатор модуля');
}
return $this->modulesConfig[$moduleId];
}
/**
* Remove directories that are not in the known list
*/
private function cleanUnknownDirectories(string $filesPath, array $knownDirs, string $modulePath): void
{
// Guard against empty/malformed remote list
if (empty($knownDirs)) {
Log::warning('Vikon sync: empty directory list from remote, skipping cleanup');
return;
}
if (!File::isDirectory($filesPath)) {
return;
}
$existingDirs = File::directories($filesPath);
foreach ($existingDirs as $dir) {
$dirName = basename($dir);
// Check for symlinks before deleting (like old code)
if (is_link($dir)) {
Log::warning('Vikon sync: skipping symlink during cleanup', [
'path' => $dir,
]);
continue;
}
if (!in_array($dirName, $knownDirs)) {
Log::info('Vikon sync: removing unknown directory', [
'directory' => $dirName,
]);
File::deleteDirectory($dir);
}
}
}
/**
* Get list of files that need to be synced
*/
private function getFilesToSync(string $filesPath, int $moduleId, string $accessToken): array
{
// Get file list from Vikon file manager
$response = $this->callVikonApiTask->getWithToken(
'sync/getFileNamesFromRootDirectoryByModule?moduleId=' . $moduleId,
$accessToken,
'filemanager'
);
$body = $response->json();
if (!isset($body['files']) || !is_array($body['files'])) {
return [];
}
// Build remote files map: name => identity (like old code used $row->i)
$remoteFiles = [];
foreach ($body['files'] as $file) {
if (isset($file['n'])) {
$remoteFiles[$file['n']] = $file['i'] ?? null; // n = name, i = identity
}
}
// Compare with local files
$localFiles = [];
if (File::isDirectory($filesPath)) {
$localFilesList = File::files($filesPath);
foreach ($localFilesList as $localFile) {
$fileName = basename($localFile);
$fileSize = filesize($localFile);
// Skip empty files (like old code: if (!filesize($fsItemPath)))
if ($fileSize > 0) {
$localFiles[$fileName] = $fileSize;
}
}
}
// Find files that don't exist locally or have different identity
$filesToSync = [];
foreach ($remoteFiles as $fileName => $fileId) {
if (!isset($localFiles[$fileName])) {
// File doesn't exist locally
$filesToSync[] = [
'name' => $fileName,
'id' => $fileId,
'reason' => 'missing',
];
}
// Note: old code also checked identity mismatch, but identity is only
// available from filemanager API. If file exists locally with same name,
// we assume it's the correct version (identity match).
}
return $filesToSync;
}
}
@@ -1,125 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Providers;
use App\Containers\VikonIntegration\Actions\Auth\AuthenticateVikonAction;
use App\Containers\VikonIntegration\Actions\Updates\CheckVikonAccessAction;
use App\Containers\VikonIntegration\Actions\Updates\CheckVikonVersionAction;
use App\Containers\VikonIntegration\Actions\Updates\DownloadModuleUpdateAction;
use App\Containers\VikonIntegration\Actions\Updates\SyncModuleFilesAction;
use App\Containers\VikonIntegration\Tasks\CallVikonApiTask;
use App\Containers\VikonIntegration\Tasks\CheckVikonEntryPointTask;
use App\Containers\VikonIntegration\Tasks\ExtractZipArchiveTask;
use App\Containers\VikonIntegration\Tasks\ManageModuleFilesTask;
use App\Containers\VikonIntegration\Tasks\RefreshVikonTokenTask;
use App\Containers\VikonIntegration\Tasks\ValidateVikonTokenTask;
use Illuminate\Support\Facades\Route;
use Illuminate\Support\ServiceProvider;
class VikonIntegrationServiceProvider extends ServiceProvider
{
public function register(): void
{
// Merge config
$this->mergeConfigFrom(config_path('vikon.php'), 'vikon');
// Register Tasks with dependencies from config
$this->app->singleton(CallVikonApiTask::class, function ($app) {
return new CallVikonApiTask(
apiDomain: config('vikon.api_domain'),
authDomain: config('vikon.auth_domain'),
filemanagerDomain: config('vikon.filemanager_domain'),
timeout: config('vikon.http_timeout', 60),
retries: config('vikon.http_retries', 3),
);
});
$this->app->singleton(ExtractZipArchiveTask::class);
$this->app->singleton(ValidateVikonTokenTask::class, function ($app) {
return new ValidateVikonTokenTask(
callVikonApiTask: $app->make(CallVikonApiTask::class),
);
});
$this->app->singleton(RefreshVikonTokenTask::class, function ($app) {
return new RefreshVikonTokenTask(
callVikonApiTask: $app->make(CallVikonApiTask::class),
clientId: config('vikon.client_id'),
clientSecret: config('vikon.client_secret'),
);
});
$this->app->singleton(CheckVikonEntryPointTask::class, function ($app) {
return new CheckVikonEntryPointTask(
callVikonApiTask: $app->make(CallVikonApiTask::class),
clientId: config('vikon.client_id'),
);
});
$this->app->singleton(ManageModuleFilesTask::class, function ($app) {
return new ManageModuleFilesTask(
basePath: public_path(),
);
});
// Register Actions
$this->app->singleton(AuthenticateVikonAction::class, function ($app) {
return new AuthenticateVikonAction(
callVikonApiTask: $app->make(CallVikonApiTask::class),
clientId: config('vikon.client_id', ''),
clientSecret: config('vikon.client_secret', ''),
);
});
$this->app->singleton(ValidateVikonTokenTask::class, function ($app) {
return new ValidateVikonTokenTask(
callVikonApiTask: $app->make(CallVikonApiTask::class),
);
});
$this->app->singleton(CheckVikonAccessAction::class, function ($app) {
return new CheckVikonAccessAction(
validateTokenTask: $app->make(ValidateVikonTokenTask::class),
callVikonApiTask: $app->make(CallVikonApiTask::class),
publicPath: public_path(),
);
});
$this->app->singleton(CheckVikonVersionAction::class, function ($app) {
return new CheckVikonVersionAction(
callVikonApiTask: $app->make(CallVikonApiTask::class),
currentVersion: config('vikon.current_version', '1.0.0'),
);
});
$this->app->singleton(DownloadModuleUpdateAction::class, function ($app) {
return new DownloadModuleUpdateAction(
callVikonApiTask: $app->make(CallVikonApiTask::class),
extractZipTask: $app->make(ExtractZipArchiveTask::class),
modulesConfig: config('vikon.modules'),
storagePath: config('vikon.storage_path'),
basePath: public_path(),
);
});
$this->app->singleton(SyncModuleFilesAction::class, function ($app) {
return new SyncModuleFilesAction(
callVikonApiTask: $app->make(CallVikonApiTask::class),
modulesConfig: config('vikon.modules'),
basePath: public_path(),
);
});
}
public function boot(): void
{
// Load routes
$this->loadRoutesFrom(app_path('Containers/VikonIntegration/UI/WEB/Routes/web.php'));
// Publish config
$this->publishes([
config_path('vikon.php') => config_path('vikon.php'),
], 'vikon-config');
}
}
@@ -1,171 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Tasks;
use Illuminate\Support\Facades\Http;
use Illuminate\Http\Client\ConnectionException;
/**
* Task: Makes secure HTTP requests to Vikon API (db-nica.ru)
*
* SSL verification is ENABLED by default (unlike old vikon_core).
* Uses Laravel Http facade with proper timeout and retry settings.
*/
class CallVikonApiTask
{
public function __construct(
private readonly string $apiDomain,
private readonly string $authDomain,
private readonly string $filemanagerDomain,
private readonly int $timeout,
private readonly int $retries,
) {}
/**
* GET request to Vikon API
*/
public function get(string $endpoint, array $headers = [], string $service = 'api'): \Illuminate\Http\Client\Response
{
$baseUrl = $this->resolveBaseUrl($service);
$url = rtrim($baseUrl, '/') . '/' . ltrim($endpoint, '/');
return $this->makeRequest('get', $url, [], $headers);
}
/**
* POST request to Vikon API
*/
public function post(string $endpoint, array $data = [], array $headers = [], string $service = 'api'): \Illuminate\Http\Client\Response
{
$baseUrl = $this->resolveBaseUrl($service);
$url = rtrim($baseUrl, '/') . '/' . ltrim($endpoint, '/');
return $this->makeRequest('post', $url, $data, $headers);
}
/**
* GET request with Bearer token authorization
*/
public function getWithToken(string $endpoint, string $token, string $service = 'api'): \Illuminate\Http\Client\Response
{
$baseUrl = $this->resolveBaseUrl($service);
$url = rtrim($baseUrl, '/') . '/' . ltrim($endpoint, '/');
return $this->makeRequest('get', $url, [], [
'Authorization' => 'Bearer ' . $token,
'Accept' => 'application/json',
]);
}
/**
* POST request with Bearer token authorization
*/
public function postWithToken(string $endpoint, string $token, array $data = [], string $service = 'api'): \Illuminate\Http\Client\Response
{
$baseUrl = $this->resolveBaseUrl($service);
$url = rtrim($baseUrl, '/') . '/' . ltrim($endpoint, '/');
return $this->makeRequest('post', $url, $data, [
'Authorization' => 'Bearer ' . $token,
'Accept' => 'application/json',
]);
}
/**
* Download binary content (ZIP archive) with Bearer token
*/
public function downloadWithToken(string $endpoint, string $token, string $service = 'api'): string
{
$baseUrl = $this->resolveBaseUrl($service);
$url = rtrim($baseUrl, '/') . '/' . ltrim($endpoint, '/');
$response = Http::withHeaders([
'Authorization' => 'Bearer ' . $token,
'Accept-Encoding' => 'zip, gzip',
'Accept' => 'application/json',
])
->timeout($this->timeout)
->retry($this->retries, 1000, function ($exception, $response) {
if ($response && $response->successful()) {
return false;
}
return true;
})
->get($url);
if ($response->failed()) {
throw new \RuntimeException(
'Vikon API error: ' . $this->extractErrorMessage($response) . ' (HTTP ' . $response->status() . ')'
);
}
return $response->body();
}
/**
* Resolve base URL by service type
*/
private function resolveBaseUrl(string $service): string
{
return match ($service) {
'auth' => $this->authDomain,
'filemanager' => $this->filemanagerDomain,
default => $this->apiDomain,
};
}
/**
* Make HTTP request with common settings
*
* @throws ConnectionException
* @throws \RuntimeException
*/
private function makeRequest(string $method, string $url, array $data, array $headers): \Illuminate\Http\Client\Response
{
$http = Http::withHeaders(array_merge([
'Accept' => 'application/json',
], $headers))
->timeout($this->timeout)
->retry($this->retries, 1000, function ($exception, $response) {
if ($response && $response->successful()) {
return false;
}
return true;
});
$response = match ($method) {
'get' => $data ? $http->get($url, $data) : $http->get($url),
'post' => $http->post($url, $data),
};
if ($response->failed()) {
throw new \RuntimeException(
'Vikon API error: ' . $this->extractErrorMessage($response) . ' (HTTP ' . $response->status() . ')'
);
}
return $response;
}
/**
* Extract error message from API response
*/
private function extractErrorMessage(\Illuminate\Http\Client\Response $response): string
{
$body = $response->json();
if (isset($body['message'])) {
return $body['message'];
}
if (isset($body['error'])) {
return $body['error'];
}
if (isset($body['messages']) && is_array($body['messages'])) {
return implode('; ', $body['messages']);
}
return 'Unknown error';
}
}
@@ -1,35 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Tasks;
/**
* Task: Check if current entry point is allowed in Vikon settings
*/
class CheckVikonEntryPointTask
{
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
private readonly string $clientId,
) {}
/**
* Verify that the current URL is registered as valid entry point
*
* @return bool
* @throws \RuntimeException
*/
public function run(string $entryPoint): bool
{
$response = $this->callVikonApiTask->get(
'oauth2/checkEntryPoint',
[
'client_id' => $this->clientId,
'entry_point' => $entryPoint,
]
);
$body = $response->json();
return isset($body['success']) && $body['success'] === true;
}
}
@@ -1,119 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Tasks;
use ZipArchive;
/**
* Task: Safely extracts ZIP archives with Zip Slip protection
*
* Unlike old vikon_core which used unpackZip() without path validation,
* this task validates every entry to prevent directory traversal attacks.
*/
class ExtractZipArchiveTask
{
/**
* Extract ZIP archive to destination with security checks
*
* @param string $zipPath Absolute path to ZIP file
* @param string $destination Absolute path to extraction directory
* @return bool
* @throws \RuntimeException
*/
public function run(string $zipPath, string $destination): bool
{
if (!file_exists($zipPath)) {
throw new \RuntimeException("ZIP file not found: {$zipPath}");
}
if (!is_writable(dirname($destination))) {
throw new \RuntimeException("Destination directory is not writable: " . dirname($destination));
}
$zip = new ZipArchive;
$openResult = $zip->open($zipPath);
if ($openResult !== true) {
throw new \RuntimeException("Failed to open ZIP archive (code: {$openResult})");
}
// Zip Slip protection: validate every entry
$this->validateZipEntries($zip, $destination);
// Extract with overwrite
$extractResult = $zip->extractTo($destination);
$zip->close();
if (!$extractResult) {
throw new \RuntimeException('Failed to extract ZIP archive');
}
return true;
}
/**
* Validate all ZIP entries to prevent Zip Slip attack
*
* @throws \RuntimeException
*/
private function validateZipEntries(ZipArchive $zip, string $destination): void
{
$realDestination = realpath($destination);
if ($realDestination === false) {
throw new \RuntimeException('Destination directory does not exist');
}
for ($i = 0; $i < $zip->numFiles; $i++) {
$filename = $zip->getNameIndex($i);
// Check for path traversal patterns
if ($this->containsPathTraversal($filename)) {
throw new \RuntimeException(
"Potentially malicious ZIP entry detected: {$filename}"
);
}
// Resolve full path and verify it's within destination
$fullPath = realpath($realDestination . '/' . $filename);
if ($fullPath === false) {
// File doesn't exist yet (will be created), check parent directory
$parentDir = dirname($realDestination . '/' . $filename);
if (strpos($parentDir, $realDestination) !== 0) {
throw new \RuntimeException(
"ZIP entry escapes destination directory: {$filename}"
);
}
} elseif (strpos($fullPath, $realDestination) !== 0) {
throw new \RuntimeException(
"ZIP entry escapes destination directory: {$filename}"
);
}
}
}
/**
* Check if filename contains path traversal patterns
*/
private function containsPathTraversal(string $filename): bool
{
// Check for directory traversal sequences
if (strpos($filename, '..') !== false) {
return true;
}
// Check for absolute paths on Windows
if (preg_match('/^[a-zA-Z]:/', $filename)) {
return true;
}
// Check for absolute paths on Unix
if (strpos($filename, '/') === 0) {
return true;
}
return false;
}
}
@@ -1,223 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Tasks;
use Illuminate\Support\Facades\File;
/**
* Task: Manage module files (scan, remove, create directories)
*
* Replaces old vikon_core Filesystem class with Laravel's File facade.
* All operations are scoped to specific module to prevent accidental deletion.
*/
class ManageModuleFilesTask
{
public function __construct(
private readonly string $basePath,
) {}
/**
* Get module root path
*/
public function getModulePath(int $moduleId, string $moduleFolder): string
{
return $this->basePath . '/' . $moduleFolder;
}
/**
* Safely remove directory with path validation
*
* @param string $path Path to remove
* @param string $allowedBasePath Base path constraint
* @param bool $recursive Remove recursively
* @return bool
*/
public function safeRemove(string $path, string $allowedBasePath, bool $recursive = false): bool
{
// Prevent path traversal
if (!$this->isPathWithinBase($path, $allowedBasePath)) {
\Illuminate\Support\Facades\Log::warning('Attempted to remove path outside allowed base', [
'path' => $path,
'allowed_base' => $allowedBasePath,
]);
return false;
}
if (!file_exists($path)) {
return true;
}
if (!is_dir($path)) {
return File::delete($path);
}
return File::deleteDirectory($path);
}
/**
* Safely create directory
*/
public function safeMkdir(string $path, int $mode = 0755): bool
{
if (File::isDirectory($path)) {
return true;
}
return File::makeDirectory($path, $mode, true, true);
}
/**
* Safely create file with content
*/
public function safeCreateFile(string $path, string $content = '', int $mode = 0644): bool
{
if (File::exists($path)) {
return true;
}
$directory = dirname($path);
if (!File::isDirectory($directory)) {
File::makeDirectory($directory, 0755, true, true);
}
$result = File::put($path, $content);
if ($result === false) {
return false;
}
chmod($path, $mode);
return true;
}
/**
* Scan directory safely (excludes . and ..)
*
* @return array|false
*/
public function safeScandir(string $path): array|false
{
if (!File::isDirectory($path) || !File::isReadable($path)) {
return false;
}
$entries = File::directories($path);
$files = File::files($path);
return array_merge(
array_map('basename', $entries),
array_map('basename', $files)
);
}
/**
* Rename file with path validation
*/
public function safeRename(string $oldPath, string $newPath, string $allowedBasePath): bool
{
if (!$this->isPathWithinBase($oldPath, $allowedBasePath)) {
return false;
}
if (!$this->isPathWithinBase($newPath, $allowedBasePath)) {
return false;
}
if (!File::exists($oldPath)) {
return false;
}
if (File::exists($newPath)) {
return false;
}
$newDir = dirname($newPath);
if (!File::isDirectory($newDir)) {
return false;
}
return File::move($oldPath, $newPath);
}
/**
* Replace directory with rename (atomic operation)
*
* Old -> _old
* New -> Old
*/
public function replaceWithRename(string $sourceDir, string $targetDir, string $allowedBasePath): bool
{
if (!$this->isPathWithinBase($sourceDir, $allowedBasePath)) {
return false;
}
if (!$this->isPathWithinBase($targetDir, $allowedBasePath)) {
return false;
}
if (!File::exists($sourceDir)) {
return false;
}
if (File::exists($targetDir)) {
return false;
}
$parentDir = dirname($targetDir);
if (!is_writable($parentDir)) {
return false;
}
if (!File::makeDirectory($targetDir, 0755, true, true)) {
return false;
}
$entries = $this->safeScandir($sourceDir);
if (empty($entries)) {
return File::deleteDirectory($sourceDir);
}
foreach ($entries as $entry) {
$item = $sourceDir . '/' . $entry;
$newPath = $targetDir . '/' . $entry;
if (File::isDirectory($item)) {
if (!$this->replaceWithRename($item, $newPath, $allowedBasePath)) {
return false;
}
} else {
if (!File::move($item, $newPath)) {
return false;
}
}
}
return File::deleteDirectory($sourceDir);
}
/**
* Check if path is within allowed base directory
*/
private function isPathWithinBase(string $path, string $basePath): bool
{
$realPath = realpath($path);
$realBase = realpath($basePath);
// If base directory doesn't exist, path cannot be valid
if ($realBase === false) {
\Illuminate\Support\Facades\Log::error('Base path does not exist', [
'base' => $basePath,
]);
return false;
}
if ($realPath === false) {
// For non-existent paths, check parent directory
$parentDir = dirname($path);
$realParent = realpath($parentDir);
if ($realParent === false) {
return false;
}
return str_starts_with($realParent . '/', $realBase . '/');
}
return str_starts_with($realPath . '/', $realBase . '/') || $realPath === $realBase;
}
}
@@ -1,50 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Tasks;
/**
* Task: Refresh Vikon access token using refresh_token
*
* Old vikon_core used refresh_token.php with SSL verification disabled.
* This task uses secure Http client with proper error handling.
*/
class RefreshVikonTokenTask
{
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
private readonly string $clientId,
private readonly string $clientSecret,
) {}
/**
* Exchange refresh_token for new access_token and refresh_token
*
* Uses api_domain (db-nica.ru) as per old update/refresh_access_token.php
* NOT auth_domain (auth.db-nica.ru)
*
* @return array{access_token: string, refresh_token: string}
* @throws \RuntimeException
*/
public function run(string $refreshToken): array
{
$response = $this->callVikonApiTask->post('oauth2/RefreshToken', [
'refresh_token' => $refreshToken,
'client_id' => $this->clientId,
'client_secret' => $this->clientSecret,
'grant_type' => 'refresh_token',
], [], 'api'); // <-- api domain (db-nica.ru), NOT auth domain
$body = $response->json();
if (!isset($body['access_token']) || !isset($body['refresh_token'])) {
throw new \RuntimeException(
'Invalid token refresh response: ' . ($body['message'] ?? 'Unknown error')
);
}
return [
'access_token' => $body['access_token'],
'refresh_token' => $body['refresh_token'],
];
}
}
@@ -1,40 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\Tasks;
/**
* Task: Validate Vikon access token by checking with remote API
*/
class ValidateVikonTokenTask
{
public function __construct(
private readonly CallVikonApiTask $callVikonApiTask,
) {}
/**
* Check if access_token is valid
*
* Uses auth_domain (auth.db-nica.ru) + api/profile_applicant/check_access_token
* as per old scripts/check_token.php
*
* @return bool
*/
public function run(string $accessToken): bool
{
try {
$response = $this->callVikonApiTask->getWithToken(
'api/profile_applicant/check_access_token',
$accessToken,
'auth' // <-- auth domain (auth.db-nica.ru)
);
return $response->successful();
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::warning('Vikon token validation failed', [
'error' => $e->getMessage(),
]);
return false;
}
}
}
@@ -1,305 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\UI\WEB\Controllers;
use App\Containers\VikonIntegration\Actions\Auth\AuthenticateVikonAction;
use App\Containers\VikonIntegration\Actions\Updates\CheckVikonAccessAction;
use App\Containers\VikonIntegration\Actions\Updates\CheckVikonVersionAction;
use App\Containers\VikonIntegration\Actions\Updates\DownloadModuleUpdateAction;
use App\Containers\VikonIntegration\Actions\Updates\SyncModuleFilesAction;
use App\Containers\VikonIntegration\Tasks\CheckVikonEntryPointTask;
use App\Containers\VikonIntegration\Tasks\RefreshVikonTokenTask;
use App\Containers\VikonIntegration\Tasks\ValidateVikonTokenTask;
use App\Containers\VikonIntegration\UI\WEB\Requests\AuthenticateVikonRequest;
use App\Containers\VikonIntegration\UI\WEB\Requests\DownloadModuleUpdateRequest;
use App\Containers\VikonIntegration\UI\WEB\Requests\RefreshVikonTokenRequest;
use App\Http\Controllers\Controller;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Session;
class VikonUpdateController extends Controller
{
public function __construct(
private readonly AuthenticateVikonAction $authenticateAction,
private readonly CheckVikonAccessAction $checkAccessAction,
private readonly CheckVikonVersionAction $checkVersionAction,
private readonly DownloadModuleUpdateAction $downloadUpdateAction,
private readonly SyncModuleFilesAction $syncFilesAction,
private readonly CheckVikonEntryPointTask $checkEntryPointTask,
private readonly RefreshVikonTokenTask $refreshTokenTask,
private readonly ValidateVikonTokenTask $validateTokenTask,
) {}
/**
* Get current version from config
*/
private function getCurrentVersion(): string
{
return config('vikon.current_version', file_get_contents(base_path('vikon_version.txt')) ?: '1.0.0');
}
/**
* GET /dashboard/vikon-updates
* Show update management page
*/
public function index(Request $request): \Inertia\Response
{
$isAuthenticated = $this->hasValidVikonSession();
return inertia()->render('Dashboard/VikonUpdates/Index', [
'is_authenticated' => $isAuthenticated,
'current_version' => $this->getCurrentVersion(),
'modules' => config('vikon.modules'),
'vikon_auth_domain' => config('vikon.api_domain'),
'vikon_client_id' => config('vikon.client_id'),
]);
}
/**
* POST /dashboard/vikon-updates/authenticate
* Exchange OAuth code for tokens
*/
public function authenticate(AuthenticateVikonRequest $request): JsonResponse
{
try {
$tokens = $this->authenticateAction->run(
$request->validated('code'),
$request->validated('redirect_uri')
);
// Store tokens in secure session (HttpOnly cookie)
Session::put('vikon_access_token', $tokens['access_token']);
Session::put('vikon_refresh_token', $tokens['refresh_token']);
return response()->json([
'success' => true,
'message' => 'Авторизация успешна',
]);
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::error('Vikon authentication failed', [
'error' => $e->getMessage(),
]);
return response()->json([
'success' => false,
'message' => 'Ошибка авторизации. Пожалуйста, попробуйте снова.',
], 422);
}
}
/**
* POST /dashboard/vikon-updates/refresh-token
* Refresh access token
*/
public function refreshToken(RefreshVikonTokenRequest $request): JsonResponse
{
try {
$tokens = $this->refreshTokenTask->run(
$request->validated('refresh_token')
);
Session::put('vikon_access_token', $tokens['access_token']);
Session::put('vikon_refresh_token', $tokens['refresh_token']);
return response()->json([
'success' => true,
'message' => 'Токен обновлён',
]);
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::error('Vikon token refresh failed', [
'error' => $e->getMessage(),
]);
return response()->json([
'success' => false,
'message' => 'Ошибка обновления токена. Пожалуйста, выполните повторную авторизацию.',
], 422);
}
}
/**
* POST /dashboard/vikon-updates/check-access
* Verify user has update permissions
*/
public function checkAccess(Request $request): JsonResponse
{
$accessToken = Session::get('vikon_access_token');
if (!$accessToken) {
return response()->json([
'success' => false,
'message' => 'Требуется авторизация',
'requires_auth' => true,
], 401);
}
$result = $this->checkAccessAction->run($accessToken);
return response()->json([
'success' => $result['has_access'],
'has_access' => $result['has_access'],
'error' => $result['error'],
'permissions' => $result['permissions'],
]);
}
/**
* POST /dashboard/vikon-updates/check-version
* Check for available updates
*/
public function checkVersion(Request $request): JsonResponse
{
$accessToken = Session::get('vikon_access_token');
if (!$accessToken) {
return response()->json([
'success' => false,
'message' => 'Требуется авторизация',
'requires_auth' => true,
], 401);
}
$result = $this->checkVersionAction->run($accessToken);
return response()->json($result);
}
/**
* POST /dashboard/vikon-updates/download-update
* Download and install module update
*/
public function downloadUpdate(DownloadModuleUpdateRequest $request): JsonResponse
{
$accessToken = Session::get('vikon_access_token');
if (!$accessToken) {
return response()->json([
'success' => false,
'message' => 'Требуется авторизация',
'requires_auth' => true,
], 401);
}
try {
$message = $this->downloadUpdateAction->run(
$request->validated('module_id'),
$accessToken
);
return response()->json([
'success' => true,
'message' => $message,
]);
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::error('Vikon module update failed', [
'module_id' => $request->validated('module_id'),
'error' => $e->getMessage(),
]);
return response()->json([
'success' => false,
'message' => 'Произошла ошибка при обновлении модуля. Обратитесь к администратору.',
], 500);
}
}
/**
* POST /dashboard/vikon-updates/sync-files
* Initialize file sync for module
*/
public function syncFiles(Request $request): JsonResponse
{
$request->validate([
'module_id' => ['required', 'integer', 'in:1,2,6'],
]);
$accessToken = Session::get('vikon_access_token');
if (!$accessToken) {
return response()->json([
'success' => false,
'message' => 'Требуется авторизация',
'requires_auth' => true,
], 401);
}
try {
$result = $this->syncFilesAction->run(
$request->input('module_id'),
$accessToken
);
return response()->json([
'success' => true,
'directories' => $result['directories'],
'files_to_sync' => $result['files_to_sync'],
]);
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::error('Vikon file sync failed', [
'module_id' => $request->input('module_id'),
'error' => $e->getMessage(),
]);
return response()->json([
'success' => false,
'message' => 'Произошла ошибка при синхронизации файлов.',
], 500);
}
}
/**
* GET /dashboard/vikon-updates/check-entry
* Verify current URL is valid entry point
*/
public function checkEntry(Request $request): JsonResponse
{
$entryPoint = $request->input('entry', url()->current());
try {
$isValid = $this->checkEntryPointTask->run($entryPoint);
return response()->json([
'success' => $isValid,
'entry_point' => $entryPoint,
]);
} catch (\Throwable $e) {
\Illuminate\Support\Facades\Log::error('Vikon entry point check failed', [
'error' => $e->getMessage(),
]);
return response()->json([
'success' => false,
'message' => 'Не удалось проверить точку входа.',
], 500);
}
}
/**
* POST /dashboard/vikon-updates/logout
* Clear Vikon session
*/
public function logout(Request $request): JsonResponse
{
Session::forget(['vikon_access_token', 'vikon_refresh_token']);
return response()->json([
'success' => true,
'message' => 'Сессия завершена',
]);
}
/**
* Check if user has valid Vikon session
*/
private function hasValidVikonSession(): bool
{
$accessToken = Session::get('vikon_access_token');
if (!$accessToken) {
return false;
}
return $this->validateTokenTask->run($accessToken);
}
}
@@ -1,31 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\UI\WEB\Requests;
use Illuminate\Foundation\Http\FormRequest;
use Illuminate\Validation\Rule;
class AuthenticateVikonRequest extends FormRequest
{
public function authorize(): bool
{
return auth()->check();
}
public function rules(): array
{
return [
'code' => ['required', 'string', 'max:255'],
'redirect_uri' => ['required', 'url'],
];
}
public function messages(): array
{
return [
'code.required' => 'Код авторизации обязателен.',
'redirect_uri.required' => 'URL перенаправления обязателен.',
'redirect_uri.url' => 'Некорректный URL перенаправления.',
];
}
}
@@ -1,30 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\UI\WEB\Requests;
use Illuminate\Foundation\Http\FormRequest;
use Illuminate\Validation\Rule;
class DownloadModuleUpdateRequest extends FormRequest
{
public function authorize(): bool
{
return auth()->check();
}
public function rules(): array
{
return [
'module_id' => ['required', 'integer', Rule::in([1, 2, 6])],
];
}
public function messages(): array
{
return [
'module_id.required' => 'Идентификатор модуля обязателен.',
'module_id.integer' => 'Идентификатор модуля должен быть числом.',
'module_id.in' => 'Неподдерживаемый идентификатор модуля. Допустимы: 1 (Сведения), 2 (Абитуриент), 6 (ВСОКО).',
];
}
}
@@ -1,27 +0,0 @@
<?php
namespace App\Containers\VikonIntegration\UI\WEB\Requests;
use Illuminate\Foundation\Http\FormRequest;
class RefreshVikonTokenRequest extends FormRequest
{
public function authorize(): bool
{
return auth()->check();
}
public function rules(): array
{
return [
'refresh_token' => ['required', 'string', 'max:500'],
];
}
public function messages(): array
{
return [
'refresh_token.required' => 'Refresh token обязателен.',
];
}
}
@@ -1,41 +0,0 @@
<?php
use App\Containers\VikonIntegration\UI\WEB\Controllers\VikonUpdateController;
use Illuminate\Support\Facades\Route;
/*
|--------------------------------------------------------------------------
| Vikon Update Management Routes
|--------------------------------------------------------------------------
|
| Secure routes for Vikon module update management.
| All routes are protected by:
| - access-check: Verify route is registered in DB
| - dashboard.auth: Require authentication
| - throttle: Rate limiting (30 requests per minute)
|
| Replaces old: /vikon_core/update/*.php direct access
|
*/
Route::prefix('/dashboard/vikon-updates')
->name('dashboard.vikon-updates.')
->middleware(['access-check', 'dashboard.auth', 'throttle:30,1'])
->group(function () {
// Main page
Route::get('/', [VikonUpdateController::class, 'index'])->name('index');
// OAuth authentication
Route::post('/authenticate', [VikonUpdateController::class, 'authenticate'])->name('authenticate');
Route::post('/refresh-token', [VikonUpdateController::class, 'refreshToken'])->name('refresh-token');
Route::post('/logout', [VikonUpdateController::class, 'logout'])->name('logout');
// Access & version checks
Route::post('/check-access', [VikonUpdateController::class, 'checkAccess'])->name('check-access');
Route::post('/check-version', [VikonUpdateController::class, 'checkVersion'])->name('check-version');
Route::get('/check-entry', [VikonUpdateController::class, 'checkEntry'])->name('check-entry');
// Update operations
Route::post('/download-update', [VikonUpdateController::class, 'downloadUpdate'])->name('download-update');
Route::post('/sync-files', [VikonUpdateController::class, 'syncFiles'])->name('sync-files');
});
+1 -1
View File
@@ -172,7 +172,7 @@ return [
// App\Providers\Filament\DashboardPanelProvider::class,
App\Providers\RouteServiceProvider::class,
\App\Providers\ForceHttpsServiceProvider::class,
\App\Containers\VikonIntegration\Providers\VikonIntegrationServiceProvider::class,
// \App\Containers\VikonIntegration\Providers\VikonServiceProvider::class, // will be re-added
])->toArray(),
/*
-101
View File
@@ -1,101 +0,0 @@
<?php
return [
/*
|--------------------------------------------------------------------------
| Vikon API Configuration
|--------------------------------------------------------------------------
|
| Credentials and endpoints for Vikon integration (db-nica.ru).
| All sensitive data moved from public/vikon_core to .env
|
*/
'client_id' => env('VIKON_CLIENT_ID', '542'),
'client_secret' => env('VIKON_CLIENT_SECRET', ''),
'vuz_id' => env('VIKON_VUZ_ID', '16775'),
/*
|--------------------------------------------------------------------------
| Current Version
|--------------------------------------------------------------------------
*/
'current_version' => env('VIKON_CURRENT_VERSION', file_get_contents(base_path('vikon_version.txt')) ?: '1.0.0'),
/*
|--------------------------------------------------------------------------
| API Endpoints
|--------------------------------------------------------------------------
*/
'api_domain' => env('VIKON_API_DOMAIN', 'https://db-nica.ru/'),
'auth_domain' => env('VIKON_AUTH_DOMAIN', 'https://auth.db-nica.ru/'),
'filemanager_domain' => env('VIKON_FILEMANAGER_DOMAIN', 'https://file.db-nica.ru/'),
/*
|--------------------------------------------------------------------------
| Module Configuration
|--------------------------------------------------------------------------
|
| Module IDs and their deployment paths
| 1 = Sveden (Сведения)
| 2 = Abitur (Абитуриент)
| 6 = VSOKO (ВСОКО)
|
*/
'modules' => [
1 => [
'name' => 'Сведения об образовательной организации',
'path' => 'sveden',
'allowed_folders' => [
'assets', 'files_zaglushka', 'common', 'struct', 'document',
'education', 'managers', 'employees', 'objects', 'paid_edu',
'budget', 'vacant', 'grants', 'inter', 'catering',
'eduStandarts', 'corruption', 'antiterrorism', 'files',
'update', 'index.html', '.vikon', '.htaccess',
],
],
2 => [
'name' => 'Абитуриент',
'path' => 'abitur',
'allowed_folders' => ['abitur'],
],
6 => [
'name' => 'ВСОКО',
'path' => 'vsoko',
'allowed_folders' => [
'assets', 'general', 'structure', 'faq', 'procedures',
'results-and-reports', 'plans', 'survey', 'files',
'.vikon', 'index.html', '.htaccess',
],
],
],
/*
|--------------------------------------------------------------------------
| HTTP Client Settings
|--------------------------------------------------------------------------
*/
'http_timeout' => env('VIKON_HTTP_TIMEOUT', 60),
'http_retries' => env('VIKON_HTTP_RETRIES', 3),
/*
|--------------------------------------------------------------------------
| Update Settings
|--------------------------------------------------------------------------
*/
'storage_path' => storage_path('app/vikon'),
'max_upload_size' => env('VIKON_MAX_UPLOAD_SIZE', 50 * 1024 * 1024), // 50MB
];
@@ -1,377 +0,0 @@
<template>
<DashboardLayout>
<template #header-icon>
<DashboardIcon name="arrow-down-tray" size="5" class="text-primary" />
</template>
<template #header-title>Обновления VIKON</template>
<template #header-subtitle>Управление обновлениями модулей</template>
<!-- Flash Messages -->
<FlashMessages />
<!-- Not Authenticated State -->
<div v-if="!isAuthenticated" class="bg-layer border border-layer-line rounded-lg shadow-xs p-8">
<div class="text-center">
<DashboardIcon name="shield-exclamation" size="16" class="text-muted-foreground-1 mx-auto mb-4" />
<h3 class="text-lg font-medium text-foreground mb-2">Требуется авторизация VIKON</h3>
<p class="text-sm text-muted-foreground-1 mb-6">
Для управления обновлениями необходимо войти через систему VIKON
</p>
<a
:href="vikonAuthUrl"
class="inline-flex items-center gap-2 px-6 py-3 bg-primary text-white text-sm font-medium rounded-lg hover:bg-primary-hover transition-all duration-200 shadow-sm hover:shadow-md"
>
<DashboardIcon name="arrow-right-on-rectangle" size="5" />
Войти через VIKON
</a>
</div>
</div>
<!-- Authenticated State -->
<div v-else class="space-y-6">
<!-- Version Info & Update Button -->
<div class="grid grid-cols-1 lg:grid-cols-2 gap-6">
<!-- Current Version -->
<div class="bg-layer border border-layer-line rounded-lg shadow-xs p-6">
<div class="flex items-center gap-3 mb-4">
<DashboardIcon name="information-circle" size="6" class="text-primary" />
<div>
<h3 class="text-sm font-medium text-foreground">Текущая версия</h3>
<p class="text-2xl font-semibold text-foreground mt-1">{{ currentVersion }}</p>
</div>
</div>
<div v-if="versionInfo.has_update" class="mt-4 p-3 bg-yellow-50 border border-yellow-200 rounded-lg">
<div class="flex items-start gap-2">
<DashboardIcon name="exclamation-triangle" size="5" class="text-yellow-600 mt-0.5" />
<div>
<p class="text-sm font-medium text-yellow-800">Доступно обновление</p>
<p class="text-xs text-yellow-700 mt-1">Версия: {{ versionInfo.latest_version }}</p>
</div>
</div>
</div>
<div v-else-if="versionInfo.latest_version" class="mt-4 p-3 bg-green-50 border border-green-200 rounded-lg">
<div class="flex items-start gap-2">
<DashboardIcon name="check-circle" size="5" class="text-green-600 mt-0.5" />
<div>
<p class="text-sm font-medium text-green-800">Установлена последняя версия</p>
</div>
</div>
</div>
<button
@click="checkVersion"
:disabled="checkingVersion"
class="mt-4 w-full inline-flex items-center justify-center gap-2 px-4 py-2 bg-surface border border-layer-line text-sm font-medium rounded-lg hover:bg-muted-hover transition-all duration-200 disabled:opacity-50"
>
<DashboardIcon v-if="checkingVersion" name="arrow-path" size="4" class="animate-spin" />
<DashboardIcon v-else name="magnifying-glass" size="4" />
{{ checkingVersion ? 'Проверка...' : 'Проверить наличие обновлений' }}
</button>
</div>
<!-- Access Status -->
<div class="bg-layer border border-layer-line rounded-lg shadow-xs p-6">
<div class="flex items-center gap-3 mb-4">
<DashboardIcon name="shield-check" size="6" class="text-primary" />
<div>
<h3 class="text-sm font-medium text-foreground">Статус доступа</h3>
<p class="text-sm text-muted-foreground-1 mt-1">
{{ accessInfo.has_access ? 'Доступ разрешён' : 'Доступ запрещён' }}
</p>
</div>
</div>
<div v-if="accessInfo.error" class="mt-4 p-3 bg-red-50 border border-red-200 rounded-lg">
<div class="flex items-start gap-2">
<DashboardIcon name="x-circle" size="5" class="text-red-600 mt-0.5" />
<p class="text-sm text-red-800">{{ accessInfo.error }}</p>
</div>
</div>
<button
@click="checkAccess"
:disabled="checkingAccess"
class="mt-4 w-full inline-flex items-center justify-center gap-2 px-4 py-2 bg-surface border border-layer-line text-sm font-medium rounded-lg hover:bg-muted-hover transition-all duration-200 disabled:opacity-50"
>
<DashboardIcon v-if="checkingAccess" name="arrow-path" size="4" class="animate-spin" />
<DashboardIcon v-else name="shield-check" size="4" />
{{ checkingAccess ? 'Проверка...' : 'Проверить права доступа' }}
</button>
</div>
</div>
<!-- Module Updates -->
<div class="bg-layer border border-layer-line rounded-lg shadow-xs">
<div class="px-6 py-4 border-b border-layer-line">
<h3 class="text-sm font-medium text-foreground">Модули для обновления</h3>
</div>
<div class="divide-y divide-line-2">
<div v-for="(module, id) in modules" :key="id" class="px-6 py-4 flex items-center justify-between">
<div class="flex items-center gap-3">
<DashboardIcon name="cube" size="6" class="text-primary" />
<div>
<p class="text-sm font-medium text-foreground">{{ module.name }}</p>
<p class="text-xs text-muted-foreground-1">ID: {{ id }}</p>
</div>
</div>
<button
@click="downloadUpdate(id)"
:disabled="updating || !accessInfo.has_access"
class="inline-flex items-center gap-2 px-4 py-2 bg-primary text-white text-sm font-medium rounded-lg hover:bg-primary-hover transition-all duration-200 shadow-sm hover:shadow-md disabled:opacity-50 disabled:cursor-not-allowed"
>
<DashboardIcon v-if="updating" name="arrow-path" size="4" class="animate-spin" />
<DashboardIcon v-else name="arrow-down-tray" size="4" />
{{ updating ? 'Обновление...' : 'Обновить' }}
</button>
</div>
</div>
</div>
<!-- Progress Bar -->
<div v-if="updating" class="bg-layer border border-layer-line rounded-lg shadow-xs p-6">
<div class="flex items-center gap-3 mb-3">
<DashboardIcon name="arrow-path" size="5" class="text-primary animate-spin" />
<p class="text-sm font-medium text-foreground">Выполняется обновление...</p>
</div>
<div class="w-full bg-muted rounded-full h-2.5">
<div
class="bg-primary h-2.5 rounded-full transition-all duration-300"
:style="{ width: progress + '%' }"
></div>
</div>
<p class="text-xs text-muted-foreground-1 mt-2">{{ progress }}%</p>
</div>
<!-- Update Error -->
<div v-if="updateError" class="bg-layer border border-red-200 rounded-lg shadow-xs p-6">
<div class="flex items-start gap-3">
<DashboardIcon name="x-circle" size="6" class="text-red-600" />
<div>
<h4 class="text-sm font-medium text-red-800">Ошибка обновления</h4>
<p class="text-sm text-red-700 mt-1">{{ updateError }}</p>
</div>
</div>
</div>
<!-- Logout Button -->
<div class="flex justify-end">
<button
@click="logout"
class="inline-flex items-center gap-2 px-4 py-2 bg-surface border border-layer-line text-sm font-medium rounded-lg hover:bg-muted-hover transition-all duration-200"
>
<DashboardIcon name="arrow-right-on-rectangle" size="4" />
Выйти из VIKON
</button>
</div>
</div>
</DashboardLayout>
</template>
<script>
import DashboardLayout from '../Components/DashboardLayout.vue';
import DashboardIcon from '../Components/DashboardIcon.vue';
import FlashMessages from '../Components/shared/FlashMessages.vue';
export default {
components: {
DashboardLayout,
DashboardIcon,
FlashMessages,
},
props: {
is_authenticated: {
type: Boolean,
default: false,
},
current_version: {
type: String,
default: '',
},
modules: {
type: Object,
default: () => ({}),
},
vikon_auth_domain: {
type: String,
default: 'https://auth.db-nica.ru/',
},
vikon_client_id: {
type: String,
default: '',
},
},
data() {
return {
isAuthenticated: this.is_authenticated,
currentVersion: this.current_version,
checkingVersion: false,
checkingAccess: false,
updating: false,
progress: 0,
updateError: null,
versionInfo: {
current_version: this.current_version,
has_update: false,
latest_version: null,
},
accessInfo: {
has_access: false,
error: null,
permissions: [],
},
};
},
computed: {
vikonAuthUrl() {
const redirectUri = encodeURIComponent(route('dashboard.vikon-updates.index'));
return `${this.vikon_auth_domain}oauth2/authorize?client_id=${this.vikon_client_id}&redirect_uri=${redirectUri}&response_type=code`;
},
},
mounted() {
if (this.isAuthenticated) {
this.checkAccess();
this.checkVersion();
}
// Check for OAuth code in URL
const urlParams = new URLSearchParams(window.location.search);
const code = urlParams.get('code');
if (code) {
this.authenticate(code);
}
},
methods: {
async authenticate(code) {
try {
const response = await this.$inertia.post(route('dashboard.vikon-updates.authenticate'), {
code: code,
redirect_uri: window.location.origin + window.location.pathname,
}, {
preserveState: true,
preserveScroll: true,
onSuccess: () => {
this.isAuthenticated = true;
this.checkAccess();
this.checkVersion();
// Clean URL
window.history.replaceState({}, document.title, window.location.pathname);
},
onError: (errors) => {
this.$inertia.visit(route('dashboard.vikon-updates.index'), {
preserveState: true,
preserveScroll: true,
});
},
});
} catch (error) {
console.error('Authentication failed:', error);
}
},
async checkAccess() {
this.checkingAccess = true;
try {
const response = await axios.post(route('dashboard.vikon-updates.check-access'));
this.accessInfo = {
has_access: response.data.has_access,
error: response.data.error,
permissions: response.data.permissions || [],
};
} catch (error) {
console.error('Access check failed:', error);
this.accessInfo = {
has_access: false,
error: 'Не удалось проверить права доступа',
permissions: [],
};
} finally {
this.checkingAccess = false;
}
},
async checkVersion() {
this.checkingVersion = true;
try {
const response = await axios.post(route('dashboard.vikon-updates.check-version'));
this.versionInfo = response.data;
} catch (error) {
console.error('Version check failed:', error);
} finally {
this.checkingVersion = false;
}
},
async downloadUpdate(moduleId) {
if (!confirm('Вы уверены, что хотите обновить этот модуль?')) {
return;
}
this.updating = true;
this.progress = 0;
this.updateError = null;
// Simulate progress
const progressInterval = setInterval(() => {
if (this.progress < 90) {
this.progress += 10;
}
}, 500);
try {
const response = await axios.post(route('dashboard.vikon-updates.download-update'), {
module_id: moduleId,
});
this.progress = 100;
clearInterval(progressInterval);
if (response.data.success) {
setTimeout(() => {
this.$inertia.visit(route('dashboard.vikon-updates.index'), {
preserveState: true,
preserveScroll: true,
});
}, 500);
} else {
this.updateError = response.data.message || 'Неизвестная ошибка';
this.updating = false;
this.progress = 0;
}
} catch (error) {
clearInterval(progressInterval);
this.updating = false;
this.progress = 0;
this.updateError = error.response?.data?.message || 'Произошла ошибка при обновлении';
}
},
async logout() {
try {
await axios.post(route('dashboard.vikon-updates.logout'));
this.isAuthenticated = false;
this.accessInfo = {
has_access: false,
error: null,
permissions: [],
};
this.versionInfo = {
current_version: this.currentVersion,
has_update: false,
latest_version: null,
};
} catch (error) {
console.error('Logout failed:', error);
}
},
},
};
</script>