mikopbx/ModuleBackup

Lib/Backup.php
2 411 строк96 KB
Alexey Portnov
checkDiskSpace: df по пути вместо Storage::getAllHdd — фикс для system-disk
24 апр 2026, 18:55
24 апр 2026, 18:55ad6e108
<?php
/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2024 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace Modules\ModuleBackup\Lib;

use Exception;
use MikoPBX\PBXCoreREST\Lib\PBXApiResult;
use MikoPBX\Core\System\{Directories, Processes, Storage, System, Util};
use MikoPBX\Modules\PbxExtensionBase;
use Modules\ModuleBackup\Models\BackupRules;

class Backup extends PbxExtensionBase
{
    public const ARH_TYPE_IMG = 'img';
    public const ARH_TYPE_ZIP = 'zip';
    public const ARH_TYPE_TAR = 'tar';
    public const ARH_TYPE_DIR = 'dir';

    private $id;
    private array $dirs;
    private array $dirs_mem;
    private string $file_list;
    private string $errorFile;
    private string $result_file;
    private string $result_dir;
    private string $progress_file;
    private string $progress_file_recover;
    private string $stage_file;
    private string $config_file;
    private array $options;
    private string $options_recover_file;
    private int $progress = 0;
    private string $type = self::ARH_TYPE_TAR;
    private bool $remote = false;
    private array $systemDbFiles = [];

    public const CONF_DB_NAME = 'mikopbx.db';
    public const DB_FILES = [
        self::CONF_DB_NAME,
        'cdr.db'
    ];

    /**
     * Проверяет, что ID бекапа содержит только допустимые символы.
     * Защита от Path Traversal и Command Injection.
     *
     * @param mixed $id
     * @return bool
     */
    public static function isValidId($id): bool
    {
        if (empty($id) || !is_string($id)) {
            return false;
        }
        return preg_match('/^[a-zA-Z0-9_\-]+$/', $id) === 1;
    }

    public function __construct($id, $options = null)
    {
        parent::__construct();
        $this->dirs     = [
            'backup'           => self::getBackupDir(),
            'custom_modules'   => $this->config->path('core.modulesDir'),
            'media'            => $this->config->path('asterisk.mediadir'),
            'astspooldir'      => $this->config->path('asterisk.astspooldir'),
            'settings_db_path' => $this->config->path('database.dbfile'),
            'cdr_db_path'      => $this->config->path('cdrDatabase.dbfile'),
            'tmp'              => $this->config->path('core.tempDir'),
        ];

        $this->dirs_mem = self::getAsteriskDirsMem();
        $this->systemDbFiles = [
            $this->dirs['settings_db_path'],
            $this->dirs['cdr_db_path'],
        ];
        // Проверим особенность бекапа на сетевой диск.
        $du      = Util::which('du');
        $awk     = Util::which('awk');

        $escapedId = escapeshellarg($id);
        Processes::mwExec(
            "$du /storage/*/{$escapedId}/flist.txt -d 0 2> /dev/null | $awk '{print $2}'",
            $out
        );
        if (($out[0] ?? false) && file_exists($out[0])) {
            $this->dirs['backup'] = dirname($out[0], 2);
        } elseif (isset($options['backup'])) {
            // Переопределяем каталог с бекапом.
            $this->dirs['backup'] = $options['backup'];
            $this->remote = true;
        }
        $this->id = $id;
        $b_dir    = "{$this->dirs['backup']}/{$this->id}";
        Util::mwMkdir($b_dir);

        if (isset($options['type'])) {
            $this->type = $options['type'];
        }
        // Определяем тип существующего бекапа по файлу архива.
        if ($this->type !== self::ARH_TYPE_DIR) {
            foreach ([self::ARH_TYPE_ZIP, self::ARH_TYPE_TAR, self::ARH_TYPE_IMG] as $extension) {
                $filename = "{$this->dirs['backup']}/{$this->id}/resultfile.$extension";
                if (file_exists($filename)) {
                    $this->type = $extension;
                    break;
                }
            }
        }
        // Если нет resultfile.* но есть flist.txt — это dir-бекап.
        if ($this->type === self::ARH_TYPE_TAR
            && !file_exists("{$this->dirs['backup']}/{$this->id}/resultfile.tar")
            && file_exists("{$this->dirs['backup']}/{$this->id}/flist.txt")
        ) {
            $this->type = self::ARH_TYPE_DIR;
        }

        $this->file_list             = "{$this->dirs['backup']}/{$this->id}/flist.txt";
        $this->result_file           = ($this->type === self::ARH_TYPE_DIR)
            ? '' : "{$this->dirs['backup']}/{$this->id}/resultfile.{$this->type}";
        $this->result_dir            = "{$this->dirs['backup']}/{$this->id}/mnt_point";
        $this->progress_file         = "{$this->dirs['backup']}/{$this->id}/progress.txt";
        $this->errorFile             = "{$this->dirs['backup']}/{$this->id}/error.txt";
        $this->config_file           = "{$this->dirs['backup']}/{$this->id}/config.json";
        $this->options_recover_file  = "{$this->dirs['backup']}/{$this->id}/options_recover.json";
        $this->progress_file_recover = "{$this->dirs['backup']}/{$this->id}/progress_recover.txt";
        $this->stage_file            = "{$this->dirs['backup']}/{$this->id}/stage.txt";

        if (!is_array($options) && file_exists($this->config_file)) {
            $this->options = json_decode(file_get_contents($this->config_file), true) ?? [];
        } elseif (is_array($options)) {
            $this->options = $options;
        }else {
            $this->options = [];
        }

        if (empty($this->options)) {
            $this->options = [
                'backup-config'      => '1',
                'backup-records'     => '1',
                'backup-cdr'         => '1',
                'backup-sound-files' => '1',
            ];
        }
        if ( ! file_exists($this->config_file) && false === @file_put_contents(
                $this->config_file,
                json_encode($this->options),
                JSON_PRETTY_PRINT | JSON_UNESCAPED_SLASHES
            )) {
            Util::sysLogMsg('Backup', 'Failed create file ' . $this->config_file);
        }
    }

    /**
     * Возвращает массив с путями к системным директориям на диске
     *
     * @return array
     */
    public static function getAsteriskDirsMem(): array
    {
        $path2dirs                   = [];
        $path2dirs['dbpath']         = '/etc/asterisk/db'; // Замена на $dirsConfig->path('astDatabase.dbfile')
        $path2dirs['astlogpath']     = '/var/asterisk/log'; // Замена на $dirsConfig->path('asterisk.astlogdir')
        $path2dirs['media']          = '/var/asterisk/spool/media';
        $path2dirs['astspooldir']    = '/var/asterisk/spool'; // Замена на $dirsConfig->path('asterisk.astspooldir')
        $path2dirs['backup']         = '/var/asterisk/backup';
        $path2dirs['tmp']            = '/ultmp';
        $path2dirs['custom_modules'] = '/var/asterisk/custom_modules';
        $path2dirs['datapath']       = '/var/asterisk'; // Замена на $dirsConfig->path('asterisk.astvarlibdir')
        $path2dirs['php_session']    = '/var/tmp/php';
        $path2dirs['cache_js_dir']   = '/var/cache/www/cache_js_dir';
        $path2dirs['cache_css_dir']  = '/var/cache/www/cache_css_dir';
        $path2dirs['cache_img_dir']  = '/var/cache/www/cache_img_dir';

        return $path2dirs;
    }

    /**
     * Распаковывает вспомогательные данные из архива резервной копии.
     *
     * @param array $data
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function unpackUploadedImgConf($data): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;

        if ( ! file_exists($data['temp_file'])) {
            $res->messages[] = "Backup file not found";
            return $res;
        }
        $backupDir         = self::getBackupDir();
        $di = MikoPBXVersion::getDefaultDi();
        if($di === null){
            $res->messages[] = "Can not create DI.";
            return $res;
        }
        $uploadDir         = $di->getShared('config')->path('www.uploadDir');

        // Проверка Path Traversal: temp_file должен быть внутри uploadDir или backupDir.
        $realTempFile = realpath($data['temp_file']);
        if ($realTempFile === false
            || (strpos($realTempFile, $uploadDir . '/') !== 0 && strpos($realTempFile, $backupDir . '/') !== 0)
        ) {
            $res->messages[] = 'File path is not allowed';
            return $res;
        }
        $data['temp_file'] = $realTempFile;

        $data['dir_name']  = str_ireplace([$uploadDir.'/', $backupDir.'/', self::ARH_TYPE_IMG, self::ARH_TYPE_TAR], ['','','', ''] , dirname($data['temp_file']));

        // Проверяем dir_name на Path Traversal.
        if (!self::isValidId($data['dir_name'])) {
            $res->messages[] = 'Invalid directory name in uploaded file path';
            return $res;
        }

        // Проверка свободного места перед распаковкой: нужно ≥ 2x размер файла
        // (архив + содержимое) + 500 MB запас.
        $uploadedFileSizeMB = intval(filesize($data['temp_file']) / 1024 / 1024);
        $freeSpaceMB = self::getFreeSpaceOnMountPoint($backupDir);
        $requiredMB = ($uploadedFileSizeMB * 2) + 500;
        if ($freeSpaceMB > 0 && $freeSpaceMB < $requiredMB) {
            $res->messages[] = "Not enough disk space. Free: {$freeSpaceMB} MB, required: {$requiredMB} MB";
            return $res;
        }

        $data['extension'] = Util::getExtensionOfFile(basename($data['temp_file']));
        $data['res_file']  = $backupDir . '/' . $data['dir_name'].'/resultfile.'.$data['extension'];
        $data['mnt_point'] = $backupDir . '/' . $data['dir_name'].'/mnt_point';
        Util::mwMkdir($data['mnt_point']);

        if($data['temp_file'] !== $data['res_file']){
            $mvPath = Util::which('mv');
            $escapedTempFile = escapeshellarg($data['temp_file']);
            $escapedResFile  = escapeshellarg($data['res_file']);
            Processes::mwExec("{$mvPath} {$escapedTempFile} {$escapedResFile}");
        }
        $res->data['id']        = $data['dir_name'];
        $res->success = true;
        if ($data['extension'] === self::ARH_TYPE_IMG) {
            $mountPath = Util::which('mount');
            $resMwExec       = Processes::mwExec("{$mountPath} -o loop {$data['res_file']} {$data['mnt_point']}");
            if ($resMwExec !== 0) {
                $res->success = false;
                $message = "Fail mount {$data['res_file']}... on loop device...";
                $res->messages[]=$message;
                Util::sysLogMsg('Backup_unpack_conf_img', $message);
                return $res;
            }

            self::unpackImgBackup($res, $backupDir, $data);
        } elseif ($data['extension'] === self::ARH_TYPE_TAR) {
            self::unpackTarBackup($res, $backupDir, $data);
        } elseif ($data['extension'] === self::ARH_TYPE_ZIP) {
            self::unpackZipBackup($backupDir, $data);
        } elseif ($data['extension'] === 'xml' || $data['extension'] === 'csv'){
            $converter = new OldConfigConverter($data['res_file']);
            $converter->parse();
            $converter->makeConfig();
        }
        return $res;
    }

    /**
     * Распаковывавем файлы настроек.
     * @param $res
     * @param $backupDir
     * @param $data
     * @return PBXApiResult
     */
    public static function unpackTarBackup($res, $backupDir, $data):PBXApiResult
    {
        $tarPath = Util::which('tar');
        $grepPath = Util::which('grep');
        file_put_contents("{$backupDir}/{$data['dir_name']}/progress.txt", '0');

        foreach (['flist.txt', 'progress.txt', 'config.json'] as $baseFile){
            $file = trim((string)shell_exec("$tarPath -Ptf {$data['res_file']} | $grepPath -e '/$baseFile$'"));
            if ($file !== '') {
                shell_exec("$tarPath --transform='flags=r;s|$file|{$backupDir}/{$data['dir_name']}/$baseFile|' -Pxf {$data['res_file']} $file");
            }
        }
        if ( ! file_exists("{$backupDir}/{$data['dir_name']}/flist.txt") ||
            ! file_exists("{$backupDir}/{$data['dir_name']}/config.json")) {
            $res->success = false;
            $message = 'Broken backup file';
            $res->messages[]=$message;
            Util::sysLogMsg('Backup_unpack_conf_tar', $message);
        }
        if (!$res->success) {
            unlink($data['res_file']);
        }

        return $res;
    }

