Feature: cleaning avatars over CLI

Author: f3l1x

app/config/app/model.neon

@@ -35,3 +35,4 @@ services:
     - App\Model\Tasks\Addons\UpdateComposerTask
     - App\Model\Tasks\Addons\UpdateBowerTask
     - App\Model\Tasks\Addons\StatsComposerTask
+    - App\Model\Tasks\Avatars\UpdateAvatarTask

app/model/tasks/avatars/BaseAvatarTask.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace App\Model\Tasks\Avatars;
+
+use App\Model\ORM\Addon\AddonRepository;
+use App\Model\Tasks\BaseTask;
+
+abstract class BaseAvatarTask extends BaseTask
+{
+
+    /** @var AddonRepository */
+    protected $addonRepository;
+
+    /**
+     * @param AddonRepository $addonRepository
+     */
+    public function __construct(AddonRepository $addonRepository)
+    {
+        $this->addonRepository = $addonRepository;
+    }
+
+}

app/model/tasks/avatars/UpdateAvatarTask.php

@@ -0,0 +1,61 @@
+<?php
+
+namespace App\Model\Tasks\Avatars;
+
+use App\Model\ORM\Addon\Addon;
+use App\Model\ORM\Addon\AddonRepository;
+use App\Model\WebImages\GithubImages;
+use App\Model\WebServices\Github\Service;
+use Nette\Utils\DateTime;
+use Nextras\Orm\Collection\ICollection;
+
+final class UpdateAvatarTask extends BaseAvatarTask
+{
+
+    /** @var Service */
+    private $github;
+
+    /** @var GithubImages */
+    private $githubImages;
+
+    /**
+     * @param AddonRepository $addonRepository
+     * @param Service $github
+     * @param GithubImages $githubImages
+     */
+    public function __construct(AddonRepository $addonRepository, Service $github, GithubImages $githubImages)
+    {
+        parent::__construct($addonRepository);
+        $this->github = $github;
+        $this->githubImages = $githubImages;
+    }
+
+    /**
+     * @param array $args
+     * @return int
+     */
+    public function run(array $args = [])
+    {
+        /** @var ICollection|Addon[] $addons */
+        $addons = $this->addonRepository->findActive();
+
+        $counter = 0;
+        foreach ($addons as $addon) {
+
+            // User avatar
+            $response = $this->github->avatar($addon->owner);
+            list ($info, $avatar) = $response;
+
+            // If avatar was update before less then a week, remove it from filesystem
+            if (DateTime::from($info['filetime']) > DateTime::from('- 1 week')) {
+                $this->githubImages->remove(['type' => 'avatar', 'owner' => $addon->owner]);
+
+                // Increase counting
+                $counter++;
+            }
+        }
+
+        return $counter;
+    }
+
+}

app/model/webimages/GithubImages.php

@@ -25,7 +25,7 @@ public function __construct($imageDir)
     }
 
     /**
-     * FACTORIES ***************************************************************
+     * AVATAR ******************************************************************
      */
 
     /**
@@ -48,6 +48,14 @@ protected function createAvatar($owner)
         }
     }
 
+    /**
+     * @param string $owner
+     */
+    protected function removeAvatar($owner)
+    {
+        FileSystem::delete($this->imageDir . '/avatar/' . $owner);
+    }
+
     /**
      * API *********************************************************************
      */
@@ -71,6 +79,25 @@ public function create(array $args)
         }
     }
 
+    /**
+     * @param array $args
+     */
+    public function remove(array $args)
+    {
+        if (!isset($args['type'])) {
+            throw new InvalidArgumentException('No type given');
+        }
+
+        switch ($args['type']) {
+            case 'avatar':
+                $this->removeAvatar($this->normalize($args['owner']));
+                break;
+
+            default:
+                throw new InvalidArgumentException('Unknown type "' . $args['type'] . '"given');
+        }
+    }
+
     /**
      * HELPERS *****************************************************************
      * *************************************************************************

app/model/webservices/github/Client.php

@@ -8,7 +8,8 @@ final class Client
 {
 
     const VERSION = 'v3';
-    const URL = 'https://api.github.com';
+    const URL_API = 'https://api.github.com';
+    const URL_AVATAR = 'https://avatars.githubusercontent.com';
 
     /** @var string */
     private $token;
