PublishCommandHandler::handleUpdate() - Code Metrics - puli/cli - Measure and Improve Code Quality continuously with Scrutinizer

PublishCommandHandler::handleUpdate() B
last analyzed 2016-08-15 16:33 UTC

↳ Parent: PublishCommandHandler

Complexity

Conditions	6
Paths	32

Size

Total Lines	32
Code Lines	19

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	19
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	32
ccs	19
cts	19
cp	1
rs	8.439
cc	6
eloc	19
nc	32
nop	1
crap	6

<?php

/*
 * This file is part of the puli/asset-plugin package.
 *
 * (c) Bernhard Schussek <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Puli\Cli\Handler;

use Puli\Manager\Api\Asset\AssetManager;
use Puli\Manager\Api\Asset\AssetMapping;
use Puli\Manager\Api\Installation\InstallationManager;
use Puli\Manager\Api\Installation\InstallationParams;
use Puli\Manager\Api\Server\Server;
use Puli\Manager\Api\Server\ServerManager;
use RuntimeException;
use Webmozart\Console\Api\Args\Args;
use Webmozart\Console\Api\IO\IO;
use Webmozart\Console\UI\Component\Table;
use Webmozart\Console\UI\Style\TableStyle;
use Webmozart\Expression\Expr;
use Webmozart\PathUtil\Path;

/**
 * @since  1.0
 *
 * @author Bernhard Schussek <[email protected]>
 */
class PublishCommandHandler
{
    /**
     * @var AssetManager
     */
    private $assetManager;

    /**
     * @var InstallationManager
     */
    private $installationManager;

    /**
     * @var ServerManager
     */
    private $serverManager;

    /**
     * @var string
     */
    private $currentPath = '/';

    public function __construct(AssetManager $assetManager, InstallationManager $installationManager, ServerManager $serveRManager)
    {
        $this->assetManager = $assetManager;
        $this->installationManager = $installationManager;
        $this->serverManager = $serveRManager;
    }

    public function handleList(Args $args, IO $io)

    {
        /** @var AssetMapping[][] $mappingsByServer */
        $mappingsByServer = array();

        /** @var Server[] $servers */
        $servers = array();
        $nonExistingServers = array();

        // Assemble mappings and validate servers
        foreach ($this->assetManager->getAssetMappings() as $mapping) {
            $serverName = $mapping->getServerName();

            if (!isset($mappingsByServer[$serverName])) {
                $mappingsByServer[$serverName] = array();

                if ($this->serverManager->hasServer($serverName)) {
                    $servers[$serverName] = $this->serverManager->getServer($serverName);
                } else {
                    $nonExistingServers[$serverName] = true;
                }
            }

            $mappingsByServer[$serverName][] = $mapping;
        }

        if (empty($mappingsByServer)) {
            $io->writeLine('No public resources. Use "puli publish <path> <server>" to publish resources.');

            return 0;
        }

        if (count($servers) > 0) {
            $io->writeLine('The following resources are published:');
            $io->writeLine('');

            foreach ($servers as $serverName => $server) {
                $serverTitle = 'Server <bu>'.$serverName.'</bu>';

                $io->writeLine(sprintf('    <b>%s</b>', $serverTitle));
                $io->writeLine(sprintf('    Location:   <c2>%s</c2>', $server->getDocumentRoot()));
                $io->writeLine(sprintf('    Installer:  %s', $server->getInstallerName()));
                $io->writeLine(sprintf('    URL Format: <c1>%s</c1>', $server->getUrlFormat()));
                $io->writeLine('');

                $this->printMappingTable($io, $mappingsByServer[$serverName]);
                $io->writeLine('');
            }

            $io->writeLine('Use "puli publish --install" to install the resources on your servers.');
        }

        if (count($servers) > 0 && count($nonExistingServers) > 0) {
            $io->writeLine('');
        }

        if (count($nonExistingServers) > 0) {
            $io->writeLine('The following public resources are disabled since their server does not exist:');
            $io->writeLine('');

            foreach ($nonExistingServers as $serverName => $_) {
                $io->writeLine(sprintf('    <b>Server <bu>%s</bu></b>', $serverName));
                $io->writeLine('');

                $this->printMappingTable($io, $mappingsByServer[$serverName], false);
                $io->writeLine('');
            }

            $io->writeLine('Use "puli server add <name> <document-root>" to add a server.');
        }

        return 0;
    }