    public static function unpackImgBackup($res, $backupDir, $data):PBXApiResult
    {
        $findPath = Util::which('find');
        $path_b_dir = '';

        // 1. Ищем бекап в каталоге оперативной памяти.
        $candidate = "{$data['mnt_point']}/var/asterisk/backup/{$data['dir_name']}";
        if (file_exists("$candidate/flist.txt")) {
            $path_b_dir = $candidate;
        }

        // 2. Ищем по точному dir_name на диске через shell glob.
        if ($path_b_dir === '') {
            Processes::mwExec(
                "$findPath {$data['mnt_point']}/storage -path '*/{$data['dir_name']}/flist.txt' -type f 2>/dev/null",
                $out
            );
            if (!empty($out[0]) && file_exists($out[0])) {
                $path_b_dir = dirname($out[0]);
            }
        }

        // 3. dir_name не совпадает с оригинальным — ищем любой backup_*/flist.txt внутри img.
        if ($path_b_dir === '') {
            Processes::mwExec(
                "$findPath {$data['mnt_point']} -name 'flist.txt' -path '*/backup*/flist.txt' -type f 2>/dev/null",
                $out
            );
            if (!empty($out[0]) && file_exists($out[0])) {
                $path_b_dir = dirname($out[0]);
                $new_id = basename($path_b_dir);
                if ($data['dir_name'] !== $new_id) {
                    $res->data['new_id'] = $new_id;
                }
            }
        }

        if ($path_b_dir === '') {
            $umount = Util::which('umount');
            Processes::mwExec("$umount {$data['res_file']}");
            $res->success = false;
            $res->messages[] = 'Backup data not found inside IMG file';
            Util::sysLogMsg('Backup_unpack_conf_img', 'Backup data not found inside IMG file');
            return $res;
        }

        $cp = Util::which('cp');
        $resMwExec = Processes::mwExec("$cp {$path_b_dir}/* {$backupDir}/{$data['dir_name']}");

        $umount = Util::which('umount');
        Processes::mwExec("$umount {$data['res_file']}");

        // Если оригинальный ID отличается от upload ID — переименовываем каталог.
        if (isset($res->data['new_id'])) {
            $mv = Util::which('mv');
            $resMwExec = Processes::mwExec(
                "$mv {$backupDir}/{$data['dir_name']} {$backupDir}/{$res->data['new_id']}"
            );
            $data['dir_name'] = $res->data['new_id'];
        }

        if ($resMwExec !== 0) {
            $res->success = false;
            $message = 'Failed to copy data from IMG backup';
            $res->messages[] = $message;
            Util::sysLogMsg('Backup_unpack_conf_img', $message);
        }

        if ( ! file_exists("{$backupDir}/{$data['dir_name']}/flist.txt") ||
            ! file_exists("{$backupDir}/{$data['dir_name']}/config.json")) {
            $res->success = false;
            $message = 'Broken backup file';
            $res->messages[] = $message;
            Util::sysLogMsg('Backup_unpack_conf_img', $message);
        }
        if (!$res->success) {
            unlink($data['res_file']);
        }

        return $res;
    }

    public static function unpackZipBackup($backupDir, $data):void
    {
        file_put_contents("{$backupDir}/{$data['dir_name']}/progress.txt", '0');

        self::staticExtractFile(
            $data['dir_name'],
            $data['res_file'],
            "{$backupDir}/{$data['dir_name']}/flist.txt"
        );
        self::staticExtractFile(
            $data['dir_name'],
            $data['res_file'],
            "{$backupDir}/{$data['dir_name']}/progress.txt"
        );
        self::staticExtractFile(
            $data['dir_name'],
            $data['res_file'],
            "{$backupDir}/{$data['dir_name']}/config.json"
        );
    }

    /**
     * Возвращает полный путь к директории с резервными копиями.
     *
     * @return string
     */
    public static function getBackupDir(): string
    {
        $di = MikoPBXVersion::getDefaultDi();
        return $di->getShared('config')->path('core.mediaMountPoint').'/mikopbx/backup';
    }

    /**
     * Извлеч файл из архива.
     *
     * @param $id
     * @param $arh
     * @param $filename
     */
    public static function staticExtractFile($id, $arh, $filename): void
    {
        $umount  = Util::which('umount');
        $mount   = Util::which('mount');
        $cp      = Util::which('cp');
        $mv      = Util::which('mv');
        $du      = Util::which('du');
        $sevenZa = Util::which('7za');
        $grep    = Util::which('grep');
        $awk     = Util::which('awk');

        $type = Util::getExtensionOfFile($arh);
        if ($type === self::ARH_TYPE_IMG) {
            $result_dir = basename($arh) . '/mnt_point';
            if ( ! Storage::diskIsMounted($arh, '')) {
                Processes::mwExec("{$mount} -o loop {$arh} {$result_dir}");
            }
            Processes::mwExec("$du /storage/*/{$id} -d 0 2> /dev/null | $awk '{print $2}'", $out);
            if (($out[0] ?? false) && file_exists($out[0])) {
                $src_file = $out[0];
            } else {
                $src_file = "{$result_dir}{$filename}";
            }
            Processes::mwExec("$cp '{$src_file}' '{$filename}'", $arr_out);
            Processes::mwExec("$umount $arh");
        } else {
            Processes::mwExec("$sevenZa e -y -r -spf {$arh} {$filename}");
            if ( ! file_exists($filename)) {
                $command_status = Processes::mwExec(
                    "$sevenZa l {$arh} | {$grep} '" . basename(
                        $filename
                    ) . "' | $awk '{print $6}'",
                    $out
                );
                if ($command_status === 0) {
                    $path_to_file = implode('', $out);

                    $file_dir = dirname($path_to_file);
                    Util::mwMkdir($file_dir);
                    $file_dir = dirname($filename);
                    Util::mwMkdir($file_dir);
                    Processes::mwExec("$sevenZa e -y -r -spf {$arh} {$path_to_file}");
                    Processes::mwExec("$mv $path_to_file $filename");
                }
            }
        }
    }

    /**
     * Старт бекапа.
     *
     * @param array | null $options
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function start($options = null): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        $id     = 'backup_' . time();
        if ($options !== null) {
            $id = $options['id'] ?? $id;
            if (!self::isValidId($id)) {
                $res->messages[] = 'Invalid backup ID';
                return $res;
            }
            // Инициализируем настройки резервного копирования.
            $b = new Backup($id, $options);
            unset($b);
        }
        $workerPath = Util::getFilePathByClassName(WorkerBackup::class);
        $phpPath    = Util::which('php');
        $command    = "$phpPath -f $workerPath";
        Processes::processWorker($command, "$id backup", WorkerBackup::class, 'start');
        usleep(2000000);
        $res->success = true;
        $res->data['id']   = $id;

        return $res;
    }

    /**
     * Старт бекапа.
     *
     * @param string $id
     * @param        $options
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function startRecover($id, $options = null): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;

        if (!self::isValidId($id)) {
            $res->messages[]= 'Invalid backup ID';
            return $res;
        }
        $b = new Backup($id);
        $b->saveOptionsRecoverFile($options);
        $workerPath = Util::getFilePathByClassName(WorkerRecover::class);
        $phpPath    = Util::which('php');
        $command    = "{$phpPath} -f {$workerPath}";
        Processes::processWorker($command, "$id recover", WorkerRecover::class, 'start');
        $res->success=true;
        $res->data[]   = $id;
        return $res;
    }

    /**
     * Сохраняем настройки восстановления.
     *
     * @param $options
     */
    public function saveOptionsRecoverFile($options): void
    {
        if ($options === null && file_exists($this->options_recover_file)) {
            // Удаляем ненужный файл настроек.
            unlink($this->options_recover_file);
        }

        if ($options !== null) {
            // Сохраняем настройки. Файл будет использоваться фоновым процессом.
            file_put_contents($this->options_recover_file, json_encode($options, JSON_UNESCAPED_SLASHES));
        }
    }

