chill-bundles/src/Bundle/ChillPersonBundle/Actions/Remove/Handler/PersonMoveRelationHandler.php

<?php

declare(strict_types=1);

/*
 * Chill is a software for social workers
 *
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 */

namespace Chill\PersonBundle\Actions\Remove\Handler;

use Chill\PersonBundle\Actions\Remove\PersonMoveSqlHandlerInterface;
use Chill\PersonBundle\Entity\Person;
use Chill\PersonBundle\Entity\Relationships\Relationship;

class PersonMoveRelationHandler implements PersonMoveSqlHandlerInterface
{
    public function supports(string $className, string $field): bool
    {
        return $className === Relationship::class;
    }

    public function getSqls(string $className, string $field, Person $from, Person $to): array
    {
        $insertSql = sprintf(<<<'SQL'
            INSERT INTO chill_person_relationships (id, relation_id, reverse, fromperson_id, toperson_id)
                SELECT nextval('chill_person_relationships_id_seq'), relation_id, reverse, fromperson_id, toperson_id
                    FROM chill_person_relationships cpr
                    WHERE fromperson_id = %d OR toperson_id = %d
                        AND NOT EXISTS (
                        SELECT 1 FROM chill_person_relationships cpr2
                                 WHERE
                                     cpr2.fromperson_id = %d AND cpr2.toperson_id = %d
                                    OR cpr2.fromperson_id = %d AND cpr2.toperson_id = %d
                                 );
        SQL, $from->getId(), $from->getId(), $to->getId(), $from->getId(), $from->getId(), $to->getId());

        $deleteSql = [
            sprintf("DELETE FROM chill_person_relationships WHERE fromperson_id = %d", $from->getId()),
            sprintf("DELETE FROM chill_person_relationships WHERE toperson_id = %d", $from->getId())
        ];

        return [$insertSql, ...$deleteSql];
    }
}