Downloader.v2

app/Downloader.php

@@ -2,6 +2,8 @@
 
 namespace App;
 
+use Exception;
+
 /**
  * The implementation is responsible for getting raw data from specified URL/path.
  *
@@ -11,30 +13,74 @@ class Downloader implements DownloaderInterface
 {
     private $url;
 
+    /**
+     * Numeric status code, 200: OK
+     */
+    const HTTP_OK = 200;
+
+    /**
+     * @param $url
+     */
     public function setUrl($url) {
         $this->url = $url;
     }
 
-
     private $cacher;
 
+    /**
+     * @param CacherInterface $c
+     */
     public function setCacher(CacherInterface $c) {
         $this->cacher = $c;
     }
 
+    /**
+     * Fetching data.
+     *
+     * @param string $method
+     * @param string $url
+     * @param string $body
+     * @param array $headers
+     * @return string
+     * @throws Exception
+     */
+    private function fetch(string $method, string $url, string $body="", array $headers = []) : string
+    {
+        $context = stream_context_create([
+            "http" => [
+                "method"        => $method,
+                "header"        => implode("\r\n", $headers),
+                "content"       => $body,
+                "ignore_errors" => true,
+            ],
+        ]);
+
+        $response = file_get_contents($url, false, $context);
+        $status_line = $http_response_header[0];
+
+        preg_match('{HTTP\/\S*\s(\d{3})}', $status_line, $match);
+
+        $status = (int)$match[1];
+
+        if ($status !== Downloader::HTTP_OK) {
+            throw new Exception("Unexpected response status: {$status_line}\n" . $response);
+        }
+
+        return $response;
+    }
 
     /**
      * Downloading data.
      *
      * @return string
-     * @throws \Exception
+     * @throws Exception
      */
-    function download() {
+    function download() : string
+    {
         if ( ! $this->url) {
-            throw new \Exception('Downloader: No url specified');
+            throw new Exception('Downloader: No url specified');
         }
 
-
         if ($this->cacher) {
             $key = sprintf('url_%s', $this->url);
 
@@ -43,20 +89,16 @@ function download() {
             }
         }
 
-
-        // TODO: check if '200 Ok' here
-        $content = @file_get_contents($this->url);
+        $content = $this->fetch("GET", $this->url);
 
         if ( ! $content) {
-            throw new \Exception(sprintf('Downloader: No content at %s', $this->url));
+            throw new Exception(sprintf('Downloader: No content at %s', $this->url));
         }
 
-
         if ($this->cacher) {
             $this->cacher->put($key, $content);
         }
 
-
         return $content;
     }
 }