Refactor summary data structure

src/Collector/CollectorInterface.php

@@ -11,6 +11,7 @@ interface CollectorInterface
 {
     /**
      * @return string Collector's name.
+     * @psalm-return non-empty-string
      */
     public function getName(): string;
 

src/Collector/CollectorTrait.php

@@ -4,6 +4,9 @@
 
 namespace Yiisoft\Yii\Debug\Collector;
 
+/**
+ * @psalm-require-implements CollectorInterface
+ */
 trait CollectorTrait
 {
     private bool $isActive = false;
@@ -15,10 +18,13 @@
 
     public function shutdown(): void
     {
         $this->reset();
         $this->isActive = false;
     }
 
+    /**
+     * @psalm-return non-empty-string
+     */
     public function getName(): string
     {
         return self::class;

src/Collector/Console/CommandCollector.php

@@ -56,7 +56,7 @@
             return;
         }
 
         $this->timelineCollector->collect($this, spl_object_id($event));
 
         $command = $event->getCommand();
 
@@ -75,7 +75,7 @@
 
         if ($event instanceof ConsoleTerminateEvent) {
             $this->commands[$event::class] = [
                 'name' => $command?->getName() ?? $event->getInput()->getFirstArgument() ?? '',
                 'command' => $command,
                 'input' => $this->castInputToString($event->getInput()),
                 'output' => $this->fetchOutput($event->getOutput()),
@@ -86,7 +86,7 @@
 
         $definition = $command?->getDefinition();
         $this->commands[$event::class] = [
             'name' => $command?->getName() ?? $event->getInput()->getFirstArgument() ?? '',
             'command' => $command,
             'input' => $this->castInputToString($event->getInput()),
             'output' => $this->fetchOutput($event->getOutput()),
@@ -117,13 +117,11 @@
             return [];
         }
 
         return [
-            'command' => [
-                'name' => $commandEvent['name'],
-                'class' => $commandEvent['command'] instanceof Command ? $commandEvent['command']::class : null,
-                'input' => $commandEvent['input'],
-                'exitCode' => $commandEvent['exitCode'] ?? self::UNDEFINED_EXIT_CODE,
-            ],
+            'name' => $commandEvent['name'],
+            'class' => $commandEvent['command'] instanceof Command ? $commandEvent['command']::class : null,
+            'input' => $commandEvent['input'],
+            'exitCode' => $commandEvent['exitCode'] ?? self::UNDEFINED_EXIT_CODE,
         ];
     }
 

src/Collector/Console/ConsoleAppInfoCollector.php

@@ -33,10 +33,10 @@
             return [];
         }
         return [
             'applicationProcessingTime' => $this->applicationProcessingTimeStopped - $this->applicationProcessingTimeStarted,
             'preloadTime' => $this->applicationProcessingTimeStarted - $this->requestProcessingTimeStarted,
             'applicationEmit' => $this->applicationProcessingTimeStopped - $this->requestProcessingTimeStopped,
             'requestProcessingTime' => $this->requestProcessingTimeStopped - $this->requestProcessingTimeStarted,
             'memoryPeakUsage' => memory_get_peak_usage(),
             'memoryUsage' => memory_get_usage(),
         ];
@@ -74,17 +74,15 @@
             return [];
         }
         return [
-            'console' => [
-                'php' => [
-                    'version' => PHP_VERSION,
-                ],
-                'request' => [
-                    'startTime' => $this->requestProcessingTimeStarted,
-                    'processingTime' => $this->requestProcessingTimeStopped - $this->requestProcessingTimeStarted,
-                ],
-                'memory' => [
-                    'peakUsage' => memory_get_peak_usage(),
-                ],
+            'php' => [
+                'version' => PHP_VERSION,
+            ],
+            'request' => [
+                'startTime' => $this->requestProcessingTimeStarted,
+                'processingTime' => $this->requestProcessingTimeStopped - $this->requestProcessingTimeStarted,
+            ],
+            'memory' => [
+                'peakUsage' => memory_get_peak_usage(),
             ],
         ];
     }

src/Collector/EventCollector.php

@@ -8,6 +8,8 @@
 use Yiisoft\Yii\Console\Event\ApplicationStartup as ConsoleApplicationStartup;
 use Yiisoft\Yii\Http\Event\ApplicationStartup as HttpApplicationStartup;
 
+use function count;
+
 final class EventCollector implements SummaryCollectorInterface
 {
     use CollectorTrait;
@@ -53,9 +55,7 @@ public function getSummary(): array
             return [];
         }
         return [
-            'event' => [
-                'total' => count($this->events),
-            ],
+            'total' => count($this->events),
         ];
     }
 

src/Collector/ExceptionCollector.php

