Added scrutinizer support

Author: WyriHaximus

examples/advanced-enable-cis-for-non-forks-and-files-with-matching-ci-file.php

@@ -1,8 +1,9 @@
 <?php declare(strict_types=1);
 
 /**
- * This example enables travis for all repositories
- * with a .travis.yml that aren't forks and aren't enabled yet.
+ * This example enables travis, appveyor, and scrutinizer for all
+ * repositories with .travis.yml, appveyor.yml, and .scrutinizer.yml
+ * files that aren't forks and aren't enabled yet.
  */
 
 use ApiClients\Client\AppVeyor\AsyncClient as AsyncAppVeyorClient;
@@ -11,6 +12,8 @@
 use ApiClients\Client\Github\Resource\Async\Repository;
 use ApiClients\Client\Github\Resource\Contents\FileInterface;
 use ApiClients\Client\Github\Resource\UserInterface;
+use ApiClients\Client\Scrutinizer\AsyncClient as AsyncScrutinizerClient;
+use ApiClients\Client\Scrutinizer\AsyncClientInterface as AsyncScrutinizerClientInterface;
 use ApiClients\Client\Travis\AsyncClient as AsyncTravisClient;
 use ApiClients\Client\Travis\AsyncClientInterface as AsyncTravisClientInterface;
 use ApiClients\Client\Travis\Resource\Async\Repository as TravisRepository;
@@ -19,6 +22,7 @@
 use ApiClients\Middleware\Delay\DelayMiddleware;
 use ApiClients\Middleware\Pool\PoolMiddleware;
 use React\EventLoop\Factory;
+use function React\Promise\resolve;
 use ResourcePool\Pool;
 use Rx\Observable;
 use function ApiClients\Foundation\resource_pretty_print;
@@ -52,12 +56,16 @@
 $travisClient = AsyncTravisClient::create($loop, require 'resolve_travis-key.php', [
     Options::TRANSPORT_OPTIONS => $transportOptions,
 ]);
+$scrutinizerClient = AsyncScrutinizerClient::create($loop, require 'resolve_scrutinizer-token.php', [
+    Options::TRANSPORT_OPTIONS => $transportOptions,
+]);
 $githubClient = AsyncClient::create($loop, require 'resolve_token.php', [
     Options::TRANSPORT_OPTIONS => $transportOptions,
     // Pass the AppVeyor and Travis client into the Github client internal container
     Options::CONTAINER_DEFINITIONS => [
         AsyncAppVeyorClient::class => $appVeyorClient,
         AsyncTravisClientInterface::class => $travisClient,
+        AsyncScrutinizerClientInterface::class => $scrutinizerClient,
     ],
 ]);
 
@@ -81,14 +89,15 @@
     // Only check repositories that start with reactphp-http
     // This is optional and you can remove this to check all repositories
     // BUT that takes a lot of calls to check and time due to throttling
