Syndesi/neo4j-sync-bundle

<?php

declare(strict_types=1);

namespace Syndesi\Neo4jSyncBundle\EventListener;

use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Mapping\ClassMetadata;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Syndesi\Neo4jSyncBundle\Event\DatabaseSyncEvent;
use Syndesi\Neo4jSyncBundle\Provider\DatabaseSyncNodeProvider;
use Syndesi\Neo4jSyncBundle\Provider\NodeAttributeProvider;

class DatabaseSyncNodeSubscriber implements EventSubscriberInterface
{
    public function __construct(
        private EntityManagerInterface $em
    ) {
    }

    public static function getSubscribedEvents()
    {
        return [
            DatabaseSyncEvent::NAME => [
                'onDatabaseSync',
                300,
            ],
        ];
    }

    public function onDatabaseSync(DatabaseSyncEvent $databaseSyncEvent): void
    {
        foreach ($this->em->getMetadataFactory()->getAllMetadata() as $metadata) {
            /** @psalm-suppress RedundantConditionGivenDocblockType */
            if ($metadata instanceof ClassMetadata) {
                $className = $metadata->getReflectionClass()->getName();
                $nodeAttribute = (new NodeAttributeProvider())->getNodeAttribute($className);
                if ($nodeAttribute) {
                    $tmpProvider = new DatabaseSyncNodeProvider($className, $this->em, $nodeAttribute, $databaseSyncEvent->getCreateType());
                    $databaseSyncEvent->addPaginatedStatementProvider($tmpProvider);
                }
            }
        }
    }
}