Client::gettable() - Code Metrics - Inspection of "Update composer.json" - MarwanAlsoltany/amqp-agent - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — dev ( e366c8...5f6227 )

by Marwan

created 2020-09-30 12:08 UTC

Client::gettable() A

↳ Parent: Project

Complexity

Conditions	3
Paths	3

Size

Total Lines	13
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	8
CRAP Score	3

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	3
eloc	7
c	1
b	0
f	0
nc	3
nop	0
dl	0
loc	13
ccs	8
cts	8
cp	1
crap	3
rs	10

<?php
/**
 * @author Marwan Al-Soltany <[email protected]>
 * @copyright Marwan Al-Soltany 2020
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

namespace MAKS\AmqpAgent;

use MAKS\AmqpAgent\Config;
use MAKS\AmqpAgent\Worker\Publisher;
use MAKS\AmqpAgent\Worker\Consumer;
use MAKS\AmqpAgent\Helper\Utility;
use MAKS\AmqpAgent\Helper\Serializer;
use MAKS\AmqpAgent\Helper\Logger;
use MAKS\AmqpAgent\Exception\AmqpAgentException;

/**
 * A class returns everything AMQP Agent has to offer. A simple service container so to say.
 *
 * Example:
 * ```
 * $config = new Config('path/to/some/config-file.php');
 * $client = new Client($config);
 * $publisher = $client->getPublisher(); // or $client->get('publisher');
 * $consumer = $client->getConsumer(); // or $client->get('consumer');
 * ```
 *
 * @since 1.0.0
 * @api
 */
class Client
{
    /**
     * An instance of the configuration object.
     * @var Config
     */
    protected $config;

    /**
     * An instance of the Publisher worker class.
     * @var Publisher
     */
    protected $publisher;

    /**
     * An instance of the Consumer worker class.
     * @var Consumer
     */
    protected $consumer;

    /**
     * An instance of the Serializer class.
     * @var Serializer
     */
    protected $serializer;

    /**
     * An instance of the Logger class.
     * @var Logger
     */
    protected $logger;


    /**
     * Client object constructor.
     * @param Config|string $config An instance of the Config class or a path to a config file.
     * @throws AmqpAgentException
     */
    public function __construct($config)
    {
        if ($config instanceof Config) {
            $this->config = $config;
        } elseif (is_string($config) && strlen(trim($config)) > 0) {
            $this->config = new Config($config);
        } else {
            throw new AmqpAgentException(
                'A Config instance or a valid path to a config file must be specified.'
            );
        }
    }

    /**
     * Gets a class member via public property access notation.
     * @param string $member Property name.
     * @return mixed
     */
    public function __get(string $member)
    {
        // using $this->get() to reuse the logic in class methods.
        return $this->get($member);
    }


    /**
     * Returns an instance of a class by its name (lowercase, UPPERCASE, PascalCase, camelCase, dot.case, kebab-case, or snake_case representation of class name).
     * @param string $member Member name. Check out `self::gettable()` for available members.
     * @return Config|Publisher|ClientEndpoint|ServerEndpoint|Consumer|Serializer|Logger
filter:
    dependency_paths: ["lib/*"]
     * @throws AmqpAgentException
     */
    public function get(string $member)
    {
        $method = __FUNCTION__ . preg_replace('/[\.\-_]+/', '', ucwords(strtolower($member), '.-_'));

        if (method_exists($this, $method)) {
            return $this->{$method}();
        }

        $available = Utility::collapse($this->gettable());
        throw new AmqpAgentException(
            "The requested member with the name \"{$member}\" does not exist! Available members are: {$available}."
        );
    }


    /**
     * Returns an array of available members that can be obtained via `self::get()`.
     * @return array
     */
    public static function gettable(): array
    {
        $methods = get_class_methods(static::class);
        $gettable = [];
        $separator = '.-_'[rand(0,2)];

        foreach ($methods as $method) {
            if (preg_match('/get[A-Z][a-z]+/', $method)) {
                $gettable[] = strtolower(preg_replace(['/get/', '/([a-z])([A-Z])/'], ['', '$1'.$separator.'$2'], $method));
            }
        }

        return $gettable;
    }


