. * * The interactive user interfaces in modified source and object code versions * of this program must display Appropriate Legal Notices, as required under * Section 5 of the GNU Affero General Public License version 3. * * In accordance with Section 7(b) of the GNU Affero General Public License version 3, * these Appropriate Legal Notices must retain the display of the "EspoCRM" word. ************************************************************************/ namespace Espo\Core\Utils; use Espo\Core\Utils\File\Manager as FileManager; use Espo\Core\Utils\Metadata\Builder; use Espo\Core\Utils\Metadata\BuilderHelper; use stdClass; use LogicException; use RuntimeException; /** * Application metadata. */ class Metadata { /** @var ?array */ private ?array $data = null; private ?stdClass $objData = null; private string $cacheKey = 'metadata'; private string $objCacheKey = 'objMetadata'; private string $customPath = 'custom/Espo/Custom/Resources/metadata'; /** @var array> */ private $deletedData = []; /** @var array> */ private $changedData = []; public function __construct( private FileManager $fileManager, private DataCache $dataCache, private Module $module, private Builder $builder, private BuilderHelper $builderHelper, private bool $useCache = false ) {} /** * Init metadata. */ public function init(bool $reload = false): void { if (!$this->useCache) { $reload = true; } if ($this->dataCache->has($this->cacheKey) && !$reload) { /** @var array $data */ $data = $this->dataCache->get($this->cacheKey); $this->data = $data; return; } $this->clearVars(); $objData = $this->getObjData($reload); $this->data = Util::objectToArray($objData); if ($this->useCache) { $this->dataCache->store($this->cacheKey, $this->data); } } /** * Get metadata array. * * @return array */ private function getData(): array { if (empty($this->data) || !is_array($this->data)) { $this->init(); } assert($this->data !== null); return $this->data; } /** * Get metadata by key. * * @param string|string[] $key * @param mixed $default * @return mixed */ public function get($key = null, $default = null) { return Util::getValueByKey($this->getData(), $key, $default); } private function objInit(bool $reload = false): void { if (!$this->useCache) { $reload = true; } if ($this->dataCache->has($this->objCacheKey) && !$reload) { /** @var stdClass $data */ $data = $this->dataCache->get($this->objCacheKey); $this->objData = $data; return; } $this->objData = $this->builder->build(); if ($this->useCache) { $this->dataCache->store($this->objCacheKey, $this->objData); } } private function getObjData(bool $reload = false): stdClass { if (!isset($this->objData) || $reload) { $this->objInit($reload); } assert($this->objData !== null); return $this->objData; } /** * Get metadata with stdClass items. * * @param string|string[] $key * @param mixed $default * @return mixed */ public function getObjects($key = null, $default = null) { $objData = $this->getObjData(); return Util::getValueByKey($objData, $key, $default); } public function getAll(): stdClass { return $this->getObjData(); } /** * Get metadata definition in custom directory. * * @param mixed $default * @return mixed */ public function getCustom(string $key1, string $key2, $default = null) { $filePath = $this->customPath . "/$key1/$key2.json"; if (!$this->fileManager->isFile($filePath)) { return $default; } $fileContent = $this->fileManager->getContents($filePath); return Json::decode($fileContent); } /** * Set and save metadata in custom directory. * The data is not merging with existing data. Use getCustom() to get existing data. * * @param array|stdClass $data */ public function saveCustom(string $key1, string $key2, $data): void { if (is_object($data)) { foreach (get_object_vars($data) as $key => $item) { if ( $item instanceof stdClass && count(get_object_vars($data)) === 0 ) { unset($data->$key); } } } $filePath = $this->customPath . "/$key1/$key2.json"; $changedData = Json::encode($data, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES); $this->fileManager->putContents($filePath, $changedData); $this->init(true); } /** * Set metadata. Will be merged with the current data. * * @param array|scalar|null $data */ public function set(string $key1, string $key2, $data): void { $this->setInternal($key1, $key2, $data); } /** * Set a first-level param. Allows setting empty arrays. * * @since 8.0.6 */ public function setParam(string $key1, string $key2, string $param, mixed $value): void { $this->setInternal($key1, $key2, [$param => $value], true); } /** * @param array|scalar|null $data */ private function setInternal(string $key1, string $key2, $data, bool $allowEmptyArray = false): void { if (!$allowEmptyArray && is_array($data)) { foreach ($data as $key => $item) { if (is_array($item) && empty($item)) { // @todo Revise. unset($data[$key]); } } } $newData = [ $key1 => [ $key2 => $data, ], ]; /** @var array> $mergedChangedData */ $mergedChangedData = Util::merge($this->changedData, $newData); /** @var array $mergedData */ $mergedData = Util::merge($this->getData(), $newData); $this->changedData = $mergedChangedData; $this->data = $mergedData; if (is_array($data)) { $this->undelete($key1, $key2, $data); } } /** * Unset some fields and other stuff in metadata. * * @param string[]|string $unsets Example: `fields.name`. */ public function delete(string $key1, string $key2, $unsets = null): void { if (!is_array($unsets)) { $unsets = (array) $unsets; } switch ($key1) { case 'entityDefs': // Unset related additional fields, e.g. a field with an 'address' type. $defs = $this->get('fields'); $unsetList = $unsets; foreach ($unsetList as $unsetItem) { if (preg_match('/fields\.([^.]+)/', $unsetItem, $matches)) { $field = $matches[1]; $fieldPath = [$key1, $key2, 'fields', $field]; // @todo Revise the need. Additional fields are supposed to exist only in the build? $additionalFields = $this->builderHelper->getAdditionalFields( field: $field, params: $this->get($fieldPath, []), defs: $defs, ); if (is_array($additionalFields)) { foreach ($additionalFields as $additionalFieldName => $additionalFieldParams) { $unsets[] = 'fields.' . $additionalFieldName; } } } } break; } $normalizedData = [ '__APPEND__', ]; $metadataUnsetData = []; foreach ($unsets as $unsetItem) { $normalizedData[] = $unsetItem; $metadataUnsetData[] = implode('.', [$key1, $key2, $unsetItem]); } $unsetData = [ $key1 => [ $key2 => $normalizedData ] ]; /** @var array> $mergedDeletedData */ $mergedDeletedData = Util::merge($this->deletedData, $unsetData); $this->deletedData = $mergedDeletedData; /** @var array> $unsetDeletedData */ /** @noinspection PhpRedundantOptionalArgumentInspection */ $unsetDeletedData = Util::unsetInArrayByValue('__APPEND__', $this->deletedData, true); $this->deletedData = $unsetDeletedData; /** @var array $data */ $data = Util::unsetInArray($this->getData(), $metadataUnsetData, true); $this->data = $data; } /** * @param array $data */ private function undelete(string $key1, string $key2, $data): void { if (isset($this->deletedData[$key1][$key2])) { foreach ($this->deletedData[$key1][$key2] as $unsetIndex => $unsetItem) { $value = Util::getValueByKey($data, $unsetItem); if (isset($value)) { unset($this->deletedData[$key1][$key2][$unsetIndex]); } } } } /** * Clear not saved changes. */ public function clearChanges(): void { $this->changedData = []; $this->deletedData = []; $this->init(true); } /** * Save changes. */ public function save(): bool { $path = $this->customPath; $result = true; if (!empty($this->changedData)) { foreach ($this->changedData as $key1 => $keyData) { foreach ($keyData as $key2 => $data) { if (empty($data)) { continue; } $filePath = $path . "/$key1/$key2.json"; $result &= $this->fileManager->mergeJsonContents($filePath, $data); } } } if (!empty($this->deletedData)) { foreach ($this->deletedData as $key1 => $keyData) { foreach ($keyData as $key2 => $unsetData) { if (empty($unsetData)) { continue; } $filePath = $path . "/$key1/$key2.json"; $rowResult = $this->fileManager->unsetJsonContents($filePath, $unsetData); if (!$rowResult) { throw new LogicException( "Metadata items $key1.$key2 can be deleted for custom code only." ); } } } } if (!$result) { throw new RuntimeException("Error while saving metadata. See log file for details."); } $this->clearChanges(); return (bool) $result; } /** * Get a module list. * * @return string[] */ public function getModuleList(): array { return $this->module->getOrderedList(); } /** * Get a module name a scope belongs to. */ public function getScopeModuleName(string $scopeName): ?string { return $this->get(['scopes', $scopeName, 'module']); } private function clearVars(): void { $this->data = null; } }