Pool::flushPromises() - Code Metrics - Inspection of "restrucured app to use simple dependency container" - bureau-va/wordpress-guzzle-wrapper - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( ea590f...4351c0 )

by Maciej

created 2016-03-15 15:09 UTC

Pool::flushPromises() A

↳ Parent: Pool

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	5

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	2

Metric	Value
c	2
b	0
f	2
dl	0
loc	10
rs	9.4285
cc	2
eloc	5
nc	2
nop	0

<?php
/**
 * Created by Maciej Paprocki for Bureau-VA.
 * Date: 23/02/2016
 * Project Name: MaciekPaprocki\WordpressGuzzle
 * Time: 17:38.
 */
namespace BureauVa\WordpressGuzzle;

use GuzzleHttp\Promise\Promise;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

/**
 * Class Pool.
 */
class Pool
{
    /**
     * @var array
     */
    private $queries = [];
    /**
     * @var array
     */
    private $promises = [];
    /**
     * @var array
     */
    private $transformers = [];
    /**
     * @var CachePool
     */
    private $cachePool = null;
    /**
     * @var Client
     */
    protected $client = null;

    /**
     * let us keep reference to our client.
     *
     * @return mixed
     */
    public function getClient()
    {
        return $this->client;
    }

    /**
     * Awaits all the requests attaching callbacks before.
     *
     * @return mixed
     */
    public function unwrap()
    {
        $promises = $this->flushPromises();
        if (empty($promises)) {
            return [];
        }
        foreach ($promises as $key => $promise) {
            $promises[$key] = $this->attachTransforms($promise);
        }

        return \GuzzleHttp\Promise\unwrap($promises);
    }

    /**
     * @param $query
     *
     * @return $this
     */
    public function addQuery($key, $query)
    {
        $this->queries[$key] = $query;

        return $this;
    }

    /**
     * @param Promise $promise
     */
    public function addPromise($name, Promise $promise)
    {
        $this->promises[$name] = $promise;
    }

    /**
     * @return array
     */
    private function flushPromises()
    {
        foreach ($this->queries as $key => $query) {

            $this->promises[$key] = $this->client->getAsync((string) $query);
            unset($this->queries[$key]);
        }

        return $this->promises;
    }

    /**
     * @return array
     */
    public function getTransformers()
    {
        return $this->transformers;
    }

    /**
     * Adds another transformer to collection of transformers.
     *
     * @param callable $transformer
     *
     * @return $this
     */
    public function addTransformer(callable $transformer)
    {
        $this->transformers[] = $transformer;

        return $this;
    }

    /**
     * @param Promise $promise
/**
 * @param array $germany
 * @param array $island
 * @param array $italy
 */
function finale($germany, $island) {
    return "2:1";
}
     */
    public function attachTransforms(Promise $req)
    {
        $transformers = $this->getTransformers();

        return $req->then(function ($res) use ($transformers) {

            $data = \json_decode((string) $res->getBody());

            if (is_object($data)) {
                foreach ($transformers as $transformer) {
                    $data = \call_user_func($transformer, $data);
                }
            } elseif (is_array($data)) {
                foreach ($data as $key => $val) {
                    foreach ($transformers as $transformer) {
                        $data[$key] = \call_user_func($transformer, $val);
                    }
                }
            }

            return $data;
        }, function (RequestException $e) {

            echo $e->getMessage().$e->getRequest()->getUri().PHP_EOL;
        });
    }

    /**
     *
     */
    public function getCachePool()
    {
        return $this->cachePool;
    }

    /**
     * @param null $cachePool
     */
    public function setCachePool($cachePool)
    {
        $this->cachePool = $cachePool;

        return $this;
    }

    /**
     * Let us set our client reference taken from transaction.
     *
     * @param $client
     *
     * @return RepositoryAbstract
     */
    public function setClient(Client $client)
    {
        $this->client = $client;

        return $this;
    }
}


