Mirrors/shlink
1
0
Fork 0
mirror of https://github.com/shlinkio/shlink.git synced 2026-02-28 04:03:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

Validate topic names in RealTimeUpdateOptions

Browse Source
This commit is contained in:
Alejandro Celaya
2025-07-03 14:34:27 +02:00
parent fb995f2bea
commit 240d9df177
1 changed files with 29 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
module/Core/src/Config/Options/RealTimeUpdatesOptions.php
View File

@@ -6,13 +6,18 @@ namespace Shlinkio\Shlink\Core\Config\Options;
use Shlinkio\Shlink\Core\Config\EnvVars;
use Shlinkio\Shlink\Core\EventDispatcher\Topic;
use Shlinkio\Shlink\Core\Exception\ValidationException;
use function count;
use function implode;
use function Shlinkio\Shlink\Core\ArrayUtils\contains;
use function Shlinkio\Shlink\Core\ArrayUtils\map;
use function Shlinkio\Shlink\Core\splitByComma;
use function sprintf;
final readonly class RealTimeUpdatesOptions
{
/** @var string[] */
public array $enabledTopics;
public function __construct(array|null $enabledTopics = null)
@@ -23,15 +28,35 @@ final readonly class RealTimeUpdatesOptions
public static function fromEnv(): self
{
$enabledTopics = splitByComma(EnvVars::REAL_TIME_UPDATES_TOPICS->loadFromEnv());
$validTopics = Topic::allTopicNames();
return new self(
enabledTopics: count($enabledTopics) === 0
? Topic::allTopicNames()
// TODO Validate provided topics are in fact Topic names
: splitByComma(EnvVars::REAL_TIME_UPDATES_TOPICS->loadFromEnv()),
enabledTopics: count($enabledTopics) === 0 ? $validTopics : self::topicsFromEnv($validTopics),
);
}
/**
* @param string[] $validTopics
* @return string[]
*/
private static function topicsFromEnv(array $validTopics): array
{
$topics = splitByComma(EnvVars::REAL_TIME_UPDATES_TOPICS->loadFromEnv());
return map($topics, function (string $topic) use ($validTopics): string {
if (contains($topic, $validTopics)) {
return $topic;
}
throw ValidationException::fromArray([
'topic' => sprintf(
'Real-time updates topic "%s" is not valid. Expected one of ["%s"].',
$topic,
implode('", "', $validTopics),
),
]);
});
}
public function isTopicEnabled(Topic $topic): bool
{
return contains($topic->name, $this->enabledTopics);