Add daemon Promise cleanup compatibility helper

library/Vspheredb/CheckPluginHelper.php

@@ -8,6 +8,7 @@
 use Exception;
 use gipfl\Cli\Screen;
 use Icinga\Module\Vspheredb\Clicommands\Command;
+use Icinga\Module\Vspheredb\Daemon\PromiseUtil;
 use Icinga\Module\Vspheredb\Data\Anonymizer;
 use InvalidArgumentException;
 use React\Promise\PromiseInterface;
@@ -75,14 +76,17 @@ protected function run($callable)
             }
 
             if ($result instanceof PromiseInterface) {
-                $result->then(function () {
-                    // All done
-                }, function (Exception $e) {
-                    $this->addProblem('UNKNOWN', $e->getMessage());
-                    $this->showOptionalTrace($e);
-                })->finally(function () {
-                    $this->shutdown();
-                });
+                PromiseUtil::finally(
+                    $result->then(function () {
+                        // All done
+                    }, function (Exception $e) {
+                        $this->addProblem('UNKNOWN', $e->getMessage());
+                        $this->showOptionalTrace($e);
+                    }),
+                    function () {
+                        $this->shutdown();
+                    }
+                );
             } else {
                 $this->shutdown();
             }

library/Vspheredb/Daemon/PromiseUtil.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace Icinga\Module\Vspheredb\Daemon;
+
+use React\Promise\PromiseInterface;
+
+/**
+ * ReactPHP Promise compatibility helpers
+ */
+class PromiseUtil
+{
+    /**
+     * Register cleanup on ReactPHP Promise v2 and v3 promises
+     *
+     * @param PromiseInterface $promise  Promise to register cleanup on
+     * @param callable         $callback Callback receiving no arguments
+     *
+     * @return PromiseInterface
+     */
+    public static function finally(PromiseInterface $promise, callable $callback): PromiseInterface
+    {
+        if (method_exists($promise, 'finally')) {
+            return $promise->finally($callback);
+        }
+
+        return $promise->always($callback);
+    }
+}

library/Vspheredb/Monitoring/CheckPlugin.php

@@ -5,6 +5,8 @@
 
 namespace Icinga\Module\Vspheredb\Monitoring;
 
+use Icinga\Module\Vspheredb\Daemon\PromiseUtil;
+
 class CheckPlugin
 {
     /** @var array */
@@ -34,15 +36,18 @@ protected function run($callable)
             }
 
             if ($result instanceof PromiseInterface) {
-                $result->then(function () {
-                    echo "as\n";
-                }, function (Exception $e) {
-                    var_dump('whut');
-                    $this->addProblem('UNKNOWN', $e->getMessage());
-                })->finally(function () {
-                    var_dump('Shut after res');
-                    $this->shutdown();
-                });
+                PromiseUtil::finally(
+                    $result->then(function () {
+                        echo "as\n";
+                    }, function (Exception $e) {
+                        var_dump('whut');
+                        $this->addProblem('UNKNOWN', $e->getMessage());
+                    }),
+                    function () {
+                        var_dump('Shut after res');
+                        $this->shutdown();
+                    }
+                );
             } else {
                 $this->shutdown();
             }