    /**
     * Приостановить резервное копирование.
     *
     * @param $id
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function stop($id): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        if (!self::isValidId($id)) {
            $res->messages[] = 'Invalid backup ID';
            return $res;
        }
        $workerPath = Util::getFilePathByClassName(WorkerBackup::class);
        $phpPath    = Util::which('php');
        $command    = "{$phpPath} -f {$workerPath}";
        Processes::processWorker($command, "{$id} backup", WorkerBackup::class, 'stop');
        $res->success = true;
        $res->data[]   = $id;
        return $res;
    }

    /**
     * Удаление резервной копии.
     *
     * @param $id
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function remove($id): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        if (!self::isValidId($id)) {
            $res->messages[] = 'Invalid backup ID';
            return $res;
        }
        $b_dir  = self::getBackupDir() . "/{$id}";
        $b_dirs = [];
        if (file_exists($b_dir)) {
            $b_dirs[] = $b_dir;
        }
        $list = self::listBackups()->data;
        foreach ($list as $backup_data) {
            if ($id === $backup_data['id'] && isset($backup_data['config']['backup'])) {
                $b_dir = $backup_data['config']['backup'] . "/{$id}";
                if (file_exists($b_dir)) {
                    $b_dirs[] = $b_dir;
                }
            }
        }

        $BackupRules = BackupRules::find('enabled="1"');
        foreach ($BackupRules as $rule) {
            $b_dir = self::getMountPath($rule)."/{$id}";
            if (file_exists($b_dir)) {
                $b_dirs[] = $b_dir;
            }
        }

        if (empty($b_dirs)) {
            $res->messages[] = 'Backup file not found for id='.$id;
            return $res;
        }

        $ret = Processes::mwExec('rm -rf ' . implode(' ', $b_dirs));
        clearstatcache();
        $res->success = $ret === 0;

        return $res;
    }

    /**
     * Возвращает список доступных резервных копий.
     *
     * @param string $backup_dir
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function listBackups(string $backup_dir = ''): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;

        // Проверка каталогов FTP / SFTP бекапа:
        if (empty($backup_dir)) {
            self::listBackupsFtp($res->data);
        }

        if ( ! empty($backup_dir)) {
            $dirs['backup'] = $backup_dir;
        } else {
            $dirs['backup'] = self::getBackupDir();
        }

        if ( ! is_dir($dirs['backup'])) {
            $res->success = true;
            $res->data = [];
            $res->messages[]="Backup dir '{$dirs['backup']}' not exist";
            return $res;
        }

        $entries = scandir($dirs['backup']);
        foreach ($entries as $entry) {
            $base_filename = basename($entry);
            $pid              = self::getPID("{$base_filename} backup");
            $pid_recover      = self::getPID("{$base_filename} recover");
            if ($base_filename === '.' || $base_filename === '..') {
                continue;
            }
            foreach ([self::ARH_TYPE_TAR, self::ARH_TYPE_IMG, self::ARH_TYPE_ZIP] as $extension){
                $filename = "{$dirs['backup']}/$base_filename/resultfile.$extension";
                if (file_exists($filename)) {
                    break;
                }
                $filename = '';
            }
            $file_progress = "{$dirs['backup']}/{$base_filename}/progress.txt";
            if (file_exists($file_progress)) {
                $size = 0;
                if ($filename !== '') {
                    $size = round(filesize($filename) / 1024 / 1024, 2);
                } elseif (is_dir("{$dirs['backup']}/$base_filename/files")
                    || is_dir("{$dirs['backup']}/$base_filename/module_archives")) {
                    // Dir-бекап: вычисляем размер каталога.
                    $duPath = Util::which('du');
                    Processes::mwExec("$duPath -sm '{$dirs['backup']}/$base_filename' 2>/dev/null", $duOut);
                    if (!empty($duOut[0])) {
                        $size = intval($duOut[0]);
                    }
                }
                // Получим данные по прогрессу и количеству файлов.
                $file_data   = file_get_contents($file_progress);
                $data        = explode('/', $file_data);
                $progress    = (!empty($data) && is_numeric($data[0])) ? intval(trim($data[0])) : 0;
                $total       = (count($data) > 1 && is_numeric($data[1])) ? intval(trim($data[1])) : 0;
                $config_file = "{$dirs['backup']}/{$base_filename}/config.json";

                if (file_exists("{$dirs['backup']}/{$base_filename}/progress_recover.txt")) {
                    $file_data        = file_get_contents("{$dirs['backup']}/{$base_filename}/progress_recover.txt");
                    $data             = explode('/', $file_data);
                    $progress_recover = (!empty($data)) ? intval(trim($data[0])) : 0;
                    if ($total === 0) {
                        $total = (count($data) > 1) ? intval(trim($data[1])) : 0;
                    }
                } else {
                    $progress_recover = '';
                }

                $config = null;
                if (file_exists($config_file)) {
                    $config = json_decode(file_get_contents($config_file), true);
                }
                // Фаза выполнения: 'preparing' (формирование списка файлов) или '' (архивирование).
                $stage = '';
                $stageFile = "{$dirs['backup']}/{$base_filename}/stage.txt";
                if (file_exists($stageFile)) {
                    $stage = trim((string)file_get_contents($stageFile));
                }
                // Вычислим timestamp.
                $arr_fname        = explode('_', $base_filename);
                $data = [
                    'date'             => preg_replace("/[^0-9+]/", '', $arr_fname[1] ?? '') ?: time(),
                    'size'             => $size,
                    'progress'         => $progress,
                    'total'            => $total,
                    'stage'            => $stage,
                    'config'           => $config,
                    'pid'              => $pid,
                    'id'               => $base_filename,
                    'progress_recover' => $progress_recover,
                    'pid_recover'      => $pid_recover,
                ];
                $errorMsgFile = "{$dirs['backup']}/{$base_filename}/error.txt";
                if(file_exists($errorMsgFile)){
                    $errorMsg = file_get_contents($errorMsgFile);
                    if(!empty($errorMsg)){
                        $data['error'] = $errorMsg;
                    }
                }
                $res->data[] = $data;
            }
        }
        $res->success = true;
        return $res;
    }

    /**
     * Получаем данные по резервным копиям с SFTP / FTP ресурсов.
     *
     * @param $data
     */
    public static function listBackupsFtp(&$data): void
    {
        $dirs       = [
            'backup' => self::getBackupDir(),
        ];

        $tmp_data = [$data];
        $BackupRules = BackupRules::find('enabled="1"');
        foreach ($BackupRules as $res) {
            $result     = self::checkStorageFtp($res->id);
            if(!$result->success){
                continue;
            }

            $backup_dir = self::getMountPath($res);
            $ftpIsLocalhost = self::ftpIsLocalhost($backup_dir, $dirs['backup']);
            if($ftpIsLocalhost === true){
                continue;
            }
            $out         = [];
            $timeoutPath = Util::which('timeout');
            $command     = "{$timeoutPath} 3 ls -l {$backup_dir}";
            Processes::mwExec($command, $out);
            $response = trim(implode('', $out));
            if ('Terminated' === $response) {
                // Удаленный сервер не ответил / или не корректно указан пароль.
                continue;
            }
            $result = self::listBackups($backup_dir)->data;
            foreach ($result as &$b) {
                $b['m_BackupRules_id']   = $res->id;
                $b['m_BackupRules_host'] = $res->ftp_host;
                $b['m_BackupRules_port'] = $res->ftp_port;
            }
            unset($b);
            $tmp_data[] = $result;
        }

        $data = array_merge(...$tmp_data);
    }

    /**
     * Проверим, не является ли удаленный диск локальным.
     * @param string $backup_dir
     * @param        $backup
     * @return bool
     */
    /**
     * Проверяет, не является ли удалённый FUSE-маунт локальным диском.
     * Записывает тестовый файл на маунт и проверяет, появился ли он локально.
     *
     * @param string $remoteMountDir — путь к FUSE-маунту (/storage/{hash})
     * @return bool true если это localhost
     */
    public static function isRemoteLocalhost(string $remoteMountDir): bool
    {
        $localBackupDir = self::getBackupDir();
        return self::ftpIsLocalhost($remoteMountDir, $localBackupDir);
    }

    private static function ftpIsLocalhost(string $backup_dir, $backup): bool{
        $ftpIsLocalhost = false;
        $test_data = md5(time() . getmypid());
        $testFile = "{$backup_dir}/localhost_test_" . getmypid() . ".tmp";
        @file_put_contents($testFile, $test_data);

        // Проверяем появился ли файл в локальном каталоге бекапов.
        $localTestFile = str_replace($backup_dir, $backup, $testFile);
        if ($localTestFile !== $testFile && file_exists($localTestFile)) {
            $localData = @file_get_contents($localTestFile);
            if ($localData === $test_data) {
                $ftpIsLocalhost = true;
            }
        }
        // Чистим тестовый файл.
        @unlink($testFile);
        return $ftpIsLocalhost;
    }
    /**
     * Проверяет, активен ли процесс резервного копирования.
     *
     * @param $id
     *
     * @return string
     */
    public static function getPID($id): string
    {
        return Processes::getPidOfProcess($id);
    }

