BundleSyncHelper::scanForBundles() - Code Metrics - Inspection of "Extensions refactor (#4103)" - zikula/core - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 89c3e8...c161b3 )

by Craig

created 2020-02-03 20:55 UTC

BundleSyncHelper::scanForBundles() B

↳ Parent: BundleSyncHelper

Complexity

Conditions	8
Paths	36

Size

Total Lines	60
Code Lines	37

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	8
eloc	37
nc	36
nop	1
dl	0
loc	60
rs	8.0835
c	1
b	0
f	0

How to fix Long Method

<?php

declare(strict_types=1);

/*
 * This file is part of the Zikula package.
 *
 * Copyright Zikula Foundation - https://ziku.la/
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Zikula\ExtensionsModule\Helper;

use Composer\Semver\Semver;
use RuntimeException;
use Symfony\Component\ErrorHandler\Error\FatalError;
use Symfony\Component\Finder\Finder;
use Symfony\Component\HttpFoundation\Session\SessionInterface;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
use Symfony\Contracts\Translation\TranslatorInterface;
use Zikula\Bundle\CoreBundle\AbstractBundle;
use Zikula\Bundle\CoreBundle\Composer\MetaData;
use Zikula\Bundle\CoreBundle\Event\GenericEvent;
use Zikula\Bundle\CoreBundle\Helper\BundlesSchemaHelper;
use Zikula\Bundle\CoreBundle\HttpKernel\ZikulaHttpKernelInterface;
use Zikula\Bundle\CoreBundle\HttpKernel\ZikulaKernel;
use Zikula\ExtensionsModule\Constant;
use Zikula\ExtensionsModule\Entity\ExtensionEntity;
use Zikula\ExtensionsModule\Entity\Repository\ExtensionDependencyRepository;
use Zikula\ExtensionsModule\Entity\RepositoryInterface\ExtensionRepositoryInterface;
use Zikula\ExtensionsModule\Entity\RepositoryInterface\ExtensionVarRepositoryInterface;
use Zikula\ExtensionsModule\ExtensionEvents;

/**
 * Helper functions for the extensions bundle
 */
class BundleSyncHelper
{
    /**
     * @var ZikulaHttpKernelInterface
     */
    private $kernel;

    /**
     * @var ExtensionRepositoryInterface
     */
    private $extensionRepository;

    /**
     * @var ExtensionVarRepositoryInterface
     */
    private $extensionVarRepository;

    /**
     * @var ExtensionDependencyRepository
     */
    private $extensionDependencyRepository;

    /**
     * @var TranslatorInterface
     */
    private $translator;

    /**
     * @var EventDispatcherInterface
     */
    private $dispatcher;

    /**
     * @var ExtensionStateHelper
     */
    private $extensionStateHelper;

    /**
     * @var BundlesSchemaHelper
     */
    private $bundlesSchemaHelper;

    /**
     * @var ComposerValidationHelper
     */
    private $composerValidationHelper;

    /**
     * @var SessionInterface
     */
    protected $session;

    public function __construct(
        ZikulaHttpKernelInterface $kernel,
        ExtensionRepositoryInterface $extensionRepository,
        ExtensionVarRepositoryInterface $extensionVarRepository,
        ExtensionDependencyRepository $extensionDependencyRepository,
        TranslatorInterface $translator,
        EventDispatcherInterface $dispatcher,
        ExtensionStateHelper $extensionStateHelper,
        BundlesSchemaHelper $bundlesSchemaHelper,
        ComposerValidationHelper $composerValidationHelper,
        SessionInterface $session
    ) {
        $this->kernel = $kernel;
        $this->extensionRepository = $extensionRepository;
        $this->extensionVarRepository = $extensionVarRepository;
        $this->extensionDependencyRepository = $extensionDependencyRepository;
        $this->translator = $translator;
        $this->dispatcher = $dispatcher;
        $this->extensionStateHelper = $extensionStateHelper;
        $this->bundlesSchemaHelper = $bundlesSchemaHelper;
        $this->composerValidationHelper = $composerValidationHelper;
        $this->session = $session;
    }

