Middleware to log Guzzle requests with Telescope

example.php

<?php

$stack = \GuzzleHttp\HandlerStack::create();
$stack->push(new \App\Http\Client\HttpClientEventsMiddleware());
$client = new \GuzzleHttp\Client(['handler' => $stack]);

$client->get('http://example.com');

HttpClientEventsMiddleware.php

<?php

namespace App\Http\Client;

use GuzzleHttp\Promise;
use Illuminate\Http\Client\Events\ConnectionFailed;
use Illuminate\Http\Client\Events\RequestSending;
use Illuminate\Http\Client\Events\ResponseReceived;
use Illuminate\Http\Client\Request;
use Illuminate\Http\Client\Response;

class HttpClientEventsMiddleware {

    public function __invoke(callable $handler)
    {
        return function ($request, array $options) use ($handler) {

            $laravelRequest = new Request($request);

            event(new RequestSending($laravelRequest));

            return $handler($request, $options)->then(
                $this->onSuccess($laravelRequest),
                $this->onFailure($laravelRequest)
            );
        };
    }

    protected function onSuccess(Request $request)
    {
        return function ($response) use ($request) {

            event(new ResponseReceived($request, new Response($response)));

            return $response;
        };
    }

    protected function onFailure(Request $request)
    {
        return function ($reason) use ($request) {

            event(new ConnectionFailed($request));

            return Promise\Create::rejectionFor($reason);
        };
    }


}

Since I'm working with Laravel 11, ConnectionFailed requires two parameters, so I changed the code to this:

<?php

namespace App\Http\Client;

use GuzzleHttp\Promise;
use Illuminate\Http\Client\Events\ConnectionFailed;
use Illuminate\Http\Client\Events\RequestSending;
use Illuminate\Http\Client\Events\ResponseReceived;
use Illuminate\Http\Client\Request;
use Illuminate\Http\Client\Response;

class HttpClientEventsMiddleware {
{
    public function __invoke(callable $handler)
    {
        return function ($request, array $options) use ($handler) {

            $laravelRequest = new Request($request);

            event(new RequestSending($laravelRequest));

            return $handler($request, $options)->then(
                $this->onSuccess($laravelRequest),
                $this->onFailure($laravelRequest)
            );
        };
    }

    protected function onSuccess(Request $request)
    {
        return function ($response) use ($request) {
            event(new ResponseReceived($request, new Response($response)));

            return $response;
        };
    }

    protected function onFailure(Request $request)
    {
        return function ($e) use ($request) {
            event(new ConnectionFailed($request, new ConnectionException($e->getMessage(), $e->getCode(), $e)));

            return Promise\Create::rejectionFor($e);
        };
    }
}