AbstractResource::executeWithState() - Code Metrics - Inspection of "refactor iterator into dedicated class" - php-opencloud/openstack - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( b2df35...c7ca15 )

by Jamie

created 2015-11-26 13:08 UTC

AbstractResource::executeWithState() A

↳ Parent: AbstractResource

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	2
Bugs	0	Features	0

Metric	Value
c	2
b	0
f	0
dl	0
loc	4
ccs	2
cts	2
cp	1
rs	10
cc	1
eloc	2
nc	1
nop	1
crap	1

<?php

namespace OpenStack\Common\Resource;

use OpenStack\Common\Api\Operator;
use OpenStack\Common\Transport\Utils;
use Psr\Http\Message\ResponseInterface;

/**
 * Represents a top-level abstraction of a remote API resource. Usually a resource represents a discrete
 * entity such as a Server, Container, Load Balancer. Apart from a representation of state, a resource can
 * also execute RESTFul operations on itself (updating, deleting, listing) or on other models.
 *
 * @package OpenStack\Common\Resource
 */
abstract class AbstractResource extends Operator implements ResourceInterface
{
    const DEFAULT_MARKER_KEY = 'id';

    /**
     * The JSON key that indicates how the API nests singular resources. For example, when
     * performing a GET, it could respond with ``{"server": {"id": "12345"}}``. In this case,
     * "server" is the resource key, since the essential state of the server is nested inside.
     *
     * @var string
     */
    protected $resourceKey;

    /**
     * The key that indicates how the API nests resource collections. For example, when
     * performing a GET, it could respond with ``{"servers": [{}, {}]}``. In this case, "servers"
     * is the resources key, since the array of servers is nested inside.
     *
     * @var string
     */
    protected $resourcesKey;

    /**
     * Indicates which attribute of the current resource should be used for pagination markers.
     *
     * @var string
     */
    protected $markerKey;

    /**
     * An array of aliases that will be checked when the resource is being populated. For example,
     *
     * 'FOO_BAR' => 'fooBar'
     *
     * will extract FOO_BAR from the response, and save it as 'fooBar' in the resource.
     *
     * @var array
     */
    protected $aliases = [];

    /**
     * Populates the current resource from a response object.
     *
     * @param ResponseInterface $response
     *
     * @return $this|ResourceInterface
     */
    public function populateFromResponse(ResponseInterface $response)
    {
        if (strpos($response->getHeaderLine('Content-Type'), 'application/json') === 0) {
            $json = Utils::jsonDecode($response);
            if (!empty($json)) {
                $this->populateFromArray(Utils::flattenJson($json, $this->resourceKey));
            }
        }

        return $this;
    }

    /**
     * Populates the current resource from a data array.
     *
     * @param array $array
     *
     * @return mixed|void
     */
    public function populateFromArray(array $array)
    {
        $reflClass = new \ReflectionClass($this);

        foreach ($array as $key => $val) {
            $propertyName = isset($this->aliases[$key]) ? $this->aliases[$key] : $key;

            if (property_exists($this, $propertyName)) {
                if ($type = $this->extractTypeFromDocBlock($reflClass, $propertyName)) {
                    $val = $this->parseDocBlockValue($type, $val);
                }

                $this->$propertyName = $val;
            }
        }
    }

    private function parseDocBlockValue($type, $val)
    {
        if (strpos($type, '[]') === 0 && is_array($val)) {
            $array = [];
            foreach ($val as $subVal) {
                $array[] = $this->model($this->normalizeModelClass(substr($type, 2)), $subVal);
            }
            $val = $array;
        } elseif (strcasecmp($type, '\datetimeimmutable') === 0) {
            $val = new \DateTimeImmutable($val);
        } elseif ($this->isNotNativeType($type)) {
            $val = $this->model($this->normalizeModelClass($type), $val);
        }

        return $val;
    }

    private function isNotNativeType($type)
    {
        return !in_array($type, [
            'string', 'bool', 'boolean', 'null', 'array', 'object', 'int', 'integer', 'float', 'numeric', 'mixed'
        ]);
    }

    private function normalizeModelClass($class)
    {
        if (strpos($class, '\\') === false) {
            $currentNamespace = (new \ReflectionClass($this))->getNamespaceName();
            $class = sprintf("%s\\%s", $currentNamespace, $class);
        }

        return $class;
    }

