upgrade to pharext v4

[m6w6/replicator] / bin / fetch

diff --git a/bin/fetch b/bin/fetch
deleted file mode 100755 (executable)
index c55e785..0000000
--- a/bin/fetch
+++ /dev/null
@@ -1,48 +0,0 @@
-#!/usr/bin/php
-<?php
-
-ini_set("display_errors", 0);
-ini_set("log_errors", 1);
-
-use http\Url;
-use http\Client;
-use http\Client\Request;
-
-$procs = [];
-$client = new Client;
-$client->setOptions([
-       "timetout" => 60,
-       "redirect" => 1,
-       "connecttimeout" => 6
-]);
-
-while (!feof(STDIN)) {
-   if (strlen($line = rtrim(fgets(STDIN)))) {
-        if (list($pkg, $ver, $url) = explode("\t", $line)) {
-                       $url = new Url($url, null, 0);
-                       $skp = sprintf("%s/../build/%s-%s.skip", __DIR__, $pkg, $ver);
-                       $tgz = sprintf("%s/../build/%s-%s.tgz", __DIR__, $pkg, $ver);
-                       $ext = sprintf("%s/../public/phars/%s/%s-%s.ext.phar", __DIR__, $pkg, $pkg, $ver);
-
-                       if (is_file($skp)) {
-                               // skip
-                       } elseif (is_file($tgz) || is_file($ext)) {
-                               printf("%s\t%s\t%s\n", $pkg, $ver, $tgz);
-                       } else {
-                               $client->enqueue(new Request("GET", $url), function($res) use($tgz, $pkg, $ver) {
-                                       $res->getBody()->toStream(fopen($tgz, "w"));
-                                       printf("%s\t%s\t%s\n", $pkg, $ver, $tgz);
-                                       return true;
-                               });
-                       }
-               }
-       }
-}
-
-while (count($client)) {
-       try {
-               $client->send();
-       } catch (Exception $e) {
-               error_log($e->getMessage());
-       }
-}