    public function handleAdd(Args $args)

    {
        $flags = $args->isOptionSet('force') ? AssetManager::IGNORE_SERVER_NOT_FOUND : 0;
        $path = Path::makeAbsolute($args->getArgument('path'), $this->currentPath);

        $this->assetManager->addRootAssetMapping(new AssetMapping(
            $path,
            $args->getArgument('server'),
            $args->getArgument('server-path')
        ), $flags);

        return 0;
    }

    public function handleUpdate(Args $args)
    {
        $flags = $args->isOptionSet('force')
            ? AssetManager::OVERRIDE | AssetManager::IGNORE_SERVER_NOT_FOUND
            : AssetManager::OVERRIDE;
        $mappingToUpdate = $this->getMappingByUuidPrefix($args->getArgument('uuid'));
        $path = $mappingToUpdate->getGlob();
        $serverPath = $mappingToUpdate->getServerPath();
        $serverName = $mappingToUpdate->getServerName();

        if ($args->isOptionSet('path')) {
            $path = Path::makeAbsolute($args->getOption('path'), $this->currentPath);
        }

        if ($args->isOptionSet('server-path')) {
            $serverPath = $args->getOption('server-path');
        }

        if ($args->isOptionSet('server')) {
            $serverName = $args->getOption('server');
        }

        $updatedMapping = new AssetMapping($path, $serverName, $serverPath, $mappingToUpdate->getUuid());

        if ($this->mappingsEqual($mappingToUpdate, $updatedMapping)) {
            throw new RuntimeException('Nothing to update.');
        }

        $this->assetManager->addRootAssetMapping($updatedMapping, $flags);

        return 0;
    }

    public function handleDelete(Args $args)
    {
        $mapping = $this->getMappingByUuidPrefix($args->getArgument('uuid'));

        $this->assetManager->removeRootAssetMapping($mapping->getUuid());

        return 0;
    }

    public function handleInstall(Args $args, IO $io)
    {
        if ($args->isArgumentSet('server')) {
            $expr = Expr::method('getServerName', Expr::same($args->getArgument('server')));
            $mappings = $this->assetManager->findAssetMappings($expr);
        } else {
            $mappings = $this->assetManager->getAssetMappings();
        }

        if (!$mappings) {

            $io->writeLine('Nothing to install.');

            return 0;
        }

        /** @var InstallationParams[] $paramsToInstall */
        $paramsToInstall = array();

        // Prepare and validate the installation of all matching mappings
        foreach ($mappings as $mapping) {
            $paramsToInstall[] = $this->installationManager->prepareInstallation($mapping);
        }

        foreach ($paramsToInstall as $params) {
            foreach ($params->getResources() as $resource) {
                $serverPath = rtrim($params->getDocumentRoot(), '/').$params->getServerPathForResource($resource);

                $io->writeLine(sprintf(
                    'Installing <c1>%s</c1> into <c2>%s</c2> via <u>%s</u>...',
                    $resource->getRepositoryPath(),
                    trim($serverPath, '/'),
                    $params->getInstallerDescriptor()->getName()
                ));

                $this->installationManager->installResource($resource, $params);
            }
        }

        return 0;
    }

    /**
     * @param IO             $io
     * @param AssetMapping[] $mappings
     * @param bool           $enabled
     */
    private function printMappingTable(IO $io, array $mappings, $enabled = true)
    {
        $table = new Table(TableStyle::borderless());

        $globTag = $enabled ? 'c1' : 'bad';
        $pathTag = $enabled ? 'c2' : 'bad';

        foreach ($mappings as $mapping) {
            $uuid = substr($mapping->getUuid()->toString(), 0, 6);
            $glob = $mapping->getGlob();
            $serverPath = $mapping->getServerPath();

            if (!$enabled) {
                $uuid = sprintf('<bad>%s</bad>', $uuid);
            }

            $table->addRow(array(
                $uuid,
                sprintf('<%s>%s</%s>', $globTag, $glob, $globTag),
                sprintf('<%s>%s</%s>', $pathTag, $serverPath, $pathTag),
            ));
        }

        $table->render($io, 8);
    }

    /**
     * @param string $uuidPrefix
     *
     * @return AssetMapping
     */
    private function getMappingByUuidPrefix($uuidPrefix)

