Add backoff behavior

README.md

@@ -68,7 +68,7 @@ This will create an yml file with this configuration:
 
 ```yaml
 urls:
-    google:
+    google: #this has to be unique
         url: 'https://www.google.fr'
         method: GET
         headers: { Accept: text/html }

src/Client/GuzzleClient.php

@@ -19,6 +19,9 @@
 use GuzzleHttp\Client;
 use GuzzleHttp\HandlerStack;
 use GuzzleHttp\MessageFormatter;
+use GuzzleHttp\Middleware;
+use Hogosha\Monitor\Middleware\Backoff;
+use Hogosha\Monitor\Monitor;
 use Symfony\Component\Console\Logger\ConsoleLogger;
 use Webmozart\Console\Adapter\IOOutput;
 use Webmozart\Console\Api\IO\IO;
@@ -47,9 +50,16 @@ public static function createClient(IO $io, $options = [])
 
         $stack->push($middleware, 'logger');
 
+        $stack->push(
+            Middleware::retry(Backoff::decider(), Backoff::delay())
+        );
+
         $defaults = [
             'handler' => $stack,
             'allow_redirects' => false,
+            'headers' => [
+                'User-Agent' => sprintf('Irongate Monitor %s', Monitor::VERSION),
+            ],
         ];
 
         $options = array_merge($defaults, $options);

src/Middleware/Backoff.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace Hogosha\Monitor\Middleware;
+
+use GuzzleHttp\Exception\ConnectException;
+use GuzzleHttp\Exception\RequestException;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Psr7\Response;
+
+/**
+ * Class Backoff.
+ */
+class Backoff
+{
+    /**
+     * decider.
+     *
+     * @return callable
+     */
+    public static function decider()
+    {
+        return function (
+            $retries,
+            Request $request,
+            Response $response = null,
+            RequestException $exception = null
+        ) {
+            // Limit to 5 retry max
+            if ($retries >= 3) {
+                return false;
+            }
+
+            // Retry connection exceptions
+            if ($exception instanceof ConnectException) {
+                return true;
+            }
+
+            if ($response) {
+                // Retry if we have a serve error
+                if ($response->getStatusCode() >= 500) {
+                    return true;
+                }
+            }
+
+            return false;
+        };
+    }
+
+    /**
+     * delay.
+     *
+     * @return callable
+     */
+    public static function delay()
+    {
+        return function ($numberOfRetries) {
+            return 1000 * $numberOfRetries;
+        };
+    }
+}

src/Runner/Runner.php

@@ -93,7 +93,8 @@ public function run()
                                     $handlerError = curl_strerror($tranferStats->getHandlerErrorData());
                                 }
 
-                                $resultCollection->append(
+                                $resultCollection->offsetSet(
+                                    $url->getName(),
                                     (new Result(
                                         $url,
                                         $statusCode,

tests/Monitor/Runner/RunnerTest.php

@@ -54,8 +54,8 @@ public function testRunner()
         $this->assertCount(1, $urlProvider->getUrls());
         $this->assertInstanceOf(UrlInfo::class, $urlProvider->getUrls()['google']);
         $this->assertInstanceOf(ResultCollection::class, $resultCollection);
-        $this->assertInstanceOf(Result::class, $resultCollection[0]);
-        $this->assertEquals((new Result($this->createUrlInfo(), 200, 0, null, true)), $resultCollection[0]);
+        $this->assertInstanceOf(Result::class, $resultCollection['google']);
+        $this->assertEquals((new Result($this->createUrlInfo(), 200, 0, null, true)), $resultCollection['google']);
     }
 
     /**