Velikonja\LabbyBundle\Remote\Scp

Complexity

Total Complexity

8

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

85.29%

Importance

Changes	5
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	18	3
A	copyFile()	0	15	2
A	getCallback()	0	16	3

<?php

namespace Velikonja\LabbyBundle\Remote;

use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Process\Process;
use Symfony\Component\Process\ProcessBuilder;

class Scp
{
    /**
     * @var array
     */
    private $config;

    /**
     * @var ProcessBuilder
     */
    private $processBuilder;

    /**
     * @param array               $config
     * @param int                 $timeout
     * @param string|null         $executable
     * @param null|ProcessBuilder $processBuilder
     */
    public function __construct(array $config, $timeout = 60, $executable = null, ProcessBuilder $processBuilder = null)
    {
        $this->config = $config;

        if (! $executable) {
            $executable = '/usr/bin/scp';
        }

        if (! $processBuilder) {
            $processBuilder = new ProcessBuilder();
        }

        $processBuilder
            ->setTimeout($timeout)
            ->setPrefix($executable);

        $this->processBuilder = $processBuilder;
    }

    /**
     * @param string               $src
     * @param string               $dst
     * @param null|OutputInterface $output
     *
     * @throws \Exception
     */
    public function copyFile($src, $dst, OutputInterface $output = null)
    {
        $process = $this->processBuilder
            ->add($this->config['hostname'] . ':' . $src)
            ->add($dst)
            ->getProcess();

        $process->run(
            $this->getCallback($output)
        );

        if (! $process->isSuccessful()) {
            throw new \Exception($process->getErrorOutput());
        }
    }

    /**
     * @param OutputInterface|null $output
     *
     * @return \Closure|null
     */
    private function getCallback(OutputInterface $output = null)
    {
        $callback = null;

        if ($output) {
            $callback = function ($type, $buffer) use ($output) {
                if (Process::ERR === $type) {
                    $output->writeln("<error>$buffer</error>");
                } else {
                    $output->writeln($buffer);
                }
            };
        }

        return $callback;
    }
}