Introduce separate push event for pushed requests

src/Connection/Internal/Http2ConnectionProcessor.php

@@ -642,6 +642,7 @@ static function () {
         );
 
         events()->requestStart($request);
+        events()->push($request);
         events()->requestHeaderStart($request, $stream->stream);
         events()->requestHeaderEnd($request, $stream->stream);
         events()->requestBodyStart($request, $stream->stream);

src/EventListener.php

@@ -53,6 +53,11 @@ public function networkInterceptorEnd(Request $request, NetworkInterceptor $inte
      */
     public function connectionAcquired(Request $request, Connection $connection): void;
 
+    /**
+     * Called after the server initiated a push.
+     */
+    public function push(Request $request): void;
+
     /**
      * Called before the request headers are sent.
      */

src/EventListener/LogHttpArchive.php

@@ -359,4 +359,9 @@ public function networkInterceptorEnd(Request $request, NetworkInterceptor $inte
     {
         // nothing to do
     }
+
+    public function push(Request $request): void
+    {
+        // nothing to do
+    }
 }

src/Internal/EventInvoker.php

@@ -89,10 +89,22 @@ public function connectionAcquired(Request $request, Connection $connection): vo
         $this->invoke($request, fn (EventListener $eventListener) => $eventListener->connectionAcquired($request, $connection));
     }
 
+    public function push(Request $request): void
+    {
+        $previousPhase = self::getPhase($request);
+        if ($previousPhase !== Phase::Blocked) {
+            throw new \Error('Invalid request phase transition from ' . $previousPhase->name . ' to Push');
+        }
+
+        $this->requestPhase[$request] = Phase::Push;
+
+        $this->invoke($request, fn (EventListener $eventListener) => $eventListener->push($request));
+    }
+
     public function requestHeaderStart(Request $request, Stream $stream): void
     {
         $previousPhase = self::getPhase($request);
-        if ($previousPhase !== Phase::Connected && $previousPhase !== Phase::Blocked) {
+        if ($previousPhase !== Phase::Connected && $previousPhase !== Phase::Push) {
             throw new \Error('Invalid request phase transition from ' . $previousPhase->name . ' to RequestHeaders');
         }
 

src/Internal/Phase.php

@@ -8,6 +8,7 @@ enum Phase
     case Unprocessed;
     case Blocked;
     case Connected;
+    case Push;
     case RequestHeaders;
     case RequestBody;
     case ServerProcessing;