Profiler Extension

config/services.yaml

@@ -43,3 +43,6 @@ services:
 
   Neusta\Pimcore\FixtureBundle\ReferenceRepository\:
     resource: '../src/ReferenceRepository/*'
+
+  Neusta\Pimcore\FixtureBundle\Profiler\:
+    resource: '../src/Profiler/*'

src/EventListener/PimcoreLoadOptimization.php

@@ -41,8 +41,6 @@ public function beforeCommand(): void
 
         $this->originalSqlLogger = Db::getConnection()->getConfiguration()->getSQLLogger();
         Db::getConnection()->getConfiguration()->setSQLLogger(null);
-
-        $this->profilerDisabler->disable();
     }
 
     public function afterCommand(): void

src/Profiler/DataCollector/FixtureLoaderCollector.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\DataCollector;
+
+use Neusta\Pimcore\FixtureBundle\Profiler\FixtureReference\FixtureReference;
+use Neusta\Pimcore\FixtureBundle\Profiler\FixtureReference\FixtureReferenceResolver;
+use Neusta\Pimcore\FixtureBundle\Profiler\PerformanceInfo\PerformanceInfo;
+use Neusta\Pimcore\FixtureBundle\Profiler\Timing\TimingCollector;
+use Symfony\Bundle\FrameworkBundle\DataCollector\AbstractDataCollector;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+
+class FixtureLoaderCollector extends AbstractDataCollector
+{
+    public function __construct(
+        private readonly FixtureReferenceResolver $fixtureReferenceResolver,
+        private readonly TimingCollector $timingCollector,
+    ) {
+    }
+
+    public function collect(Request $request, Response $response, ?\Throwable $exception = null): void
+    {
+        $this->data['timings'] = $this->timingCollector->getAll();
+
+        $this->data['references'] = $this->fixtureReferenceResolver->getRootReferences();
+    }
+
+    public static function getTemplate(): ?string
+    {
+        return '@NeustaPimcoreFixture/data_collector/template.html.twig';
+    }
+
+    public function getDependencyFreeFixtures(): array
+    {
+        return $this->data['references'];
+    }
+
+    public function getTiming(FixtureReference $fixtureReference): PerformanceInfo
+    {
+        return $this->data['timings'][$fixtureReference->getName()];
+    }
+
+    /**
+     * @return array<class-string, PerformanceInfo>
+     */
+    public function getTimings(): array
+    {
+        return $this->data['timings'];
+    }
+}

src/Profiler/EventListener/FixtureDependencyGraphSubscriber.php

@@ -0,0 +1,36 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\EventListener;
+
+use Neusta\Pimcore\FixtureBundle\Event\AfterLoadFixtures;
+use Neusta\Pimcore\FixtureBundle\Event\BeforeExecuteFixture;
+use Neusta\Pimcore\FixtureBundle\Profiler\FixtureReference\FixtureReferenceResolver;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+class FixtureDependencyGraphSubscriber implements EventSubscriberInterface
+{
+    private array $loadedFixtures = [];
+
+    public function __construct(
+        private readonly FixtureReferenceResolver $fixtureReferenceResolver,
+    ) {
+    }
+
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            BeforeExecuteFixture::class => ['beforeExecuteFixture', 10],
+            AfterLoadFixtures::class => 'afterLoadFixtures',
+        ];
+    }
+
+    public function beforeExecuteFixture(BeforeExecuteFixture $event): void
+    {
+        $this->loadedFixtures[] = $event->fixture;
+    }
+
+    public function afterLoadFixtures(): void
+    {
+        $this->fixtureReferenceResolver->setFixtures($this->loadedFixtures);
+    }
+}