    /**
     * Scan the extensions directory for bundles and returns an array with all (potential) bundles found.
     */
    public function scanForBundles($includeCore = false): array
    {
        // sync the extensions directory and the bundles table
        $this->bundlesSchemaHelper->load();
        $scanner = $this->bundlesSchemaHelper->getScanner();
        foreach ($scanner->getInvalid() as $invalidName) {
            $this->session->getFlashBag()->add(
                'warning',
                $this->translator->trans(
                    'WARNING: %extension% has an invalid composer.json file which could not be decoded.',
                    ['%extension%' => $invalidName]
                )
            );
        }
        $extensions = $scanner->getExtensionsMetaData();

        $bundles = [];
        $srcDir = $this->kernel->getProjectDir() . '/src/';
        /** @var MetaData $bundleMetaData */
        foreach ($extensions as $name => $bundleMetaData) {
            foreach ($bundleMetaData->getPsr4() as $ns => $path) {
                $this->kernel->getAutoloader()->addPsr4($ns, $srcDir . $path);
            }

            $bundleClass = $bundleMetaData->getClass();

            /** @var $bundle \Zikula\Bundle\CoreBundle\AbstractBundle */
            $bundle = new $bundleClass();
            $bundleMetaData->setTranslator($this->translator);
            $bundleVersionArray = $bundleMetaData->getFilteredVersionInfoArray();

            $finder = new Finder();
            $finder->files()->in($bundle->getPath())->depth(0)->name('composer.json');
            foreach ($finder as $splFileInfo) {
                // there will only be one loop here
                $this->composerValidationHelper->check($splFileInfo);
                if ($this->composerValidationHelper->isValid()) {
                    $bundles[$bundle->getName()] = $bundleVersionArray;
                    $bundles[$bundle->getName()]['oldnames'] = $bundleVersionArray['oldnames'] ?? '';
                } else {
                    $this->session->getFlashBag()->add(
                        'error',
                        $this->translator->trans(
                            'Cannot load %extension% because the composer file is invalid.',
                            ['%extension%' => $bundle->getName()]
                        )
                    );
                    foreach ($this->composerValidationHelper->getErrors() as $error) {
                        $this->session->getFlashBag()->add('error', $error);
                    }
                }
            }
        }

        if ($includeCore) {
            $this->appendCoreExtensionsMetaData($bundles);
        }
        $this->validate($bundles);

        return $bundles;
    }

    private function appendCoreExtensionsMetaData(array &$extensions): void
    {
        foreach (ZikulaKernel::$coreExtension as $systemModule => $bundleClass) {
            $bundle = $this->kernel->getBundle($systemModule);
            if ($bundle instanceof AbstractBundle) {
                $extensions[$systemModule] = $bundle->getMetaData()->getFilteredVersionInfoArray();
            }
        }
    }

    /**
     * Validate the extensions and ensure there are no duplicate names, display names or urls.
     *
     * @throws FatalError
     */
    private function validate(array $extensions = []): void
    {
        $fieldNames = ['name', 'displayname', 'url'];
        $moduleValues = [
            'name' => [],
            'displayname' => [],
            'url' => []
        ];

        // check for duplicate name, display name or url
        foreach ($extensions as $dir => $modInfo) {
            foreach ($fieldNames as $fieldName) {
                $key = mb_strtolower($modInfo[$fieldName]);
                if (!empty($moduleValues[$fieldName][$key]) && !empty($modInfo[$fieldName])) {
                    $message = $this->translator->trans('Fatal error: Two extensions share the same %field%. [%ext1%] and [%ext2%]', [
                        '%field%' => $fieldName,
                        '%ext1%' => $modInfo['name'],
                        '%ext2%' => $moduleValues[$fieldName][$key]
                    ]);
                    throw new FatalError($message, 500, error_get_last());
                }
                $moduleValues[$fieldName][$key] = $dir;
            }
        }
    }

    /**
     * Sync extensions in the filesystem and the extensions table.
     *
     * @return array $upgradedExtensions[<name>] = <version>
     */
    public function syncExtensions(array $extensionsFromFile, bool $forceDefaults = false): array
    {
        // Get all extensions in DB, indexed by name
        $extensionsFromDB = $this->extensionRepository->getIndexedArrayCollection('name');

        // see if any extensions have changed since last regeneration
        $this->syncUpdatedExtensions($extensionsFromFile, $extensionsFromDB, $forceDefaults);

        // See if any extensions have been lost since last sync
        $this->syncLostExtensions($extensionsFromFile, $extensionsFromDB);

        // See any extensions have been gained since last sync,
        // or if any current extensions have been upgraded
        $upgradedExtensions = $this->syncAddedExtensions($extensionsFromFile, $extensionsFromDB);

        // Clear and reload the dependencies table with all current dependencies
        $this->extensionDependencyRepository->reloadExtensionDependencies($extensionsFromFile);

        return $upgradedExtensions;
    }

