Update to amphp/parallel v0.2.5

This fixes running as PHAR if the PHAR doesn't end with '.phar'.

.travis.yml

@@ -12,15 +12,14 @@ cache:
 
 install:
   - phpenv config-rm xdebug.ini || true
-  - composer config --global discard-changes true
-  - composer update
-  - composer require satooshi/php-coveralls dev-master --dev
-  - composer show --installed
+  - composer install
 
 script:
   - find -name "*.php" -not -path "./vendor/*" -print0 | xargs -n 1 -0 php -l
   - phpdbg -qrr vendor/bin/phpunit --coverage-text --coverage-clover build/logs/clover.xml
-  - php vendor/bin/php-cs-fixer --diff --dry-run -v fix
+  - PHP_CS_FIXER_IGNORE_ENV=1 php vendor/bin/php-cs-fixer --diff --dry-run -v fix
 
 after_script:
-  - php vendor/bin/coveralls -v
+  - curl -OL https://github.com/php-coveralls/php-coveralls/releases/download/v1.0.0/coveralls.phar
+  - chmod +x coveralls.phar
+  - ./coveralls.phar -v

bin/acme

@@ -139,8 +139,9 @@ $injector->share(new AcmeFactory);
 $injector->share(new Amp\Artax\DefaultClient);
 
 $command = $injector->make($class);
+$exitCode = 1;
 
