SF2Helpers\SFTPBundle\SFTP\SFTP

Complexity

Total Complexity

15

Size/Duplication

Total Lines	105
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	2
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	connect()	0	4	1
A	login()	0	8	3
A	loginWithKey()	0	8	2
A	fetchFrom()	0	8	2
A	sendTo()	0	13	3
A	getRemoteFilesList()	0	15	3
A	disconnect()	0	5	1

<?php

namespace SF2Helpers\SFTPBundle\SFTP;

class SFTP implements ConnectionInterface, ResourceTransferInterface
{
    /**
     * Connection instance
     *
     * @var $connection
     */
    private $connection;

    /**
     * Established sftp resource
     *
     * @var $sftp
     */
    private $sftp;

    /**
     * @inheritdoc
     */
    public function connect($host, $port)
    {
        $this->connection = ssh2_connect($host, $port);
    }

    /**
     * @inheritdoc
     */
    public function login($username, $password = null)
    {
        if (!$this->connection) {
            throw new \LogicException('Establish connection with server before login');
        }
        is_null($password) ? ssh2_auth_agent($this->connection, $username) : ssh2_auth_password($this->connection, $username, $password);
        $this->sftp = ssh2_sftp($this->connection);
    }

    /**
     * @inheritdoc
     */
    public function loginWithKey($username, $pubkeyfile, $privkeyfile, $passphrase = null)
    {
        if (!$this->connection) {
            throw new \LogicException('Establish connection with server before login');
        }
        ssh2_auth_pubkey_file($this->connection, $username, $pubkeyfile, $privkeyfile, $passphrase);
        $this->sftp = ssh2_sftp($this->connection);
    }

    /**
     * @inheritdoc
     */
    public function fetchFrom($remoteFile, $localFile)
    {
        $remoteData = file_get_contents('ssh2.sftp://' . intval($this->sftp) . $remoteFile);
        if (!$remoteData) {
            throw new \Exception('File can`t be loaded from the SFTP server.');
        }
        file_put_contents($localFile, $remoteData);
    }

    /**
     * @inheritdoc
     */
    public function sendTo($localFile, $remoteFile)
    {
        if (!file_exists($localFile)) {
            throw new \Exception('Local file doesn\'t exists.');
        }

        $sftp = "ssh2.sftp://" . intval($this->sftp);
        $data = file_get_contents($localFile);

        if (!file_put_contents($sftp . $remoteFile, $data)) {
            throw new \Exception('File could not be uploaded to the SFTP server.');
        }
    }

    /**
     * @inheritdoc
     */
    public function getRemoteFilesList($dir)
    {
        $handle = opendir("ssh2.sftp://" . intval($this->sftp) . $dir);
        $files  = array();

        if (is_bool($handle)) {
            throw new \Exception('Could not read files list from remote SFTP server. Check your connection.');
        }

        while (false !== ($entry = readdir($handle))) {
            $files[] = $entry;
        }

        return $files;
    }

    /**
     * @inheritdoc
     */
    public function disconnect()
    {
        unset($this->connection);
        unset($this->sftp);
    }
}