Filesystem.php

Go to the documentation of this file.

<?php
namespace Magento\Framework\Backup;

use Magento\Framework\App\ObjectManager;
use Magento\Framework\Archive\Gz;
use Magento\Framework\Backup\Archive\Tar;
use Magento\Framework\Backup\Exception\NotEnoughFreeSpace;
use Magento\Framework\Backup\Exception\NotEnoughPermissions;
use Magento\Framework\Backup\Filesystem\Helper;
use Magento\Framework\Backup\Filesystem\Rollback\Fs;
use Magento\Framework\Backup\Filesystem\Rollback\Ftp;
use Magento\Framework\Exception\LocalizedException;
use Magento\Framework\Phrase;

class Filesystem extends AbstractBackup
{
    protected $_ignorePaths = [];

    protected $_useFtp = false;

    protected $_ftpHost;

    protected $_ftpUser;

    protected $_ftpPass;

    protected $_ftpPath;

    protected $rollBackFtp;

    protected $rollBackFs;

    public function rollback()
    {
        $this->_lastOperationSucceed = false;

        set_time_limit(0);
        ignore_user_abort(true);

        $rollbackWorker = $this->_useFtp ? $this->getRollBackFtp() : $this->getRollBackFs();
        $rollbackWorker->run();

        $this->_lastOperationSucceed = true;
        return $this->_lastOperationSucceed;
    }

    public function create()
    {
        set_time_limit(0);
        ignore_user_abort(true);

        $this->_lastOperationSucceed = false;

        $this->_checkBackupsDir();

        $fsHelper = new Helper();

        $filesInfo = $fsHelper->getInfo(
            $this->getRootDir(),
            Helper::INFO_READABLE |
            Helper::INFO_SIZE,
            $this->getIgnorePaths()
        );

        if (!$filesInfo['readable']) {
            throw new NotEnoughPermissions(
                new Phrase('Not enough permissions to read files for backup')
            );
        }
        $this->validateAvailableDiscSpace($this->getBackupsDir(), $filesInfo['size']);

        $tarTmpPath = $this->_getTarTmpPath();

        $tarPacker = new Tar();
        $tarPacker->setSkipFiles($this->getIgnorePaths())->pack($this->getRootDir(), $tarTmpPath, true);

        if (!is_file($tarTmpPath) || filesize($tarTmpPath) == 0) {
            throw new LocalizedException(
                new Phrase('Failed to create backup')
            );
        }

        $backupPath = $this->getBackupPath();

        $gzPacker = new Gz();
        $gzPacker->pack($tarTmpPath, $backupPath);

        if (!is_file($backupPath) || filesize($backupPath) == 0) {
            throw new LocalizedException(
                new Phrase('Failed to create backup')
            );
        }

        @unlink($tarTmpPath);

        $this->_lastOperationSucceed = true;
        return $this->_lastOperationSucceed;
    }

    public function validateAvailableDiscSpace($backupDir, $size)
    {
        $freeSpace = disk_free_space($backupDir);
        $requiredSpace = 2 * $size;
        if ($requiredSpace > $freeSpace) {
            throw new NotEnoughFreeSpace(
                new Phrase(
                    'Warning: necessary space for backup is ' . (ceil($requiredSpace) / 1024)
                    . 'MB, but your free disc space is ' . (ceil($freeSpace) / 1024) . 'MB.'
                )
            );
        }
    }

    public function setUseFtp($host, $username, $password, $path)
    {
        $this->_useFtp = true;
        $this->_ftpHost = $host;
        $this->_ftpUser = $username;
        $this->_ftpPass = $password;
        $this->_ftpPath = $path;
        return $this;
    }

    public function getType()
    {
        return 'filesystem';
    }

    public function addIgnorePaths($paths)
    {
        if (is_string($paths)) {
            if (!in_array($paths, $this->_ignorePaths)) {
                $this->_ignorePaths[] = $paths;
            }
        } elseif (is_array($paths)) {
            foreach ($paths as $path) {
                $this->addIgnorePaths($path);
            }
        }

        return $this;
    }

    public function getIgnorePaths()
    {
        return $this->_ignorePaths;
    }

    public function setBackupsDir($backupsDir)
    {
        parent::setBackupsDir($backupsDir);
        $this->addIgnorePaths($backupsDir);
        return $this;
    }

    public function getFtpPath()
    {
        return $this->_ftpPath;
    }

    public function getFtpConnectString()
    {
        return 'ftp://' . $this->_ftpUser . ':' . $this->_ftpPass . '@' . $this->_ftpHost . $this->_ftpPath;
    }

    protected function _checkBackupsDir()
    {
        $backupsDir = $this->getBackupsDir();

        if (!is_dir($backupsDir)) {
            $backupsDirParentDirectory = basename($backupsDir);

            if (!is_writeable($backupsDirParentDirectory)) {
                throw new NotEnoughPermissions(
                    new Phrase('Cant create backups directory')
                );
            }

            mkdir($backupsDir);
            chmod($backupsDir);
        }

        if (!is_writable($backupsDir)) {
            throw new NotEnoughPermissions(
                new Phrase('Backups directory is not writeable')
            );
        }
    }

    protected function _getTarTmpPath()
    {
        $tmpName = '~tmp-' . microtime(true) . '.tar';
        return $this->getBackupsDir() . '/' . $tmpName;
    }

    protected function getRollBackFtp()
    {
        if (!$this->rollBackFtp) {
            $this->rollBackFtp = ObjectManager::getInstance()->create(
                Ftp::class,
                ['snapshotObject' => $this]
            );
        }

        return $this->rollBackFtp;
    }

    protected function getRollBackFs()
    {
        if (!$this->rollBackFs) {
            $this->rollBackFs = ObjectManager::getInstance()->create(
                Fs::class,
                ['snapshotObject' => $this]
            );
        }

        return $this->rollBackFs;
    }
}