AbstractFile::flush() - Code Metrics - Inspection of "Merge pull request #24 from gyselroth/dev" - gyselroth/tubee - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 3896ee...e50616 )

by Raffael

created 2019-02-07 14:25 UTC

AbstractFile::flush() A

↳ Parent: AbstractFile

Complexity

Conditions	4
Paths	4

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	4.0218

Importance

Changes

Metric	Value
dl	0
loc	18
ccs	8
cts	9
cp	0.8889
rs	9.6666
c	0
b	0
f	0
cc	4
nc	4
nop	1
crap	4.0218

<?php

declare(strict_types=1);

/**
 * tubee.io
 *
 * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Tubee\Endpoint;

use Psr\Log\LoggerInterface;
use Tubee\Collection\CollectionInterface;
use Tubee\Storage\StorageInterface;
use Tubee\Workflow\Factory as WorkflowFactory;

abstract class AbstractFile extends AbstractEndpoint
{
    /**
     * File.
     *
     * @var string
     */
    protected $file;

    /**
     * Storage.
     *
     * @var StorageInterface
     */
    protected $storage;

    /**
     * Files.
     *
     * @var array
     */
    protected $files = [];

    /**
     * Init endpoint.
     */
    public function __construct(string $name, string $type, string $file, StorageInterface $storage, CollectionInterface $collection, WorkflowFactory $workflow, LoggerInterface $logger, ?Iterable $resource = [])
    {
        $this->storage = $storage;
        $this->file = $file;
        parent::__construct($name, $type, $collection, $workflow, $logger, $resource);
    }

    /**
     * {@inheritdoc}
     */
    public function flush(bool $simulate = false): bool
    {
        $this->logger->info('flush file ['.$this->file.'] from endpoint ['.$this->name.']', [
            'category' => get_class($this),
        ]);

        if ($simulate === true) {
            return true;
        }

        foreach ($this->files as $stream) {
            if (ftruncate($stream['stream'], 0) === false) {
                throw new Exception\WriteOperationFailed('failed flush file '.$this->file);
            }
        }

        return true;
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		/**
6		* tubee.io
7		*
8		* @copyright Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
9		* @license GPL-3.0 https://opensource.org/licenses/GPL-3.0
10		*/
11
12		namespace Tubee\Endpoint;
13
14		use Psr\Log\LoggerInterface;
15		use Tubee\Collection\CollectionInterface;
16		use Tubee\Storage\StorageInterface;
17		use Tubee\Workflow\Factory as WorkflowFactory;
18
19		abstract class AbstractFile extends AbstractEndpoint
20		{
21		/**
22		* File.
23		*
24		* @var string
25		*/
26		protected $file;
27
28		/**
29		* Storage.
30		*
31		* @var StorageInterface
32		*/
33		protected $storage;
34
35		/**
36		* Files.
37		*
38		* @var array
39		*/
40		protected $files = [];
41
42		/**
43		* Init endpoint.
44		*/
45	24	public function __construct(string $name, string $type, string $file, StorageInterface $storage, CollectionInterface $collection, WorkflowFactory $workflow, LoggerInterface $logger, ?Iterable $resource = [])
46		{
47	24	$this->storage = $storage;
48	24	$this->file = $file;
49	24	parent::__construct($name, $type, $collection, $workflow, $logger, $resource);
50	24	}
51
52		/**
53		* {@inheritdoc}
54		*/
55	8	public function flush(bool $simulate = false): bool
56		{
57	8	$this->logger->info('flush file ['.$this->file.'] from endpoint ['.$this->name.']', [
58	8	'category' => get_class($this),
59		]);
60
61	8	if ($simulate === true) {
62		return true;
63		}
64
65	8	foreach ($this->files as $stream) {
66	8	if (ftruncate($stream['stream'], 0) === false) {
67	8	throw new Exception\WriteOperationFailed('failed flush file '.$this->file);
68		}
69		}
70
71	7	return true;
72		}
73		}
74

gyselroth / tubee

Push — master ( 3896ee...e50616 )

AbstractFile::flush() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like