+ Timeouts and errors

Author: dusterio

README.md

@@ -75,6 +75,23 @@ array(4) {
 }
 ```
 
+## Timeouts and errors
+
+```php
+// Default connect timeout is 5 seconds, you can change it to anything you want
+$client->getParser('general')->getReader()->config(['connect_timeout' => 3.14]);
+
+// Default maximum redirect count is 10, but you can change it too
+$client->getParser('general')->getReader()->config(['allow_redirects' => ['max' => 10]]);
+
+// If there is a network error (DNS, connect, etc), we throw ConnectionErrorException
+try {
+    $previews = $previewClient->getPreviews();
+} catch (\Dusterio\LinkPreview\Exceptions\ConnectionErrorException $e) {
+    echo "Oh no!";
+}
+```
+
 ### YouTube example
 
 ```php

src/Client.php

@@ -74,6 +74,15 @@ public function addParser(ParserInterface $parser)
         return $this;
     }
 
+    /**
+     * @param $id
+     * @return bool|ParserInterface
+     */
+    public function getParser($id)
+    {
+        return isset($this->parsers[$id]) ? $this->parsers[$id] : false;
+    }
+
     /**
      * Get parsers
      * @return ParserInterface[]

src/Contracts/LinkInterface.php

@@ -75,4 +75,10 @@ public function isHtml();
      * @return boolean
      */
     public function isImage();
+
+    /**
+     * Is this link functioning? (could we open it?)
+     * @return boolean
+     */
+    public function isUp();
 }

src/Contracts/ReaderInterface.php

@@ -13,4 +13,10 @@ interface ReaderInterface
      * @return LinkInterface
      */
     public function readLink(LinkInterface $link);
+
+    /**
+     * @param array $parameters
+     * @return void
+     */
+    public function config(array $parameters);
 }

src/Exceptions/ConnectionErrorException.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Dusterio\LinkPreview\Exceptions;
+
+/**
+ * Class ConnectionErorException
+ * @package Dusterio\LinkPreview\Exceptions
+ */
+class ConnectionErrorException extends \Exception
+{
+
+}

src/Models/Link.php

@@ -129,4 +129,12 @@ public function isImage()
     {
         return !strncmp($this->getContentType(), 'image/', strlen('image/'));
     }
+
+    /**
+     * @inheritdoc
+     */
+    public function isUp()
+    {
+        return $this->content !== false && $this->contentType !== false;
+    }
 }

src/Parsers/HtmlParser.php

@@ -6,6 +6,7 @@
 use Dusterio\LinkPreview\Contracts\PreviewInterface;
 use Dusterio\LinkPreview\Contracts\ReaderInterface;
 use Dusterio\LinkPreview\Contracts\ParserInterface;
+use Dusterio\LinkPreview\Exceptions\ConnectionErrorException;
 use Dusterio\LinkPreview\Models\Link;
 use Dusterio\LinkPreview\Readers\HttpReader;
 use Dusterio\LinkPreview\Models\HtmlPreview;
@@ -93,6 +94,8 @@ public function parseLink(LinkInterface $link)
     {
         $link = $this->readLink($link);
 
+        if (!$link->isUp()) throw new ConnectionErrorException();
+
         if ($link->isHtml()) {
             $this->getPreview()->update($this->parseHtml($link));
         } else if ($link->isImage()) {

src/Readers/HttpReader.php

@@ -7,6 +7,7 @@
 use GuzzleHttp\Client;
 use GuzzleHttp\Cookie\CookieJar;
 use GuzzleHttp\TransferStats;
+use GuzzleHttp\Exception\ConnectException;
 
 /**
  * Class HttpReader
@@ -18,6 +19,49 @@ class HttpReader implements ReaderInterface
      */
     private $client;
 
+    /**
+     * @var array $config
+     */
+    private $config;
+
+    /**
+     * @var CookieJar $jar
+     */
+    private $jar;
+
+    /**
+     * HttpReader constructor.
+     * @param array|null $config
+     */
+    public function __construct($config = null)
+    {
+        $this->jar = new CookieJar();
+
+        $this->config = $config ?: [
+            'allow_redirects' => ['max' => 10],
+            'cookies' => $this->jar,
+            'connect_timeout' => 5
+        ];
+    }
+
+    /**
+     * @param int $timeout
+     */
+    public function setTimeout($timeout)
+    {
+        $this->config(['connect_timeout' => $timeout]);
+    }
+
+    /**
+     * @param array $parameters
+     */
+    public function config(array $parameters)
+    {
+        foreach ($parameters as $key => $value) {
+            $this->config[$key] = $value;
+        }
+    }
+
     /**
      * @return Client
      */
@@ -44,18 +88,19 @@ public function setClient($client)
     public function readLink(LinkInterface $link)
     {
         $client = $this->getClient();
-        $jar = new CookieJar();
 
-        $response = $client->request('GET', $link->getUrl(), [
-            'allow_redirects' => ['max' => 10],
-            'cookies' => $jar,
-            'on_stats' => function (TransferStats $stats) use (&$link) {
-                $link->setEffectiveUrl($stats->getEffectiveUri());
-            }
-        ]);
-
-        $link->setContent($response->getBody())
-            ->setContentType($response->getHeader('Content-Type')[0]);
+        try {
+            $response = $client->request('GET', $link->getUrl(), array_merge($this->config, [
+                'on_stats' => function (TransferStats $stats) use (&$link) {
+                    $link->setEffectiveUrl($stats->getEffectiveUri());
+                }
+            ]));
+
+            $link->setContent($response->getBody())
+                ->setContentType($response->getHeader('Content-Type')[0]);
+        } catch (ConnectException $e) {
+            $link->setContent(false)->setContentType(false);
+        }
 
         return $link;
     }