test(laravel): cover concurrent identical requests in ClientRequestWatcher

Sends two identical requests through Http::pool() and asserts each
gets its own span correctly matched to its own response, reproducing
the span collision fixed in the previous commit.

Author: zigzagdev

src/Instrumentation/Laravel/tests/Integration/Http/ClientTest.php

@@ -6,10 +6,18 @@
 
 use GuzzleHttp\Exception\ConnectException;
 use GuzzleHttp\Promise\RejectedPromise;
+use GuzzleHttp\Psr7\Request as Psr7Request;
+use GuzzleHttp\Psr7\Response as Psr7Response;
+use Illuminate\Http\Client\Events\ConnectionFailed;
+use Illuminate\Http\Client\Events\ResponseReceived;
+use Illuminate\Http\Client\Pool;
 use Illuminate\Http\Client\Request;
+use Illuminate\Http\Client\Response;
+use Illuminate\Support\Facades\Event;
 use Illuminate\Support\Facades\Http;
 use OpenTelemetry\API\Trace\StatusCode;
 use OpenTelemetry\SDK\Trace\StatusData;
+use OpenTelemetry\SemConv\Attributes\HttpAttributes;
 use OpenTelemetry\SemConv\Attributes\UrlAttributes;
 use OpenTelemetry\Tests\Contrib\Instrumentation\Laravel\Integration\TestCase;
 
@@ -60,4 +68,51 @@ public function test_it_records_connection_failures(): void
         self::assertEquals('http://fail', $span->getAttributes()->get(UrlAttributes::URL_FULL));
         self::assertEquals(StatusData::create(StatusCode::STATUS_ERROR, 'Connection failed'), $span->getStatus());
     }
+
+    public function test_it_matches_spans_to_responses_for_concurrent_identical_requests(): void
+    {
+        Http::fake([
+            'same.opentelemetry.io' => Http::sequence()
+                ->push(status: 200)
+                ->push(status: 500),
+        ]);
+
+        $responses = Http::pool(fn (Pool $pool) => [
+            $pool->get('same.opentelemetry.io'),
+            $pool->get('same.opentelemetry.io'),
+        ]);
+
+        self::assertEquals(200, $responses[0]->status());
+        self::assertEquals(500, $responses[1]->status());
+
+        self::assertCount(2, $this->storage);
+
+        $firstSpan = $this->storage[0];
+        $secondSpan = $this->storage[1];
+
+        self::assertEquals(200, $firstSpan->getAttributes()->get(HttpAttributes::HTTP_RESPONSE_STATUS_CODE));
+        self::assertEquals(StatusCode::STATUS_UNSET, $firstSpan->getStatus()->getCode());
+
+        self::assertEquals(500, $secondSpan->getAttributes()->get(HttpAttributes::HTTP_RESPONSE_STATUS_CODE));
+        self::assertEquals(StatusCode::STATUS_ERROR, $secondSpan->getStatus()->getCode());
+    }
+
+    public function test_it_ignores_response_with_no_matching_request(): void
+    {
+        $request = new Request(new Psr7Request('GET', 'http://untracked.opentelemetry.io'));
+        $response = new Response(new Psr7Response(200));
+
+        Event::dispatch(new ResponseReceived($request, $response));
+
+        self::assertCount(0, $this->storage);
+    }
+
+    public function test_it_ignores_connection_failure_with_no_matching_request(): void
+    {
+        $request = new Request(new Psr7Request('GET', 'http://untracked.opentelemetry.io'));
+
+        Event::dispatch(new ConnectionFailed($request));
+
+        self::assertCount(0, $this->storage);
+    }
 }