    /**
     * Returns an instance of the Publisher class.
     * @return Publisher
     * @api
     */
    public function getPublisher(): Publisher
    {
        if (!isset($this->publisher)) {
            $this->publisher = new Publisher(
                $this->config->connectionOptions,
                $this->config->channelOptions,
                $this->config->queueOptions,
                $this->config->exchangeOptions,
                $this->config->bindOptions,
                $this->config->messageOptions,
                $this->config->publishOptions
            );
        }

        return $this->publisher;
    }

    /**
     * Returns an instance of the Consumer class.
     * @return Consumer
     */
    public function getConsumer(): Consumer
    {
        if (!isset($this->consumer)) {
            $this->consumer = new Consumer(
                $this->config->connectionOptions,
                $this->config->channelOptions,
                $this->config->queueOptions,
                $this->config->qosOptions,
                $this->config->waitOptions,
                $this->config->consumeOptions
            );
        }

        return $this->consumer;
    }

    /**
     * Returns an instance of the Serializer class.
     * @return Serializer
     */
    public function getSerializer(): Serializer
    {
        if (!isset($this->serializer)) {
            $this->serializer = new Serializer();
        }

        return $this->serializer;
    }

    /**
     * Returns an instance of the Logger class. Filename and directory must be set through setters.
     * @return Logger
     */
    public function getLogger(): Logger
    {
        if (!isset($this->logger)) {
            $this->logger = new Logger(null, null);
        }

        return $this->logger;
    }

    /**
     * Returns the currently used config object.
     * @return Config
     */
    public function getConfig(): Config
    {
        return $this->config;
    }
}


