* @author Alexander Pankratov * @copyright 2016-2024 Daniil Gentili * @copyright 2016-2024 Alexander Pankratov * @license https://opensource.org/license/apache-2-0 Apache 2.0 * @link https://github.com/danog/AsyncOrm AsyncOrm documentation */ namespace danog\AsyncOrm; use danog\AsyncOrm\Annotations\OrmMappedArray; use danog\AsyncOrm\Internal\Driver\CachedArray; use danog\AsyncOrm\Settings\DriverSettings; use danog\AsyncOrm\Settings\MysqlSettings; use ReflectionClass; use function Amp\async; use function Amp\Future\await; /** * Trait that provides autoconfiguration of OrmMappedArray properties. * * @api */ trait DbAutoProperties { /** @var list */ private array $properties = []; /** @return list<\ReflectionProperty> */ private function getDbAutoProperties(): array { $res = []; foreach ((new ReflectionClass(static::class))->getProperties() as $property) { $attr = $property->getAttributes(OrmMappedArray::class); if (!$attr) { continue; } $res []= $property; } return $res; } /** * Initialize database properties. */ public function initDbProperties(Settings $settings, string $tablePrefix): void { $this->properties = []; $promises = []; foreach ($this->getDbAutoProperties() as $property) { $attr = $property->getAttributes(OrmMappedArray::class); \assert(\count($attr) !== 0); $attr = $attr[0]->newInstance(); if ($settings instanceof DriverSettings) { $ttl = $attr->cacheTtl ?? $settings->cacheTtl; if ($ttl !== $settings->cacheTtl) { $settings = new $settings(...\array_merge( (array) $settings, ['cacheTtl' => $ttl] )); } $serializer = $attr->serializer ?? $settings->serializer; if ($serializer !== $settings->serializer) { $settings = new $settings(...\array_merge( (array) $settings, ['serializer' => $serializer] )); } if ($settings instanceof MysqlSettings) { $optimize = $attr->optimizeIfWastedMb ?? $settings->optimizeIfWastedMb; if ($optimize !== $settings->optimizeIfWastedMb) { $settings = new $settings(...\array_merge( (array) $settings, ['optimizeIfWastedMb' => $optimize] )); } } } $config = new DbArrayBuilder( $tablePrefix.($attr->tablePostfix ?? $property->getName()), $settings, $attr->keyType, $attr->valueType, ); $promises[] = async(function () use ($config, $property) { $v = $config->build( $property->isInitialized($this) ? $property->getValue($this) : null ); $property->setValue($this, $v); if ($v instanceof CachedArray) { $this->properties []= $v; } }); } await($promises); } /** * Save all properties. */ public function saveDbProperties(): void { $futures = []; foreach ($this->properties as $prop) { $futures []= async($prop->flushCache(...)); } await($futures); } }