src/Profiler/EventListener/TimingSubscriber.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\EventListener;
+
+use Neusta\Pimcore\FixtureBundle\Event\AfterExecuteFixture;
+use Neusta\Pimcore\FixtureBundle\Event\BeforeExecuteFixture;
+use Neusta\Pimcore\FixtureBundle\Profiler\Timing\Timing;
+use Neusta\Pimcore\FixtureBundle\Profiler\Timing\TimingCollector;
+use Symfony\Component\EventDispatcher\EventSubscriberInterface;
+
+class TimingSubscriber implements EventSubscriberInterface
+{
+    public function __construct(
+        private readonly Timing $timing,
+        private readonly TimingCollector $timingCollector,
+    ) {
+    }
+
+    public static function getSubscribedEvents(): array
+    {
+        return [
+            BeforeExecuteFixture::class => 'beforeExecuteFixture',
+            AfterExecuteFixture::class => 'afterExecuteFixture',
+        ];
+    }
+
+    public function beforeExecuteFixture(BeforeExecuteFixture $event): void
+    {
+        $this->timing->beforeExecuteFixture($event->fixture);
+    }
+
+    public function afterExecuteFixture(AfterExecuteFixture $event): void
+    {
+        $this->timing->afterExecuteFixture($event->fixture);
+
+        $this->timingCollector->add($event->fixture, $this->timing->getPerformanceInfo($event->fixture));
+    }
+}

src/Profiler/FixtureReference/FixtureReference.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\FixtureReference;
+
+use Neusta\Pimcore\FixtureBundle\Fixture\Fixture;
+
+class FixtureReference
+{
+    /** @var class-string */
+    private string $fixtureFqcn;
+    /** @var list<FixtureReference> */
+    private array $dependencies = [];
+    /** @var list<FixtureReference> */
+    private array $dependants = [];
+
+    public function __construct(Fixture $fixture)
+    {
+        $this->fixtureFqcn = get_class($fixture);
+    }
+
+    /**
+     * @return class-string
+     */
+    public function getName(): string
+    {
+        return $this->fixtureFqcn;
+    }
+
+    public function addDependencyReference(FixtureReference $dependency): void
+    {
+        $this->dependencies[] = $dependency;
+    }
+
+    public function addDependantReference(FixtureReference $fixtureReference): void
+    {
+        $this->dependants[] = $fixtureReference;
+    }
+
+    public function getDependencies(): array
+    {
+        return $this->dependencies;
+    }
+
+    public function hasDependencies(): bool
+    {
+        return !empty($this->dependencies);
+    }
+
+    public function getDependants(): array
+    {
+        return $this->dependants;
+    }
+
+    public function hasDependants(): bool
+    {
+        return !empty($this->dependants);
+    }
+}

src/Profiler/FixtureReference/FixtureReferenceResolver.php

@@ -0,0 +1,101 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\FixtureReference;
+
+use Neusta\Pimcore\FixtureBundle\Fixture\Fixture;
+use Neusta\Pimcore\FixtureBundle\Fixture\HasDependencies;
+
+class FixtureReferenceResolver
+{
+    /** @var array<class-string, FixtureReference> */
+    private array $allReferences;
+    /** @var list<FixtureReference> */
+    private array $rootReferences;
+
+    /**
+     * @param array<Fixture> $loadedFixtures
+     * @return void
+     */
+    public function setFixtures(array $loadedFixtures): void
+    {
+        $this->initAllReferences($loadedFixtures);
+        $this->resolveDependencies($this->createIndexedListOfFixtures($loadedFixtures));
+        $this->collectRootReferences();
+    }
+
+    private function initAllReferences(array $loadedFixtures): void
+    {
+        $this->allReferences = [];
+
+        foreach ($loadedFixtures as $fixture) {
+            $fixtureReference = new FixtureReference($fixture);
+            $this->allReferences[$fixtureReference->getName()] = $fixtureReference;
+        }
+    }
+
+    /**
+     * @param array<Fixture> $loadedFixtures
+     * @return array<class-string, Fixture>
+     */
+    private function createIndexedListOfFixtures(array $loadedFixtures): array
+    {
+        $indexedList = [];
+
+        foreach ($loadedFixtures as $fixture) {
+            $indexedList[get_class($fixture)] = $fixture;
+        }
+
+        return $indexedList;
+    }
+
+    /**
+     * @param array<class-string, Fixture> $indexedListOfFixtures
+     * @return void
+     */
+    private function resolveDependencies(array $indexedListOfFixtures): void
+    {
+        foreach ($this->allReferences as $name => $reference) {
+            $this->collect($reference, $indexedListOfFixtures[$name]);
+        }
+    }
+
+    private function collect(FixtureReference $fixtureReference, Fixture $fixture): void
+    {
+        if (!$fixture instanceof HasDependencies) {
+            return;
+        }
+
+        foreach ($fixture->getDependencies() as $dependencyFixtureFqcn) {
+            $dependencyReference = $this->allReferences[$dependencyFixtureFqcn];
+            $fixtureReference->addDependencyReference($dependencyReference);
+            $dependencyReference->addDependantReference($fixtureReference);
+        }
+    }
+
+    private function collectRootReferences(): void
+    {
+        $this->rootReferences = [];
+
+        foreach ($this->allReferences as $reference) {
+            if (!$reference->hasDependants()) {
+                $this->rootReferences[] = $reference;
+            }
+        }
+    }
+
+    /**
+     * @return array<class-string, FixtureReference>
+     */
+    public function getAllReferences(): array
+    {
+        return $this->allReferences;
+    }
+
+    /**
+     * @return list<FixtureReference>
+     */
+    public function getRootReferences(): array
+    {
+        return $this->rootReferences;
+    }
+}

