vendor/terminal42/notification_center/src/Config/ConfigLoader.php line 115

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Terminal42\NotificationCenterBundle\Config;
  7. use Contao\DcaLoader;
  8. use Contao\StringUtil;
  9. use Doctrine\DBAL\Connection;
  10. use Symfony\Contracts\Service\ResetInterface;
  12. class ConfigLoader implements ResetInterface
  13. {
  14. /**
  15. * @var array<string, array<int, array<string, mixed>>>
  16. */
  17. private array $cache = [];
  19. public function __construct(private readonly Connection $connection)
  20. {
  21. }
  23. public function loadGateway(int $id): GatewayConfig|null
  24. {
  25. return $this->loadConfig($id, 'tl_nc_gateway', GatewayConfig::class);
  26. }
  28. public function loadNotification(int $id): NotificationConfig|null
  29. {
  30. return $this->loadConfig($id, 'tl_nc_notification', NotificationConfig::class);
  31. }
  33. public function loadMessage(int $id): MessageConfig|null
  34. {
  35. return $this->loadConfig($id, 'tl_nc_message', MessageConfig::class);
  36. }
  38. public function loadModule(int $id): ModuleConfig|null
  39. {
  40. return $this->loadConfig($id, 'tl_module', ModuleConfig::class);
  41. }
  43. public function loadForm(int $id): FormConfig|null
  44. {
  45. return $this->loadConfig($id, 'tl_form', FormConfig::class);
  46. }
  48. /**
  49. * @return array<MessageConfig>
  50. */
  51. public function loadMessagesForNotification(int $notificationId): array
  52. {
  53. $messages = [];
  55. $query = $this->connection->createQueryBuilder()
  56. ->select('*')
  57. ->from('tl_nc_message')
  58. ->where('pid = :pid')
  59. ->setParameter('pid', $notificationId)
  60. ->orderBy('sorting')
  61. ;
  63. foreach ($query->fetchAllAssociative() as $row) {
  64. $row = $this->cleanParameters($row, 'tl_nc_message');
  66. $this->cache['tl_nc_message'][$row['id']] = $row;
  68. $messages[] = MessageConfig::fromArray($row);
  69. }
  71. return $messages;
  72. }
  74. public function loadLanguage(int $id): LanguageConfig|null
  75. {
  76. return $this->loadConfig($id, 'tl_nc_language', LanguageConfig::class);
  77. }
  79. public function loadLanguageForMessageAndLocale(int $messageId, string|null $locale = null): LanguageConfig|null
  80. {
  81. $query = $this->connection->createQueryBuilder()
  82. ->select('*')
  83. ->from('tl_nc_language')
  84. ->where('pid = :pid')
  85. ->setParameter('pid', $messageId)
  86. ;
  88. if (null === $locale) {
  89. $query
  90. ->andWhere('fallback = :fallback')
  91. ->setParameter('fallback', true)
  92. ;
  93. } else {
  94. $localeWithoutRegion = substr($locale, 0, 2);
  95. $query
  96. ->andWhere('language = :locale OR language = :localeWithoutRegion OR fallback = :fallback')
  97. ->orderBy('LENGTH(language) DESC, fallback') // First the exact match with region, then without region, then fallback
  98. ->setParameter('locale', $locale)
  99. ->setParameter('localeWithoutRegion', $localeWithoutRegion)
  100. ->setParameter('fallback', true)
  101. ;
  102. }
  104. $parameters = $query->fetchAssociative();
  106. if (false === $parameters) {
  107. return null;
  108. }
  110. $parameters = $this->cleanParameters($parameters, 'tl_nc_language');
  112. return LanguageConfig::fromArray($parameters);
  113. }
  115. public function reset(): void
  116. {
  117. $this->cache = [];
  118. }
  120. /**
  121. * @template T of AbstractConfig
  122. *
  123. * @param class-string<T> $className
  124. *
  125. * @return T|null
  126. */
  127. private function loadConfig(int $id, string $table, string $className): AbstractConfig|null
  128. {
  129. if (null === ($parameters = $this->loadParameters($id, $table))) {
  130. return null;
  131. }
  133. return $className::fromArray($parameters);
  134. }
  136. /**
  137. * @return array<string, mixed>|null
  138. */
  139. private function loadParameters(int $id, string $table): array|null
  140. {
  141. if (isset($this->cache[$table][$id])) {
  142. return $this->cache[$table][$id];
  143. }
  145. if (!isset($this->cache[$table])) {
  146. $this->cache[$table] = [];
  147. }
  149. try {
  150. $parameters = $this->connection->createQueryBuilder()
  151. ->select('*')
  152. ->from($table)
  153. ->where('id = :id')
  154. ->setParameter('id', $id)
  155. ->fetchAssociative()
  156. ;
  158. if (false === $parameters) {
  159. return $this->cache[$table][$id] = null;
  160. }
  162. $parameters = $this->cleanParameters($parameters, $table);
  164. return $this->cache[$table][$id] = $parameters;
  165. } catch (\Exception) {
  166. return $this->cache[$table][$id] = null;
  167. }
  168. }
  170. /**
  171. * @param array<mixed> $parameters
  172. *
  173. * @return array<mixed>
  174. */
  175. private function cleanParameters(array $parameters, string $table): array
  176. {
  177. $cleanedParameters = [];
  179. try {
  180. $dcaLoader = new DcaLoader($table);
  181. $dcaLoader->load();
  183. foreach ($parameters as $field => $parameter) {
  184. $cleanedParameters[$field] = $parameter;
  186. if (($GLOBALS['TL_DCA'][$table]['fields'][$field]['eval']['decodeEntities'] ?? false) && \is_string($parameter)) {
  187. $cleanedParameters[$field] = StringUtil::decodeEntities($parameter);
  188. }
  189. }
  190. } catch (\Exception) {
  191. $cleanedParameters = $parameters;
  192. }
  194. return $cleanedParameters;
  195. }
  196. }