    private function extractTypeFromDocBlock(\ReflectionClass $reflClass, $propertyName)
    {
        $docComment = $reflClass->getProperty($propertyName)->getDocComment();

        if (!$docComment) {
            return false;
        }

        $matches = [];
        preg_match('#@var ((\[\])?[\w|\\\]+)#', $docComment, $matches);
        return isset($matches[1]) ? $matches[1] : null;
    }

    /**
     * Internal method which retrieves the values of provided keys.
     *
     * @param array $keys
     *
     * @return array
     */
    protected function getAttrs(array $keys)
    {
        $output = [];

        foreach ($keys as $key) {
            if (property_exists($this, $key) && $this->$key !== null) {
                $output[$key] = $this->$key;
            }
        }

        return $output;
    }

    /**
     * @param array $definition
     *
     * @return mixed
     */
    public function executeWithState(array $definition)
    {
        return $this->execute($definition, $this->getAttrs(array_keys($definition['params'])));
    }

    /**
     * {@inheritDoc}
     */
    public function enumerate(array $def, array $userVals = [], callable $mapFn = null)
    {
        $operation = $this->getOperation($def);

        $requestFn = function ($marker) use ($operation, $userVals) {
            if ($operation->hasParam('marker') && $marker) {
                $userVals['marker'] = $marker;
            }
            return $this->sendRequest($operation, $userVals);
        };

        $resourceFn = function (array $data) {
            $resource = $this->newInstance();
            $resource->populateFromArray($data);
            return $resource;
        };

        $opts = [
            'limit'        => isset($userVals['limit']) ? $userVals['limit'] : null,
            'resourcesKey' => $this->resourcesKey,
            'markerKey'    => $this->markerKey,
            'mapFn'        => $mapFn,
        ];

        $iterator = new Iterator($opts, $requestFn, $resourceFn);
        return $iterator();
    }
}