    {
        $expr = Expr::method('getUuid', Expr::startsWith($uuidPrefix));

        $mappings = $this->assetManager->findAssetMappings($expr);

        if (!$mappings) {

            throw new RuntimeException(sprintf(
                'The mapping with the UUID prefix "%s" does not exist.',
                $uuidPrefix
            ));
        }

        if (count($mappings) > 1) {
            throw new RuntimeException(sprintf(
                'More than one mapping matches the UUID prefix "%s".',
                $uuidPrefix
            ));
        }

        return reset($mappings);
    }

    private function mappingsEqual(AssetMapping $mapping1, AssetMapping $mapping2)
    {
        return $mapping1->getUuid() === $mapping2->getUuid() &&
            $mapping1->getGlob() === $mapping2->getGlob() &&
            $mapping1->getServerPath() === $mapping2->getServerPath() &&
            $mapping1->getServerName() === $mapping2->getServerName();
    }
}


1			<?php
2
3			/*
4			* This file is part of the puli/asset-plugin package.
5			*
6			* (c) Bernhard Schussek <[email protected]>
7			*
8			* For the full copyright and license information, please view the LICENSE
9			* file that was distributed with this source code.
10			*/
11
12			namespace Puli\Cli\Handler;
13
14			use Puli\Manager\Api\Asset\AssetManager;
15			use Puli\Manager\Api\Asset\AssetMapping;
16			use Puli\Manager\Api\Installation\InstallationManager;
17			use Puli\Manager\Api\Installation\InstallationParams;
18			use Puli\Manager\Api\Server\Server;
19			use Puli\Manager\Api\Server\ServerManager;
20			use RuntimeException;
21			use Webmozart\Console\Api\Args\Args;
22			use Webmozart\Console\Api\IO\IO;
23			use Webmozart\Console\UI\Component\Table;
24			use Webmozart\Console\UI\Style\TableStyle;
25			use Webmozart\Expression\Expr;
26			use Webmozart\PathUtil\Path;
27
28			/**
29			* @since 1.0
30			*
31			* @author Bernhard Schussek <[email protected]>
32			*/
33			class PublishCommandHandler
34			{
35			/**
36			* @var AssetManager
37			*/
38			private $assetManager;
39
40			/**
41			* @var InstallationManager
42			*/
43			private $installationManager;
44
45			/**
46			* @var ServerManager
47			*/
48			private $serverManager;
49
50			/**
51			* @var string
52			*/
53			private $currentPath = '/';
54
55	21		public function __construct(AssetManager $assetManager, InstallationManager $installationManager, ServerManager $serveRManager)
56			{
57	21		$this->assetManager = $assetManager;
58	21		$this->installationManager = $installationManager;
59	21		$this->serverManager = $serveRManager;
60	21		}
61
62	4		public function handleList(Args $args, IO $io)
			0 ignored issues – show Unused Code introduced 2015-12-06 22:45 UTC by Report Bug Copy Issue Report The parameter `$args` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
63			{
64			/** @var AssetMapping[][] $mappingsByServer */
65	4		$mappingsByServer = array();
66
67			/** @var Server[] $servers */
68	4		$servers = array();
69	4		$nonExistingServers = array();
70
71			// Assemble mappings and validate servers
72	4		foreach ($this->assetManager->getAssetMappings() as $mapping) {
73	3		$serverName = $mapping->getServerName();
74
75	3		if (!isset($mappingsByServer[$serverName])) {
76	3		$mappingsByServer[$serverName] = array();
77
78	3		if ($this->serverManager->hasServer($serverName)) {
79	2		$servers[$serverName] = $this->serverManager->getServer($serverName);
80			} else {
81	2		$nonExistingServers[$serverName] = true;
82			}
83			}
84
85	3		$mappingsByServer[$serverName][] = $mapping;
86			}
87
88	4		if (empty($mappingsByServer)) {
89	1		$io->writeLine('No public resources. Use "puli publish <path> <server>" to publish resources.');
90
91	1		return 0;
92			}
93
94	3		if (count($servers) > 0) {
95	2		$io->writeLine('The following resources are published:');
96	2		$io->writeLine('');
97
98	2		foreach ($servers as $serverName => $server) {
99	2		$serverTitle = 'Server <bu>'.$serverName.'</bu>';
100
101	2		$io->writeLine(sprintf(' <b>%s</b>', $serverTitle));
102	2		$io->writeLine(sprintf(' Location: <c2>%s</c2>', $server->getDocumentRoot()));
103	2		$io->writeLine(sprintf(' Installer: %s', $server->getInstallerName()));
104	2		$io->writeLine(sprintf(' URL Format: <c1>%s</c1>', $server->getUrlFormat()));
105	2		$io->writeLine('');
106
107	2		$this->printMappingTable($io, $mappingsByServer[$serverName]);
108	2		$io->writeLine('');
109			}
110
111	2		$io->writeLine('Use "puli publish --install" to install the resources on your servers.');
112			}
113
114	3		if (count($servers) > 0 && count($nonExistingServers) > 0) {
115	1		$io->writeLine('');
116			}
117
118	3		if (count($nonExistingServers) > 0) {
119	2		$io->writeLine('The following public resources are disabled since their server does not exist:');
120	2		$io->writeLine('');
121
122	2		foreach ($nonExistingServers as $serverName => $_) {
123	2		$io->writeLine(sprintf(' <b>Server <bu>%s</bu></b>', $serverName));
124	2		$io->writeLine('');
125
126	2		$this->printMappingTable($io, $mappingsByServer[$serverName], false);
127	2		$io->writeLine('');
128			}
129
130	2		$io->writeLine('Use "puli server add <name> <document-root>" to add a server.');
131			}
132
133	3		return 0;
134			}
135
136	5	View Code Duplication	public function handleAdd(Args $args)
			0 ignored issues – show Duplication introduced 2015-12-06 22:45 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
137			{
138	5		$flags = $args->isOptionSet('force') ? AssetManager::IGNORE_SERVER_NOT_FOUND : 0;
139	5		$path = Path::makeAbsolute($args->getArgument('path'), $this->currentPath);
140
141	5		$this->assetManager->addRootAssetMapping(new AssetMapping(
142			$path,
143	5		$args->getArgument('server'),
144	5		$args->getArgument('server-path')
145			), $flags);
146
147	5		return 0;
148			}
149
150	5		public function handleUpdate(Args $args)
151			{
152	5		$flags = $args->isOptionSet('force')
153	1		? AssetManager::OVERRIDE \| AssetManager::IGNORE_SERVER_NOT_FOUND
154	5		: AssetManager::OVERRIDE;
155	5		$mappingToUpdate = $this->getMappingByUuidPrefix($args->getArgument('uuid'));
156	5		$path = $mappingToUpdate->getGlob();
157	5		$serverPath = $mappingToUpdate->getServerPath();
158	5		$serverName = $mappingToUpdate->getServerName();
159
160	5		if ($args->isOptionSet('path')) {
161	3		$path = Path::makeAbsolute($args->getOption('path'), $this->currentPath);
162			}
163
164	5		if ($args->isOptionSet('server-path')) {
165	2		$serverPath = $args->getOption('server-path');
166			}
167
168	5		if ($args->isOptionSet('server')) {
169	1		$serverName = $args->getOption('server');
170			}
171
172	5		$updatedMapping = new AssetMapping($path, $serverName, $serverPath, $mappingToUpdate->getUuid());
173
174	5		if ($this->mappingsEqual($mappingToUpdate, $updatedMapping)) {
175	1		throw new RuntimeException('Nothing to update.');
176			}
177
178	4		$this->assetManager->addRootAssetMapping($updatedMapping, $flags);
179
180	4		return 0;
181			}
182
183	3		public function handleDelete(Args $args)
184			{
185	3		$mapping = $this->getMappingByUuidPrefix($args->getArgument('uuid'));
186
187	1		$this->assetManager->removeRootAssetMapping($mapping->getUuid());
188
189	1		return 0;
190			}
191
192	4		public function handleInstall(Args $args, IO $io)
193			{
194	4		if ($args->isArgumentSet('server')) {
195	1		$expr = Expr::method('getServerName', Expr::same($args->getArgument('server')));
196	1		$mappings = $this->assetManager->findAssetMappings($expr);
197			} else {
198	3		$mappings = $this->assetManager->getAssetMappings();
199			}
200
201	4		if (!$mappings) {
			0 ignored issues – show Bug Best Practice introduced 2015-12-06 22:45 UTC by Report Bug Copy Issue Report The expression `$mappings` of type `Puli\Manager\Api\Asset\AssetMapping[]` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
202	1		$io->writeLine('Nothing to install.');
203
204	1		return 0;
205			}
206
207			/** @var InstallationParams[] $paramsToInstall */
208	3		$paramsToInstall = array();
209
210			// Prepare and validate the installation of all matching mappings
211	3		foreach ($mappings as $mapping) {
212	3		$paramsToInstall[] = $this->installationManager->prepareInstallation($mapping);
213			}
214
215	2		foreach ($paramsToInstall as $params) {
216	2		foreach ($params->getResources() as $resource) {
217	2		$serverPath = rtrim($params->getDocumentRoot(), '/').$params->getServerPathForResource($resource);
218
219	2		$io->writeLine(sprintf(
220	2		'Installing <c1>%s</c1> into <c2>%s</c2> via <u>%s</u>...',
221	2		$resource->getRepositoryPath(),
222	2		trim($serverPath, '/'),
223	2		$params->getInstallerDescriptor()->getName()
224			));
225
226	2		$this->installationManager->installResource($resource, $params);
227			}
228			}
229
230	2		return 0;
231			}
232
233			/**
234			* @param IO $io
235			* @param AssetMapping[] $mappings
236			* @param bool $enabled
237			*/
238	3		private function printMappingTable(IO $io, array $mappings, $enabled = true)
239			{
240	3		$table = new Table(TableStyle::borderless());
241
242	3		$globTag = $enabled ? 'c1' : 'bad';
243	3		$pathTag = $enabled ? 'c2' : 'bad';
244
245	3		foreach ($mappings as $mapping) {
246	3		$uuid = substr($mapping->getUuid()->toString(), 0, 6);
247	3		$glob = $mapping->getGlob();
248	3		$serverPath = $mapping->getServerPath();
249
250	3		if (!$enabled) {
251	2		$uuid = sprintf('<bad>%s</bad>', $uuid);
252			}
253
254	3		$table->addRow(array(
255	3		$uuid,
256	3		sprintf('<%s>%s</%s>', $globTag, $glob, $globTag),
257	3		sprintf('<%s>%s</%s>', $pathTag, $serverPath, $pathTag),
258			));
259			}
260
261	3		$table->render($io, 8);
262	3		}
263
264			/**
265			* @param string $uuidPrefix
266			*
267			* @return AssetMapping
268			*/
269	8	View Code Duplication	private function getMappingByUuidPrefix($uuidPrefix)
			0 ignored issues – show Duplication introduced 2015-12-06 22:45 UTC by Report Bug Copy Issue Report This method seems to be duplicated in your project. Duplicated code is one of the most pungent code smells. If you need to duplicate the same code in three or more different places, we strongly encourage you to look into extracting the code into a single class or operation. You can also find more detailed suggestions in the “Code” section of your repository. Loading history...
270			{
271	8		$expr = Expr::method('getUuid', Expr::startsWith($uuidPrefix));
272
273	8		$mappings = $this->assetManager->findAssetMappings($expr);
274
275	8		if (!$mappings) {
			0 ignored issues – show Bug Best Practice introduced 2015-12-06 22:45 UTC by Report Bug Copy Issue Report The expression `$mappings` of type `Puli\Manager\Api\Asset\AssetMapping[]` is implicitly converted to a boolean; are you sure this is intended? If so, consider using `empty($expr)` instead to make it clear that you intend to check for an array without elements. This check marks implicit conversions of arrays to boolean values in a comparison. While in PHP an empty array is considered to be equal (but not identical) to false, this is not always apparent. Consider making the comparison explicit by using `empty(..)` or `! empty(...)` instead. Loading history...
276	1		throw new RuntimeException(sprintf(
277	1		'The mapping with the UUID prefix "%s" does not exist.',
278			$uuidPrefix
279			));
280			}
281
282	7		if (count($mappings) > 1) {
283	1		throw new RuntimeException(sprintf(
284	1		'More than one mapping matches the UUID prefix "%s".',
285			$uuidPrefix
286			));
287			}
288
289	6		return reset($mappings);
290			}
291
292	5		private function mappingsEqual(AssetMapping $mapping1, AssetMapping $mapping2)
293			{
294	5		return $mapping1->getUuid() === $mapping2->getUuid() &&
295	5		$mapping1->getGlob() === $mapping2->getGlob() &&
296	5		$mapping1->getServerPath() === $mapping2->getServerPath() &&
297	5		$mapping1->getServerName() === $mapping2->getServerName();
298			}
299			}
300

puli / cli

PublishCommandHandler::handleUpdate() B last analyzed 2016-08-15 16:33 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

PublishCommandHandler::handleUpdate() B
last analyzed 2016-08-15 16:33 UTC