phpbu\App\Backup\Sync\Ftp

Complexity

Total Complexity

13

Size/Duplication

Total Lines	98
Duplicated Lines	11.22 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

35.56%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setup()	0	8	2
A	checkRequirements()	0	6	2
A	getProtocolName()	0	4	1
C	sync()	11	50	8

<?php
namespace phpbu\App\Backup\Sync;

use phpbu\App\Result;
use phpbu\App\Backup\Sync;
use phpbu\App\Backup\Target;
use phpbu\App\Util\Arr;
use phpbu\App\Util\Str;

/**
 * Ftp sync
 *
 * @package    phpbu
 * @subpackage Backup
 * @author     Chris Hawes <me@chrishawes.net>
 * @copyright  Sebastian Feldmann <sebastian@phpbu.de>
 * @license    https://opensource.org/licenses/MIT The MIT License (MIT)
 * @link       http://phpbu.de/
 */
class Ftp extends Xtp implements Simulator
{
    /**
     * Setup the Ftp sync.
     *
     * @param  array $config
     * @throws \phpbu\App\Backup\Sync\Exception
     */
    public function setup(array $config)
    {
        $path = Arr::getValue($config, 'path', '');
        if ('/' === substr($path, 0, 1)) {
            throw new Exception('absolute path is not allowed');
        }
        parent::setup($config);
    }

    /**
     * Check for required loaded libraries or extensions.
     *
     * @throws \phpbu\App\Backup\Sync\Exception
     */
    protected function checkRequirements()
    {
        if (!function_exists('ftp_connect')) {
            throw new Exception('ftp functions not enabled');
        }
    }

    /**
     * Return implemented (*)TP protocol name.
     *
     * @return string
     */
    protected function getProtocolName()
    {
        return 'FTP';
    }

    /**
     * (non-PHPDoc)
     *
     * @see    \phpbu\App\Backup\Sync::sync()
     * @param  \phpbu\App\Backup\Target $target
     * @param  \phpbu\App\Result        $result
     * @throws \phpbu\App\Backup\Sync\Exception
     */
    public function sync(Target $target, Result $result)
    {
        // silence ftp errors
        $old  = error_reporting(0);
        if (!$ftpConnection = ftp_connect($this->host)) {
            throw new Exception(
                sprintf(
                    'Unable to connect to ftp server %s',
                    $this->host
                )
            );
        }

        if (!ftp_login($ftpConnection, $this->user, $this->password)) {
            error_reporting($old);
            throw new Exception(
                sprintf(
                    'authentication failed for %s@%s%s',
                    $this->user,
                    $this->host,
                    empty($this->password) ? '' : ' with password ****'
                )
            );
        }

        $remoteFilename = $target->getFilename();
        $localFile      = $target->getPathname();

        if ('' !== $this->remotePath) {
            $remoteDirs = explode('/', $this->remotePath);
            foreach ($remoteDirs as $dir) {
                if (!ftp_chdir($ftpConnection, $dir)) {
                    $result->debug(sprintf('creating remote dir \'%s\'', $dir));
                    ftp_mkdir($ftpConnection, $dir);
                    ftp_chdir($ftpConnection, $dir);
                } else {
                    $result->debug(sprintf('change to remote dir \'%s\'', $dir));
                }
            }
        }
        $result->debug(sprintf('store file \'%s\' as \'%s\'', $localFile, $remoteFilename));

        if (!ftp_put($ftpConnection, $remoteFilename, $localFile, FTP_BINARY)) {
            $error = error_get_last();
            $message = $error['message'];
            throw new Exception(sprintf('error uploading file: %s - %s', $localFile, $message));
        }

        error_reporting($old);
    }
}