Version 1

[yaffs-website] / web / modules / contrib / devel / webprofiler / src / Http / HttpClientMiddleware.php

diff --git a/web/modules/contrib/devel/webprofiler/src/Http/HttpClientMiddleware.php b/web/modules/contrib/devel/webprofiler/src/Http/HttpClientMiddleware.php
new file mode 100644 (file)
index 0000000..b64a2a6
--- /dev/null
+++ b/web/modules/contrib/devel/webprofiler/src/Http/HttpClientMiddleware.php
@@ -0,0 +1,84 @@
+<?php
+
+namespace Drupal\webprofiler\Http;
+
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\TransferStats;
+use Psr\Http\Message\RequestInterface;
+
+/**
+ * Class HttpClientMiddleware
+ */
+class HttpClientMiddleware {
+
+  /**
+   * @var array
+   */
+  private $completedRequests;
+
+  /**
+   * @var array
+   */
+  private $failedRequests;
+
+  /**
+   *
+   */
+  public function __construct() {
+    $this->completedRequests = [];
+    $this->failedRequests = [];
+  }
+
+  /**
+   * {@inheritdoc}
+   */
+  public function __invoke() {
+    return function ($handler) {
+      return function (RequestInterface $request, array $options) use ($handler) {
+
+        $options['on_stats'] = function (TransferStats $stats) use ($request) {
+          $request->stats = $stats;
+        };
+
+        return $handler($request, $options)->then(
+          function ($response) use ($request) {
+
+            $this->completedRequests[] = [
+              'request' => $request,
+              'response' => $response,
+            ];
+
+            return $response;
+          },
+          function ($reason) use ($request) {
+            $response = $reason instanceof RequestException
+              ? $reason->getResponse()
+              : null;
+
+            $this->failedRequests[] = [
+              'request' => $request,
+              'response' => $response,
+              'message' => $reason->getMessage(),
+            ];
+
+            return \GuzzleHttp\Promise\rejection_for($reason);
+          }
+        );
+      };
+    };
+  }
+
+  /**
+   * @return array
+   */
+  public function getCompletedRequests() {
+    return $this->completedRequests;
+  }
+
+  /**
+   * @return array
+   */
+  public function getFailedRequests() {
+    return $this->failedRequests;
+  }
+}