-    return strpos($repository->name(), 'php-super') === 0;
+    return strpos($repository->name(), 'reactphp-') === 0;
 })->flatMap(function (Repository $repository) {
     // Check if the repository contains a .travis.yml
     return Observable::fromPromise(new React\Promise\Promise(function ($resolve, $reject) use ($repository) {
         $hasCi = [
             'repo' => $repository,
             'travis' => false,
             'appveyor' => false,
+            'scrutinizer' => false,
         ];
         $repository->contents()->filter(function ($node) {
             // Only let through files
@@ -102,6 +111,11 @@
             if ($file->name() === 'appveyor.yml') {
                 $hasCi['appveyor'] = true;
 
+                return;
+            }
+            if ($file->name() === '.scrutinizer.yml') {
+                $hasCi['scrutinizer'] = true;
+
                 return;
             }
         }, function ($error) use ($reject) {
@@ -134,8 +148,14 @@
     // Activate repository on Travis
     $repository->enable()->done(function (TravisRepository $repository) {
         resource_pretty_print($repository);
-    }, 'display_throwable');
-}, 'display_throwable');
+    }, function ($e) {
+        echo 'Travis', PHP_EOL;
+        echo (string)$e;
+    });
+}, function ($e) {
+    echo 'Travis', PHP_EOL;
+    echo (string)$e;
+});
 
 /**
  * Stream handling the AppVeyor side of things.
@@ -153,8 +173,47 @@
         return $appVeyorClient->addProject('gitHub', $repository->fullName());
     })->done(function ($repository) {
         resource_pretty_print($repository);
-    }, 'display_throwable');
-}, 'display_throwable');
+    }, function ($e) {
+        if ($e === null) {
+            return;
+        }
+
+        echo 'AppVeyor', PHP_EOL;
+        echo (string)$e;
+    });
+}, function ($e) {
+    echo 'AppVeyor', PHP_EOL;
+    echo (string)$e;
+});
+
+/**
+ * Stream handling the Scrutinizer side of things.
+ */
+$baseStream->filter(function (array $d) {
+    return $d['scrutinizer'];
+})->map(function (array $d) {
+    return $d['repo'];
+})->subscribe(function (Repository $repository) use ($scrutinizerClient) {
+    $repository->scrutinizerRepository()->then(function ($scrutinizer) use ($scrutinizerClient, $repository) {
+        if ($scrutinizer !== false) {
+            return reject();
+        }
+
+        return $scrutinizerClient->github()->addRepository($repository->fullName());
+    })->done(function ($repository) {
+        resource_pretty_print($repository);
+    }, function ($e) {
+        if ($e === null) {
+            return;
+        }
+
+        echo 'Scrutinizer', PHP_EOL;
+        echo (string)$e;
+    });
+}, function ($e) {
+    echo 'Scrutinizer', PHP_EOL;
+    echo (string)$e;
+});
 
 $loop->run();
 

src/CommandBus/Command/Repository/ScrutinizerCommand.php

@@ -0,0 +1,47 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Command\Repository;
+
+use WyriHaximus\Tactician\CommandHandler\Annotations\Handler;
+
+/**
+ * @Handler("ApiClients\Client\Github\CommandBus\Handler\Repository\ScrutinizerHandler")
+ */
+final class ScrutinizerCommand
+{
+    /**
+     * @var string
+     */
+    private $login;
+
+    /**
+     * @var string
+     */
+    private $name;
+
+    /**
+     * @param string $login
+     * @param string $name
+     */
+    public function __construct(string $login, string $name)
+    {
+        $this->login = $login;
+        $this->name = $name;
+    }
+
+    /**
+     * @return string
+     */
+    public function getLogin(): string
+    {
+        return $this->login;
+    }
+
+    /**
+     * @return string
+     */
+    public function getName(): string
+    {
+        return $this->name;
+    }
+}

src/CommandBus/Handler/Repository/ScrutinizerHandler.php

@@ -0,0 +1,49 @@
+<?php declare(strict_types=1);
+
+namespace ApiClients\Client\Github\CommandBus\Handler\Repository;
+
+use ApiClients\Client\Github\CommandBus\Command\Repository\ScrutinizerCommand;
+use ApiClients\Client\Scrutinizer\AsyncClientInterface;
+use ApiClients\Client\Scrutinizer\Github\AsyncClientInterface as ScrutinizerGithubAsyncClientInterface;
+use Clue\React\Buzz\Message\ResponseException;
+use React\Promise\PromiseInterface;
+use function React\Promise\reject;
+use function React\Promise\resolve;
+
+final class ScrutinizerHandler
+{
+    /**
+     * @var ScrutinizerGithubAsyncClientInterface
+     */
+    private $scrutinizer;
+
+    /**
+     * @param AsyncClientInterface $client
+     */
+    public function __construct(AsyncClientInterface $client)
+    {
+        $this->scrutinizer = $client->github();
+    }
+
+    /**
+     * @param  ScrutinizerCommand $command
+     * @return PromiseInterface
+     */
+    public function handle(ScrutinizerCommand $command): PromiseInterface
+    {
+        return $this->scrutinizer->repository(
+            $command->getLogin(),
+            $command->getName()
+        )->then(null, function ($throwable) {
+            if (!($throwable instanceof ResponseException)) {
+                return reject($throwable);
+            }
+
+            if ($throwable->getCode() !== 404) {
+                return reject($throwable);
+            }
+
+            return resolve(false);
+        });
+    }
+}

src/Resource/Async/Repository.php

@@ -14,6 +14,7 @@
 use ApiClients\Client\Github\CommandBus\Command\Repository\LanguagesCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\ReleasesCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\ReplaceTopicsCommand;
+use ApiClients\Client\Github\CommandBus\Command\Repository\ScrutinizerCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\SubscribeCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\TagsCommand;
 use ApiClients\Client\Github\CommandBus\Command\Repository\TravisCommand;
@@ -149,4 +150,9 @@ public function appVeyorRepository(): PromiseInterface
     {
         return $this->handleCommand(new AppVeyorCommand($this->fullName()));
     }
+
+    public function scrutinizerRepository(): PromiseInterface
+    {
+        return $this->handleCommand(new ScrutinizerCommand(...explode('/', $this->fullName())));
+    }
 }