StreamHandler::src() - Code Metrics - Inspection of "Fix doc" - the-junty/junty - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 1e5a44...44a0d0 )

by Gabriel

created 2016-04-07 20:21 UTC

StreamHandler::src() C

↳ Parent: StreamHandler

Complexity

Conditions	14
Paths	9

Size

Total Lines	43
Code Lines	25

Duplication

Lines	0
Ratio	0 %

Metric	Value
dl	0
loc	43
rs	5.0864
cc	14
eloc	25
nc	9
nop	2

How to fix Complexity

<?php 
/**
 * Junty
 *
 * @author Gabriel Jacinto aka. GabrielJMJ <[email protected]>
 * @license MIT License
 */

namespace Junty\Stream;

use Psr\Http\Message\StreamInterface;
use GuzzleHttp\Psr7;
use Junty\Stream\Stream;
use Junty\Plugin\PluginInterface;
use Junty\ToDir\ToDirPlugin;

class StreamHandler
{
    private $globs = [];

    private $toPush = [];

    private $temp = [];

    /**
     * Provides streams by the pattern passed
     *
     * @param string|array      $accept
     * @param string|array|null $exclude
     *
     * @return self
     */
    public function src($accept, $exclude = null) : self
    {
        if ((!is_string($accept) && !is_array($accept)) || ($exclude !== null && !is_string($exclude) && !is_array($exclude))) {
            throw new \InvalidArgumentException('You can only pass a string pattern or array with patterns');
        }

        if (is_array($accept)) {
            $fileGroups = [];

            foreach ($accept as $pattern) {
                $fileGroups[] = $this->recoursiveGlob($pattern, GLOB_ERR);
            }

            $this->globs = call_user_func_array('array_merge', $fileGroups);

        } else {
            $this->globs = $this->recoursiveGlob($accept, GLOB_ERR);
        }

        if ($exclude !== null) {
            $cbFilter = function () {return true;};

            if (is_array($exclude) && count($exclude) > 0) {
                $cbFilter = function ($glob) use ($exclude) {
                    foreach ($exclude as $pattern) {
                        if (preg_match($pattern, $glob)) {
                            return false;
                        }
                    }

                    return true;
                };echo 'a';
            } elseif (is_string($exclude)) {
                echo 'a';
                $cbFilter = function ($glob) use ($exclude) {
                    return !preg_match($exclude, $glob);
                };
            }

            $this->globs = array_filter($this->globs, $cbFilter);
        }

        return $this;
    }

    /**
     * Handle each stream
     *
     * @param callable|PluginInterface $callback
     *
     * @return self
     */
    public function forStream($callback) : self
    {
        $cb = \Closure::bind($this->getCallback($callback), $this);

        if (count($this->toPush)) {
            foreach ($this->toPush as $stream) {
                $cb($stream);
            }

            return $this;
        }

        $streams = array_map(function ($file) {
            return new Stream(fopen($file, 'r+'));
        }, $this->globs);

        foreach ($streams as $stream) {
            $cb($stream);
        }

        return $this;
    }

    /**
     * Handle all streams
     *
     * @param callable|PluginInterface $callback
     *
     * @return self
     */
    public function forStreams($callback) : self
    {
        $cb = \Closure::bind($this->getCallback($callback), $this);

        if (count($this->toPush)) {
            $cb($this->toPush);

            return $this;
        }

        $streams = array_map(function ($file) {
            return new Stream(fopen($file, 'r+'));
        }, $this->globs);

        $cb($streams);

        return $this;
    }

    private function getCallback($cb) : callable
    {
        if (!($cb instanceof PluginInterface) && !is_callable($cb)) {
            throw new \InvalidArgumentException('Invalid callback type: ' + gettype($cb));
        }

        if ($cb instanceof PluginInterface) {
            return $cb->getCallback();
        }

        return $cb;
    }