    /**
     * Sync extensions that are already in the Database.
     *  - update from old names
     *  - update compatibility
     *  - update user settings (or reset to defaults)
     *  - ensure current core compatibility
     */
    private function syncUpdatedExtensions(
        array $extensionsFromFile,
        array &$extensionsFromDB,
        bool $forceDefaults = false
    ): void {
        foreach ($extensionsFromFile as $name => $extensionFromFile) {
            foreach ($extensionsFromDB as $dbname => $extensionFromDB) {
                if (isset($extensionFromDB['name']) && in_array($extensionFromDB['name'], (array)$extensionFromFile['oldnames'], true)) {
                    // migrate its modvars
                    $this->extensionVarRepository->updateName($dbname, $name);
                    // rename the extension register
                    $this->extensionRepository->updateName($dbname, $name);
                    // replace the old extension with the new one in the $extensionsFromDB array
                    $extensionsFromDB[$name] = $extensionFromDB;
                    unset($extensionsFromDB[$dbname]);
                }
            }

            // If extension was previously determined to be incompatible with the core. return to original state
            if (isset($extensionsFromDB[$name]) && $extensionsFromDB[$name]['state'] > 10) {
                $extensionsFromDB[$name]['state'] -= Constant::INCOMPATIBLE_CORE_SHIFT;
                $this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], $extensionsFromDB[$name]['state']);
            }

            // update the DB information for this extension to reflect user settings (e.g. url)
            if (isset($extensionsFromDB[$name]['id'])) {
                $extensionFromFile['id'] = $extensionsFromDB[$name]['id'];
                if (Constant::STATE_UNINITIALISED !== $extensionsFromDB[$name]['state'] && Constant::STATE_INVALID !== $extensionsFromDB[$name]['state']) {
                    unset($extensionFromFile['version']);
                }
                if (!$forceDefaults) {
                    unset($extensionFromFile['displayname'], $extensionFromFile['description'], $extensionFromFile['url']);
                }

                unset($extensionFromFile['oldnames'], $extensionFromFile['dependencies']);

                /** @var ExtensionEntity $extension */
                $extension = $this->extensionRepository->find($extensionFromFile['id']);
                $extension->merge($extensionFromFile);
                $this->extensionRepository->persistAndFlush($extension);
            }

