Yaffs site version 1.1

[yaffs-website] / vendor / drupal-composer / drupal-scaffold / src / PrestissimoFileFetcher.php

diff --git a/vendor/drupal-composer/drupal-scaffold/src/PrestissimoFileFetcher.php b/vendor/drupal-composer/drupal-scaffold/src/PrestissimoFileFetcher.php
new file mode 100644 (file)
index 0000000..a99aa1d
--- /dev/null
+++ b/vendor/drupal-composer/drupal-scaffold/src/PrestissimoFileFetcher.php
@@ -0,0 +1,66 @@
+<?php
+
+/**
+ * @file
+ * Contains \DrupalComposer\DrupalScaffold\FileFetcher.
+ */
+
+namespace DrupalComposer\DrupalScaffold;
+
+use Composer\Config;
+use Composer\IO\IOInterface;
+use Hirak\Prestissimo\CopyRequest;
+use Hirak\Prestissimo\CurlMulti;
+
+class PrestissimoFileFetcher extends FileFetcher {
+
+  /**
+   * @var \Composer\IO\IOInterface
+   */
+  protected $io;
+
+  /**
+   * @var \Composer\Config
+   */
+  protected $config;
+
+  public function __construct(\Composer\Util\RemoteFilesystem $remoteFilesystem, $source, array $filenames = [], IOInterface $io, Config $config) {
+    parent::__construct($remoteFilesystem, $source, $filenames);
+    $this->io = $io;
+    $this->config = $config;
+  }
+
+  public function fetch($version, $destination) {
+    if (class_exists(CurlMulti::class)) {
+      $this->fetchWithPrestissimo($version, $destination);
+      return;
+    }
+    parent::fetch($version, $destination);
+  }
+
+  protected function fetchWithPrestissimo($version, $destination) {
+    $requests = [];
+    array_walk($this->filenames, function ($filename) use ($version, $destination, &$requests) {
+      $url = $this->getUri($filename, $version);
+      $this->fs->ensureDirectoryExists($destination . '/' . dirname($filename));
+      $requests[] = new CopyRequest($url, $destination . '/' . $filename, false, $this->io, $this->config);
+    });
+
+    $successCnt = $failureCnt = 0;
+    $totalCnt = count($requests);
+
+    $multi = new CurlMulti;
+    $multi->setRequests($requests);
+    do {
+      $multi->setupEventLoop();
+      $multi->wait();
+      $result = $multi->getFinishedResults();
+      $successCnt += $result['successCnt'];
+      $failureCnt += $result['failureCnt'];
+      foreach ($result['urls'] as $url) {
+        $this->io->writeError("    <comment>$successCnt/$totalCnt</comment>:\t$url", true, \Composer\IO\IOInterface::VERBOSE);
+      }
+    } while ($multi->remain());
+  }
+
+}