Sftp::handleData() - Code Metrics - dazzle-php/ssh - Measure and Improve Code Quality continuously with Scrutinizer

Sftp::handleData() D
last analyzed 2017-07-23 20:23 UTC

↳ Parent: Sftp

Complexity

Conditions	9
Paths	10

Size

Total Lines	25
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	90

Importance

Changes

Metric	Value
cc	9
eloc	9
nc	10
nop	0
dl	0
loc	25
rs	4.909
c	0
b	0
f	0
ccs	0
cts	10
cp	0
crap	90

<?php

namespace Dazzle\SSH\Driver;

use Dazzle\Event\BaseEventEmitterTrait;
use Dazzle\Loop\Timer\TimerInterface;
use Dazzle\Loop\LoopAwareTrait;
use Dazzle\SSH\Driver\Sftp\SftpResource;
use Dazzle\SSH\SSH2DriverInterface;
use Dazzle\SSH\SSH2Interface;
use Dazzle\SSH\SSH2ResourceInterface;
use Dazzle\Throwable\Exception\Logic\ResourceUndefinedException;
use Dazzle\Throwable\Exception\Runtime\ExecutionException;
use Error;
use Exception;


class Sftp implements SSH2DriverInterface
{
    use BaseEventEmitterTrait;
    use LoopAwareTrait;

    /**
     * @var int
     */
    const BUFFER_SIZE = 4096;

    /**
     * @var SSH2Interface
     */
    protected $ssh2;

    /**
     * @var resource
     */
    protected $conn;

    /**
     * @var float
     */
    protected $interval;

    /**
     * @var resource
     */
    protected $resource;

    /**
     * @var SftpResource[]|SSH2ResourceInterface[]
     */
    protected $resources;

    /**
     * @var bool
     */
    protected $paused;

    /**
     * @var TimerInterface|null
     */
    private $timer;

    /**
     * @var int
     */
    private $resourcesCounter;

    /**
     * @var string
     */
    private $buffer;

    /**
     * @var string
     */
    private $prefix;

    /**
     * @param SSH2Interface $ssh2
     * @param resource $conn
     * @param float $interval
     */
    public function __construct(SSH2Interface $ssh2, $conn, $interval = 1e-1)

    {
        $this->ssh2 = $ssh2;
        $this->conn = $conn;
        $this->interval = $interval;

        $this->loop = $ssh2->getLoop();

        $this->resource = null;
        $this->resources = [];
        $this->paused = true;

        $this->timer = null;
        $this->resourcesCounter = 0;
        $this->buffer = '';
        $this->prefix = '';

        $this->resume();
    }

    /**
     *
     */
    public function __destruct()
    {
        $this->disconnect();


    }

    /**
     * @override
     * @inheritDoc
     */
    public function getName()
    {
        return 'sftp';
    }

    /**
     * @override
     * @inheritDoc
     */
    public function connect()

    {
        if ($this->resource !== null)
        {
            return;
        }

        $resource = $this->createConnection($this->conn);

        if (!$resource || !is_resource($resource))
        {
            $this->emit('error', [ $this, new ExecutionException('SSH2:Sftp could not be connected.') ]);
            return;
        }

        $this->resource = $resource;

        $this->emit('connect', [ $this ]);
    }

    /**
     * @override
     * @inheritDoc
     */
    public function disconnect()

    {
        if ($this->resource === null || !is_resource($this->resource))
        {
            return;
        }

        $this->pause();

        foreach ($this->resources as $resource)
        {
            $resource->close();
        }

        $this->handleDisconnect();
        $this->emit('disconnect', [ $this ]);
    }

    /**
     * @override
     * @inheritDoc
     */
    public function isConnected()
    {
        return $this->resource !== null && is_resource($this->resource);
    }

    /**
     * @override
     * @inheritDoc
     */
    public function pause()

    {
        if (!$this->paused)
        {
            $this->paused = true;

            if ($this->timer !== null)
            {
                $this->timer->cancel();
                $this->timer = null;
            }
        }
    }

    /**
     * @override
     * @inheritDoc
     */
    public function resume()

    {
        if ($this->paused)
        {
            $this->paused = false;

            if ($this->timer === null)
            {
                $this->timer = $this->loop->addPeriodicTimer($this->interval, [ $this, 'handleHeartbeat' ]);
            }
        }
    }

    /**
     * @override
     * @inheritDoc
     */
    public function isPaused()
    {
        return $this->paused;
    }