src/Profiler/PerformanceInfo/PerformanceInfo.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\PerformanceInfo;
+
+class PerformanceInfo
+{
+    public function __construct(
+        public readonly float $duration,
+        public readonly int $memory,
+    ) {
+    }
+}

src/Profiler/Timing/Timing.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\Timing;
+
+use Neusta\Pimcore\FixtureBundle\Fixture\Fixture;
+use Neusta\Pimcore\FixtureBundle\Profiler\PerformanceInfo\PerformanceInfo;
+use Symfony\Component\Stopwatch\Stopwatch;
+
+class Timing
+{
+    private const STOPWATCH_NAME_PREFIX = 'fixture:';
+    private const STOPWATCH_CATEGORY = 'execute';
+
+    public function __construct(
+        private readonly Stopwatch $stopwatch,
+    ) {
+    }
+
+    public function beforeExecuteFixture(Fixture $fixture): void
+    {
+        $this->stopwatch->start($this->stopWatchName($fixture), self::STOPWATCH_CATEGORY);
+    }
+
+    public function afterExecuteFixture(Fixture $fixture): void
+    {
+        $this->stopwatch->stop($this->stopWatchName($fixture));
+    }
+
+    private function stopWatchName(Fixture $fixture): string
+    {
+        $fixtureName = (new \ReflectionClass($fixture))->getShortName();
+
+        return sprintf(
+            '%s%s',
+            self::STOPWATCH_NAME_PREFIX,
+            $fixtureName
+        );
+    }
+
+    public function getPerformanceInfo(Fixture $fixture): PerformanceInfo
+    {
+        try {
+            $event = $this->stopwatch->getEvent($this->stopWatchName($fixture));
+        } catch (\LogicException) {
+            return new PerformanceInfo(-1, -1);
+        }
+
+        return new PerformanceInfo(
+            $event->getDuration(),
+            $event->getMemory(),
+        );
+    }
+
+}

src/Profiler/Timing/TimingCollector.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace Neusta\Pimcore\FixtureBundle\Profiler\Timing;
+
+use Neusta\Pimcore\FixtureBundle\Fixture\Fixture;
+use Neusta\Pimcore\FixtureBundle\Profiler\PerformanceInfo\PerformanceInfo;
+
+class TimingCollector
+{
+    /** @var array<class-string, PerformanceInfo> */
+    private array $timings = [];
+
+    public function add(Fixture $fixture, PerformanceInfo $performanceInfo): void
+    {
+        $this->timings[get_class($fixture)] = $performanceInfo;
+    }
+
+    /**
+     * @return array<class-string, PerformanceInfo>
+     */
+    public function getAll(): array
+    {
+        return $this->timings;
+    }
+}