    /**
     * Pushes a stream to be used on destination
     *
     * @param StreamInterface $stream
     */
    public function push(StreamInterface $stream)
    {
        $this->toPush[] = $stream;
    }

    /**
     * Creates a temporary stream
     * It will be deleted in the end of task execution
     *
     * @param StreamInterface $stream
     */
    public function temp(StreamInterface $stream)
    {
        $this->push($stream);
        $this->temp[] = $stream->getMetadata('uri');
    }

    /**
     * Sends pushed streams to a directory (plugin)
     *
     * @param string $dest
     *
     * @return callable
     */
    public function toDir(string $dest) : ToDirPlugin
    {
        return new ToDirPlugin($dest);
    }

    /**
     * Cleans up pushed streams and delete indicated temporary files
     *
     * @return self
     */
    public function end() : self
    {
        foreach ($this->toPush as $stream) {
            $stream->close();
        }

        foreach ($this->temp as $tempf) {
            unlink($tempf);
        }

        $this->toPush = [];
        return $this;
    }

    private function recoursiveGlob($pattern, $flags = 0) : array
    {
        $globs = glob($pattern, $flags);
        $hasDir = false;

        foreach ($globs as $glob) {
            if (is_dir($glob)) {
                $hasDir = true;
            }
        }

        if (!$hasDir) {
            return $globs;
        }

        foreach (glob(dirname($pattern).'/*', GLOB_ONLYDIR|GLOB_NOSORT) as $dir) {
            $globs = array_merge($globs, $this->recoursiveGlob($dir.'/'.basename($pattern), $flags));
        }

        $globs = array_filter($globs, function ($res) {
            return !is_dir($res);
        });

        return $globs;
    }
}