            // check extension core requirement is compatible with current core
            $coreCompatibility = $extensionFromFile['coreCompatibility'];
            if (isset($extensionsFromDB[$name])) {
                if (!Semver::satisfies(ZikulaKernel::VERSION, $coreCompatibility)) {
                    // extension is incompatible with current core
                    $extensionsFromDB[$name]['state'] += Constant::INCOMPATIBLE_CORE_SHIFT;
                    $this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], $extensionsFromDB[$name]['state']);
                }
                if (isset($extensionsFromDB[$name]['state'])) {
                    $extensionFromFile['state'] = $extensionsFromDB[$name]['state'];
                }
            }
        }
    }

    /**
     * Remove extensions from the DB that have been removed from the filesystem.
     */
    private function syncLostExtensions(array $extensionsFromFile, array &$extensionsFromDB): void
    {
        foreach ($extensionsFromDB as $extensionName => $unusedVariable) {
            if ($this->kernel::isCoreExtension($extensionName) || array_key_exists($extensionName, $extensionsFromFile)) {
                continue;
            }

            $lostExtension = $this->extensionRepository->get($extensionName); // must obtain Entity because value from $extensionsFromDB is only an array
            if (!$lostExtension) {
                throw new RuntimeException($this->translator->trans('Error! Could not load data for %extension%.', ['%extension%' => $extensionName]));
            }
            $lostExtensionState = $lostExtension->getState();
            if ((Constant::STATE_INVALID === $lostExtensionState)
                || ($lostExtensionState === Constant::STATE_INVALID + Constant::INCOMPATIBLE_CORE_SHIFT)) {
                // extension was invalid and subsequently removed from file system,
                // or extension was incompatible with core and subsequently removed, delete it
                $this->extensionRepository->removeAndFlush($lostExtension);
            } elseif ((Constant::STATE_UNINITIALISED === $lostExtensionState)
                || ($lostExtensionState === Constant::STATE_UNINITIALISED + Constant::INCOMPATIBLE_CORE_SHIFT)) {
                // extension was uninitialised and subsequently removed from file system, delete it
                $this->extensionRepository->removeAndFlush($lostExtension);
            } else {
                // Set state of extension to 'missing'
                // This state cannot be reached in with an ACTIVE bundle. - ACTIVE bundles are part of the pre-compiled Kernel.
                // extensions that are inactive can be marked as missing.
                $this->extensionStateHelper->updateState($lostExtension->getId(), Constant::STATE_MISSING);
            }

            unset($extensionsFromDB[$extensionName]);
        }
    }

    /**
     * Add extensions to the DB that have been added to the filesystem.
     *  - add uninitialized extensions
     *  - update missing or invalid extensions
     *
     * @return array $upgradedExtensions[<name>] => <version>
     */
    private function syncAddedExtensions(array $extensionsFromFile, array $extensionsFromDB): array
    {
        $upgradedExtensions = [];

        foreach ($extensionsFromFile as $name => $extensionFromFile) {
            if (empty($extensionsFromDB[$name])) {
                $extensionFromFile['state'] = Constant::STATE_UNINITIALISED;
                if (!$extensionFromFile['version']) {
                    // set state to invalid if we can't determine a version
                    $extensionFromFile['state'] = Constant::STATE_INVALID;
                } else {
                    $coreCompatibility = $extensionFromFile['coreCompatibility'];
                    // shift state if extension is incompatible with core version
                    $extensionFromFile['state'] = Semver::satisfies(ZikulaKernel::VERSION, $coreCompatibility)
                        ? $extensionFromFile['state']
                        : $extensionFromFile['state'] + Constant::INCOMPATIBLE_CORE_SHIFT;
                }

                // unset vars that don't matter
                unset($extensionFromFile['oldnames'], $extensionFromFile['dependencies']);

                // insert new extension to db
                $newExtension = new ExtensionEntity();
                $newExtension->merge($extensionFromFile);
                $vetoEvent = new GenericEvent($newExtension);
                $this->dispatcher->dispatch($vetoEvent, ExtensionEvents::INSERT_VETO);
                if (!$vetoEvent->isPropagationStopped()) {
                    $this->extensionRepository->persistAndFlush($newExtension);
                }
            } else {
                // extension is in the db already
                if ((Constant::STATE_MISSING === $extensionsFromDB[$name]['state'])
                    || ($extensionsFromDB[$name]['state'] === Constant::STATE_MISSING + Constant::INCOMPATIBLE_CORE_SHIFT)) {
                    // extension was lost, now it is here again
                    $this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], Constant::STATE_INACTIVE);
                } elseif (((Constant::STATE_INVALID === $extensionsFromDB[$name]['state'])
                        || ($extensionsFromDB[$name]['state'] === Constant::STATE_INVALID + Constant::INCOMPATIBLE_CORE_SHIFT))
                    && $extensionFromFile['version']) {
                    $coreCompatibility = $extensionFromFile['coreCompatibility'];
                    if (Semver::satisfies(ZikulaKernel::VERSION, $coreCompatibility)) {
                        // extension was invalid, now it is valid
                        $this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], Constant::STATE_UNINITIALISED);
                    }
                }

                if ($extensionsFromDB[$name]['version'] !== $extensionFromFile['version']) {
                    if (Constant::STATE_UNINITIALISED !== $extensionsFromDB[$name]['state'] &&
                        Constant::STATE_INVALID !== $extensionsFromDB[$name]['state']) {
                        $this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], Constant::STATE_UPGRADED);
                        $upgradedExtensions[$name] = $extensionFromFile['version'];
                    }
                }
            }
        }

        return $upgradedExtensions;
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			/*
6			* This file is part of the Zikula package.
7			*
8			* Copyright Zikula Foundation - https://ziku.la/
9			*
10			* For the full copyright and license information, please view the LICENSE
11			* file that was distributed with this source code.
12			*/
13
14			namespace Zikula\ExtensionsModule\Helper;
15
16			use Composer\Semver\Semver;
17			use RuntimeException;
18			use Symfony\Component\ErrorHandler\Error\FatalError;
19			use Symfony\Component\Finder\Finder;
20			use Symfony\Component\HttpFoundation\Session\SessionInterface;
21			use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
22			use Symfony\Contracts\Translation\TranslatorInterface;
23			use Zikula\Bundle\CoreBundle\AbstractBundle;
24			use Zikula\Bundle\CoreBundle\Composer\MetaData;
25			use Zikula\Bundle\CoreBundle\Event\GenericEvent;
26			use Zikula\Bundle\CoreBundle\Helper\BundlesSchemaHelper;
27			use Zikula\Bundle\CoreBundle\HttpKernel\ZikulaHttpKernelInterface;
28			use Zikula\Bundle\CoreBundle\HttpKernel\ZikulaKernel;
29			use Zikula\ExtensionsModule\Constant;
30			use Zikula\ExtensionsModule\Entity\ExtensionEntity;
31			use Zikula\ExtensionsModule\Entity\Repository\ExtensionDependencyRepository;
32			use Zikula\ExtensionsModule\Entity\RepositoryInterface\ExtensionRepositoryInterface;
33			use Zikula\ExtensionsModule\Entity\RepositoryInterface\ExtensionVarRepositoryInterface;
34			use Zikula\ExtensionsModule\ExtensionEvents;
35
36			/**
37			* Helper functions for the extensions bundle
38			*/
39			class BundleSyncHelper
40			{
41			/**
42			* @var ZikulaHttpKernelInterface
43			*/
44			private $kernel;
45
46			/**
47			* @var ExtensionRepositoryInterface
48			*/
49			private $extensionRepository;
50
51			/**
52			* @var ExtensionVarRepositoryInterface
53			*/
54			private $extensionVarRepository;
55
56			/**
57			* @var ExtensionDependencyRepository
58			*/
59			private $extensionDependencyRepository;
60
61			/**
62			* @var TranslatorInterface
63			*/
64			private $translator;
65
66			/**
67			* @var EventDispatcherInterface
68			*/
69			private $dispatcher;
70
71			/**
72			* @var ExtensionStateHelper
73			*/
74			private $extensionStateHelper;
75
76			/**
77			* @var BundlesSchemaHelper
78			*/
79			private $bundlesSchemaHelper;
80
81			/**
82			* @var ComposerValidationHelper
83			*/
84			private $composerValidationHelper;
85
86			/**
87			* @var SessionInterface
88			*/
89			protected $session;
90
91			public function __construct(
92			ZikulaHttpKernelInterface $kernel,
93			ExtensionRepositoryInterface $extensionRepository,
94			ExtensionVarRepositoryInterface $extensionVarRepository,
95			ExtensionDependencyRepository $extensionDependencyRepository,
96			TranslatorInterface $translator,
97			EventDispatcherInterface $dispatcher,
98			ExtensionStateHelper $extensionStateHelper,
99			BundlesSchemaHelper $bundlesSchemaHelper,
100			ComposerValidationHelper $composerValidationHelper,
101			SessionInterface $session
102			) {
103			$this->kernel = $kernel;
104			$this->extensionRepository = $extensionRepository;
105			$this->extensionVarRepository = $extensionVarRepository;
106			$this->extensionDependencyRepository = $extensionDependencyRepository;
107			$this->translator = $translator;
108			$this->dispatcher = $dispatcher;
109			$this->extensionStateHelper = $extensionStateHelper;
110			$this->bundlesSchemaHelper = $bundlesSchemaHelper;
111			$this->composerValidationHelper = $composerValidationHelper;
112			$this->session = $session;
113			}
114
115			/**
116			* Scan the extensions directory for bundles and returns an array with all (potential) bundles found.
117			*/
118			public function scanForBundles($includeCore = false): array
119			{
120			// sync the extensions directory and the bundles table
121			$this->bundlesSchemaHelper->load();
122			$scanner = $this->bundlesSchemaHelper->getScanner();
123			foreach ($scanner->getInvalid() as $invalidName) {
124			$this->session->getFlashBag()->add(
125			'warning',
126			$this->translator->trans(
127			'WARNING: %extension% has an invalid composer.json file which could not be decoded.',
128			['%extension%' => $invalidName]
129			)
130			);
131			}
132			$extensions = $scanner->getExtensionsMetaData();
133
134			$bundles = [];
135			$srcDir = $this->kernel->getProjectDir() . '/src/';
136			/** @var MetaData $bundleMetaData */
137			foreach ($extensions as $name => $bundleMetaData) {
138			foreach ($bundleMetaData->getPsr4() as $ns => $path) {
139			$this->kernel->getAutoloader()->addPsr4($ns, $srcDir . $path);
140			}
141
142			$bundleClass = $bundleMetaData->getClass();
143
144			/** @var $bundle \Zikula\Bundle\CoreBundle\AbstractBundle */
145			$bundle = new $bundleClass();
146			$bundleMetaData->setTranslator($this->translator);
147			$bundleVersionArray = $bundleMetaData->getFilteredVersionInfoArray();
148
149			$finder = new Finder();
150			$finder->files()->in($bundle->getPath())->depth(0)->name('composer.json');
151			foreach ($finder as $splFileInfo) {
152			// there will only be one loop here
153			$this->composerValidationHelper->check($splFileInfo);
154			if ($this->composerValidationHelper->isValid()) {
155			$bundles[$bundle->getName()] = $bundleVersionArray;
156			$bundles[$bundle->getName()]['oldnames'] = $bundleVersionArray['oldnames'] ?? '';
157			} else {
158			$this->session->getFlashBag()->add(
159			'error',
160			$this->translator->trans(
161			'Cannot load %extension% because the composer file is invalid.',
162			['%extension%' => $bundle->getName()]
163			)
164			);
165			foreach ($this->composerValidationHelper->getErrors() as $error) {
166			$this->session->getFlashBag()->add('error', $error);
167			}
168			}
169			}
170			}
171
172			if ($includeCore) {
173			$this->appendCoreExtensionsMetaData($bundles);
174			}
175			$this->validate($bundles);
176
177			return $bundles;
178			}
179
180			private function appendCoreExtensionsMetaData(array &$extensions): void
181			{
182			foreach (ZikulaKernel::$coreExtension as $systemModule => $bundleClass) {
183			$bundle = $this->kernel->getBundle($systemModule);
184			if ($bundle instanceof AbstractBundle) {
185			$extensions[$systemModule] = $bundle->getMetaData()->getFilteredVersionInfoArray();
186			}
187			}
188			}
189
190			/**
191			* Validate the extensions and ensure there are no duplicate names, display names or urls.
192			*
193			* @throws FatalError
194			*/
195			private function validate(array $extensions = []): void
196			{
197			$fieldNames = ['name', 'displayname', 'url'];
198			$moduleValues = [
199			'name' => [],
200			'displayname' => [],
201			'url' => []
202			];
203
204			// check for duplicate name, display name or url
205			foreach ($extensions as $dir => $modInfo) {
206			foreach ($fieldNames as $fieldName) {
207			$key = mb_strtolower($modInfo[$fieldName]);
208			if (!empty($moduleValues[$fieldName][$key]) && !empty($modInfo[$fieldName])) {
209			$message = $this->translator->trans('Fatal error: Two extensions share the same %field%. [%ext1%] and [%ext2%]', [
210			'%field%' => $fieldName,
211			'%ext1%' => $modInfo['name'],
212			'%ext2%' => $moduleValues[$fieldName][$key]
213			]);
214			throw new FatalError($message, 500, error_get_last());
215			}
216			$moduleValues[$fieldName][$key] = $dir;
217			}
218			}
219			}
220
221			/**
222			* Sync extensions in the filesystem and the extensions table.
223			*
224			* @return array $upgradedExtensions[<name>] = <version>
225			*/
226			public function syncExtensions(array $extensionsFromFile, bool $forceDefaults = false): array
227			{
228			// Get all extensions in DB, indexed by name
229			$extensionsFromDB = $this->extensionRepository->getIndexedArrayCollection('name');
230
231			// see if any extensions have changed since last regeneration
232			$this->syncUpdatedExtensions($extensionsFromFile, $extensionsFromDB, $forceDefaults);
233
234			// See if any extensions have been lost since last sync
235			$this->syncLostExtensions($extensionsFromFile, $extensionsFromDB);
236
237			// See any extensions have been gained since last sync,
238			// or if any current extensions have been upgraded
239			$upgradedExtensions = $this->syncAddedExtensions($extensionsFromFile, $extensionsFromDB);
240
241			// Clear and reload the dependencies table with all current dependencies
242			$this->extensionDependencyRepository->reloadExtensionDependencies($extensionsFromFile);
243
244			return $upgradedExtensions;
245			}
246
247			/**
248			* Sync extensions that are already in the Database.
249			* - update from old names
250			* - update compatibility
251			* - update user settings (or reset to defaults)
252			* - ensure current core compatibility
253			*/
254			private function syncUpdatedExtensions(
255			array $extensionsFromFile,
256			array &$extensionsFromDB,
257			bool $forceDefaults = false
258			): void {
259			foreach ($extensionsFromFile as $name => $extensionFromFile) {
260			foreach ($extensionsFromDB as $dbname => $extensionFromDB) {
261			if (isset($extensionFromDB['name']) && in_array($extensionFromDB['name'], (array)$extensionFromFile['oldnames'], true)) {
262			// migrate its modvars
263			$this->extensionVarRepository->updateName($dbname, $name);
264			// rename the extension register
265			$this->extensionRepository->updateName($dbname, $name);
266			// replace the old extension with the new one in the $extensionsFromDB array
267			$extensionsFromDB[$name] = $extensionFromDB;
268			unset($extensionsFromDB[$dbname]);
269			}
270			}
271
272			// If extension was previously determined to be incompatible with the core. return to original state
273			if (isset($extensionsFromDB[$name]) && $extensionsFromDB[$name]['state'] > 10) {
274			$extensionsFromDB[$name]['state'] -= Constant::INCOMPATIBLE_CORE_SHIFT;
275			$this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], $extensionsFromDB[$name]['state']);
276			}
277
278			// update the DB information for this extension to reflect user settings (e.g. url)
279			if (isset($extensionsFromDB[$name]['id'])) {
280			$extensionFromFile['id'] = $extensionsFromDB[$name]['id'];
281			if (Constant::STATE_UNINITIALISED !== $extensionsFromDB[$name]['state'] && Constant::STATE_INVALID !== $extensionsFromDB[$name]['state']) {
282			unset($extensionFromFile['version']);
283			}
284			if (!$forceDefaults) {
285			unset($extensionFromFile['displayname'], $extensionFromFile['description'], $extensionFromFile['url']);
286			}
287
288			unset($extensionFromFile['oldnames'], $extensionFromFile['dependencies']);
289
290			/** @var ExtensionEntity $extension */
291			$extension = $this->extensionRepository->find($extensionFromFile['id']);
292			$extension->merge($extensionFromFile);
293			$this->extensionRepository->persistAndFlush($extension);
294			}
295
296			// check extension core requirement is compatible with current core
297			$coreCompatibility = $extensionFromFile['coreCompatibility'];
298			if (isset($extensionsFromDB[$name])) {
299			if (!Semver::satisfies(ZikulaKernel::VERSION, $coreCompatibility)) {
300			// extension is incompatible with current core
301			$extensionsFromDB[$name]['state'] += Constant::INCOMPATIBLE_CORE_SHIFT;
302			$this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], $extensionsFromDB[$name]['state']);
303			}
304			if (isset($extensionsFromDB[$name]['state'])) {
305			$extensionFromFile['state'] = $extensionsFromDB[$name]['state'];
306			}
307			}
308			}
309			}
310
311			/**
312			* Remove extensions from the DB that have been removed from the filesystem.
313			*/
314			private function syncLostExtensions(array $extensionsFromFile, array &$extensionsFromDB): void
315			{
316			foreach ($extensionsFromDB as $extensionName => $unusedVariable) {
317			if ($this->kernel::isCoreExtension($extensionName) \|\| array_key_exists($extensionName, $extensionsFromFile)) {
318			continue;
319			}
320
321			$lostExtension = $this->extensionRepository->get($extensionName); // must obtain Entity because value from $extensionsFromDB is only an array
322			if (!$lostExtension) {
323			throw new RuntimeException($this->translator->trans('Error! Could not load data for %extension%.', ['%extension%' => $extensionName]));
324			}
325			$lostExtensionState = $lostExtension->getState();
326			if ((Constant::STATE_INVALID === $lostExtensionState)
327			\|\| ($lostExtensionState === Constant::STATE_INVALID + Constant::INCOMPATIBLE_CORE_SHIFT)) {
328			// extension was invalid and subsequently removed from file system,
329			// or extension was incompatible with core and subsequently removed, delete it
330			$this->extensionRepository->removeAndFlush($lostExtension);
331			} elseif ((Constant::STATE_UNINITIALISED === $lostExtensionState)
332			\|\| ($lostExtensionState === Constant::STATE_UNINITIALISED + Constant::INCOMPATIBLE_CORE_SHIFT)) {
333			// extension was uninitialised and subsequently removed from file system, delete it
334			$this->extensionRepository->removeAndFlush($lostExtension);
335			} else {
336			// Set state of extension to 'missing'
337			// This state cannot be reached in with an ACTIVE bundle. - ACTIVE bundles are part of the pre-compiled Kernel.
338			// extensions that are inactive can be marked as missing.
339			$this->extensionStateHelper->updateState($lostExtension->getId(), Constant::STATE_MISSING);
340			}
341
342			unset($extensionsFromDB[$extensionName]);
343			}
344			}
345
346			/**
347			* Add extensions to the DB that have been added to the filesystem.
348			* - add uninitialized extensions
349			* - update missing or invalid extensions
350			*
351			* @return array $upgradedExtensions[<name>] => <version>
352			*/
353			private function syncAddedExtensions(array $extensionsFromFile, array $extensionsFromDB): array
354			{
355			$upgradedExtensions = [];
356
357			foreach ($extensionsFromFile as $name => $extensionFromFile) {
358			if (empty($extensionsFromDB[$name])) {
359			$extensionFromFile['state'] = Constant::STATE_UNINITIALISED;
360			if (!$extensionFromFile['version']) {
361			// set state to invalid if we can't determine a version
362			$extensionFromFile['state'] = Constant::STATE_INVALID;
363			} else {
364			$coreCompatibility = $extensionFromFile['coreCompatibility'];
365			// shift state if extension is incompatible with core version
366			$extensionFromFile['state'] = Semver::satisfies(ZikulaKernel::VERSION, $coreCompatibility)
367			? $extensionFromFile['state']
368			: $extensionFromFile['state'] + Constant::INCOMPATIBLE_CORE_SHIFT;
369			}
370
371			// unset vars that don't matter
372			unset($extensionFromFile['oldnames'], $extensionFromFile['dependencies']);
373
374			// insert new extension to db
375			$newExtension = new ExtensionEntity();
376			$newExtension->merge($extensionFromFile);
377			$vetoEvent = new GenericEvent($newExtension);
378			$this->dispatcher->dispatch($vetoEvent, ExtensionEvents::INSERT_VETO);
379			if (!$vetoEvent->isPropagationStopped()) {
380			$this->extensionRepository->persistAndFlush($newExtension);
381			}
382			} else {
383			// extension is in the db already
384			if ((Constant::STATE_MISSING === $extensionsFromDB[$name]['state'])
385			\|\| ($extensionsFromDB[$name]['state'] === Constant::STATE_MISSING + Constant::INCOMPATIBLE_CORE_SHIFT)) {
386			// extension was lost, now it is here again
387			$this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], Constant::STATE_INACTIVE);
388			} elseif (((Constant::STATE_INVALID === $extensionsFromDB[$name]['state'])
389			\|\| ($extensionsFromDB[$name]['state'] === Constant::STATE_INVALID + Constant::INCOMPATIBLE_CORE_SHIFT))
390			&& $extensionFromFile['version']) {
391			$coreCompatibility = $extensionFromFile['coreCompatibility'];
392			if (Semver::satisfies(ZikulaKernel::VERSION, $coreCompatibility)) {
393			// extension was invalid, now it is valid
394			$this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], Constant::STATE_UNINITIALISED);
395			}
396			}
397
398			if ($extensionsFromDB[$name]['version'] !== $extensionFromFile['version']) {
399			if (Constant::STATE_UNINITIALISED !== $extensionsFromDB[$name]['state'] &&
400			Constant::STATE_INVALID !== $extensionsFromDB[$name]['state']) {
401			$this->extensionStateHelper->updateState($extensionsFromDB[$name]['id'], Constant::STATE_UPGRADED);
402			$upgradedExtensions[$name] = $extensionFromFile['version'];
403			}
404			}
405			}
406			}
407
408			return $upgradedExtensions;
409			}
410			}
411

zikula / core

Push — master ( 89c3e8...c161b3 )

BundleSyncHelper::scanForBundles() B

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like