mirror of
https://github.com/Icinga/icingadb-web.git
synced 2026-05-28 04:36:06 -04:00
fb9c2b65fa
Add explicit return types to `ipl-orm`-derived methods to prepare for strict
typing. These additions are safe, as they only annotate existing methods that
previously lacked return type declarations.
(cherry picked from commit f8d4f92566)
96 lines
2.9 KiB
PHP
96 lines
2.9 KiB
PHP
<?php
|
|
|
|
/* Icinga DB Web | (c) 2024 Icinga GmbH | GPLv2 */
|
|
|
|
namespace Icinga\Module\Icingadb\Model\Behavior;
|
|
|
|
use Icinga\Module\Icingadb\Model\DependencyEdge;
|
|
use ipl\Orm\AliasedExpression;
|
|
use ipl\Orm\ColumnDefinition;
|
|
use ipl\Orm\Exception\InvalidColumnException;
|
|
use ipl\Orm\Query;
|
|
use ipl\Sql\Expression;
|
|
use ipl\Stdlib\Filter;
|
|
use ipl\Orm\Contract\RewriteColumnBehavior;
|
|
use ipl\Orm\Contract\QueryAwareBehavior;
|
|
|
|
/**
|
|
* Behavior to check if the service has a problematic parent
|
|
*/
|
|
class HasProblematicParent implements RewriteColumnBehavior, QueryAwareBehavior
|
|
{
|
|
/** @var Query */
|
|
protected $query;
|
|
|
|
public function setQuery(Query $query): static
|
|
{
|
|
$this->query = $query;
|
|
|
|
return $this;
|
|
}
|
|
|
|
public function rewriteColumn($column, ?string $relation = null): ?AliasedExpression
|
|
{
|
|
if (! $this->isSelectableColumn($column)) {
|
|
return null;
|
|
}
|
|
|
|
$resolver = $this->query->getResolver();
|
|
if ($relation !== null) {
|
|
$serviceTableAlias = $resolver->getAlias($resolver->resolveRelation($relation)->getTarget());
|
|
$column = $resolver->qualifyColumnAlias($column, $serviceTableAlias);
|
|
} else {
|
|
$serviceTableAlias = $resolver->getAlias($this->query->getModel());
|
|
}
|
|
|
|
$subQueryModel = new DependencyEdge();
|
|
$subQuery = (new Query())
|
|
->setDb($this->query->getDb())
|
|
->setModel($subQueryModel)
|
|
->columns([new Expression('1')])
|
|
->utilize('from')
|
|
->limit(1)
|
|
->filter(Filter::equal('state.failed', 'y'));
|
|
|
|
$subQueryResolver = $subQuery->getResolver()->setAliasPrefix('hpp_');
|
|
$subQueryTarget = $subQueryResolver->resolveRelation($subQueryModel->getTableName() . '.from')->getTarget();
|
|
$targetForeignKey = $subQueryResolver->qualifyColumn(
|
|
'service_id',
|
|
$subQueryResolver->getAlias($subQueryTarget)
|
|
);
|
|
|
|
$subQuery->getSelectBase()
|
|
->where("$targetForeignKey = {$resolver->qualifyColumn('id', $serviceTableAlias)}");
|
|
|
|
[$select, $values] = $this->query->getDb()
|
|
->getQueryBuilder()
|
|
->assembleSelect($subQuery->assembleSelect());
|
|
|
|
return new AliasedExpression(
|
|
$this->query->getDb()->quoteIdentifier([$column]),
|
|
"($select)",
|
|
null,
|
|
...$values
|
|
);
|
|
}
|
|
|
|
public function isSelectableColumn(string $name): bool
|
|
{
|
|
return $name === 'has_problematic_parent';
|
|
}
|
|
|
|
public function rewriteColumnDefinition(ColumnDefinition $def, string $relation): void
|
|
{
|
|
}
|
|
|
|
public function rewriteCondition(Filter\Condition $condition, $relation = null): null
|
|
{
|
|
$column = substr($condition->getColumn(), strlen($relation ?? ''));
|
|
|
|
if ($this->isSelectableColumn($column)) {
|
|
throw new InvalidColumnException($column, $this->query->getModel());
|
|
}
|
|
|
|
return null;
|
|
}
|
|
}
|