BureauVa\WordpressGuzzle\Pool

Complexity

Total Complexity

14

Size/Duplication

Total Lines	115
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	unwrap()	0	8	2
A	addPromise()	0	7	1
A	getPromises()	0	4	1
A	setPromises()	0	6	1
A	getTransformers()	0	4	1
A	setTransformers()	0	6	1
A	addTransformer()	0	6	1
B	attachTransforms()	0	23	6

<?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;

/**
 * Class Pool.
 */
class Pool
{
    /**
     * @var array
     */
    private $promises = [];
    /**
     * @var array
     */
    private $transformers = [];

    /**
     * Awaits all the requests.
     *
     * @return mixed
     */
    public function unwrap()
    {
        if (empty($this->getPromises())) {
            return [];
        }

        return \GuzzleHttp\Promise\unwrap($this->getPromises());
    }

    /**
     * @param $query
     *
     * @return $this
     */
    public function addPromise($key, Promise $query)
    {
        $query = $this->attachTransforms($query);
        $this->promises[$key] = $query;

        return $this;
    }

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

    /**
     * @param array $promise

There is no parameter named $promise. Did you maybe mean $promises?

     */
    public function setPromises($promises)
    {
        $this->promises = $promises;

        return $this;
    }

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

    /**
     * @param array $transformers
     */
    public function setTransformers($transformers)
    {
        $this->transformers = $transformers;

        return $this;
    }

    /**
     * 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
     */
    public function attachTransforms(Promise $promise)
    {
        $transformers = $this->transformers;

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

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

            if ($data instanceof \stdClass) {
                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;
        });
    }
}