Add searching for XHProf local files

psalm-baseline.xml

@@ -222,18 +222,4 @@
       <code><![CDATA[getDescriptorByClassName]]></code>
     </MixedMethodCall>
   </file>
-  <file src="src/functions.php">
-    <MixedArrayAccess>
-      <code><![CDATA[AbstractCloner::$defaultCasters[EnumValue::class]]]></code>
-      <code><![CDATA[AbstractCloner::$defaultCasters[MapField::class]]]></code>
-      <code><![CDATA[AbstractCloner::$defaultCasters[Message::class]]]></code>
-      <code><![CDATA[AbstractCloner::$defaultCasters[RepeatedField::class]]]></code>
-    </MixedArrayAccess>
-    <MixedArrayAssignment>
-      <code><![CDATA[AbstractCloner::$defaultCasters[EnumValue::class]]]></code>
-      <code><![CDATA[AbstractCloner::$defaultCasters[MapField::class]]]></code>
-      <code><![CDATA[AbstractCloner::$defaultCasters[Message::class]]]></code>
-      <code><![CDATA[AbstractCloner::$defaultCasters[RepeatedField::class]]]></code>
-    </MixedArrayAssignment>
-  </file>
 </files>

src/Application.php

@@ -4,6 +4,9 @@
 
 namespace Buggregator\Trap;
 
+use Buggregator\Trap\Config\Server\Files\SPX as SPXFileConfig;
+use Buggregator\Trap\Config\Server\Files\XDebug as XDebugFileConfig;
+use Buggregator\Trap\Config\Server\Files\XHProf as XHProfFileConfig;
 use Buggregator\Trap\Config\Server\Frontend as FrontendConfig;
 use Buggregator\Trap\Config\Server\SocketServer;
 use Buggregator\Trap\Handler\Http\Handler\Websocket;
@@ -28,7 +31,7 @@
     private array $servers = [];
 
     /** @var \Fiber[] Any tasks in fibers */
     private array $fibers = [];
 
     private readonly Buffer $buffer;
 
@@ -67,7 +70,8 @@
         ]);
         $this->processors[] = $inspector;
 
         $withFrontend and $this->configureFrontend(8000);
+        $this->configureFileObserver();
 
         foreach ($map as $config) {
             $this->prepareServerFiber($config, $inspector, $this->logger);
@@ -80,13 +84,13 @@
     public function run(int $sleep = 50): void
     {
         foreach ($this->senders as $sender) {
             \assert($sender instanceof Sender);
             if ($sender instanceof Processable) {
                 $this->processors[] = $sender;
             }
         }
 
         while (true) {
             $this->process($this->senders);
             \usleep($sleep);
         }
@@ -143,6 +147,11 @@
                 }
             },
         );