-Loop::run(function () use ($command, $climate) {
+Loop::run(function () use ($command, $climate, &$exitCode) {
     $handler = function ($e) use ($climate) {
         $error = (string) $e;
         $lines = explode("\n", $error);
@@ -159,13 +160,13 @@ Loop::run(function () use ($command, $climate) {
         $exitCode = yield $command->execute($climate->arguments);
 
         if ($exitCode === null) {
-            exit(0);
+            $exitCode = 0;
         }
-
-        exit($exitCode);
     } catch (Throwable $e) {
         $handler($e);
     }
 
     Loop::stop();
 });
+
+exit($exitCode);

composer.json

@@ -14,6 +14,7 @@
         "php": ">=7",
         "ext-openssl": "*",
         "amphp/process": "^0.2",
+        "amphp/parallel": "^0.2.5",
         "kelunik/acme": "^0.5",
         "kelunik/certificate": "^1",
         "league/climate": "^3.2",
@@ -41,18 +42,27 @@
             "src/functions.php"
         ]
     },
+    "config": {
+        "platform": {
+            "php": "7.0.0"
+        }
+    },
     "extra": {
         "phar-builder": {
             "compression": "GZip",
             "name": "acme-client.phar",
             "output-dir": "build",
-            "include": ["info", "src", "vendor/kelunik/acme/res", "vendor/amphp/socket/var"],
+            "include": ["info", "src", "vendor/kelunik/acme/res"],
+            "include-dev": false,
+            "skip-shebang": false,
             "entry-point": "bin/acme",
             "events": {
                 "command.package.start": [
                     "mkdir -p info",
                     "git describe --tags > info/build.version",
-                    "php -r 'echo time();' > info/build.time"
+                    "php -r 'echo time();' > info/build.time",
+                    "rm -rf vendor/amphp/file/travis",
+                    "rm -rf vendor/amphp/parallel/travis"
                 ],
                 "command.package.end": [
                     "rm -rf info",

src/Commands/Issue.php

@@ -2,6 +2,7 @@
 
 namespace Kelunik\AcmeClient\Commands;
 
+use Amp\Dns;
 use Amp\Promise;
 use Kelunik\Acme\AcmeException;
 use Kelunik\Acme\AcmeService;
@@ -109,7 +110,7 @@ class Issue implements Command {
             $this->climate->br();
             $this->climate->whisper('    Requesting certificate ...');
 
-            $csr = (new OpensslCsrGenerator)->generateCsr($key, $domains);
+            $csr = yield (new OpensslCsrGenerator)->generateCsr($key, $domains);
 
             $location = yield $acme->requestCertificate($csr);
             $certificates = yield $acme->pollForCertificate($location);
@@ -161,7 +162,10 @@ class Issue implements Command {
     }
 
     private function checkDnsRecords(array $domains): \Generator {
-        $promises = AcmeClient\concurrentMap(10, \array_combine($domains, $domains), 'Amp\Dns\resolve');
+        $promises = AcmeClient\concurrentMap(10, $domains, function (string $domain): Promise {
+            return Dns\resolve($domain);
+        });
+
         list($errors) = yield Promise\any($promises);
 
         if ($errors) {

src/Stores/CertificateStore.php

@@ -47,8 +47,12 @@ class CertificateStore {
                 $chain = \array_slice($certificates, 1);
                 $path = $this->root . '/' . $commonName;
 
-                if (!yield File\isdir($path) && !yield File\mkdir($path, 0644, true) && !yield File\isdir($path)) {
-                    throw new FilesystemException("Couldn't create certificate directory: '{$path}'");
+                if (!yield File\isdir($path)) {
+                    yield File\mkdir($path, 0755, true);
+
+                    if (!yield File\isdir($path)) {
+                        throw new FilesystemException("Couldn't create certificate directory: '{$path}'");
+                    }
                 }
 
                 yield File\put($path . '/cert.pem', $certificates[0]);

src/Stores/ChallengeStore.php

@@ -22,8 +22,12 @@ class ChallengeStore {
                 throw new ChallengeStoreException("Document root doesn't exist: '{$this->docroot}'");
             }
 
-            if (!yield File\isdir($path) && !yield File\mkdir($path, 0644, true) && !yield File\isdir($path)) {
-                throw new ChallengeStoreException("Couldn't create key directory: '{$path}'");
+            if (!yield File\isdir($path)) {
+                yield File\mkdir($path, 0755, true);
+
+                if (!yield File\isdir($path)) {
+                    throw new ChallengeStoreException("Couldn't create key directory: '{$path}'");
+                }
             }
 
             if ($user && !$userInfo = \posix_getpwnam($user)) {
@@ -35,13 +39,13 @@ class ChallengeStore {
                 yield File\chown($this->docroot . '/.well-known/acme-challenge', $userInfo['uid'], -1);
             }
 
-            yield \Amp\File\put("{$path}/{$token}", $payload);
+            yield File\put("{$path}/{$token}", $payload);
 
             if ($userInfo !== null) {
-                yield \Amp\File\chown("{$path}/{$token}", $userInfo['uid'], -1);
+                yield File\chown("{$path}/{$token}", $userInfo['uid'], -1);
             }
 
-            yield \Amp\File\chmod("{$path}/{$token}", 0644);
+            yield File\chmod("{$path}/{$token}", 0644);
         });
     }
 
@@ -50,7 +54,7 @@ class ChallengeStore {
             $path = $this->docroot . "/.well-known/acme-challenge/{$token}";
 
             if (yield File\exists($path)) {
-                yield \Amp\File\unlink($path);
+                yield File\unlink($path);
             }
         });
     }

src/Stores/KeyStore.php

@@ -18,16 +18,21 @@ class KeyStore {
     public function get(string $path): Promise {
         return call(function () use ($path) {
             $file = $this->root . '/' . $path;
-            $privateKey = yield File\get($file);
 
-            // Check key here to be valid, PrivateKey doesn't do that, we fail early here
-            $res = \openssl_pkey_get_private($privateKey);
+            try {
+                $privateKey = yield File\get($file);
 
-            if ($res === false) {
-                throw new KeyStoreException("Invalid private key: '{$file}'");
+                // Check key here to be valid, PrivateKey doesn't do that, we fail early here
+                $res = \openssl_pkey_get_private($privateKey);
+
+                if ($res === false) {
+                    throw new KeyStoreException("Invalid private key: '{$file}'");
+                }
+
+                return new PrivateKey($privateKey);
+            } catch (FilesystemException $e) {
+                throw new KeyStoreException("Key not found: '{$file}'");
             }
-
-            return new PrivateKey($privateKey);
         });
     }
 
@@ -38,8 +43,12 @@ class KeyStore {
             try {
                 $dir = \dirname($file);
 
-                if (!yield File\isdir($dir) && !yield File\mkdir($dir, 0644, true) && !yield File\isdir($dir)) {
-                    throw new FilesystemException("Couldn't create key directory: '{$path}'");
+                if (!yield File\isdir($dir)) {
+                    yield File\mkdir($dir, 0755, true);
+
+                    if (!yield File\isdir($dir)) {
+                        throw new FilesystemException("Couldn't create key directory: '{$dir}'");
+                    }
                 }
 
                 yield File\put($file, $key->toPem());