@@ -23,10 +24,29 @@ public function __construct($token = NULL)
 
     /**
      * @param string $uri
+     * @return string
+     */
+    public function getApiUrl($uri)
+    {
+        return self::URL_API . '/' . trim($uri, '/');
+    }
+
+    /**
+     * @param string $username
+     * @return string
+     */
+    public function getAvatarUrl($username)
+    {
+        return self::URL_AVATAR . '/' . trim($username, '/');
+    }
+
+    /**
+     * @param string $url
      * @param array $headers
-     * @return mixed (array|NULL)
+     * @param array $opts
+     * @return array
      */
-    public function makeRequest($uri, array $headers = [])
+    public function makeRequest($url, array $headers = [], array $opts = [])
     {
         $ch = curl_init();
 
@@ -39,35 +59,34 @@ public function makeRequest($uri, array $headers = [])
             $_headers[] = 'Authorization: token ' . $this->token;
         }
 
-        $url = self::URL . '/' . trim($uri, '/');
-
-        curl_setopt_array($ch, [
+        $_opts = [
             CURLOPT_RETURNTRANSFER => 1,
             CURLOPT_URL => $url,
             CURLOPT_USERAGENT => 'ComponetteClient-v1',
             CURLOPT_HTTPHEADER => $_headers,
             CURLOPT_FOLLOWLOCATION => 1,
             CURLOPT_SSL_VERIFYPEER => FALSE,
-        ]);
+        ];
+        curl_setopt_array($ch, $opts + $_opts);
 
         $result = curl_exec($ch);
         $info = curl_getinfo($ch);
         curl_close($ch);
 
         if ($info['http_code'] > 300) {
-            throw new GithubException($uri, $headers, [], $info, $result);
+            throw new GithubException($url, $headers, [], $info, $result);
         }
 
         // Pure result
         if (strpos($info['content_type'], 'application/json') === FALSE) {
-            return $result;
+            return [$info, $result];
         }
 
         // Parse result from json
         if ($result) {
-            return @json_decode($result, TRUE);
+            return [$info, @json_decode($result, TRUE)];
         } else {
-            return NULL;
+            return [$info, NULL];
         }
     }
 

app/model/webservices/github/Service.php

@@ -22,14 +22,15 @@ public function __construct(Client $client)
     }
 
     /**
-     * @param string $uri
+     * @param string $url
      * @param array $headers
-     * @return mixed
+     * @param array $opts
+     * @return array
      */
-    protected function call($uri, array $headers = [])
+    protected function makeRequest($url, array $headers = [], array $opts = [])
     {
         try {
-            return $this->client->makeRequest($uri, $headers);
+            return $this->client->makeRequest($url, $headers, $opts);
         } catch (GithubException $e) {
             // Trigger events
             foreach ($this->onException as $cb) {
@@ -41,6 +42,18 @@ protected function call($uri, array $headers = [])
         }
     }
 
+    /**
+     * @param string $uri
+     * @param array $headers
+     * @param array $opts
+     * @return mixed
+     */
+    protected function call($uri, array $headers = [], array $opts = [])
+    {
+        list($info, $result) = $this->makeRequest($this->client->getApiUrl($uri), $headers, $opts);
+        return $result;
+    }
+
     /**
      * @param string $owner
      * @param string $repo
@@ -146,6 +159,28 @@ public function stargazers($owner, $repo)
         return $this->call("/repos/$owner/$repo/stargazers");
     }
 
+    /**
+     * @param string $owner
+     * @return mixed
+     */
+    public function user($owner)
+    {
+        return $this->call("/users/$owner");
+    }
+
+    /**
+     * @param string $username
+     * @return array
+     */
+    public function avatar($username)
+    {
+        return $this->makeRequest(
+            $this->client->getAvatarUrl($username),
+            [],
+            [CURLOPT_FILETIME => TRUE, CURLOPT_NOBODY => TRUE]
+        );
+    }
+
     /**
      * @return mixed
      */

app/modules/Cli/AvatarsPresenter.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace App\Modules\Cli;
+
+use App\Model\Tasks\Avatars\UpdateAvatarTask;
+
+final class AvatarsPresenter extends BasePresenter
+{
+
+    /** @var UpdateAvatarTask @inject */
+    public $updateAvatarTask;
+
+    public function actionUpdate()
+    {
+        $this->output->outln('Avatars:update');
+
+        $this->output->outln('* running [UpdateAvatar]');
+        $res = $this->updateAvatarTask->run($this->getParameters());
+        $this->output->outln('* result [UpdateAvatar](' . $res . ')');
+
+        $this->finish();
+    }
+
+
+}