+        foreach ($this->processors as $processor) {
+            if ($processor instanceof Cancellable) {
+                $processor->cancel();
+            }
+        }
     }
 
     /**
@@ -150,7 +159,7 @@
      * @param Inspector $inspector
      * @return \Fiber
      */
     public function prepareServerFiber(SocketServer $config, Inspector $inspector, Logger $logger): \Fiber
     {
         return $this->fibers[] = new \Fiber(function () use ($config, $inspector, $logger): void {
             do {
@@ -216,8 +225,17 @@
         return Server::init(
             $config->port,
             payloadSize: 524_288,
             clientInflector: $clientInflector,
             logger: $this->logger,
         );
     }
+
+    private function configureFileObserver(): void
+    {
+        $this->processors[] = $this->container->make(Service\FilesObserver::class, [
+            $this->container->get(XHProfFileConfig::class),
+            $this->container->get(XDebugFileConfig::class),
+            $this->container->get(SPXFileConfig::class),
+        ]);
+    }
 }

src/Client/TrapHandle.php

@@ -41,6 +41,7 @@ public static function fromArray(array $array): self
      *
      * @param int<0, max> $number The tick number.
      * @param float $delta The time delta between the current and previous tick.
+     * @param int<0, max> $memory The memory usage.
      *
      * @internal
      */

src/Client/TrapHandle/StackTrace.php

@@ -47,11 +47,19 @@ public static function stackTrace(string $baseDir = '', bool $provideObjects = f
         $cwdLen = \strlen($dir);
         $stack = [];
         $internal = false;
-        foreach (
-            \debug_backtrace(
-                ($provideObjects ? \DEBUG_BACKTRACE_PROVIDE_OBJECT : 0) | \DEBUG_BACKTRACE_IGNORE_ARGS,
-            ) as $frame
-        ) {
+
+        /** @var array{
+         *     function: non-empty-string,
+         *     line?: int,
+         *     file?: string,
+         *     class?: class-string,
+         *     type?: string,
+         *     object?: object,
+         *     args?: list<mixed>
+         * } $frame */
+        foreach (\debug_backtrace(
+            ($provideObjects ? \DEBUG_BACKTRACE_PROVIDE_OBJECT : 0) | \DEBUG_BACKTRACE_IGNORE_ARGS,
+        ) as $frame) {
             $class = $frame['class'] ?? '';
             if (\str_starts_with($class, 'Buggregator\\Trap\\Client\\')) {
                 $internal = true;

src/Command/Run.php

@@ -95,7 +95,9 @@ public function createRegistry(OutputInterface $output): Sender\SenderRegistry
     public function getSubscribedSignals(): array
     {
         $result = [];
+        /** @psalm-suppress MixedAssignment */
         \defined('SIGINT') and $result[] = \SIGINT;
+        /** @psalm-suppress MixedAssignment */
         \defined('SIGTERM') and $result[] = \SIGTERM;
 
         return $result;

src/Config/Server/Files/ObserverConfig.php

@@ -0,0 +1,33 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Buggregator\Trap\Config\Server\Files;
+
+use Buggregator\Trap\Service\FilesObserver\FrameConverter;
+
+/**
+ * @internal
+ */
+abstract class ObserverConfig
+{
+    /** @var non-empty-string|null */
+    public ?string $path = null;
+
+    /** @var class-string<FrameConverter>|null */
+    public ?string $converterClass = null;
+
+    /** @var float Scan interval in seconds */
+    public float $scanInterval = 5.0;
+
+    /**
+     * @psalm-assert-if-true non-empty-string $this->path
+     * @psalm-assert-if-true class-string<FrameConverter> $this->converterClass
+     */
+    public function isValid(): bool
+    {
+        /** @psalm-suppress RedundantCondition */
+        return $this->path !== null && $this->converterClass !== null && $this->path !== ''
+            && \is_a($this->converterClass, FrameConverter::class, true) && $this->scanInterval > 0.0;
+    }
+}

src/Config/Server/Files/SPX.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Buggregator\Trap\Config\Server\Files;
+
+use Buggregator\Trap\Service\Config\PhpIni;
+
+/**
+ * @internal
+ */
+final class SPX extends ObserverConfig
+{
+    /** @var non-empty-string|null Path to SPX files */
+    #[PhpIni('spx.data_dir')]
+    public ?string $path = null;
+}

src/Config/Server/Files/XDebug.php

@@ -0,0 +1,17 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Buggregator\Trap\Config\Server\Files;
+
+use Buggregator\Trap\Service\Config\PhpIni;
+
+/**
+ * @internal
+ */
+final class XDebug extends ObserverConfig
+{
+    /** @var non-empty-string|null Path to XDebug files */
+    #[PhpIni('xdebug.output_dir')]
+    public ?string $path = null;
+}

src/Config/Server/Files/XHProf.php

@@ -0,0 +1,35 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Buggregator\Trap\Config\Server\Files;
+
+use Buggregator\Trap\Service\Config\Env;
+use Buggregator\Trap\Service\Config\PhpIni;
+use Buggregator\Trap\Service\FilesObserver\Converter\XHProf as Converter;
+use Buggregator\Trap\Service\FilesObserver\FrameConverter;
+
+/**
+ * @internal
+ */
+final class XHProf extends ObserverConfig
+{
+    /**
+     * @var int<0, 3> Edges sorting algorithm
+     *      Where:
+     *        0 - Deep-first
+     *        1 - Deep-first with sorting by WT
+     *        2 - Level-by-level
+     *        3 - Level-by-level with sorting by WT
+     */
+    #[Env('TRAP_XHPROF_SORT')]
+    public int $algorithm = 3;
+
+    /** @var non-empty-string|null Path to XHProf files */
+    #[Env('TRAP_XHPROF_PATH')]
+    #[PhpIni('xhprof.output_dir')]
+    public ?string $path = null;
+
+    /** @var class-string<FrameConverter>|null */
+    public ?string $converterClass = Converter::class;
+}

src/Processable.php

@@ -5,7 +5,7 @@
 namespace Buggregator\Trap;
 
 /**
- * Must be processed in a main loop.
+ * Must be processed in a main loop outside a Fiber
  *
  * @internal
  */