Adding upstream version 1:1.1.2.upstream/1%1.1.2upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 59 insertions, 0 deletions

diff --git a/library/X509/React/StreamOptsCaptureConnector.php b/library/X509/React/StreamOptsCaptureConnector.php
new file mode 100644
index 0000000..81cd8aa
--- /dev/null
+++ b/library/X509/React/StreamOptsCaptureConnector.php
@@ -0,0 +1,59 @@
+<?php
+// Icinga Web 2 X.509 Module | (c) 2020 Icinga GmbH | GPLv2
+
+namespace Icinga\Module\X509\React;
+
+use React\Socket\ConnectionInterface;
+use React\Socket\ConnectorInterface;
+
+use function React\Promise\resolve;
+
+/**
+ * Connector that captures stream context options upon close of the underlying connection
+ */
+class StreamOptsCaptureConnector implements ConnectorInterface
+{
+    /** @var array|null */
+    protected $capturedStreamOptions;
+
+    /** @var ConnectorInterface */
+    protected $connector;
+
+    public function __construct(ConnectorInterface $connector)
+    {
+        $this->connector = $connector;
+    }
+
+    /**
+     * @return array
+     */
+    public function getCapturedStreamOptions()
+    {
+        return (array) $this->capturedStreamOptions;
+    }
+
+    /**
+     * @param array $capturedStreamOptions
+     *
+     * @return $this
+     */
+    public function setCapturedStreamOptions($capturedStreamOptions)
+    {
+        $this->capturedStreamOptions = $capturedStreamOptions;
+
+        return $this;
+    }
+
+    public function connect($uri)
+    {
+        return $this->connector->connect($uri)->then(function (ConnectionInterface $conn) {
+            $conn->on('close', function () use ($conn) {
+                if (is_resource($conn->stream)) {
+                    $this->setCapturedStreamOptions(stream_context_get_options($conn->stream));
+                }
+            });
+
+            return resolve($conn);
+        });
+    }
+}