@@ -52,14 +52,15 @@ public function getSummary(): array
         if (!$this->isActive()) {
             return [];
         }
+        if ($this->exception === null) {
+            return [];
+        }
         return [
-            'exception' => $this->exception === null ? [] : [
-                'class' => $this->exception::class,
-                'message' => $this->exception->getMessage(),
-                'file' => $this->exception->getFile(),
-                'line' => $this->exception->getLine(),
-                'code' => $this->exception->getCode(),
-            ],
+            'class' => $this->exception::class,
+            'message' => $this->exception->getMessage(),
+            'file' => $this->exception->getFile(),
+            'line' => $this->exception->getLine(),
+            'code' => $this->exception->getCode(),
         ];
     }
 

src/Collector/HttpClientCollector.php

@@ -89,17 +89,15 @@ public function getSummary(): array
             return [];
         }
         return [
-            'http' => [
-                'count' => array_sum(array_map(static fn (array $requests) => count($requests), $this->requests)),
-                'totalTime' => array_sum(
-                    array_merge(
-                        ...array_map(
-                            static fn (array $entry) => array_column($entry, 'totalTime'),
-                            array_values($this->requests)
-                        )
+            'count' => array_sum(array_map(static fn (array $requests) => count($requests), $this->requests)),
+            'totalTime' => array_sum(
+                array_merge(
+                    ...array_map(
+                        static fn (array $entry) => array_column($entry, 'totalTime'),
+                        array_values($this->requests)
                     )
-                ),
-            ],
+                )
+            ),
         ];
     }
 }

src/Collector/LogCollector.php

@@ -4,6 +4,8 @@
 
 namespace Yiisoft\Yii\Debug\Collector;
 
+use function count;
+
 class LogCollector implements SummaryCollectorInterface
 {
     use CollectorTrait;
@@ -50,9 +52,7 @@ public function getSummary(): array
             return [];
         }
         return [
-            'logger' => [
-                'total' => count($this->messages),
-            ],
+            'total' => count($this->messages),
         ];
     }
 }

src/Collector/ServiceCollector.php

@@ -4,6 +4,8 @@
 
 namespace Yiisoft\Yii\Debug\Collector;
 
+use function count;
+
 final class ServiceCollector implements SummaryCollectorInterface
 {
     use CollectorTrait;
@@ -58,9 +60,7 @@ public function getSummary(): array
             return [];
         }
         return [
-            'service' => [
-                'total' => count($this->items),
-            ],
+            'total' => count($this->items),
         ];
     }
 

src/Collector/Stream/FilesystemStreamCollector.php