1		<?php
2		/**
3		* @author Marwan Al-Soltany <[email protected]>
4		* @copyright Marwan Al-Soltany 2020
5		* For the full copyright and license information, please view
6		* the LICENSE file that was distributed with this source code.
7		*/
8
9		namespace MAKS\AmqpAgent;
10
11		use MAKS\AmqpAgent\Config;
12		use MAKS\AmqpAgent\Worker\Publisher;
13		use MAKS\AmqpAgent\Worker\Consumer;
14		use MAKS\AmqpAgent\Helper\Utility;
15		use MAKS\AmqpAgent\Helper\Serializer;
16		use MAKS\AmqpAgent\Helper\Logger;
17		use MAKS\AmqpAgent\Exception\AmqpAgentException;
18
19		/**
20		* A class returns everything AMQP Agent has to offer. A simple service container so to say.
21		*
22		* Example:
23		* ```
24		* $config = new Config('path/to/some/config-file.php');
25		* $client = new Client($config);
26		* $publisher = $client->getPublisher(); // or $client->get('publisher');
27		* $consumer = $client->getConsumer(); // or $client->get('consumer');
28		* ```
29		*
30		* @since 1.0.0
31		* @api
32		*/
33		class Client
34		{
35		/**
36		* An instance of the configuration object.
37		* @var Config
38		*/
39		protected $config;
40
41		/**
42		* An instance of the Publisher worker class.
43		* @var Publisher
44		*/
45		protected $publisher;
46
47		/**
48		* An instance of the Consumer worker class.
49		* @var Consumer
50		*/
51		protected $consumer;
52
53		/**
54		* An instance of the Serializer class.
55		* @var Serializer
56		*/
57		protected $serializer;
58
59		/**
60		* An instance of the Logger class.
61		* @var Logger
62		*/
63		protected $logger;
64
65
66		/**
67		* Client object constructor.
68		* @param Config\|string $config An instance of the Config class or a path to a config file.
69		* @throws AmqpAgentException
70		*/
71	8	public function __construct($config)
72		{
73	8	if ($config instanceof Config) {
74	8	$this->config = $config;
75	2	} elseif (is_string($config) && strlen(trim($config)) > 0) {
76	1	$this->config = new Config($config);
77		} else {
78	1	throw new AmqpAgentException(
79	1	'A Config instance or a valid path to a config file must be specified.'
80		);
81		}
82	8	}
83
84		/**
85		* Gets a class member via public property access notation.
86		* @param string $member Property name.
87		* @return mixed
88		*/
89	5	public function __get(string $member)
90		{
91		// using $this->get() to reuse the logic in class methods.
92	5	return $this->get($member);
93		}
94
95
96		/**
97		* Returns an instance of a class by its name (lowercase, UPPERCASE, PascalCase, camelCase, dot.case, kebab-case, or snake_case representation of class name).
98		* @param string $member Member name. Check out `self::gettable()` for available members.
99		* @return Config\|Publisher\|ClientEndpoint\|ServerEndpoint\|Consumer\|Serializer\|Logger
		0 ignored issues – show Bug introduced 2020-09-30 12:11 UTC by Report Bug Copy Issue Report The type `MAKS\AmqpAgent\ClientEndpoint` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history... Bug introduced 2020-09-30 12:11 UTC by Report Bug Copy Issue Report The type `MAKS\AmqpAgent\ServerEndpoint` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
100		* @throws AmqpAgentException
101		*/
102	6	public function get(string $member)
103		{
104	6	$method = __FUNCTION__ . preg_replace('/[\.\-_]+/', '', ucwords(strtolower($member), '.-_'));
105
106	6	if (method_exists($this, $method)) {
107	5	return $this->{$method}();
108		}
109
110	1	$available = Utility::collapse($this->gettable());
111	1	throw new AmqpAgentException(
112	1	"The requested member with the name \"{$member}\" does not exist! Available members are: {$available}."
113		);
114		}
115
116
117		/**
118		* Returns an array of available members that can be obtained via `self::get()`.
119		* @return array
120		*/
121	1	public static function gettable(): array
122		{
123	1	$methods = get_class_methods(static::class);
124	1	$gettable = [];
125	1	$separator = '.-_'[rand(0,2)];
126
127	1	foreach ($methods as $method) {
128	1	if (preg_match('/get[A-Z][a-z]+/', $method)) {
129	1	$gettable[] = strtolower(preg_replace(['/get/', '/([a-z])([A-Z])/'], ['', '$1'.$separator.'$2'], $method));
130		}
131		}
132
133	1	return $gettable;
134		}
135
136
137		/**
138		* Returns an instance of the Publisher class.
139		* @return Publisher
140		* @api
141		*/
142	1	public function getPublisher(): Publisher
143		{
144	1	if (!isset($this->publisher)) {
145	1	$this->publisher = new Publisher(
146	1	$this->config->connectionOptions,
147	1	$this->config->channelOptions,
148	1	$this->config->queueOptions,
149	1	$this->config->exchangeOptions,
150	1	$this->config->bindOptions,
151	1	$this->config->messageOptions,
152	1	$this->config->publishOptions
153		);
154		}
155
156	1	return $this->publisher;
157		}
158
159		/**
160		* Returns an instance of the Consumer class.
161		* @return Consumer
162		*/
163	1	public function getConsumer(): Consumer
164		{
165	1	if (!isset($this->consumer)) {
166	1	$this->consumer = new Consumer(
167	1	$this->config->connectionOptions,
168	1	$this->config->channelOptions,
169	1	$this->config->queueOptions,
170	1	$this->config->qosOptions,
171	1	$this->config->waitOptions,
172	1	$this->config->consumeOptions
173		);
174		}
175
176	1	return $this->consumer;
177		}
178
179		/**
180		* Returns an instance of the Serializer class.
181		* @return Serializer
182		*/
183	1	public function getSerializer(): Serializer
184		{
185	1	if (!isset($this->serializer)) {
186	1	$this->serializer = new Serializer();
187		}
188
189	1	return $this->serializer;
190		}
191
192		/**
193		* Returns an instance of the Logger class. Filename and directory must be set through setters.
194		* @return Logger
195		*/
196	2	public function getLogger(): Logger
197		{
198	2	if (!isset($this->logger)) {
199	2	$this->logger = new Logger(null, null);
200		}
201
202	2	return $this->logger;
203		}
204
205		/**
206		* Returns the currently used config object.
207		* @return Config
208		*/
209	1	public function getConfig(): Config
210		{
211	1	return $this->config;
212		}
213		}
214

MarwanAlsoltany / amqp-agent

Push — dev ( e366c8...5f6227 )

Client::gettable() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like