1			<?php
2			/**
3			* Created by Maciej Paprocki for Bureau-VA.
4			* Date: 23/02/2016
5			* Project Name: MaciekPaprocki\WordpressGuzzle
6			* Time: 17:38.
7			*/
8			namespace BureauVa\WordpressGuzzle;
9
10			use GuzzleHttp\Promise\Promise;
11			use GuzzleHttp\Client;
12			use GuzzleHttp\Exception\RequestException;
13
14			/**
15			* Class Pool.
16			*/
17			class Pool
18			{
19			/**
20			* @var array
21			*/
22			private $queries = [];
23			/**
24			* @var array
25			*/
26			private $promises = [];
27			/**
28			* @var array
29			*/
30			private $transformers = [];
31			/**
32			* @var CachePool
33			*/
34			private $cachePool = null;
35			/**
36			* @var Client
37			*/
38			protected $client = null;
39
40			/**
41			* let us keep reference to our client.
42			*
43			* @return mixed
44			*/
45			public function getClient()
46			{
47			return $this->client;
48			}
49
50			/**
51			* Awaits all the requests attaching callbacks before.
52			*
53			* @return mixed
54			*/
55			public function unwrap()
56			{
57			$promises = $this->flushPromises();
58			if (empty($promises)) {
59			return [];
60			}
61			foreach ($promises as $key => $promise) {
62			$promises[$key] = $this->attachTransforms($promise);
63			}
64
65			return \GuzzleHttp\Promise\unwrap($promises);
66			}
67
68			/**
69			* @param $query
70			*
71			* @return $this
72			*/
73			public function addQuery($key, $query)
74			{
75			$this->queries[$key] = $query;
76
77			return $this;
78			}
79
80			/**
81			* @param Promise $promise
82			*/
83			public function addPromise($name, Promise $promise)
84			{
85			$this->promises[$name] = $promise;
86			}
87
88			/**
89			* @return array
90			*/
91			private function flushPromises()
92			{
93			foreach ($this->queries as $key => $query) {
94
95			$this->promises[$key] = $this->client->getAsync((string) $query);
96			unset($this->queries[$key]);
97			}
98
99			return $this->promises;
100			}
101
102			/**
103			* @return array
104			*/
105			public function getTransformers()
106			{
107			return $this->transformers;
108			}
109
110			/**
111			* Adds another transformer to collection of transformers.
112			*
113			* @param callable $transformer
114			*
115			* @return $this
116			*/
117			public function addTransformer(callable $transformer)
118			{
119			$this->transformers[] = $transformer;
120
121			return $this;
122			}
123
124			/**
125			* @param Promise $promise
			0 ignored issues – show Bug introduced 2016-03-15 15:15 UTC by Report Bug Copy Issue Report There is no parameter named `$promise`. Was it maybe removed? This check looks for PHPDoc comments describing methods or function parameters that do not exist on the corresponding method or function. Consider the following example. The parameter `$italy` is not defined by the method `finale(...)`. /** * @param array $germany * @param array $island * @param array $italy */ function finale($germany, $island) { return "2:1"; } The most likely cause is that the parameter was removed, but the annotation was not. Loading history...
126			*/
127			public function attachTransforms(Promise $req)
128			{
129			$transformers = $this->getTransformers();
130
131			return $req->then(function ($res) use ($transformers) {
132
133			$data = \json_decode((string) $res->getBody());
134
135			if (is_object($data)) {
136			foreach ($transformers as $transformer) {
137			$data = \call_user_func($transformer, $data);
138			}
139			} elseif (is_array($data)) {
140			foreach ($data as $key => $val) {
141			foreach ($transformers as $transformer) {
142			$data[$key] = \call_user_func($transformer, $val);
143			}
144			}
145			}
146
147			return $data;
148			}, function (RequestException $e) {
149
150			echo $e->getMessage().$e->getRequest()->getUri().PHP_EOL;
151			});
152			}
153
154			/**
155			*
156			*/
157			public function getCachePool()
158			{
159			return $this->cachePool;
160			}
161
162			/**
163			* @param null $cachePool
164			*/
165			public function setCachePool($cachePool)
166			{
167			$this->cachePool = $cachePool;
168
169			return $this;
170			}
171
172			/**
173			* Let us set our client reference taken from transaction.
174			*
175			* @param $client
176			*
177			* @return RepositoryAbstract
178			*/
179			public function setClient(Client $client)
180			{
181			$this->client = $client;
182
183			return $this;
184			}
185			}
186

bureau-va / wordpress-guzzle-wrapper

Push — master ( ea590f...4351c0 )

Pool::flushPromises() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like