1		<?php
2
3		namespace OpenStack\Common\Resource;
4
5		use OpenStack\Common\Api\Operator;
6		use OpenStack\Common\Transport\Utils;
7		use Psr\Http\Message\ResponseInterface;
8
9		/**
10		* Represents a top-level abstraction of a remote API resource. Usually a resource represents a discrete
11		* entity such as a Server, Container, Load Balancer. Apart from a representation of state, a resource can
12		* also execute RESTFul operations on itself (updating, deleting, listing) or on other models.
13		*
14		* @package OpenStack\Common\Resource
15		*/
16		abstract class AbstractResource extends Operator implements ResourceInterface
17		{
18		const DEFAULT_MARKER_KEY = 'id';
19
20		/**
21		* The JSON key that indicates how the API nests singular resources. For example, when
22		* performing a GET, it could respond with ``{"server": {"id": "12345"}}``. In this case,
23		* "server" is the resource key, since the essential state of the server is nested inside.
24		*
25		* @var string
26		*/
27		protected $resourceKey;
28
29		/**
30		* The key that indicates how the API nests resource collections. For example, when
31		* performing a GET, it could respond with ``{"servers": [{}, {}]}``. In this case, "servers"
32		* is the resources key, since the array of servers is nested inside.
33		*
34		* @var string
35		*/
36		protected $resourcesKey;
37
38		/**
39		* Indicates which attribute of the current resource should be used for pagination markers.
40		*
41		* @var string
42		*/
43		protected $markerKey;
44
45		/**
46		* An array of aliases that will be checked when the resource is being populated. For example,
47		*
48		* 'FOO_BAR' => 'fooBar'
49		*
50		* will extract FOO_BAR from the response, and save it as 'fooBar' in the resource.
51		*
52		* @var array
53		*/
54		protected $aliases = [];
55
56		/**
57		* Populates the current resource from a response object.
58		*
59		* @param ResponseInterface $response
60		*
61		* @return $this\|ResourceInterface
62		*/
63	66	public function populateFromResponse(ResponseInterface $response)
64		{
65	66	if (strpos($response->getHeaderLine('Content-Type'), 'application/json') === 0) {
66	54	$json = Utils::jsonDecode($response);
67	54	if (!empty($json)) {
68	54	$this->populateFromArray(Utils::flattenJson($json, $this->resourceKey));
69	54	}
70	54	}
71
72	66	return $this;
73		}
74
75		/**
76		* Populates the current resource from a data array.
77		*
78		* @param array $array
79		*
80		* @return mixed\|void
81		*/
82	116	public function populateFromArray(array $array)
83		{
84	116	$reflClass = new \ReflectionClass($this);
85
86	116	foreach ($array as $key => $val) {
87	116	$propertyName = isset($this->aliases[$key]) ? $this->aliases[$key] : $key;
88
89	116	if (property_exists($this, $propertyName)) {
90	114	if ($type = $this->extractTypeFromDocBlock($reflClass, $propertyName)) {
91	111	$val = $this->parseDocBlockValue($type, $val);
92	111	}
93
94	114	$this->$propertyName = $val;
95	114	}
96	116	}
97	116	}
98
99	111	private function parseDocBlockValue($type, $val)
100		{
101	111	if (strpos($type, '[]') === 0 && is_array($val)) {
102	6	$array = [];
103	6	foreach ($val as $subVal) {
104	6	$array[] = $this->model($this->normalizeModelClass(substr($type, 2)), $subVal);
105	6	}
106	6	$val = $array;
107	111	} elseif (strcasecmp($type, '\datetimeimmutable') === 0) {
108	20	$val = new \DateTimeImmutable($val);
109	110	} elseif ($this->isNotNativeType($type)) {
110	11	$val = $this->model($this->normalizeModelClass($type), $val);
111	11	}
112
113	111	return $val;
114		}
115
116	107	private function isNotNativeType($type)
117		{
118	107	return !in_array($type, [
119	107	'string', 'bool', 'boolean', 'null', 'array', 'object', 'int', 'integer', 'float', 'numeric', 'mixed'
120	107	]);
121		}
122
123	12	private function normalizeModelClass($class)
124		{
125	12	if (strpos($class, '\\') === false) {
126	12	$currentNamespace = (new \ReflectionClass($this))->getNamespaceName();
127	12	$class = sprintf("%s\\%s", $currentNamespace, $class);
128	12	}
129
130	12	return $class;
131		}
132
133	114	private function extractTypeFromDocBlock(\ReflectionClass $reflClass, $propertyName)
134		{
135	114	$docComment = $reflClass->getProperty($propertyName)->getDocComment();
136
137	114	if (!$docComment) {
138	3	return false;
139		}
140
141	111	$matches = [];
142	111	preg_match('#@var ((\[\])?[\w\|\\\]+)#', $docComment, $matches);
143	111	return isset($matches[1]) ? $matches[1] : null;
144		}
145
146		/**
147		* Internal method which retrieves the values of provided keys.
148		*
149		* @param array $keys
150		*
151		* @return array
152		*/
153	52	protected function getAttrs(array $keys)
154		{
155	52	$output = [];
156
157	52	foreach ($keys as $key) {
158	52	if (property_exists($this, $key) && $this->$key !== null) {
159	52	$output[$key] = $this->$key;
160	52	}
161	52	}
162
163	52	return $output;
164		}
165
166		/**
167		* @param array $definition
168		*
169		* @return mixed
170		*/
171	47	public function executeWithState(array $definition)
172		{
173	47	return $this->execute($definition, $this->getAttrs(array_keys($definition['params'])));
174		}
175
176		/**
177		* {@inheritDoc}
178		*/
179	28	public function enumerate(array $def, array $userVals = [], callable $mapFn = null)
180		{
181	28	$operation = $this->getOperation($def);
182
183		$requestFn = function ($marker) use ($operation, $userVals) {
184	28	if ($operation->hasParam('marker') && $marker) {
185	4	$userVals['marker'] = $marker;
186	4	}
187	28	return $this->sendRequest($operation, $userVals);
188	28	};
189
190	28	$resourceFn = function (array $data) {
191	28	$resource = $this->newInstance();
192	28	$resource->populateFromArray($data);
193	28	return $resource;
194	28	};
195
196		$opts = [
197	28	'limit' => isset($userVals['limit']) ? $userVals['limit'] : null,
198	28	'resourcesKey' => $this->resourcesKey,
199	28	'markerKey' => $this->markerKey,
200	28	'mapFn' => $mapFn,
201	28	];
202
203	28	$iterator = new Iterator($opts, $requestFn, $resourceFn);
204	28	return $iterator();
205		}
206		}

php-opencloud / openstack

GitHub Access Token became invalid

Push — master ( b2df35...c7ca15 )

AbstractResource::executeWithState() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like