    /**
     * @override
     * @inheritDoc
     */
    public function open($resource = null, $flags = 'r')
    {
        if (!$this->isConnected())
        {
            throw new ResourceUndefinedException('Tried to open resource before establishing SSH2 connection!');
        }

        $stream = @fopen("ssh2.sftp://" . $this->resource . $resource, $flags);

        if (!$stream)
        {
            throw new ResourceUndefinedException("Access to SFTP resource [$resource] denied!");
        }

        $resource = new SftpResource($this, $stream);
        $resource->on('open', function(SSH2ResourceInterface $resource) {
            $this->emit('resource:open', [ $this, $resource ]);
        });
        $resource->on('close', function(SSH2ResourceInterface $resource) {
            $this->removeResource($resource->getId());
            $this->emit('resource:close', [ $this, $resource ]);
        });

        $this->resources[$resource->getId()] = $resource;
        $this->resourcesCounter++;
        $this->resume();

        return $resource;
    }

    /**
     * Determine whether connection is still open.
     *
     * @internal
     */
    public function handleHeartbeat()
    {
        $fp = @fopen("ssh2.sftp://" . $this->resource . "/.", "r");

        if (!$fp || !is_resource($fp))
        {
            return $this->ssh2->disconnect();
        }

        fclose($fp);

        $this->handleData();
    }

    /**
     * Handle data.
     *
     * @internal
     */
    public function handleData()
    {
        if ($this->paused || $this->resourcesCounter === 0)
        {
            return;
        }

        // handle all reading
        foreach ($this->resources as $resource)
        {
            if (!$resource->isPaused() && $resource->isReadable())
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}
            {
                $resource->handleRead();
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}
            }
        }

        // handle all writing
        foreach ($this->resources as $resource)
        {
            if (!$resource->isPaused() && $resource->isWritable())
            {
                $resource->handleWrite();
class A
{
    public function foo() { }
}

class B extends A
{
    public function bar() { }
}

/**
 * @param A|B $x
 */
function someFunction($x)
{
    $x->foo(); // This call is fine as the method exists in A and B.
    $x->bar(); // This method only exists in B and might cause an error.
}
            }
        }
    }

    /**
     *
     */
    protected function handleDisconnect()
    {
        @fclose($this->resource);
// For example instead of
@mkdir($dir);

// Better use
if (@mkdir($dir) === false) {
    throw new \RuntimeException('The directory '.$dir.' could not be created.');
}
        $this->resource = null;
    }

    /**
     * @param resource $conn
     * @return resource
     */
    protected function createConnection($conn)
    {
        return @ssh2_shell($conn);
    }

    /**
     * Remove resource from known collection.
     *
     * @param string $prefix
     */
    private function removeResource($prefix)

    {
        if (!isset($this->resources[$prefix]))
        {
            return;
        }

        unset($this->resources[$prefix]);
        $this->resourcesCounter--;

        if ($this->resourcesCounter === 0)
        {
            $this->pause();
        }
    }
}


Sftp::handleData() D
last analyzed 2017-07-23 20:23 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Available Fixes