    /**
     * Start backup action by schedule
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function startScheduled(): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        $commands       = BackupRules::find('enabled="1"');
        $queue_commands = [];
        $workerPath     = Util::getFilePathByClassName(WorkerBackup::class);
        $phpPath        = Util::which('php');
        $nohupPath      = Util::which('nohup');
        foreach ($commands as $cmd) {
            $command          = "{$nohupPath} {$phpPath} -f {$workerPath} ";
            $params           = "none backup {$cmd->id} > /dev/null 2>&1 &";
            $queue_commands[] = "{$command} {$params}\n";
        }
        Processes::mwExecCommands($queue_commands);
        if (!empty($queue_commands)) {
            $res->success=true;
        }
        return $res;
    }

    public static function getMountPath(BackupRules $res):string
    {
        return '/storage/'.md5("$res->ftp_host.$res->ftp_port");
    }

    /**
     * Проверка возможности подключения диска.
     *
     * @param $id
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function checkStorageFtp($id): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        $first_by_id    = BackupRules::findFirstById($id);
        if ($first_by_id === null) {
            $res->messages[]='Backup rule not found for id='.$id;
            return $res;
        }
        $backup_dir = self::getMountPath($first_by_id);
        /** @var Storage::isStorageDiskMounted $disk_mounted */
        $disk_mounted       = Storage::isStorageDiskMounted("$backup_dir ");
        if ( !$disk_mounted) {
            if ($first_by_id->ftp_sftp_mode === '1') {
                $disk_mounted = self::mountSftpDisk(
                    $first_by_id->ftp_host,
                    $first_by_id->ftp_port,
                    $first_by_id->ftp_username,
                    $first_by_id->ftp_secret,
                    $first_by_id->ftp_path,
                    $backup_dir
                );
            } elseif ($first_by_id->ftp_sftp_mode === '3') {
                $disk_mounted = self::mountWebDav(
                    $first_by_id->ftp_host,
                    $first_by_id->ftp_username,
                    $first_by_id->ftp_secret,
                    $first_by_id->ftp_path,
                    $backup_dir
                );
            } else {
                $disk_mounted = self::mountFtp(
                    $first_by_id->ftp_host,
                    $first_by_id->ftp_port,
                    $first_by_id->ftp_username,
                    $first_by_id->ftp_secret,
                    $first_by_id->ftp_path,
                    $backup_dir
                );
            }
        }
        if ( ! $disk_mounted) {
            $res->messages[]='Failed to mount backup disk...';
            return $res;
        }
        $res->success = true;
        return $res;
    }

    /**
     * Mount an SFTP disk.
     *
     * @param string $host The SFTP server host.
     * @param string $port The SFTP server port.
     * @param string $user The SFTP server username.
     * @param string $pass The SFTP server password.
     * @param string $remote_dir The remote directory on the SFTP server.
     * @param string $local_dir The local directory to mount the SFTP disk.
     * @return bool Returns true if the SFTP disk is successfully mounted, false otherwise.
     */
    public static function mountSftpDisk(string $host, string $port, string $user, string $pass, string $remote_dir, string $local_dir): bool
    {
        // Create the local directory if it doesn't exist
        Util::mwMkdir($local_dir);

        $out = [];
        $timeoutPath = Util::which('timeout');
        $sshfsPath   = Util::which('sshfs');

        // Build the command to mount the SFTP disk
        $command = "$timeoutPath 3 $sshfsPath -p $port -o password_stdin -o 'StrictHostKeyChecking=no' " . "$user@$host:$remote_dir $local_dir << EOF\n" . "$pass\n" . "EOF\n";

        // Execute the command to mount the SFTP disk
        Processes::mwExec($command, $out);
        $response = trim(implode('', $out));

        if ('Terminated' === $response) {
            // The remote server did not respond or an incorrect password was provided.
            unset($response);
        }

        return Storage::isStorageDiskMounted("$local_dir ");
    }

    /**
     * Mount an FTP disk.
     *
     * @param string $host The FTP server host.
     * @param string $port The FTP server port.
     * @param string $user The FTP server username.
     * @param string $pass The FTP server password.
     * @param string $remote_dir The remote directory on the FTP server.
     * @param string $local_dir The local directory to mount the FTP disk.
     * @return bool Returns true if the FTP disk is successfully mounted, false otherwise.
     */
    public static function mountFtp(string $host, string $port, string $user, string $pass, string $remote_dir, string $local_dir): bool
    {

        // Create the local directory if it doesn't exist
        Util::mwMkdir($local_dir);
        $out = [];

        // Build the authentication line for the FTP connection
        $auth_line = '';
        if (!empty($user)) {
            $auth_line .= 'user="' . $user;
            if (!empty($pass)) {
                $auth_line .= ":$pass";
            }
            $auth_line .= '",';
        }

        // Build the connect line for the FTP connection
        $connect_line = 'ftp://' . $host;
        if (!empty($port)) {
            $connect_line .= ":$port";
        }
        if (!empty($remote_dir)) {
            $connect_line .= $remote_dir;
        }

        $timeoutPath = Util::which('timeout');
        $curlftpfsPath = Util::which('curlftpfs');

        // Build the command to mount the FTP disk
        $command = "$timeoutPath 3 $curlftpfsPath  -o allow_other -o {$auth_line}fsname=$host $connect_line $local_dir";

        // Execute the command to mount the FTP disk
        Processes::mwExec($command, $out);
        $response = trim(implode('', $out));
        if ('Terminated' === $response) {
            // The remote server did not respond or an incorrect password was provided.
            unset($response);
        }

        return Storage::isStorageDiskMounted("$local_dir ");
    }

    /**
     * Mount a WebDAV disk.
     *
     * @param string $host The WebDAV server host.
     * @param string $user The WebDAV server username.
     * @param string $pass The WebDAV server password.
     * @param string $dstDir The destination directory on the WebDAV server.
     * @param string $local_dir The local directory to mount the WebDAV disk.
     * @return bool Returns true if the WebDAV disk is successfully mounted, false otherwise.
     */
    public static function mountWebDav(string $host, string $user, string $pass, string $dstDir, string $local_dir): bool
    {
        $host = trim($host);
        $dstDir = trim($dstDir);

        // Remove trailing slash from host if present
        if (substr($host, -1) === '/') {
            $host = substr($host, 0, -1);
        }

        // Remove leading slash from destination directory if present
        if ($dstDir[0] === '/') {
            $dstDir = substr($dstDir, 1);
        }

        // Create the local directory if it doesn't exist
        Util::mwMkdir($local_dir);
        $di = MikoPBXVersion::getDefaultDi();

        // Кеш davfs2 размещаем на дисковом хранилище, не в tmpfs (RAM),
        // иначе при бекапе больших файлов RAM переполняется.
        $diskTmpBase = $di->getShared('config')->path('core.mediaMountPoint') . '/mikopbx/tmp';
        Util::mwMkdir($diskTmpBase);
        $tmpDir = "$diskTmpBase/webdav-cache";
        Util::mwMkdir($tmpDir, true);
        $tmpDirBackUp = "$diskTmpBase/webdav-backup-cache";
        Util::mwMkdir($tmpDirBackUp, true);
        $out = [];
        $conf = 'dav_user www'.PHP_EOL.
                'dav_group www'.PHP_EOL.
                'cache_size 50'.PHP_EOL.
                "backup_dir $tmpDirBackUp".PHP_EOL.
                "cache_dir $tmpDir".PHP_EOL;

        // Write WebDAV credentials to secrets file
        file_put_contents('/etc/davfs2/secrets', "$host/$dstDir $user $pass");
        file_put_contents('/etc/davfs2/davfs2.conf', $conf);
        $timeoutPath = Util::which('timeout');
        $mount = Util::which('mount.davfs');

        // Build the command to mount the WebDAV disk
        $command = "$timeoutPath 3 yes | $mount $host/$dstDir $local_dir";

        // Execute the command to mount the WebDAV disk
        Processes::mwExec($command, $out);
        $response = trim(implode('', $out));
        if ('Terminated' === $response) {
            // The remote server did not respond or an incorrect password was provided.
            unset($response);
        }
        return Storage::isStorageDiskMounted("$local_dir ");
    }

    /**
     * Очищает кеш davfs2 (WebDAV) на диске.
     * Вызывать после завершения бекапа на WebDAV.
     */
    public static function cleanupWebDavCache(): void
    {
        $di = MikoPBXVersion::getDefaultDi();
        if ($di === null) {
            return;
        }
        $diskTmpBase = $di->getShared('config')->path('core.mediaMountPoint') . '/mikopbx/tmp';
        $rmPath = Util::which('rm');
        foreach (['webdav-cache', 'webdav-backup-cache'] as $dir) {
            $path = "$diskTmpBase/$dir";
            if (is_dir($path)) {
                Processes::mwExec("{$rmPath} -rf '$path'");
                Util::mwMkdir($path, true);
            }
        }
    }

    /**
     * Makes download link for img file
     *
     * @param $id - backup ID
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function download($id):PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        if (!self::isValidId($id)) {
            $res->messages[] = 'Invalid backup ID';
            return $res;
        }
        $b = new Backup($id);

        // Dir-бекапы (SFTP/WebDAV) хранятся как файлы — скачивание не поддерживается.
        if ($b->getType() === self::ARH_TYPE_DIR) {
            $res->messages[] = 'Download is not available for directory backups on remote server';
            return $res;
        }

        $filename = $b->getResultFile();

        if ( ! file_exists($filename)) {
            $res->messages[] = "File not found for backup $id";
            return $res;
        }

        $extension    = Util::getExtensionOfFile($filename);
        $uid          = Util::generateRandomString(36);
        $di = MikoPBXVersion::getDefaultDi();
        $downloadLink = $di->getShared('config')->path('www.downloadCacheDir');

        $result_dir = "{$downloadLink}/{$uid}";
        Util::mwMkdir($result_dir);
        Util::createUpdateSymlink($filename, "{$result_dir}/{$id}.{$extension}");
        $downloadLink = "/pbxcore/files/cache/{$uid}/{$id}.{$extension}";

        $res->success = true;
        $res->data[] = $downloadLink;
        return $res;
    }

    /**
     * Возвращает путь к файлу резервной копии.
     *
     * @return string
     */
    /**
     * Возвращает тип бекапа.
     * @return string
     */
    public function getType(): string
    {
        return $this->type;
    }

    public function getResultFile(): string
    {
        if ( ! file_exists($this->result_file)) {
            $BackupRules = BackupRules::find('enabled="1"');
            foreach ($BackupRules as $res) {
                $backup_dir = self::getMountPath($res);
                $filename   = "{$backup_dir}/{$this->id}/resultfile";
                if (file_exists("{$filename}.zip")) {
                    $this->result_file = "{$filename}.zip";
                }
                if (file_exists("{$filename}.img")) {
                    $this->result_file = "{$filename}.img";
                }
                if (file_exists("{$filename}.tar")) {
                    $this->result_file = "{$filename}.tar";
                }
            }
        }

        return $this->result_file;
    }

    /**
     * Проверка хватает ли свободноо места на диске;
     * @return bool
     */
    public function checkDiskSpace():bool
    {
        $estimatedSize = self::getEstimatedSize();
        $needSpace = 0;
        $freeSpace = 0;
        foreach ($this->options as $key => $data){
            if($data !== '1'){
                continue;
            }
            $needSpace += intval($estimatedSize->getResult()['data'][$key]);
        }
        // df по фактическому пути — работает и для выделенного диска, и для
        // system-disk (когда /storage/usbdisk1 — раздел системного диска).
        $freeSpace = self::getFreeSpaceOnMountPoint($this->dirs['backup']);

        return ($freeSpace > $needSpace && ($freeSpace - $needSpace) > 500);
    }

    /**
     * Возвращает свободное место в MB по фактическому пути (df сам резолвит
     * подкаталог в точку монтирования). `timeout 3` защищает от зависания
     * на stale FUSE/FTP/SFTP маунте.
     */
    private static function getFreeSpaceOnMountPoint(string $mountPoint): int
    {
        $pathDf = Util::which('df');
        $pathTail = Util::which('tail');
        $pathAwk = Util::which('awk');
        $pathTimeout = Util::which('timeout');
        $escapedMountPoint = escapeshellarg($mountPoint);
        return intval(shell_exec("$pathTimeout 3 $pathDf -m -P $escapedMountPoint 2>/dev/null | $pathTail -n 1 | $pathAwk '{print \$4}'"));
    }

    /**
     * Вычисляет размер батча в зависимости от общего количества файлов.
     *
     * @param int $totalFiles
     * @return int
     */
    private function getBatchSize(int $totalFiles): int
    {
        if ($totalFiles <= 500) {
            return 50;
        }
        if ($totalFiles <= 2000) {
            return 100;
        }
        if ($totalFiles <= 10000) {
            return 200;
        }
        return 500;
    }

    /**
     * Создает файл бекапа.
     *
     * @return array
     */
    public function createArchive(): array
    {
        file_put_contents($this->errorFile, '');
        // Переходим в фазу подготовки: сборка списка файлов и архивов модулей.
        file_put_contents($this->stage_file, 'preparing');
        if (file_exists($this->progress_file)) {
            $file_data      = file_get_contents($this->progress_file);
            $data           = explode('/', $file_data);
            $this->progress = intval(trim($data[0]));
        }else{
            // Изначально показываем 0/1 — чтобы percent считался как 0, а не "не определён".
            file_put_contents($this->progress_file, '0/1');
        }
        if(!$this->checkDiskSpace()){
            $msg = 'There is not enough free disk space.';
            file_put_contents($this->errorFile, $msg);
            Util::sysLogMsg(__CLASS__, $msg);
            @unlink($this->stage_file);
            return ['result' => 'ERROR', 'message' => $msg];
        }
        if ( ! file_exists("{$this->dirs['backup']}/{$this->id}")) {
            $msg = 'Unable to create directory for the backup.';
            file_put_contents($this->errorFile, $msg);
            Util::sysLogMsg(__CLASS__, $msg);
            @unlink($this->stage_file);
            return ['result' => 'ERROR', 'message' => $msg];
        }
        $result = $this->createFileList();
        if ( ! $result) {
            $msg = 'Unable to create file list. Failed to create file.';
            file_put_contents($this->errorFile, $msg);
            Util::sysLogMsg(__CLASS__, $msg);
            @unlink($this->stage_file);
            return ['result' => 'ERROR', 'message' => $msg];
        }

        if ( ! file_exists($this->file_list)) {
            $msg = 'File list not found.';
            file_put_contents($this->errorFile, $msg);
            Util::sysLogMsg(__CLASS__, $msg);
            @unlink($this->stage_file);
            return ['result' => 'ERROR', 'message' => $msg];
        }
        $lines = file($this->file_list);
        if ($lines === false) {
            $msg = 'File list empty.';
            file_put_contents($this->errorFile, $msg);
            Util::sysLogMsg(__CLASS__, $msg);
            @unlink($this->stage_file);
            return ['result' => 'ERROR', 'message' => $msg];
        }
        $count_files = count($lines);
        $batchSize   = $this->getBatchSize($count_files);
        file_put_contents($this->progress_file, "{$this->progress}/{$count_files}");
        // Подготовка завершена — переходим в фазу архивации.
        if (file_exists($this->stage_file)) {
            unlink($this->stage_file);
        }

        $batchFiles = [];
        while ($this->progress < $count_files) {
            $filename_data = trim($lines[$this->progress]);
            if (strpos($filename_data, ':') === false) {
                $section  = '';
                $filename = $filename_data;
            } else {
                $parts    = explode(':', $filename_data, 2);
                $section  = $parts[0];
                $filename = $parts[1] ?? '';
            }

            $this->progress++;

            if ($filename === '') {
                continue;
            }

            // Сжатые архивы модулей — добавляем как один файл и удаляем tmp.
            if ($section === 'backup-module-archive') {
                if (!empty($batchFiles)) {
                    $this->addBatchToArchive($batchFiles);
                    $batchFiles = [];
                }
                if ($this->type === self::ARH_TYPE_DIR) {
                    $this->copyModuleArchiveToDir($filename);
                } else {
                    $this->addModuleArchiveToBackup($filename);
                }
                if (file_exists($filename)) {
                    unlink($filename);
                }
                file_put_contents($this->progress_file, "{$this->progress}/{$count_files}");
                continue;
            }

            if (is_dir($filename) || !file_exists($filename)) {
                continue;
            }

            // DB-файлы обрабатываем поштучно (.backup + gzip).
            $isDbFile = $this->isDbFile($filename);
            if ($isDbFile) {
                // Сначала сбросим накопленный батч обычных файлов.
                if (!empty($batchFiles)) {
                    $this->addBatchToArchive($batchFiles);
                    $batchFiles = [];
                }
                if ($this->type === self::ARH_TYPE_DIR) {
                    $this->copyDbFileToDir($filename);
                } else {
                    $this->addFileToArchive($filename);
                }
            } else {
                $batchFiles[] = $filename;
            }

            // Когда батч набран — сбрасываем в архив и обновляем прогресс.
            if (count($batchFiles) >= $batchSize) {
                $this->addBatchToArchive($batchFiles);
                $batchFiles = [];
                file_put_contents($this->progress_file, "{$this->progress}/{$count_files}");
            }
        }

        // Остаток файлов.
        if (!empty($batchFiles)) {
            $this->addBatchToArchive($batchFiles);
        }

        file_put_contents($this->progress_file, "{$this->progress}/{$count_files}");
        if ($this->type !== self::ARH_TYPE_DIR) {
            $this->addFileToArchive($this->progress_file);
        }

        if (Storage::diskIsMounted($this->result_file, '')) {
            $unmountPath = Util::which('umount');
            Processes::mwExec("{$unmountPath} $this->result_file");
        }

        return ['result' => 'Success', 'count_files' => $count_files];
    }

    /**
     * Собирает файлы модулей для бекапа.
     * Каждый модуль (каталог с module.json) сжимается в .tar.gz (без содержимого db/).
     * DB-файлы модулей записываются отдельно для обработки через .backup + gzip.
     *
     * @return string строки для flist.txt
     */
    private function collectModuleFiles(int &$prepDone = 0, int $prepTotal = 1): string
    {
        $flist = '';
        $customModulesDir = $this->dirs['custom_modules'];
        if (!is_dir($customModulesDir)) {
            return $flist;
        }
        $tarPath  = Util::which('tar');
        $findPath = Util::which('find');
        $tmpDir   = $this->di->getShared('config')->path('core.tempDir');
        $entries  = scandir($customModulesDir);

        foreach ($entries as $entry) {
            if ($entry === '.' || $entry === '..') {
                continue;
            }
            $moduleDir = "$customModulesDir/$entry";
            if (!is_dir($moduleDir)) {
                continue;
            }

            // Проверяем наличие module.json — признак модуля.
            if (!file_exists("$moduleDir/module.json")) {
                continue;
            }

            // 1. Собираем DB-файлы из db/ подкаталога отдельно.
            $dbDir = "$moduleDir/db";
            if (is_dir($dbDir)) {
                $dbFiles = [];
                Processes::mwExec("{$findPath} '$dbDir' -type f -name '*.db'", $dbFiles);
                foreach ($dbFiles as $dbFile) {
                    if (!empty($dbFile)) {
                        $flist .= 'backup-config:' . $dbFile . "\n";
                    }
                }
            }

            // 2. Сжимаем каталог модуля (без содержимого db/).
            $escapedEntry = escapeshellarg($entry);
            $tmpFile = "$tmpDir/backup_module_{$entry}.tar.gz";
            $res = Processes::mwExec(
                "$tarPath -czf '$tmpFile' --exclude='db/*' -C '$customModulesDir' $escapedEntry"
            );
            if ($res === 0 && file_exists($tmpFile)) {
                $flist .= 'backup-module-archive:' . $tmpFile . "\n";
            } else {
                // Fallback: старый способ — поштучно.
                Util::sysLogMsg('Backup', "Failed to compress module $entry, falling back to individual files");
                if (file_exists($tmpFile)) {
                    unlink($tmpFile);
                }
                $moduleFiles = [];
                Processes::mwExec("{$findPath} '$moduleDir'", $moduleFiles);
                foreach ($moduleFiles as $mf) {
                    if (!empty($mf)) {
                        $flist .= 'backup-config:' . $mf . "\n";
                    }
                }
            }
            // Отражаем прогресс фазы подготовки: модуль обработан.
            $prepDone++;
            file_put_contents($this->progress_file, "{$prepDone}/{$prepTotal}");
        }
        return $flist;
    }

    /**
     * Добавляет сжатый архив модуля в основной архив бекапа.
     * Хранит под путём /module_archives/{basename} внутри архива.
     *
     * @param string $archivePath путь к .tar.gz файлу
     */
    private function addModuleArchiveToBackup(string $archivePath): void
    {
        if (!file_exists($archivePath)) {
            return;
        }
        $baseName = basename($archivePath);
        $archiveStorePath = "/module_archives/$baseName";

        if ($this->type === self::ARH_TYPE_TAR) {
            $tarPath = Util::which('tar');
            if (!file_exists($this->result_file)) {
                Processes::mwExec("$tarPath -cf $this->result_file -T /dev/null");
            }
            Processes::mwExec(
                "$tarPath --transform='flags=r;s|$archivePath|$archiveStorePath|' -Prf $this->result_file $archivePath"
            );
        } elseif ($this->type === self::ARH_TYPE_IMG) {
            $cpPath = Util::which('cp');
            $this->createImgFile();
            $destDir = $this->result_dir . '/module_archives';
            Util::mwMkdir($destDir);
            Processes::mwExec("$cpPath '$archivePath' '$destDir/$baseName'");
        } else {
            $sevenZaPath = Util::which('7za');
            Processes::mwExec("{$sevenZaPath} a -tzip -spf '{$this->result_file}' '{$archivePath}'", $out);
        }
    }

    /**
     * Извлекает сжатый архив модуля из бекапа и распаковывает в custom_modules.
     *
     * @param string $archivePath путь внутри архива (/module_archives/backup_module_XXX.tar.gz)
     * @return bool
     */
    private function extractModuleArchive(string $archivePath): bool
    {
        $tarPath = Util::which('tar');
        $cpPath  = Util::which('cp');
        $tmpDir  = $this->di->getShared('config')->path('core.tempDir');
        $baseName = basename($archivePath);
        $tmpFile = "$tmpDir/$baseName";

        // Извлекаем .tar.gz из основного архива (или каталога dir-бекапа).
        if ($this->type === self::ARH_TYPE_DIR) {
            $b_dir = "{$this->dirs['backup']}/{$this->id}";
            $srcFile = "$b_dir/$archivePath";
            if (file_exists($srcFile)) {
                Processes::mwExec("$cpPath '$srcFile' '$tmpFile'");
            }
        } elseif ($this->type === self::ARH_TYPE_TAR) {
            Processes::mwExec(
                "$tarPath --transform='flags=r;s|$archivePath|$tmpFile|' -Pxf $this->result_file $archivePath"
            );
        } elseif ($this->type === self::ARH_TYPE_IMG) {
            $mountPath = Util::which('mount');
            if (!Storage::diskIsMounted($this->result_file, '')) {
                Processes::mwExec("{$mountPath} -o loop {$this->result_file} {$this->result_dir}");
            }
            Processes::mwExec("$cpPath '{$this->result_dir}{$archivePath}' '$tmpFile'");
        } else {
            $sevenZaPath = Util::which('7za');
            Processes::mwExec("{$sevenZaPath} e -y -r -spf '{$this->result_file}' '{$archivePath}'");
            if (file_exists($archivePath) && $archivePath !== $tmpFile) {
                rename($archivePath, $tmpFile);
            }
        }

        if (!file_exists($tmpFile)) {
            Util::sysLogMsg('Backup', "Failed to extract module archive: $archivePath");
            return false;
        }

        // Распаковываем содержимое .tar.gz в каталог модулей.
        $customModulesDir = $this->dirs['custom_modules'];
        Util::mwMkdir($customModulesDir);
        $res = Processes::mwExec("$tarPath -xzf '$tmpFile' -C '$customModulesDir'");
        unlink($tmpFile);

        if ($res !== 0) {
            Util::sysLogMsg('Backup', "Failed to extract module archive contents: $baseName");
            return false;
        }
        return true;
    }

    /**
     * Копирует батч обычных файлов в каталог dir-бекапа с сохранением структуры.
     * Использует rsync (инкрементальность, один вызов на батч), fallback на cp.
     *
     * @param array $files
     */
    private function copyFilesToDir(array $files): void
    {
        $b_dir = "{$this->dirs['backup']}/{$this->id}/files";
        $rsyncPath = Util::which('rsync');
        if (!empty($rsyncPath)) {
            $tmpDir = $this->di->getShared('config')->path('core.tempDir');
            $batchListFile = "$tmpDir/backup_rsync_" . getmypid() . '.txt';
            file_put_contents($batchListFile, implode("\n", $files) . "\n");
            Processes::mwExec("$rsyncPath -a --files-from='$batchListFile' / '$b_dir/'");
            unlink($batchListFile);
        } else {
            // Fallback на cp.
            $cpPath = Util::which('cp');
            foreach ($files as $file) {
                if (!file_exists($file)) {
                    continue;
                }
                $destFile = "$b_dir$file";
                Util::mwMkdir(dirname($destFile));
                Processes::mwExec("$cpPath '$file' '$destFile'");
            }
        }
    }

    /**
     * Копирует DB-файл в каталог dir-бекапа (.backup + gzip).
     *
     * @param string $filename
     */
    private function copyDbFileToDir(string $filename): void
    {
        if (!file_exists($filename)) {
            return;
        }
        $b_dir = "{$this->dirs['backup']}/{$this->id}";
        $tmpDir = $this->di->getShared('config')->path('core.tempDir');

        $gzFile = false;
        if (self::isSqliteFile($filename)) {
            $gzFile = $this->backupAndCompressDb($filename, $tmpDir);
        }
        if ($gzFile === false) {
            $gzFile = $this->compressFileGzip($filename, $tmpDir);
        }

        $cpPath = Util::which('cp');
        if ($gzFile !== false) {
            $destFile = "$b_dir/files{$filename}.gz";
            $destDir = dirname($destFile);
            Util::mwMkdir($destDir);
            Processes::mwExec("$cpPath '$gzFile' '$destFile'");
            unlink($gzFile);
        } else {
            // Fallback — копируем как есть.
            $destFile = "$b_dir/files$filename";
            $destDir = dirname($destFile);
            Util::mwMkdir($destDir);
            Processes::mwExec("$cpPath '$filename' '$destFile'");
        }
    }

    /**
     * Копирует сжатый модульный архив в каталог dir-бекапа.
     *
     * @param string $archivePath
     */
    private function copyModuleArchiveToDir(string $archivePath): void
    {
        if (!file_exists($archivePath)) {
            return;
        }
        $b_dir = "{$this->dirs['backup']}/{$this->id}";
        $destDir = "$b_dir/module_archives";
        Util::mwMkdir($destDir);
        $cpPath = Util::which('cp');
        $escapedBaseName = escapeshellarg(basename($archivePath));
        Processes::mwExec("$cpPath '$archivePath' $destDir/$escapedBaseName");
    }

    /**
     * Создает список файлов к бекапу.
     */
    private function createFileList(): bool
    {
        try {
            $result = @file_put_contents($this->file_list, '');
        } catch (Exception $e) {
            Util::sysLogMsg('Backup', $e->getMessage());
            $result = false;
        }
        if ($result === false || ! file_exists($this->file_list)) {
            Util::sysLogMsg('Backup', 'Failed to create file ' . $this->file_list);

            return $result;
        }

        // Считаем общее число шагов подготовки для отображения прогресса.
        // Шаги: модули (каждый = 1 tar.gz) + find по media + find по records.
        $moduleCount = $this->countModuleCandidates();
        $prepTotal   = $moduleCount;
        if (($this->options['backup-sound-files'] ?? '') === '1') {
            $prepTotal++;
        }
        if (($this->options['backup-records'] ?? '') === '1' && $this->remote) {
            $prepTotal++;
        }
        if ($prepTotal < 1) {
            $prepTotal = 1;
        }
        $prepDone = 0;
        file_put_contents($this->progress_file, "{$prepDone}/{$prepTotal}");

        $flist = '';
        if (($this->options['backup-config'] ?? '') === '1') {
            file_put_contents($this->file_list, 'backup-config:' . $this->dirs['settings_db_path'] . "\n", FILE_APPEND);
            $flist .= $this->collectModuleFiles($prepDone, $prepTotal);
        } else {
            // backup-config отключён — модули не сжимаем, но шаги учтены в prepTotal.
            $prepDone += $moduleCount;
            file_put_contents($this->progress_file, "{$prepDone}/{$prepTotal}");
        }
        if (($this->options['backup-cdr'] ?? '') === '1') {
            file_put_contents($this->file_list, 'backup-cdr:' . $this->dirs['cdr_db_path'] . "\n", FILE_APPEND);
        }

        file_put_contents($this->file_list, $this->file_list . "\n", FILE_APPEND);
        file_put_contents($this->file_list, $this->config_file . "\n", FILE_APPEND);

        $findPath = Util::which('find');
        if (($this->options['backup-sound-files'] ?? '') === '1') {
            Processes::mwExec("{$findPath} {$this->dirs['media']} -type f", $out);
            foreach ($out as $filename) {
                $flist .= 'backup-sound-files:' . $filename . "\n";
            }
            $prepDone++;
            file_put_contents($this->progress_file, "{$prepDone}/{$prepTotal}");
        }
        if (($this->options['backup-records'] ?? '') === '1') {
            if ($this->remote) {
                // Записи разговоров бекапим только на удалённый сервер.
                // Локально это бессмысленно — файлы уже на этом же диске.
                Processes::mwExec("{$findPath} {$this->dirs['astspooldir']} -type f -name '*.mp3'", $out);
                foreach ($out as $filename) {
                    $flist .= 'backup-records:' . $filename . "\n";
                }
                $prepDone++;
                file_put_contents($this->progress_file, "{$prepDone}/{$prepTotal}");
            }
        }
        file_put_contents($this->file_list, $flist, FILE_APPEND);

        return true;
    }

    /**
     * Подсчитывает количество кандидатов-модулей (каталог с module.json).
     * Используется для расчёта прогресса фазы подготовки.
     */
    private function countModuleCandidates(): int
    {
        $customModulesDir = $this->dirs['custom_modules'];
        if (!is_dir($customModulesDir)) {
            return 0;
        }
        $count = 0;
        $entries = scandir($customModulesDir) ?: [];
        foreach ($entries as $entry) {
            if ($entry === '.' || $entry === '..') {
                continue;
            }
            $moduleDir = "$customModulesDir/$entry";
            if (is_dir($moduleDir) && file_exists("$moduleDir/module.json")) {
                $count++;
            }
        }
        return $count;
    }

    /**
     * Добавляет батч обычных файлов в архив одной командой.
     *
     * @param array $files
     */
    private function addBatchToArchive(array $files): void
    {
        if (empty($files)) {
            return;
        }

        if ($this->type === self::ARH_TYPE_DIR) {
            $this->copyFilesToDir($files);
            return;
        }

        if ($this->type === self::ARH_TYPE_TAR) {
            $tarPath = Util::which('tar');
            if (!file_exists($this->result_file)) {
                Processes::mwExec("$tarPath -cf $this->result_file -T /dev/null");
            }
            $tmpDir = $this->di->getShared('config')->path('core.tempDir');
            $batchListFile = "$tmpDir/backup_batch_" . getmypid() . '.txt';
            file_put_contents($batchListFile, implode("\n", $files) . "\n");
            Processes::mwExec("$tarPath -Prf $this->result_file -T $batchListFile");
            unlink($batchListFile);
        } elseif ($this->type === self::ARH_TYPE_IMG) {
            foreach ($files as $file) {
                $this->addFileToArchive($file);
            }
        } else {
            // ZIP — 7za поддерживает список файлов через @listfile.
            $sevenZaPath = Util::which('7za');
            $tmpDir = $this->di->getShared('config')->path('core.tempDir');
            $batchListFile = "$tmpDir/backup_batch_" . getmypid() . '.txt';
            file_put_contents($batchListFile, implode("\n", $files) . "\n");
            Processes::mwExec("{$sevenZaPath} a -tzip -spf '{$this->result_file}' @{$batchListFile}", $out);
            unlink($batchListFile);
        }
    }

    /**
     * Проверяет, является ли файл базой данных (по расширению .db).
     *
     * @param string $filename
     * @return bool
     */
    private function isDbFile(string $filename): bool
    {
        return strtolower(pathinfo($filename, PATHINFO_EXTENSION)) === 'db';
    }

    /**
     * Проверяет, является ли файл базой данных SQLite (по magic bytes).
     *
     * @param string $filename
     * @return bool
     */
    private static function isSqliteFile(string $filename): bool
    {
        $fh = @fopen($filename, 'rb');
        if (!$fh) {
            return false;
        }
        $header = fread($fh, 16);
        fclose($fh);
        return strpos($header, 'SQLite format') === 0;
    }

    /**
     * Создаёт безопасную копию SQLite БД через .backup и сжимает gzip.
     * Возвращает путь к сжатому файлу.
     *
     * @param string $dbPath — путь к исходной БД
     * @param string $tmpDir — каталог для временных файлов
     * @return string|false — путь к .gz файлу или false при ошибке
     */
    private function backupAndCompressDb(string $dbPath, string $tmpDir)
    {
        $sqlite3Path = Util::which('sqlite3');
        $gzipPath    = Util::which('gzip');
        $tmpFile     = "$tmpDir/" . basename($dbPath) . '_bak';

        // .backup не блокирует БД и работает атомарно.
        $res = Processes::mwExec("$sqlite3Path '$dbPath' '.backup $tmpFile'");
        if ($res !== 0 || !file_exists($tmpFile)) {
            Util::sysLogMsg('Backup', "sqlite3 .backup failed for $dbPath");
            return false;
        }

        // Сжимаем копию.
        Processes::mwExec("$gzipPath -f $tmpFile");
        $gzFile = "$tmpFile.gz";
        if (!file_exists($gzFile)) {
            Util::sysLogMsg('Backup', "gzip failed for $tmpFile");
            return false;
        }
        return $gzFile;
    }

    /**
     * Проверяет, является ли файл gzip-архивом по magic bytes.
     *
     * @param string $filePath
     * @return bool
     */
    public static function isGzipped(string $filePath): bool
    {
        $fh = @fopen($filePath, 'rb');
        if (!$fh) {
            return false;
        }
        $magic = fread($fh, 2);
        fclose($fh);
        return ($magic === "\x1f\x8b");
    }

    /**
     * Добавляем файл к архиву.
     *
     * @param $filename
     */
    /**
     * Сжимает файл gzip. Возвращает путь к .gz файлу или false.
     *
     * @param string $filePath
     * @param string $tmpDir
     * @return string|false
     */
    private function compressFileGzip(string $filePath, string $tmpDir)
    {
        $gzipPath = Util::which('gzip');
        $cpPath   = Util::which('cp');
        $tmpFile  = "$tmpDir/" . basename($filePath) . '_copy';
        Processes::mwExec("$cpPath '$filePath' '$tmpFile'");
        if (!file_exists($tmpFile)) {
            return false;
        }
        Processes::mwExec("$gzipPath -f $tmpFile");
        $gzFile = "$tmpFile.gz";
        return file_exists($gzFile) ? $gzFile : false;
    }

    private function addFileToArchive($filename): void
    {
        if ( ! file_exists($filename)) {
            return;
        }

        $isDbFile = $this->isDbFile($filename);
        if ($this->type === self::ARH_TYPE_IMG) {
            $sqlite3Path = Util::which('sqlite3');
            $cpPath = Util::which('cp');

            $this->createImgFile();
            $res_dir = dirname($this->result_dir . $filename);
            Util::mwMkdir($res_dir);
            if ($isDbFile && self::isSqliteFile($filename)) {
                // SQLite: .backup создаёт атомарную копию, не блокируя БД.
                $res = Processes::mwExec(
                    "$sqlite3Path '$filename' '.backup {$this->result_dir}{$filename}'",
                    $out
                );
                if ($res !== 0) {
                    Processes::mwExec("{$cpPath} '{$filename}' '{$this->result_dir}{$filename}'", $out);
                }
            } else {
                Processes::mwExec("{$cpPath} '{$filename}' '{$this->result_dir}{$filename}' ", $out);
            }
        }elseif ($this->type === self::ARH_TYPE_TAR){
            $tarPath = Util::which('tar');
            if(!file_exists($this->result_file)){
                Processes::mwExec("$tarPath -cf $this->result_file -T /dev/null");
            }
            $tmpDir = $this->di->getShared('config')->path('core.tempDir');
            if ($isDbFile) {
                $gzFile = false;
                if (self::isSqliteFile($filename)) {
                    // SQLite: .backup + gzip
                    $gzFile = $this->backupAndCompressDb($filename, $tmpDir);
                }
                if ($gzFile === false) {
                    // Не SQLite или .backup не сработал — просто gzip копию.
                    $gzFile = $this->compressFileGzip($filename, $tmpDir);
                }
                if ($gzFile !== false) {
                    Processes::mwExec("$tarPath --transform='flags=r;s|$gzFile|$filename|' -Prf $this->result_file $gzFile");
                    unlink($gzFile);
                } else {
                    // Совсем fallback — добавляем как есть.
                    Processes::mwExec("$tarPath -Prf $this->result_file $filename");
                }
            } else {
                Processes::mwExec("$tarPath -Prf $this->result_file $filename");
            }
        } else {
            $sevenZaPath = Util::which('7za');
            $tmpDir = $this->di->getShared('config')->path('core.tempDir');
            if ($isDbFile) {
                $gzFile = false;
                if (self::isSqliteFile($filename)) {
                    $gzFile = $this->backupAndCompressDb($filename, $tmpDir);
                }
                if ($gzFile === false) {
                    $gzFile = $this->compressFileGzip($filename, $tmpDir);
                }
                if ($gzFile !== false) {
                    Processes::mwExec("{$sevenZaPath} a -tzip -spf '{$this->result_file}' '{$gzFile}'", $out);
                    unlink($gzFile);
                } else {
                    Processes::mwExec("{$sevenZaPath} a -mx=0 -tzip -spf '{$this->result_file}' '{$filename}'", $out);
                }
            } else {
                Processes::mwExec("{$sevenZaPath} a -tzip -spf '{$this->result_file}' '{$filename}'", $out);
            }
        }
    }

    /**
     * Создает файл образа для бекапа. Резервирует место под резервную копию.
     */
    private function createImgFile(): void
    {
        // Создаем директорию монтирования.
        Util::mwMkdir($this->result_dir);
        if ( ! file_exists($this->result_file)) {
            // Оценим размер бекапа.
            $result_size = 0;
            $arr_size    = self::getEstimatedSize()->data;
            foreach ($this->options as $key => $enable) {
                if (trim($enable) === '1') {
                    $result_size += $arr_size[$key];
                }
            }
            // Округляем в большую сторону.
            $result_size = $result_size < 1 ? 1 : round($result_size);
            $tmp_name    = $this->dirs['tmp'] . '/' . Util::generateRandomString();
            // Создаем образ файловой системы.
            $ddPath = Util::which('dd');
            $res    = Processes::mwExec("{$ddPath} if=/dev/zero of={$tmp_name} bs=1 count=0 seek={$result_size}M");
            if ($res !== 0) {
                Util::sysLogMsg('Backup', 'Error creating img file...');
            }

            // Создаем разметку файловой системы.
            $mke2fsPath = Util::which('mke2fs');
            $res        = Processes::mwExec("{$mke2fsPath} -m0 -L backup -F {$tmp_name}");
            if ($res !== 0) {
                Util::sysLogMsg('Backup', 'Error create the layout of the file system... ' . $tmp_name);
                // throw new Exception('Error create the layout of the file system...');
            }
            // Тюним.
            $tune2fsPath = Util::which('tune2fs');
            $cpPath      = Util::which('cp');
            $rmPath      = Util::which('rm');
            Processes::mwExec("{$tune2fsPath} -c0  {$tmp_name}");
            Processes::mwExec("{$cpPath} '{$tmp_name}' '{$this->result_file}' ");
            Processes::mwExec("{$rmPath} -rf  '{$tmp_name}'");
        }
        // Монтируем.
        if ( ! Storage::diskIsMounted($this->result_file, '')) {
            $mountPath = Util::which('mount');
            $res       = Processes::mwExec("{$mountPath} -o loop {$this->result_file} {$this->result_dir}");
            if ($res > 1) {
                Util::sysLogMsg('Backup', 'File system mount error...');
            }
        }
    }

    /**
     * Возвращает предполагаемый размер каталогов для бекапа.
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function getEstimatedSize(): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;

        $arr_size                       = [];
        $di = MikoPBXVersion::getDefaultDi();
        $dirsConfig                     = $di->getShared('config');
        $dirs                           = [
            'backup'           => self::getBackupDir(),
            'custom_modules'   => $dirsConfig->path('core.modulesDir'),
            'media'            => $dirsConfig->path('asterisk.mediadir'),
            'astspooldir'      => $dirsConfig->path('asterisk.astspooldir'),
            'settings_db_path' => $dirsConfig->path('database.dbfile'),
            'cdr_db_path'      => $dirsConfig->path('cdrDatabase.dbfile'),
        ];
        $arr_size['backup-sound-files'] = Util::getSizeOfFile($dirs['media']);
        $arr_size['backup-records']     = Util::getSizeOfFile($dirs['astspooldir']);
        $arr_size['backup-cdr']         = Util::getSizeOfFile($dirs['cdr_db_path']);

        $backup_config             = Util::getSizeOfFile($dirs['settings_db_path']);
        $backup_config             += Util::getSizeOfFile($dirs['custom_modules']);
        $arr_size['backup-config'] = $backup_config;

        foreach ($arr_size as $key => $value) {
            // Есть какие то аномалии с преобразование значение в json
            // Без этого костыля есть проблемы с округлением.
            $arr_size[$key] = intval($value);
        }

        $res->success = true;
        $res->data = $arr_size;
        return $res;
    }

    /**
     * Восстановление из резервной копиии.
     *
     * @return array
     */
    public function recoverWithProgress(): array
    {
        if ( ! Storage::isStorageDiskMounted()) {
            return ['result' => 'ERROR', 'message' => 'Storage is not mounted.'];
        }
        $backupOptions = null;
        if (file_exists($this->options_recover_file)) {
            $backupOptions = json_decode(file_get_contents($this->options_recover_file), true);
        }

        if ( ! file_exists($this->file_list)) {
            return ['result' => 'ERROR', 'message' => 'File list not found.'];
        }
        $lines = file($this->file_list);
        if ($lines === false) {
            return ['result' => 'ERROR', 'message' => 'File list not read.'];
        }

        if (file_exists($this->progress_file_recover)) {
            // Получим текущий прогресс.
            $file_data      = file_get_contents($this->progress_file_recover);
            $data           = explode('/', $file_data);
            $this->progress = intval(trim($data[0]));
        }

        $count_files = count($lines);
        if ($this->progress === $count_files) {
            $this->progress = 0;
        }

        file_put_contents($this->progress_file_recover, "{$this->progress}/{$count_files}");
        while ($this->progress < $count_files) {
            $filename_data = trim($lines[$this->progress]);
            if (strpos($filename_data, ':') === false) {
                $section  = ''; // Этот файл будет восстановленр в любом случае.
                $filename = $filename_data;
            } else {
                $tmp_data = explode(':', $filename_data, 2);
                $section  = $tmp_data[0] ?? '';
                $filename = $tmp_data[1] ?? '';
            }

            // backup-module-archive привязан к опции backup-config.
            $effectiveSection = $section;
            if ($section === 'backup-module-archive') {
                $effectiveSection = 'backup-config';
            }

            $this->progress++;
            if (in_array(basename($filename), ['flist.txt', 'config.json'])) {
                continue;
            }

            if ($effectiveSection !== '' && is_array($backupOptions) && ! isset($backupOptions[$effectiveSection])) {
                // Если секция указана, и она не определена в массиве опций,
                // то не восстанавливаем файл.
                unset($filename);
            } else {
                $this->extractFile($filename);
            }
            if ($this->progress % 10 === 0) {
                file_put_contents($this->progress_file_recover, "{$this->progress}/{$count_files}");
            }
        }
        file_put_contents($this->progress_file_recover, "{$this->progress}/{$count_files}");

        if (Storage::diskIsMounted($this->result_file, '')) {
            $unmountPath = Util::which('umount');
            Processes::mwExec("{$unmountPath} $this->result_file");
        }

        if (isset($backupOptions['backup-config']) && $backupOptions['backup-config'] === '1') {
            System::rebootSync();
        }

        return ['result' => 'Success', 'count_files' => $count_files];
    }

    /**
     * Извлечь файл из архива.
     *
     * @param string        $filename
     * @param null | string $out
     *
     * @return bool
     */
    public function extractFile($filename = '', &$out = null): bool
    {
        // Сжатые архивы модулей — обрабатываем отдельно.
        if (strpos($filename, '/module_archives/') === 0
            && substr($filename, -7) === '.tar.gz'
        ) {
            return $this->extractModuleArchive($filename);
        }

        $arr_out     = [];
        $mountPath   = Util::which('mount');
        $sedPath     = Util::which('sed');
        $sqlite3Path = Util::which('sqlite3');
        $rmPath      = Util::which('rm');
        $cpPath      = Util::which('cp');
        $mvPath      = Util::which('mv');
        $sevenZaPath = Util::which('7za');
        $tarPath     = Util::which('tar');

        $result_file     = $filename;
        $tmp_path        = '/var/asterisk/';
        $mem_monitor_dir = $this->dirs_mem['astspooldir'] . '/mikopbx/voicemailarchive/monitor';
        $monitor_dir     = Storage::getMonitorDir();
        if (strpos($filename, $tmp_path) === 0) {
            $var_search  = [
                $mem_monitor_dir,
                $this->dirs_mem['media'],
                $this->dirs_mem['astlogpath'],
                $this->dirs_mem['backup'],
            ];
            $var_replace = [
                $monitor_dir,
                $this->dirs['media'],
                $this->dirs['astlogpath'],
                $this->dirs['backup'],
            ];
            $result_file = str_replace($var_search, $var_replace, $filename);
        }

        $file_dir = dirname($filename);
        Util::mwMkdir($file_dir);
        $file_dir = dirname($result_file);
        Util::mwMkdir($file_dir);

        if ($this->type === self::ARH_TYPE_DIR) {
            // Dir-бекап: файлы лежат в каталоге бекапа.
            $b_dir = "{$this->dirs['backup']}/{$this->id}";
            $isDbExtension = (strtolower(pathinfo($filename, PATHINFO_EXTENSION)) === 'db');

            if ($isDbExtension) {
                // DB-файл: может быть .gz (новый формат) или обычный (старый).
                $srcGz = "$b_dir/files{$filename}.gz";
                $srcPlain = "$b_dir/files{$filename}";
                if (file_exists($srcGz)) {
                    $gzipPath = Util::which('gzip');
                    $tmpDir = $this->di->getShared('config')->path('core.tempDir');
                    $tmpFile = "$tmpDir/" . basename($filename) . '.gz';
                    Processes::mwExec("$cpPath '$srcGz' '$tmpFile'");
                    Processes::mwExec("$gzipPath -d -f '$tmpFile'");
                    $tmpFileDb = substr($tmpFile, 0, -3);
                    Processes::mwExec("$cpPath '$tmpFileDb' '$result_file'");
                    unlink($tmpFileDb);
                } elseif (file_exists($srcPlain)) {
                    Processes::mwExec("$cpPath '$srcPlain' '$result_file'");
                }
                Util::addRegularWWWRights($result_file);
            } else {
                // Обычный файл: копируем из каталога бекапа.
                $srcFile = "$b_dir/files{$filename}";
                if (file_exists($srcFile)) {
                    Processes::mwExec("$cpPath '$srcFile' '$result_file'");
                }
            }
        } elseif (in_array($this->type, [self::ARH_TYPE_IMG, self::ARH_TYPE_TAR], true)) {
            if (self::ARH_TYPE_IMG === $this->type && !Storage::diskIsMounted($this->result_file, '')) {
                Processes::mwExec("{$mountPath} -o loop {$this->result_file} {$this->result_dir}");
            }
            $baseFilename = basename($filename);
            $isDbExtension = (strtolower(pathinfo($filename, PATHINFO_EXTENSION)) === 'db');
            $isSystemDb    = in_array($baseFilename, self::DB_FILES);

            if ($isDbExtension) {
                $tmpDir = $this->di->getShared('config')->path('core.tempDir');

                // Для системных БД: сохраняем m_Storage перед восстановлением.
                $sed_command = '';
                if ($isSystemDb) {
                    if ($result_file !== $filename) {
                        $sed_command = ' | ' . $sedPath . ' \'s/' . str_replace(
                                '/',
                                '\/',
                                $mem_monitor_dir
                            ) . '/' . str_replace(
                                '/',
                                '\/',
                                $monitor_dir
                            ) . '/g\'';
                        $sed_command .= ' | ' . $sedPath . ' \'s/' . str_replace(
                                '/',
                                '\/',
                                $this->dirs_mem['media']
                            ) . '/' . str_replace('/', '\/', $this->dirs['media']) . '/g\'';
                    }
                    if ($baseFilename === self::CONF_DB_NAME) {
                        $grepPath    = Util::which('grep');
                        $dmpDbFile   = $tmpDir.'/tmp-storage.sql';
                        $grepOptions = " -e '^INSERT INTO m_Storage'  -e '^INSERT INTO \"m_Storage'";
                        Processes::mwExec("{$sqlite3Path} {$result_file} .dump | {$grepPath} {$grepOptions} > " . $dmpDbFile);
                    }
                    Processes::mwExec("{$rmPath} -rf {$result_file}* ");
                }

                if (self::ARH_TYPE_IMG === $this->type) {
                    $imgDbFile = "{$this->result_dir}{$filename}";
                    if ($isSystemDb && $sed_command !== '') {
                        // Системная БД с трансформацией путей — dump + sed.
                        Processes::mwExec("{$sqlite3Path} '{$imgDbFile}' .dump $sed_command | {$sqlite3Path} '{$result_file}' ", $arr_out);
                    } else {
                        Processes::mwExec("{$cpPath} '{$imgDbFile}' '{$result_file}'", $arr_out);
                    }
                } else {
                    // TAR: извлекаем файл и определяем формат.
                    $tmpDbFile = $tmpDir . "/" . time() . '-' . $baseFilename;
                    Processes::mwExec("$tarPath --transform='flags=r;s|$filename|$tmpDbFile|' -Pxf $this->result_file $filename");
                    if (self::isGzipped($tmpDbFile)) {
                        // Новый формат: gzip-сжатый (.backup или просто gzip копия).
                        $gzipPath = Util::which('gzip');
                        $tmpDbFileGz = "$tmpDbFile.gz";
                        rename($tmpDbFile, $tmpDbFileGz);
                        Processes::mwExec("$gzipPath -d $tmpDbFileGz");
                        // $tmpDbFile теперь содержит бинарный файл БД.
                        Processes::mwExec("$cpPath '$tmpDbFile' '$result_file'", $arr_out);
                    } else {
                        // Старый формат: SQL dump — импортируем через sqlite3.
                        if ($isSystemDb) {
                            Processes::mwExec("$sqlite3Path '$result_file' < $tmpDbFile", $arr_out);
                        } else {
                            // Модульная БД из старого бекапа — пробуем как sqlite dump, если не получится — как бинарный файл.
                            $res = Processes::mwExec("$sqlite3Path '$result_file' < $tmpDbFile", $arr_out);
                            if ($res !== 0) {
                                Processes::mwExec("$cpPath '$tmpDbFile' '$result_file'", $arr_out);
                            }
                        }
                    }
                    if (file_exists($tmpDbFile)) {
                        unlink($tmpDbFile);
                    }
                }

                // Для системных БД: восстанавливаем m_Storage.
                if ($isSystemDb && $baseFilename === self::CONF_DB_NAME) {
                    Processes::mwExec("$sqlite3Path $result_file 'DELETE FROM m_Storage'");
                    Processes::mwExec("$sqlite3Path $result_file < $dmpDbFile");
                    unlink($dmpDbFile);
                }
                Util::addRegularWWWRights($result_file);
            } else {
                // Обычный файл (не DB).
                if (self::ARH_TYPE_IMG === $this->type) {
                    // IMG: копируем из смонтированного образа.
                    Processes::mwExec("{$cpPath} '{$this->result_dir}{$filename}' '{$result_file}'", $arr_out);
                } else {
                    // TAR: извлекаем файл напрямую из архива.
                    $file_dir_restore = dirname($result_file);
                    Util::mwMkdir($file_dir_restore);
                    if ($result_file !== $filename) {
                        Processes::mwExec("$tarPath --transform='flags=r;s|$filename|$result_file|' -Pxf $this->result_file $filename", $arr_out);
                    } else {
                        Processes::mwExec("$tarPath -Pxf $this->result_file $filename", $arr_out);
                    }
                }
            }
        } else {
            Processes::mwExec("{$sevenZaPath} e -y -r -spf '{$this->result_file}' '{$filename}'", $arr_out);
            if ($filename !== $result_file && file_exists($filename)) {
                Processes::mwExec("{$mvPath} '{$filename}' '{$result_file}'", $arr_out);
            }
            // Для DB-файлов из ZIP: декомпрессия gzip если нужно.
            if (strtolower(pathinfo($filename, PATHINFO_EXTENSION)) === 'db' && file_exists($result_file)) {
                if (self::isGzipped($result_file)) {
                    $gzipPath = Util::which('gzip');
                    $tmpGz = "$result_file.gz";
                    rename($result_file, $tmpGz);
                    Processes::mwExec("$gzipPath -d $tmpGz");
                }
                Util::addRegularWWWRights($result_file);
            }
        }
        $out = implode(' ', $arr_out);

        return (strpos($out, 'ERROR') === false);
    }


    /**
     * Convert old Askozia Config
     *
     * @param string $config_file
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function convertConfig($config_file = ''): PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        $res->success = true;
        $tempDir = Directories::getDir(Directories::CORE_TEMP_DIR);
        if (empty($config_file)) {
            $config_file = "{$tempDir}/old_config.xml";
        }

        // Проверка Path Traversal: разрешаем файлы только из tempDir или backupDir.
        $realPath = realpath($config_file);
        $backupDir = self::getBackupDir();
        if ($realPath === false
            || (strpos($realPath, $tempDir . '/') !== 0 && strpos($realPath, $backupDir . '/') !== 0)
        ) {
            $res->success = false;
            $res->messages[] = 'Config file path is not allowed';
            return $res;
        }
        $config_file = $realPath;

        if (file_exists($config_file)) {
            try {
                $cntr = new OldConfigConverter($config_file);
                $cntr->parse();
                $cntr->makeConfig();
                file_put_contents('/tmp/ejectcd', '');
                $mikopbx_rebootPath = Util::which('mikopbx_reboot');
                Processes::mwExecBg($mikopbx_rebootPath, '/dev/null', 3);
            } catch (Exception $e) {
                $res->success = false;
                $res->messages[] = $e->getMessage();
            }
        } else {
            $res->success = false;
            $res->messages[] = 'XML config not found';
        }

        return $res;
    }

    /**
     * Returns status uploading backup file
     *
     * @return PBXApiResult An object containing the result of the API call.
     */
    public static function statusUpload($id):PBXApiResult
    {
        $res = new PBXApiResult();
        $res->processor = __METHOD__;
        if (self::isValidId($id)) {
            $backup_dir  = Backup::getBackupDir();
            $status_file = "{$backup_dir}/{$id}/upload_status";
        } else {
            $status_file = '';
        }

        if ($status_file === '') {
            $res->data['status_upload']= 'ERROR_EMPTY_ID_BACKUP';
        } elseif (file_exists($status_file)) {
            $res->data['status_upload'] = file_get_contents($status_file);
            $res->success = true;
        } else {
            $res->data['status_upload']='ERROR_FILE_NOT_FOUND';
        }
        return $res;
    }

}