Maslosoft\Mangan\Helpers\IndexManager

Complexity

Total Complexity

13

Size/Duplication

Total Lines	113
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	fly()	0	8	2
B	create()	0	56	9
A	getStoragePath()	0	17	2

<?php
/**
 * Created by PhpStorm.
 * User: peter
 * Date: 17.12.17
 * Time: 14:36
 */

namespace Maslosoft\Mangan\Helpers;

use Maslosoft\Addendum\Addendum;
use Maslosoft\Addendum\Helpers\SoftIncluder;
use Maslosoft\Addendum\Interfaces\AnnotatedInterface;
use Maslosoft\Cli\Shared\Helpers\PhpExporter;
use Maslosoft\Mangan\Helpers\Index\IndexModel;
use Maslosoft\Mangan\Mangan;
use Maslosoft\Mangan\Meta\DocumentPropertyMeta;
use Maslosoft\Mangan\Meta\ManganMeta;
use Maslosoft\ManganTest\Extensions\IndexMetaCleaner;

class IndexManager
{
	const IndexTypeHashed = 'hashed';
	const IndexType2dSphere = '2dsphere';

	const DefaultInstanceId = 'indexManager';

	private static $instances = [];

	private static $paths = [];

	private static $haveIndex = [];

	/**
	 * NOTE: This is public because of IndexMetaCleaner testing extension
	 *
	 * @see IndexMetaCleaner
	 * @internal
	 * @var bool
	 */
	public static $haveDir = false;

	/**
	 * Create flyweight instance of index manager
	 * @param string $instanceId
	 * @return static
	 */
	public static function fly($instanceId = self::DefaultInstanceId)
	{
		if (empty(self::$instances[$instanceId]))
		{
			self::$instances[$instanceId] = new static();
		}
		return self::$instances[$instanceId];
	}

	public function create(AnnotatedInterface $model)
	{
		$className = get_class($model);

		// If have or don't have indexes skip further checks
		if(array_key_exists($className, self::$haveIndex))
		{
			return self::$haveIndex[$className];
		}

		$fieldMetas = ManganMeta::create($model)->fields('index');

The call to ManganMeta::fields() has too many arguments starting with 'index'.

		// Does not have indexes, mark as index-less
		if(empty($fieldMetas))
		{
			self::$haveIndex[$className] = false;
			return false;
		}

		$path = $this->getStoragePath($model, $className);

		$data = SoftIncluder::includeFile($path);

		if(!empty($data))
		{
			return true;
		}
		$results = [];
		$indexes = [];
		foreach($fieldMetas as $fieldMeta)
		{
			if(empty($fieldMeta->index))
			{
				continue;
			}
			/* @var $fieldMeta DocumentPropertyMeta */

			foreach($fieldMeta->index as $indexMeta)
			{
				$index = new IndexModel($model, $indexMeta);
				$results[] = (int)$index->apply();
				$indexes[] = $index->getIndexes();
			}
		}
		self::$haveIndex[$className] = true;

		$dir = dirname($path);
		if(!self::$haveDir && !file_exists($dir))
		{
			self::$haveDir = mkdir($dir);
		}

		file_put_contents($path, PhpExporter::export($indexes, 'Auto generated, do not modify'));

		return array_sum($results) === count($results);
	}

	public function getStoragePath(AnnotatedInterface $model, $className)
	{
		if(empty(self::$paths[$className]))
		{
			$mn = Mangan::fromModel($model);

			$params = [
				Addendum::fly()->runtimePath,
				str_replace('\\', '.', static::class),
				$mn->connectionId,
				$mn->dbName,
				str_replace('\\', '.', $className),
];
			self::$paths[$className] = vsprintf('%s/%s/%s.%s@%s.php', $params);
		}
		return self::$paths[$className];
	}


}