1			<?php
2
3			namespace Dazzle\SSH\Driver;
4
5			use Dazzle\Event\BaseEventEmitterTrait;
6			use Dazzle\Loop\Timer\TimerInterface;
7			use Dazzle\Loop\LoopAwareTrait;
8			use Dazzle\SSH\Driver\Sftp\SftpResource;
9			use Dazzle\SSH\SSH2DriverInterface;
10			use Dazzle\SSH\SSH2Interface;
11			use Dazzle\SSH\SSH2ResourceInterface;
12			use Dazzle\Throwable\Exception\Logic\ResourceUndefinedException;
13			use Dazzle\Throwable\Exception\Runtime\ExecutionException;
14			use Error;
15			use Exception;
16
17
18			class Sftp implements SSH2DriverInterface
19			{
20			use BaseEventEmitterTrait;
21			use LoopAwareTrait;
22
23			/**
24			* @var int
25			*/
26			const BUFFER_SIZE = 4096;
27
28			/**
29			* @var SSH2Interface
30			*/
31			protected $ssh2;
32
33			/**
34			* @var resource
35			*/
36			protected $conn;
37
38			/**
39			* @var float
40			*/
41			protected $interval;
42
43			/**
44			* @var resource
45			*/
46			protected $resource;
47
48			/**
49			* @var SftpResource[]\|SSH2ResourceInterface[]
50			*/
51			protected $resources;
52
53			/**
54			* @var bool
55			*/
56			protected $paused;
57
58			/**
59			* @var TimerInterface\|null
60			*/
61			private $timer;
62
63			/**
64			* @var int
65			*/
66			private $resourcesCounter;
67
68			/**
69			* @var string
70			*/
71			private $buffer;
72
73			/**
74			* @var string
75			*/
76			private $prefix;
77
78			/**
79			* @param SSH2Interface $ssh2
80			* @param resource $conn
81			* @param float $interval
82			*/
83	21	View Code Duplication	public function __construct(SSH2Interface $ssh2, $conn, $interval = 1e-1)
			0 ignored issues – show Duplication introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
84			{
85	21		$this->ssh2 = $ssh2;
86	21		$this->conn = $conn;
87	21		$this->interval = $interval;
88
89	21		$this->loop = $ssh2->getLoop();
90
91	21		$this->resource = null;
92	21		$this->resources = [];
93	21		$this->paused = true;
94
95	21		$this->timer = null;
96	21		$this->resourcesCounter = 0;
97	21		$this->buffer = '';
98	21		$this->prefix = '';
99
100	21		$this->resume();
101	21		}
102
103			/**
104			*
105			*/
106	13		public function __destruct()
107			{
108	13		$this->disconnect();
109
110
111	13		}
112
113			/**
114			* @override
115			* @inheritDoc
116			*/
117	1		public function getName()
118			{
119	1		return 'sftp';
120			}
121
122			/**
123			* @override
124			* @inheritDoc
125			*/
126	4	View Code Duplication	public function connect()
			0 ignored issues – show Duplication introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
127			{
128	4		if ($this->resource !== null)
129			{
130	1		return;
131			}
132
133	3		$resource = $this->createConnection($this->conn);
134
135	3		if (!$resource \|\| !is_resource($resource))
136			{
137	2		$this->emit('error', [ $this, new ExecutionException('SSH2:Sftp could not be connected.') ]);
138	2		return;
139			}
140
141	1		$this->resource = $resource;
142
143	1		$this->emit('connect', [ $this ]);
144	1		}
145
146			/**
147			* @override
148			* @inheritDoc
149			*/
150	16	View Code Duplication	public function disconnect()
			0 ignored issues – show Duplication introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
151			{
152	16		if ($this->resource === null \|\| !is_resource($this->resource))
153			{
154	13		return;
155			}
156
157	3		$this->pause();
158
159	3		foreach ($this->resources as $resource)
160			{
161	1		$resource->close();
162			}
163
164	3		$this->handleDisconnect();
165	3		$this->emit('disconnect', [ $this ]);
166	3		}
167
168			/**
169			* @override
170			* @inheritDoc
171			*/
172	3		public function isConnected()
173			{
174	3		return $this->resource !== null && is_resource($this->resource);
175			}
176
177			/**
178			* @override
179			* @inheritDoc
180			*/
181	3	View Code Duplication	public function pause()
			0 ignored issues – show Duplication introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
182			{
183	3		if (!$this->paused)
184			{
185	2		$this->paused = true;
186
187	2		if ($this->timer !== null)
188			{
189	2		$this->timer->cancel();
190	2		$this->timer = null;
191			}
192			}
193	3		}
194
195			/**
196			* @override
197			* @inheritDoc
198			*/
199	21	View Code Duplication	public function resume()
			0 ignored issues – show Duplication introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
200			{
201	21		if ($this->paused)
202			{
203	21		$this->paused = false;
204
205	21		if ($this->timer === null)
206			{
207	21		$this->timer = $this->loop->addPeriodicTimer($this->interval, [ $this, 'handleHeartbeat' ]);
208			}
209			}
210	21		}
211
212			/**
213			* @override
214			* @inheritDoc
215			*/
216	6		public function isPaused()
217			{
218	6		return $this->paused;
219			}
220
221			/**
222			* @override
223			* @inheritDoc
224			*/
225			public function open($resource = null, $flags = 'r')
226			{
227			if (!$this->isConnected())
228			{
229			throw new ResourceUndefinedException('Tried to open resource before establishing SSH2 connection!');
230			}
231
232			$stream = @fopen("ssh2.sftp://" . $this->resource . $resource, $flags);
233
234			if (!$stream)
235			{
236			throw new ResourceUndefinedException("Access to SFTP resource [$resource] denied!");
237			}
238
239			$resource = new SftpResource($this, $stream);
240			$resource->on('open', function(SSH2ResourceInterface $resource) {
241			$this->emit('resource:open', [ $this, $resource ]);
242			});
243			$resource->on('close', function(SSH2ResourceInterface $resource) {
244			$this->removeResource($resource->getId());
245			$this->emit('resource:close', [ $this, $resource ]);
246			});
247
248			$this->resources[$resource->getId()] = $resource;
249			$this->resourcesCounter++;
250			$this->resume();
251
252			return $resource;
253			}
254
255			/**
256			* Determine whether connection is still open.
257			*
258			* @internal
259			*/
260			public function handleHeartbeat()
261			{
262			$fp = @fopen("ssh2.sftp://" . $this->resource . "/.", "r");
263
264			if (!$fp \|\| !is_resource($fp))
265			{
266			return $this->ssh2->disconnect();
267			}
268
269			fclose($fp);
270
271			$this->handleData();
272			}
273
274			/**
275			* Handle data.
276			*
277			* @internal
278			*/
279			public function handleData()
280			{
281			if ($this->paused \|\| $this->resourcesCounter === 0)
282			{
283			return;
284			}
285
286			// handle all reading
287			foreach ($this->resources as $resource)
288			{
289			if (!$resource->isPaused() && $resource->isReadable())
			0 ignored issues – show Bug introduced 2017-07-23 20:23 UTC by Report Bug Copy Issue Report The method `isPaused` does only exist in `Dazzle\SSH\Driver\Sftp\SftpResource`, but not in `Dazzle\SSH\SSH2ResourceInterface`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
290			{
291			$resource->handleRead();
			0 ignored issues – show Bug introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report The method `handleRead` does only exist in `Dazzle\SSH\Driver\Sftp\SftpResource`, but not in `Dazzle\SSH\SSH2ResourceInterface`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
292			}
293			}
294
295			// handle all writing
296			foreach ($this->resources as $resource)
297			{
298			if (!$resource->isPaused() && $resource->isWritable())
299			{
300			$resource->handleWrite();
			0 ignored issues – show Bug introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report The method `handleWrite` does only exist in `Dazzle\SSH\Driver\Sftp\SftpResource`, but not in `Dazzle\SSH\SSH2ResourceInterface`. It seems like the method you are trying to call exists only in some of the possible types. Let’s take a look at an example: class A { public function foo() { } } class B extends A { public function bar() { } } /** * @param A\|B $x / function someFunction($x) { $x->foo(); // This call is fine as the method exists in A and B. $x->bar(); // This method only exists in B and might cause an error. } Available Fixes Add an additional type-check: /* * @param A\|B $x / function someFunction($x) { $x->foo(); if ($x instanceof B) { $x->bar(); } } Only allow a single type to be passed if the variable comes from a parameter: function someFunction(B $x) { /* ... */ } Loading history...
301			}
302			}
303			}
304
305			/**
306			*
307			*/
308	1		protected function handleDisconnect()
309			{
310	1		@fclose($this->resource);
			0 ignored issues – show Security Best Practice introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report It seems like you do not handle an error condition here. This can introduce security issues, and is generally not recommended. If you suppress an error, we recommend checking for the error condition explicitly: // For example instead of @mkdir($dir); // Better use if (@mkdir($dir) === false) { throw new \RuntimeException('The directory '.$dir.' could not be created.'); } Loading history...
311	1		$this->resource = null;
312	1		}
313
314			/**
315			* @param resource $conn
316			* @return resource
317			*/
318			protected function createConnection($conn)
319			{
320			return @ssh2_shell($conn);
321			}
322
323			/**
324			* Remove resource from known collection.
325			*
326			* @param string $prefix
327			*/
328		View Code Duplication	private function removeResource($prefix)
			0 ignored issues – show Duplication introduced 2017-06-24 22:28 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
329			{
330			if (!isset($this->resources[$prefix]))
331			{
332			return;
333			}
334
335			unset($this->resources[$prefix]);
336			$this->resourcesCounter--;
337
338			if ($this->resourcesCounter === 0)
339			{
340			$this->pause();
341			}
342			}
343			}
344

dazzle-php / ssh

Sftp::handleData() D last analyzed 2017-07-23 20:23 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like

Sftp::handleData() D
last analyzed 2017-07-23 20:23 UTC