1			<?php
2			/**
3			* Junty
4			*
5			* @author Gabriel Jacinto aka. GabrielJMJ <[email protected]>
6			* @license MIT License
7			*/
8
9			namespace Junty\Stream;
10
11			use Psr\Http\Message\StreamInterface;
12			use GuzzleHttp\Psr7;
13			use Junty\Stream\Stream;
14			use Junty\Plugin\PluginInterface;
15			use Junty\ToDir\ToDirPlugin;
16
17			class StreamHandler
18			{
19			private $globs = [];
20
21			private $toPush = [];
22
23			private $temp = [];
24
25			/**
26			* Provides streams by the pattern passed
27			*
28			* @param string\|array $accept
29			* @param string\|array\|null $exclude
30			*
31			* @return self
32			*/
33			public function src($accept, $exclude = null) : self
34			{
35			if ((!is_string($accept) && !is_array($accept)) \|\| ($exclude !== null && !is_string($exclude) && !is_array($exclude))) {
36			throw new \InvalidArgumentException('You can only pass a string pattern or array with patterns');
37			}
38
39			if (is_array($accept)) {
40			$fileGroups = [];
41
42			foreach ($accept as $pattern) {
43			$fileGroups[] = $this->recoursiveGlob($pattern, GLOB_ERR);
44			}
45
46			$this->globs = call_user_func_array('array_merge', $fileGroups);
			0 ignored issues – show Documentation Bug introduced 2016-02-28 05:25 UTC by Report Bug Copy Issue Report It seems like `call_user_func_array('array_merge', $fileGroups)` of type `*` is incompatible with the declared type `array` of property `$globs`. Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property. Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property.. Loading history...
47			} else {
48			$this->globs = $this->recoursiveGlob($accept, GLOB_ERR);
49			}
50
51			if ($exclude !== null) {
52			$cbFilter = function () {return true;};
53
54			if (is_array($exclude) && count($exclude) > 0) {
55			$cbFilter = function ($glob) use ($exclude) {
56			foreach ($exclude as $pattern) {
57			if (preg_match($pattern, $glob)) {
58			return false;
59			}
60			}
61
62			return true;
63			};echo 'a';
64			} elseif (is_string($exclude)) {
65			echo 'a';
66			$cbFilter = function ($glob) use ($exclude) {
67			return !preg_match($exclude, $glob);
68			};
69			}
70
71			$this->globs = array_filter($this->globs, $cbFilter);
72			}
73
74			return $this;
75			}
76
77			/**
78			* Handle each stream
79			*
80			* @param callable\|PluginInterface $callback
81			*
82			* @return self
83			*/
84			public function forStream($callback) : self
85			{
86			$cb = \Closure::bind($this->getCallback($callback), $this);
87
88			if (count($this->toPush)) {
89			foreach ($this->toPush as $stream) {
90			$cb($stream);
91			}
92
93			return $this;
94			}
95
96			$streams = array_map(function ($file) {
97			return new Stream(fopen($file, 'r+'));
98			}, $this->globs);
99
100			foreach ($streams as $stream) {
101			$cb($stream);
102			}
103
104			return $this;
105			}
106
107			/**
108			* Handle all streams
109			*
110			* @param callable\|PluginInterface $callback
111			*
112			* @return self
113			*/
114			public function forStreams($callback) : self
115			{
116			$cb = \Closure::bind($this->getCallback($callback), $this);
117
118			if (count($this->toPush)) {
119			$cb($this->toPush);
120
121			return $this;
122			}
123
124			$streams = array_map(function ($file) {
125			return new Stream(fopen($file, 'r+'));
126			}, $this->globs);
127
128			$cb($streams);
129
130			return $this;
131			}
132
133			private function getCallback($cb) : callable
134			{
135			if (!($cb instanceof PluginInterface) && !is_callable($cb)) {
136			throw new \InvalidArgumentException('Invalid callback type: ' + gettype($cb));
137			}
138
139			if ($cb instanceof PluginInterface) {
140			return $cb->getCallback();
141			}
142
143			return $cb;
144			}
145
146			/**
147			* Pushes a stream to be used on destination
148			*
149			* @param StreamInterface $stream
150			*/
151			public function push(StreamInterface $stream)
152			{
153			$this->toPush[] = $stream;
154			}
155
156			/**
157			* Creates a temporary stream
158			* It will be deleted in the end of task execution
159			*
160			* @param StreamInterface $stream
161			*/
162			public function temp(StreamInterface $stream)
163			{
164			$this->push($stream);
165			$this->temp[] = $stream->getMetadata('uri');
166			}
167
168			/**
169			* Sends pushed streams to a directory (plugin)
170			*
171			* @param string $dest
172			*
173			* @return callable
174			*/
175			public function toDir(string $dest) : ToDirPlugin
176			{
177			return new ToDirPlugin($dest);
178			}
179
180			/**
181			* Cleans up pushed streams and delete indicated temporary files
182			*
183			* @return self
184			*/
185			public function end() : self
186			{
187			foreach ($this->toPush as $stream) {
188			$stream->close();
189			}
190
191			foreach ($this->temp as $tempf) {
192			unlink($tempf);
193			}
194
195			$this->toPush = [];
196			return $this;
197			}
198
199			private function recoursiveGlob($pattern, $flags = 0) : array
200			{
201			$globs = glob($pattern, $flags);
202			$hasDir = false;
203
204			foreach ($globs as $glob) {
205			if (is_dir($glob)) {
206			$hasDir = true;
207			}
208			}
209
210			if (!$hasDir) {
211			return $globs;
212			}
213
214			foreach (glob(dirname($pattern).'/*', GLOB_ONLYDIR\|GLOB_NOSORT) as $dir) {
215			$globs = array_merge($globs, $this->recoursiveGlob($dir.'/'.basename($pattern), $flags));
216			}
217
218			$globs = array_filter($globs, function ($res) {
219			return !is_dir($res);
220			});
221
222			return $globs;
223			}
224			}

the-junty / junty

Push — master ( 1e5a44...44a0d0 )

StreamHandler::src() C

Complexity

Size

Duplication

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like