@@ -78,7 +78,7 @@ public function getSummary(): array
             return [];
         }
         return [
-            'fs_stream' => array_merge(
+            'streams' => array_merge(
                 ...array_map(
                     fn (string $operation) => [$operation => count($this->operations[$operation])],
                     array_keys($this->operations)

src/Collector/Stream/HttpStreamCollector.php

@@ -87,7 +87,7 @@ public function getSummary(): array
             return [];
         }
         return [
-            'http_stream' => array_merge(
+            'streams' => array_merge(
                 ...array_map(
                     fn (string $operation) => [
                         $operation => count($this->requests[$operation]),

src/Collector/VarDumperCollector.php

@@ -4,6 +4,8 @@
 
 namespace Yiisoft\Yii\Debug\Collector;
 
+use function count;
+
 final class VarDumperCollector implements SummaryCollectorInterface
 {
     use CollectorTrait;
@@ -40,9 +42,7 @@ public function getSummary(): array
         }
 
         return [
-            'var-dumper' => [
-                'total' => count($this->vars),
-            ],
+            'total' => count($this->vars),
         ];
     }
 }

src/Collector/Web/WebAppInfoCollector.php

@@ -65,17 +65,15 @@ public function getSummary(): array
             return [];
         }
         return [
-            'web' => [
-                'php' => [
-                    'version' => PHP_VERSION,
-                ],
-                'request' => [
-                    'startTime' => $this->requestProcessingTimeStarted,
-                    'processingTime' => $this->requestProcessingTimeStopped - $this->requestProcessingTimeStarted,
-                ],
-                'memory' => [
-                    'peakUsage' => memory_get_peak_usage(),
-                ],
+            'php' => [
+                'version' => PHP_VERSION,
+            ],
+            'request' => [
+                'startTime' => $this->requestProcessingTimeStarted,
+                'processingTime' => $this->requestProcessingTimeStopped - $this->requestProcessingTimeStarted,
+            ],
+            'memory' => [
+                'peakUsage' => memory_get_peak_usage(),
             ],
         ];
     }

src/Debugger.php

@@ -15,13 +15,19 @@
 
 /**
  * Debugger collects data from collectors and stores it in a storage.
+ *
+ * @psalm-type TSummary = array{
+ *     id: non-empty-string,
+ *     collectors: list<non-empty-string>,
+ *     summary: array<non-empty-string, array>,
+ * }
  */
 final class Debugger
 {
     /**
      * @var CollectorInterface[] Collectors, indexed by their names.
      *
-     * @psalm-var array<string, CollectorInterface>
+     * @psalm-var array<non-empty-string, CollectorInterface>
      */
     private readonly array $collectors;
 
@@ -31,7 +37,7 @@ final class Debugger
     private readonly DataNormalizer $dataNormalizer;
 
     /**
-     * @var string|null ID of the current request. `null` if debugger is not active.
+     * @var non-empty-string|null ID of the current request. `null` if debugger is not active.
      */
     private ?string $id = null;
 
@@ -83,6 +89,8 @@ public function isActive(): bool
      * Throws `LogicException` if debugger is not started. Use {@see isActive()} to check if debugger is active.
      *
      * @return string ID of the current request.
+     *
+     * @psalm-return non-empty-string
      */
     public function getId(): string
     {
@@ -110,6 +118,7 @@ public function start(object $event): void
             return;
         }
 
+        /** @var non-empty-string */
         $this->id = str_replace('.', '', uniqid('', true));
 
         foreach ($this->collectors as $collector) {
@@ -178,18 +187,25 @@ private function deactivate(): void
     }
 
     /**
-     * Collects summary data of current request.
+     * Collects summary data of current request. Structure of the summary data is:
+     *
+     * - `id` - ID of the current request,
+     * - `collectors` - list of collector names used in the current request,
+     * - `summary` - summary data collected by collectors indexed by collector names.
+     *
+     * @psalm-return TSummary
      */
     private function collectSummaryData(): array
     {
         $summaryData = [
             'id' => $this->getId(),
             'collectors' => array_keys($this->collectors),
+            'summary' => [],
         ];
 
         foreach ($this->collectors as $collector) {
             if ($collector instanceof SummaryCollectorInterface) {
-                $summaryData = [...$summaryData, ...$collector->getSummary()];
+                $summaryData['summary'][$collector->getName()] = $collector->getSummary();
             }
         }
 

src/Storage/StorageInterface.php

@@ -27,12 +27,12 @@ interface StorageInterface
     /**
      * Read all data from storage
      *
-     * @param string $type type of data being read. Available types:
+     * @param string $type Type of data being read. Available types:
      * - {@see TYPE_SUMMARY}
      * - {@see TYPE_DATA}
      * - {@see TYPE_OBJECTS}
      *
-     * @return array data from storage
+     * @return array Data from storage
      *
      * @psalm-param self::TYPE_* $type
      */

tests/Unit/Collector/CommandCollectorTest.php

@@ -71,10 +71,9 @@ protected function checkCollectedData(array $data): void
 
     protected function checkSummaryData(array $data): void
     {
-        $this->assertArrayHasKey('command', $data);
-        $this->assertArrayHasKey('input', $data['command']);
-        $this->assertArrayHasKey('class', $data['command']);
-        $this->assertEquals('test1', $data['command']['input']);
-        $this->assertEquals(null, $data['command']['class']);
+        $this->assertArrayHasKey('input', $data);
+        $this->assertArrayHasKey('class', $data);
+        $this->assertEquals('test1', $data['input']);
+        $this->assertEquals(null, $data['class']);
     }
 }

tests/Unit/Collector/ConsoleAppInfoCollectorTest.php

@@ -58,15 +58,14 @@ protected function checkSummaryData(array $data): void
     {
         parent::checkSummaryData($data);
 
-        $this->assertArrayHasKey('console', $data);
-        $this->assertArrayHasKey('php', $data['console']);
-        $this->assertArrayHasKey('version', $data['console']['php']);
-        $this->assertArrayHasKey('request', $data['console']);
-        $this->assertArrayHasKey('startTime', $data['console']['request']);
-        $this->assertArrayHasKey('processingTime', $data['console']['request']);
-        $this->assertArrayHasKey('memory', $data['console']);
-        $this->assertArrayHasKey('peakUsage', $data['console']['memory']);
+        $this->assertArrayHasKey('php', $data);
+        $this->assertArrayHasKey('version', $data['php']);
+        $this->assertArrayHasKey('request', $data);
+        $this->assertArrayHasKey('startTime', $data['request']);
+        $this->assertArrayHasKey('processingTime', $data['request']);
+        $this->assertArrayHasKey('memory', $data);
+        $this->assertArrayHasKey('peakUsage', $data['memory']);
 
-        $this->assertEquals(PHP_VERSION, $data['console']['php']['version']);
+        $this->assertEquals(PHP_VERSION, $data['php']['version']);
     }
 }